Giới thiệu về RabbitMQ: Khái niệm và Thành phần
Mục tiêu bài viết
Cuối bài viết này, bạn sẽ có khả năng:
- Định nghĩa mensageria và hiểu rõ mục đích của nó;
- Giải thích mối quan hệ giữa mensageria, hệ thống nhắn tin và message broker;
- Nhận diện các thành phần cơ bản của một hệ thống nhắn tin;
- Phân biệt được các thuật ngữ như message broker, producer, consumer, exchange, queue, binding, listener, thông điệp và topologia;
Giới thiệu
Khi chúng ta sử dụng Internet, chúng ta thường xuyên trao đổi thông tin: nhận nội dung từ trang web, gửi dữ liệu qua các biểu mẫu hoặc kích hoạt các dịch vụ khi nhấn nút. Trong một số tình huống, tốc độ truyền tải là ưu tiên chính, ngay cả khi có thể dẫn đến mất gói tin. Ví dụ, trong các cuộc hội nghị truyền hình, để đảm bảo giao tiếp thời gian thực, âm thanh và video được gửi qua giao thức UDP, không đảm bảo việc giao hàng toàn vẹn của các gói tin, dẫn đến giảm chất lượng hình ảnh hoặc biến dạng âm thanh.
Ngược lại, trong các mô hình kiến trúc microservices, ưu tiên là đảm bảo rằng thông tin từ dịch vụ này đến dịch vụ khác được gửi đi và tại đây mensageria trở nên quan trọng.
Mensageria, hệ thống nhắn tin và message broker là gì?
Thuật ngữ Mensageria mô tả quá trình giao tiếp giữa các hệ thống, thành phần phần mềm hoặc dịch vụ thông qua việc gửi và nhận các thông điệp. Khi đề cập đến thuật ngữ này, chúng ta không chỉ nói đến một công cụ cụ thể mà là cơ chế cho phép giao tiếp đồng bộ hoặc bất đồng bộ giữa các hệ thống phân tán.
Các thông điệp được gửi và nhận thường là các khối dữ liệu (thường là nhị phân hoặc ở dạng JSON) được xác định bởi lập trình viên.
Để thực hiện giao tiếp này trong một hệ thống thực tế, chúng ta cần một hạ tầng có khả năng áp dụng cơ chế này vào thực tiễn. Và đó là lý do mà hệ thống nhắn tin xuất hiện, cung cấp các tính năng cho:
- Tạo, truyền tải, lưu trữ và giao nhận thông điệp giữa các ứng dụng.
- Các giao thức truyền tải (AMQP, MQTT, STOMP).
- APIs và SDKs cho việc sản xuất và tiêu thụ thông điệp.
- Hỗ trợ các hàng đợi, chủ đề và định tuyến.
- message broker.
Một ví dụ điển hình của hệ thống nhắn tin là RabbitMQ, hỗ trợ các giao thức AMQP, MQTT và STOMP, và có một message broker, thành phần chịu trách nhiệm nhận, lưu trữ và chuyển tiếp thông điệp giữa các producer và consumer.
Lưu ý: Về kỹ thuật, message broker của RabbitMQ chỉ là một phần của hệ thống nhắn tin. Nhưng trong thực tế, người ta thường gọi RabbitMQ đơn giản là broker.
Sơ đồ hệ thống nhắn tin
Bây giờ, khi đã hiểu các khái niệm chính, chúng ta có thể hình dung quá trình này đang hoạt động. Trong sơ đồ dưới đây, bạn có thể theo dõi con đường mà một thông điệp đi qua: từ ứng dụng sản xuất, đi qua message broker (exchange và queue), đến tay người tiêu dùng xử lý thông tin và trả lại kết quả cho ứng dụng cuối.
- Lớp nghiệp vụ gọi đến thành phần producer
- Producer gửi thông điệp đến một exchange của message broker
- Exchange định tuyến thông điệp đến một hoặc nhiều hàng đợi
- Consumer đọc từ hàng đợi và xử lý thông điệp
- Kết quả của quá trình xử lý được sử dụng bởi ứng dụng.
Trong sơ đồ, chúng ta quan sát thấy luồng thông điệp từ producer đến consumer. Bên trong chính message broker, như bạn đã nhận thấy, có các thành phần giúp quy trình này diễn ra một cách có tổ chức.
Các thành phần trong Message Broker
Exchange nhận các thông điệp được gửi từ producer và quyết định cho mỗi thông điệp đi đâu. Nó không lưu trữ dữ liệu, mà chỉ chuyển tiếp thông điệp dựa trên các quy tắc đã được xác định.
Tiếp theo, chúng ta có queue, hoạt động như một hàng đợi. Các thông điệp được lưu trữ trong đó cho đến khi có một consumer sẵn sàng để xử lý chúng.
Liên kết giữa một exchange và một queue được gọi là binding. Thông qua cấu hình này, broker hiểu được thông điệp nào nên được chuyển hướng đến hàng đợi nào. Sự tổ chức này liên quan đến các exchanges có mặt và loại của mỗi exchange, như direct, fanout, topic hoặc headers (chủ đề này có thể sẽ được thảo luận trong một bài viết sau).
Tiêu thụ thông điệp trong ứng dụng
Thông điệp đến hàng đợi sẽ được xử lý bởi một consumer. Trong ứng dụng, vai trò này thường được thực hiện bởi một listener lắng nghe hàng đợi và khi nhận được một thông điệp mới, thực hiện logic nghiệp vụ. Sau khi xử lý thành công, consumer gửi một ACK đến broker, sau đó broker sẽ xóa thông điệp khỏi hàng đợi.
Lưu ý: ACK là tín hiệu xác nhận việc xử lý thành công của thông điệp.
Mối quan hệ giữa exchange, queue, binding và listener và cách mà chúng tổ chức trong hệ thống nhắn tin được gọi là topologia. Topologia cho thấy các exchange tồn tại và loại của chúng, các hàng đợi nhận thông điệp, cách mà các binding kết nối từng exchange đến các hàng đợi và các consumer gắn liền với từng hàng đợi.
Thông qua đó, chúng ta có thể mô hình hóa từ các kịch bản đơn giản, nơi chỉ có một hàng đợi được tiêu thụ bởi một dịch vụ duy nhất, đến các kiến trúc phức tạp, nơi nhiều exchange phân phối thông điệp cho các hàng đợi và consumer chuyên môn hóa.
Suy nghĩ về topologia là rất quan trọng vì nó xác định con đường của thông tin trong hệ thống và đảm bảo rằng mỗi thông điệp đến đúng đích.
Thực hành và Kết luận
Trong phần đầu tiên này, chúng ta đã tổ chức các khái niệm: producer, exchange, queue, binding, listener và topologia. Với các thuật ngữ rõ ràng và con đường của thông điệp đã được hiểu, việc triển khai topologia trong mã sẽ trở nên dễ dàng hơn. Trong phần hai, chúng ta sẽ đi vào thực hành với Java và RabbitMQ.
Thực hành tốt nhất
- Xác định rõ các thành phần: Hãy đảm bảo rằng bạn hiểu rõ các thành phần trong hệ thống nhắn tin để có thể triển khai hiệu quả.
- Kiểm tra hiệu suất: Thực hiện các bài kiểm tra hiệu suất để đảm bảo hệ thống hoạt động trơn tru khi quy mô tăng lên.
Những sai lầm thường gặp
- Không cấu hình đúng binding: Điều này có thể dẫn đến thông điệp không đến đúng hàng đợi.
- Quá nhiều consumer: Mặc dù có nhiều consumer có thể tăng tốc độ xử lý, nhưng cũng có thể dẫn đến tình trạng quá tải nếu không được quản lý tốt.
Mẹo nâng cao hiệu suất
- Sử dụng các hàng đợi tạm thời: Nếu bạn không cần lưu trữ thông điệp lâu dài, hãy cân nhắc sử dụng các hàng đợi tạm thời để giảm tải cho hệ thống.
- Theo dõi và tối ưu hóa: Sử dụng các công cụ giám sát để theo dõi hiệu suất và tối ưu hóa cấu hình của bạn theo thời gian.
Câu hỏi thường gặp (FAQ)
- RabbitMQ có phải là message broker duy nhất không?
- Không, còn có nhiều message broker khác như Kafka, ActiveMQ, nhưng RabbitMQ phổ biến vì tính linh hoạt và dễ sử dụng.
- Làm thế nào để cài đặt RabbitMQ?
- Bạn có thể tham khảo tài liệu chính thức của RabbitMQ để biết hướng dẫn cài đặt chi tiết.
