[Phần 1]Sử dụng RabbitMQ trong C# (.NET) (lý thuyết tổng quan)

Hi mọi người,

Hôm nay mình sẽ chia sẻ về cách sử dụng RabbitMQ trong C# .Net 6.
Bài viết sẽ giới thiệu các kiến thức cơ bản nhất về RabbitMQ và thực hành sử dụng RabbitMQ trong ứng dụng .NET 6.

Không để mọi người chờ lâu, cùng bắt đầu nào!

1. Message Queue là gì?

• Message queue là một hàng đợi chứa các message, cho phép các ứng dụng có thể giao tiếp với nhau thông qua việc gửi message vào Message Queue như một hộp thư. Message queue đóng vai trò như nơi lưu trữ tạm thời các message khi các ứng dụng đích đến bận hoặc không kết nối.

• Message queue là hàng đợi nên hoạt động theo cơ chế FIFO (first in first out) – message nào vào trước thì được lấy ra trước.

• Hình ở trên minh họa các thành phần của hệ thống message queue.

  • Producer: ứng dụng tạo và gửi message vào Queue. Có thể hiểu là bên gửi.
  • Queue: nơi lưu trữ tạm thời các message, hoạt động theo cơ chế FIFO.
  • Message: thông tin được gửi đi (có thể dạng string, number, object, json…)
  • Cosumer: ứng dụng nhận và xử lý message từ queue.

• Các message queue phổ biến:

  • RabbitMQ
  • Kafka
  • MSMQ
  • Amazon SQS

Ở bài viết này chúng ta sẽ tìm hiểu về RabbitMQ.

2. Message broker là gì?

• Message broker (hay còn gọi là integration broker hoặc interface engine) là một module trung gian trung chuyển message từ người gửi đến người nhận. Nhiệm vụ của message broker là tiếp nhận message và thực hiện một thao tác nào đó.

3. RabbitMQ là gì?

• RabbitMQ là một message broker cho phép nhận, lưu trữ và gửi message.
• RabbitMQ là open source và cross-platform message broker.
• RabbitMQ được xây dựng bằng ngôn ngữ Erlang.
• RabbitMQ cung cấp thư viện để tích hợp với nhiều thư viện, framework và ngôn ngữ như: Net, Java, Python, Ruby, Node.Js….
• RabbitMQ được sử dụng rất phổ biến hiện nay. Các ứng dụng sử dụng RabbitMQ như: WhatsApp, Instagram, …
  

4. Các khái niệm chính trong RabbitMQ?

• Publisher/Producer: Ứng dụng gửi message.
• Consumer: Ứng dụng nhận message.
• Queue: nơi lưu trữ tạm thời message, hoạt động theo cơ chế FIFO.
• Message: thông tin được gửi đi (có thể dạng string, number, object, json…)
• Connection: một tcp connection giữa ứng dụng và message broker.
• Channel:
  • Một kết nối ảo trong connection. Các message được pusblish và cosume dựa trên kết nối ảo này.
  • Ta có thể xem các thông tin trong channel: username, mode, state of channel, unconfirmed, prefetch…

• Exchange: Trong RabbitMQ thì message sẽ không gửi trực tiếp tới queue, thay vào đó message sẽ gửi qua exchange sau đó sẽ được routing tới queue phù hợp với header attributes, bindding key, routting pattern…
• Binding: cấu hình giúp thiết lập quan hệ giữa exchange và queue.
• Routing key: giúp cho exchange biết được message nào routing đến queue nào dựa vào key. Key đóng vai trò như địa chỉ của message.
• AMQP là một advance message queue protocol cho phép gửi và nhận message cho message broker.
• User: để có thể sử dụng rabbitMQ ta cần một user và password, có thể cấu hình các quyền cho từng user trên một virtual host nào đó.
  
• Virtual host: cho phép tạo ra nhiều host trên một RabbitMQ instance. Các virtual host này có exchange, queue, binding, user permission và policy riêng…
  

5. Các loại exchange

Trong RabbitMQ có 4 loại exchange:

• Direct: route message dựa trên routing key. Các queue sẽ nhận message đúng chính xác routing key đó. Ví dụ như hình ở trên ta có thể dựa vào routing key Mumbai_key để lấy chính xác message đó, hoặc dựa vào routing key Bangalore_key để lấy đúng message cho key đó.

• Fanout: route tất cả messages tới tất cả queue ràng buộc tới nó. Như hình dưới tất cả message được gửi tới queue qua exchange với type là Fanout thì tất cả queue sẽ đều nhận message đó.

• Topic: với exchange type là topic thì các message sẽ route theo một pattern nhất định của queue đó. Ví dụ queue có pattern: .Bombay. thì message với routing key User.Bombay.Message sẽ đến queue đó.

• Header: sử dụng message header attribute cho việc routing.

5. Tổng kết

• Vậy là chúng ta đã đi qua tổng quan lý thuyết về RabbitMQ. Ở phần 2 mình sẽ đi vào phần thực hành sử dụng RabbitMQ trong .net 6.
• Cảm ơn mọi người đã xem bài viết. Chúc mọi người một cuối tuần vui vẻ.
• Nếu có thắc mắc về các phần trong bài này mọi người có thể inbox qua facebook:https://www.facebook.com/FriendsCode-108096425243996 Mình sẽ giải đáp thắc mắc trong tầm hiểu biết. Cảm ơn mọi người

Tham khảo:

• https://aws.amazon.com/message-queue/
• https://www.cloudamqp.com/blog/what-is-message-queuing.html
• https://tsh.io/blog/message-broker/
  –https://www.tutlane.com/tutorial/rabbitmq/introduction-to-rabbitmq
• https://www.cloudamqp.com/blog/what-is-amqp-and-why-is-it-used-in-rabbitmq.html
• https://www.tutlane.com/tutorial/rabbitmq/rabbitmq-users
• https://www.tutlane.com/tutorial/rabbitmq/rabbitmq-virtual-hosts
• https://www.tutlane.com/tutorial/rabbitmq/rabbitmq-exchanges