Làm thế nào để giải quyết bài toán giao tiếp bất đồng bộ giữa các Microservices bằng cách sử dụng Message Brokers như RabbitMQ hoặc Apache Kafka?

Question

Accepted Answer

Trong kiến trúc Microservices, giao tiếp đồng bộ (Synchronous HTTP/REST) tạo ra sự phụ thuộc chặt chẽ giữa các dịch vụ (tight coupling). Nếu một dịch vụ trung gian chết, toàn bộ luồng xử lý bị gián đoạn. Giao tiếp bất đồng bộ thông qua Message Brokers là giải pháp giải quyết triệt để vấn đề này.
1. Bản chất cơ chế hoạt động

Producer: Dịch vụ phát ra sự kiện (Event) hoặc thông điệp khi có hành động xảy ra (ví dụ: OrderCreatedEvent).
Message Broker (RabbitMQ / Kafka): Trung gian nhận, lưu trữ tạm thời và điều phối thông điệp đến các Consumer.
Consumer: Dịch vụ lắng nghe và xử lý thông điệp một cách độc lập mà không làm ảnh hưởng đến tốc độ của Producer.

2. Sự khác biệt cơ bản giữa RabbitMQ và Kafka

RabbitMQ: Phù hợp với các bài toán Task Queues truyền thống, địnhrouting phức tạp dựa trên Exchanges, xóa thông điệp ngay sau khi Consumer xác nhận (ACK).
Apache Kafka: Phù hợp với hệ thống Event Streaming quy mô lớn, lưu trữ thông điệp theo dạng Log bất biến (Commit Log) cho phép nhiều Consumer đọc lại dữ liệu cũ bất cứ lúc nào.

3. Ví dụ xử lý sự kiện trong Spring Boot với RabbitMQ
OrderConsumer.java

@Component
public class OrderConsumer {

@RabbitListener(queues = "order-queue")
    public void handleOrderCreated(OrderCreatedEvent event) {
        // Xử lý logic nghiệp vụ tạo hóa đơn hoặc gửi email
        System.out.println("Nhan duoc don hang ID: " + event.getOrderId());
    }
}
4. Lưu ý kinh nghiệm thực chiến

Idempotency (Tính lũy đẳng): Vì mạng có thể bị lỗi dẫn đến việc Message Broker gửi lại thông điệp nhiều lần (At-least-once delivery), Consumer phải được thiết kế để xử lý cùng một sự kiện nhiều lần mà không làm sai lệch dữ liệu.
Dead Letter Queue (DLQ): Luôn cấu hình DLQ để hứng các thông điệp bị lỗi xử lý nhiều lần (poison messages), tránh việc làm tắc nghẽn toàn bộ hàng đợi chính.

Làm thế nào để giải quyết bài toán giao tiếp bất đồng bộ giữa các Microservices bằng cách sử dụng Message Brokers như RabbitMQ hoặc Apache Kafka?

Làm Chủ Phỏng Vấn & Nâng Cao Trình Độ Chuyên Nghiệp

Tải Tuyển Tập 100+ Câu Hỏi Phỏng Vấn Chuyên Sâu (PDF)

Cần Mentor Phỏng Vấn Thử 1-1 & Tối Ưu CV?

Kiểm Tra CV Chuẩn ATS Miễn Phí

Câu hỏi microservices liên quan cùng chủ đề