Khái niệm cơ bản về Message Queue (MQ)

Message Queue (MQ) là một thành phần trung gian được sử dụng để lưu trữ các thông điệp trong quá trình truyền tải giữa các hệ thống. Trong các kiến trúc hệ thống phân tán, MQ đóng vai trò như một "bưu cục" giúp các thành phần giao tiếp với nhau mà không cần kết nối trực tiếp.

• Producer (Người sản xuất): Thành phần gửi thông điệp.
• Consumer (Người tiêu thụ): Thành phần nhận và xử lý thông điệp.
• Broker: Phần mềm trung gian lưu trữ hàng đợi (như RabbitMQ).

Ưu điểm và nhược điểm của việc sử dụng MQ

Ưu điểm:

1. Giải quyết sự phụ thuộc (Decoupling): Khi hệ thống A gửi tin nhắn cho hệ thống B qua MQ, A không cần biết B có đang hoạt động hay không. Điều này làm giảm sự ràng buộc giữa các module, tăng khả năng bảo trì.
2. Xử lý bất đồng bộ (Asynchrony): Thay vì bắt người dùng đợi phản hồi từ tất cả các dịch vụ (ví dụ: đặt hàng -> thanh toán -> gửi email -> cập nhật kho), hệ thống có thể đẩy các tác vụ không cấp thiết vào MQ và phản hồi ngay lập tức cho người dùng, giúp tăng trải nghiệm khách hàng và thông lượng hệ thống.
3. Cân bằng tải (Peak Shaving): Trong các đợt cao điểm, lượng yêu cầu tăng đột biến có thể làm sập hệ thống. MQ đóng vai trò là vùng đệm, giữ lại các yêu cầu và đẩy dần cho phía consumer xử lý theo đúng năng lực của nó, giúp hệ thống ổn định hơn.

Nhược điểm:

• Độ sẵn sàng của hệ thống: Nếu MQ gặp sự cố (downtime), toàn bộ luồng giao tiếp giữa các dịch vụ có thể bị gián đoạn.
• Độ phức tạp tăng cao: Cần xử lý các vấn đề như tin nhắn lặp lại, mất tin nhắn hoặc thứ tự xử lý thông điệp.
• Tính nhất quán dữ liệu: Việc xử lý bất đồng bộ có thể dẫn đến tình trạng dữ liệu không được cập nhật ngay lập tức trên tất cả các hệ thống (Eventual Consistency).

So sánh các loại Message Queue phổ biến

Đặc điểm	RabbitMQ	RocketMQ	Kafka
Ngôn ngữ phát triển	Erlang	Java	Scala & Java
Giao thức hỗ trợ	AMQP, STOMP, MQTT	Custom	Custom Binary
Thông lượng (Throughput)	Hàng chục nghìn/giây	Hàng trăm nghìn/giây	Hàng triệu/giây
Độ trễ	Micro giây (rất thấp)	Mili giây	Mili giây

Kiến trúc và các thành phần trong RabbitMQ

RabbitMQ được xây dựng dựa trên giao thức AMQP (Advanced Message Queuing Protocol). Đây là một giao thức mở ở tầng ứng dụng, đảm bảo tính tương thích giữa các ngôn ngữ lập trình khác nhau.

Các thành phần chính bao gồm:

• Broker: Chính là RabbitMQ Server.
• Virtual Host (vhost): Một cách phân chia tài nguyên logic bên trong một Broker, tương tự như khái niệm Database trong MySQL.
• Connection: Kết nối TCP vật lý giữa Client (Producer/Consumer) và Broker.
• Channel: Một kết nối logic nằm bên trong Connection. Việc tạo mới Connection rất tốn tài nguyên, nên RabbitMQ sử dụng các Channel để thực hiện nhiều tác vụ trên cùng một kết nối TCP.
• Exchange: Tiếp nhận thông điệp từ Producer và định tuyến chúng đến các Queue dựa trên các quy tắc (Binding). Các loại Exchange phổ biến: Direct, Fanout, Topic, Headers.
• Queue: Nơi lưu trữ thông điệp thực tế cho đến khi Consumer lấy đi.
• Binding: Mối liên kết giữa Exchange và Queue.

Hướng dẫn cài đặt RabbitMQ trên Linux

1. Cài đặt các thư viện phụ thuộc

yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc-c++ kernel-devel m4 ncurses-devel tk tc xz

2. Cài đặt Erlang

Vì RabbitMQ chạy trên Erlang, bạn cần cài đặt môi trường này trước. Nếu phiên bản Glibc hiện tại quá thấp, hãy cập nhật trước khi cài đặt Erlang RPM:

# Kiểm tra phiên bản Glibc
strings /lib64/libc.so.6 | grep GLIBC

# Cài đặt Erlang (ví dụ phiên bản 18.3)
rpm -ivh erlang-18.3-1.el7.centos.x86_64.rpm

3. Cài đặt và cấu hình RabbitMQ

# Cài đặt thành phần phụ trợ
rpm -ivh socat-1.7.3.2-5.el7.lux.x86_64.rpm

# Cài đặt RabbitMQ Server
rpm -ivh rabbitmq-server-3.6.5-1.noarch.rpm

# Kích hoạt giao diện quản lý (Web UI)
rabbitmq-plugins enable rabbitmq_management

4. Quản lý dịch vụ

service rabbitmq-server start   # Khởi động
service rabbitmq-server stop    # Dừng
service rabbitmq-server restart # Khởi động lại

Quản lý người dùng và quyền truy cập

Sau khi cài đặt, giao diện quản lý có thể truy cập qua cổng 15672 (mặc định là http://localhost:15672). RabbitMQ cung cấp các cấp độ phân quyền (Roles):

• Administrator: Toàn quyền quản lý người dùng, vhost và các chính sách.
• Monitoring: Có thể xem thông tin về các node, thống kê bộ nhớ và tài nguyên.
• Policymaker: Quản lý các chính sách (policies) của hệ thống.
• Management: Chỉ có thể đăng nhập vào giao diện quản lý và xem thông tin cơ bản.