LazyCodet

a

22:14:05 9/3/2025 - 0 views -
RabbitMQ

RabbitMQ: Mô hình Pub/Sub

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)

Pasted Image

​- 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...