JBoss Fuse - Apache AMQ
Trong chương này, chúng ta sẽ tìm hiểu về ActiveMQ và cách nó hoạt động như một nhà môi giới các thông điệp để cho phép các ứng dụng giao tiếp với nhau.
AMQ là gì?
ActiveMQ là một trình môi giới thông báo mã nguồn mở được viết bằng Java. Nó hoàn toàn tuân thủ các tiêu chuẩn JMS 1.1.
JMS là một đặc tả cho phép phát triển hệ thống dựa trên tin nhắn. ActiveMQ hoạt động như một nhà môi giới của các thông điệp nằm giữa các ứng dụng và cho phép chúng giao tiếp theo cách không đồng bộ và đáng tin cậy.
Các loại nhắn tin
Có hai loại tùy chọn nhắn tin được giải thích bên dưới để hiểu rõ hơn.
Chỉ đến điểm
Trong kiểu giao tiếp này, người môi giới chỉ gửi tin nhắn đến một người tiêu dùng, trong khi những người tiêu dùng khác sẽ đợi cho đến khi họ nhận được tin nhắn từ người môi giới. Không người tiêu dùng nào sẽ nhận được thông điệp tương tự.
Nếu không có người tiêu dùng, Nhà môi giới sẽ giữ các thông điệp cho đến khi có người tiêu dùng. Loại giao tiếp này còn được gọi làQueue based communicationtrong đó Nhà sản xuất gửi tin nhắn đến hàng đợi và chỉ một người tiêu dùng nhận được một tin nhắn từ hàng đợi. Nếu có nhiều hơn một người tiêu dùng, họ có thể nhận được thông báo tiếp theo nhưng họ sẽ không nhận được thông báo tương tự như người tiêu dùng khác.
Theo dõi công khai
Trong kiểu giao tiếp này, Nhà môi giới sẽ gửi một bản sao thông điệp giống nhau đến tất cả những người tiêu dùng đang hoạt động. Loại giao tiếp này còn được gọi làTopic based communicationnơi người môi giới gửi cùng một thông điệp đến tất cả người tiêu dùng đang hoạt động đã đăng ký Chủ đề cụ thể. Mô hình này hỗ trợ giao tiếp một chiều mà không cần xác minh thông điệp đã truyền.
Tạo hàng đợi và chủ đề
Cầu chì đi kèm với ActiveMQ. Chúng tôi có thể truy cập ActiveMQ bằng bảng điều khiển FMC (giao diện dựa trên trình duyệt để làm việc với AMQ).
Đăng nhập FMC bằng localhost:8181 và chọn ActiveMQ chuyển hướng.
- Nhấp vào + Tạo
- Nhập hàng đợi / tên chủ đề
- Chọn Hàng đợi / Chủ đề từ nút radio
- Nhấp vào Tạo hàng đợi / Tạo chủ đề
Bây giờ bạn sẽ có thể thấy TestQ được tạo dưới gốc → Hàng đợi →
Để kiểm tra chủ đề đã tạo, hãy truy cập root → Chủ đề.
Duyệt / Xóa nội dung của Hàng đợi
Đăng nhập FMC bằng localhost:8181
Chọn tab ActiveMQ
Gốc → Hàng đợi → TestQ <chọn hàng đợi mà bạn muốn duyệt> → Duyệt
- Để kiểm tra nội dung của tin nhắn này, hãy nhấp vào tin nhắn cụ thể đó.
Bạn có thể xóa một tin nhắn cụ thể bằng cách nhấp vào nút Xóa được hiển thị ở góc trên cùng bên phải