Mô hình Pub/Sub:
+ Có 1 cái exchange: Nhận tin nhắn từ producer, loại bỏ tin nhắn , phân bố tin nhắn vào queue hoặc nhiều queue
+ Từ exchange sẽ chuyển đến queue ( có thể có nhiều queue)
- Các bước viết code : publish
+ Tạo connect đến RabbitMQ
+ Tạo channel
+ Tạo exchange ( producer sẽ ko gửi trực tiếp đến queue mà gửi vào exchange, từ exchange sẽ phân bổ đến nhiều queu
+ publish
- Các bước viết code: receive
+ Tạo connect đến RabbitMQ
+ Tạo channel
+ Tạo exchange ( producer sẽ ko gửi trực tiếp đến queue mà gửi vào exchange, từ exchange sẽ phân bổ đến nhiều queu
+ Create queue: nên để rỗng để hàm tự tạo 1 queue tmp thời, nên thêm exclusive: true để hàng đợi đó tự xóa khi chúng ta thoát khỏi hệ thống.
+ Binding: mối quan hệ giữa exchange, queue. Phần này có tác dụng yêu cầu exchange gửi message đến queue của chúng ta
+ Consume message trong queue của chúng ta
Note: Gửi thông điệp đến với nhiều consumer chứ ko phải mỗi consumer sẽ giải quyết 1 công việc, chỉ cần có đăng ký đến đó thì tất cả consumer đều nhận được chứ ko bị phân bố như mô hình queue thông thường
=> Hệ thông noti...