# Giới thiệu RabbitMQ - Message Broker mạnh mẽ

> Nguồn: https://tiennhm.io.vn/blog/introduction-to-rabbitmq
> Tìm hiểu về RabbitMQ, một message broker phổ biến trong kiến trúc microservices. Bài viết bao gồm khái niệm cơ bản, cài đặt và ví dụ thực tế với .NET 8.

> RabbitMQ là một open-source message broker phổ biến trong kiến trúc microservices, hỗ trợ nhiều messaging protocols như AMQP, MQTT, STOMP. Bài viết giới thiệu khái niệm cơ bản (Producer, Consumer, Queue, Exchange), cách cài đặt RabbitMQ, và ví dụ thực tế với .NET 8 để gửi/nhận messages. RabbitMQ giúp giải quyết các vấn đề về decoupling, scalability và reliability trong distributed systems.

RabbitMQ là một trong những message broker phổ biến nhất trong thế giới phát triển phần mềm hiện đại. Trong bài viết này, chúng ta sẽ tìm hiểu về RabbitMQ và cách sử dụng nó trong ứng dụng .NET 8.

## RabbitMQ là gì?

RabbitMQ là một open-source message broker (còn gọi là message queue) được phát triển bởi Rabbit Technologies. Nó hỗ trợ nhiều messaging protocols như AMQP, MQTT, STOMP và HTTP thông qua các plugins.

### Các khái niệm cơ bản

- **Producer**: Ứng dụng gửi message
- **Consumer**: Ứng dụng nhận và xử lý message
- **Queue**: Nơi lưu trữ message
- **Exchange**: Nhận message từ producer và định tuyến đến queue
- **Binding**: Quy tắc kết nối exchange với queue
- **Routing Key**: Khóa để exchange định tuyến message

Sơ đồ dưới đây ghép các khái niệm trên vào đúng ví dụ exchange `logs` ở phần 4:

![Producer gửi message có routing key error tới exchange logs kiểu direct. Exchange so routing key với binding key của từng queue và chỉ đẩy message vào queue error; consumer đăng ký BasicConsume(error) nhận message đó. Queue warning và info có binding key khác nên không nhận message này.](./rabbitmq-direct-exchange.png#gh-light-mode-only)
![Producer gửi message có routing key error tới exchange logs kiểu direct. Exchange so routing key với binding key của từng queue và chỉ đẩy message vào queue error; consumer đăng ký BasicConsume(error) nhận message đó. Queue warning và info có binding key khác nên không nhận message này.](./rabbitmq-direct-exchange-dark.png#gh-dark-mode-only)

File gốc: [nền sáng](pathname:///files/diagrams/2025-08-23-gioi-thieu-rabbitmq-net9/vi/rabbitmq-direct-exchange.html) · [nền tối](pathname:///files/diagrams/2025-08-23-gioi-thieu-rabbitmq-net9/vi/rabbitmq-direct-exchange-dark.html)

## Cài đặt RabbitMQ

### Sử dụng Docker (Khuyến nghị)

```bash
docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
```

Sau khi chạy, bạn có thể truy cập RabbitMQ Management UI tại: `http://localhost:15672` (username/password: guest/guest)

### Cài đặt trực tiếp

Tải và cài đặt từ [rabbitmq.com](https://www.rabbitmq.com/download.html)

## Ví dụ ứng dụng .NET 8

Chúng ta sẽ tạo một ứng dụng đơn giản để gửi và nhận message qua RabbitMQ.

### 1. Tạo project .NET 8

```bash
dotnet new console -n RabbitMQDemo
cd RabbitMQDemo
dotnet add package RabbitMQ.Client
```

### 2. Tạo Producer (Ứng dụng gửi message)

```csharp Producer/Program.cs
using RabbitMQ.Client;
using System.Text;

class Producer
{
    static void Main(string[] args)
    {
        // Kết nối đến RabbitMQ
        var factory = new ConnectionFactory()
        {
            HostName = "localhost",
            UserName = "guest",
            Password = "guest"
        };

        using var connection = factory.CreateConnection();
        using var channel = connection.CreateModel();

        // Khai báo queue
        const string queueName = "hello";
        channel.QueueDeclare(
            queue: queueName,
            durable: false,
            exclusive: false,
            autoDelete: false,
            arguments: null);

        Console.WriteLine("Nhập message để gửi (nhập 'quit' để thoát):");

        while (true)
        {
            var message = Console.ReadLine();
            if (message?.ToLower() == "quit") break;

            if (!string.IsNullOrEmpty(message))
            {
                var body = Encoding.UTF8.GetBytes(message);
                channel.BasicPublish(
                    exchange: "",
                    routingKey: queueName,
                    basicProperties: null,
                    body: body);

                Console.WriteLine($"Đã gửi: {message}");
            }
        }
    }
}
```

### 3. Tạo Consumer (Ứng dụng nhận message)

```csharp Consumer/Program.cs
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;

class Consumer
{
    static void Main(string[] args)
    {
        // Kết nối đến RabbitMQ
        var factory = new ConnectionFactory()
        {
            HostName = "localhost",
            UserName = "guest",
            Password = "guest"
        };

        using var connection = factory.CreateConnection();
        using var channel = connection.CreateModel();

        // Khai báo queue
        const string queueName = "hello";
        channel.QueueDeclare(
            queue: queueName,
            durable: false,
            exclusive: false,
            autoDelete: false,
            arguments: null);

        Console.WriteLine("Đang chờ message...");

        // Tạo consumer
        var consumer = new EventingBasicConsumer(channel);
        consumer.Received += (model, ea) =>
        {
            var body = ea.Body.ToArray();
            var message = Encoding.UTF8.GetString(body);

            Console.WriteLine($"Nhận được: {message}");

            // Xác nhận đã xử lý message
            channel.BasicAck(ea.DeliveryTag, false);
        };

        // Bắt đầu nhận message
        channel.BasicConsume(
            queue: queueName,
            autoAck: false,
            consumer: consumer);

        Console.WriteLine("Nhấn Enter để thoát");
        Console.ReadLine();
    }
}
```

### 4. Sử dụng Exchange và Routing

Đây là ví dụ nâng cao sử dụng Exchange với routing key:

```csharp AdvancedProducer/Program.cs
using RabbitMQ.Client;
using System.Text;

class AdvancedProducer
{
    static void Main(string[] args)
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using var connection = factory.CreateConnection();
        using var channel = connection.CreateModel();

        // Khai báo exchange
        const string exchangeName = "logs";
        channel.ExchangeDeclare(
            exchange: exchangeName,
            type: ExchangeType.Direct);

        // Khai báo queues
        var queueNames = new[] { "error", "warning", "info" };
        foreach (var queueName in queueNames)
        {
            channel.QueueDeclare(queueName, false, false, false, null);
            channel.QueueBind(queueName, exchangeName, queueName);
        }

        Console.WriteLine("Nhập message theo format 'level:message' (ví dụ: error:Database connection failed)");
        Console.WriteLine("Levels: error, warning, info");

        while (true)
        {
            var input = Console.ReadLine();
            if (input?.ToLower() == "quit") break;

            if (input?.Contains(':') == true)
            {
                var parts = input.Split(':', 2);
                var level = parts[0].Trim().ToLower();
                var message = parts[1].Trim();

                if (queueNames.Contains(level))
                {
                    var body = Encoding.UTF8.GetBytes(message);
                    channel.BasicPublish(
                        exchange: exchangeName,
                        routingKey: level,
                        basicProperties: null,
                        body: body);

                    Console.WriteLine($"Đã gửi {level}: {message}");
                }
                else
                {
                    Console.WriteLine($"Level không hợp lệ: {level}");
                }
            }
        }
    }
}
```

### 5. Consumer cho từng loại message

```csharp AdvancedConsumer/Program.cs
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;

class AdvancedConsumer
{
    static void Main(string[] args)
    {
        Console.WriteLine("Chọn level để nhận message (error/warning/info):");
        var level = Console.ReadLine()?.Trim().ToLower();

        if (string.IsNullOrEmpty(level) || !new[] { "error", "warning", "info" }.Contains(level))
        {
            Console.WriteLine("Level không hợp lệ!");
            return;
        }

        var factory = new ConnectionFactory() { HostName = "localhost" };
        using var connection = factory.CreateConnection();
        using var channel = connection.CreateModel();

        // Khai báo exchange
        const string exchangeName = "logs";
        channel.ExchangeDeclare(
            exchange: exchangeName,
            type: ExchangeType.Direct);

        // Khai báo queue
        channel.QueueDeclare(level, false, false, false, null);
        channel.QueueBind(level, exchangeName, level);

        Console.WriteLine($"Đang chờ {level} messages...");

        var consumer = new EventingBasicConsumer(channel);
        consumer.Received += (model, ea) =>
        {
            var body = ea.Body.ToArray();
            var message = Encoding.UTF8.GetString(body);

            Console.WriteLine($"[{level.ToUpper()}] {message}");
            channel.BasicAck(ea.DeliveryTag, false);
        };

        channel.BasicConsume(level, false, consumer);

        Console.WriteLine("Nhấn Enter để thoát");
        Console.ReadLine();
    }
}
```

## Các tính năng nâng cao

### 1. Message Persistence

```csharp
// Đảm bảo queue và message được lưu trữ
channel.QueueDeclare(
    queue: "persistent-queue",
    durable: true,  // Queue sẽ được lưu trữ
    exclusive: false,
    autoDelete: false,
    arguments: null);

// Đảm bảo message được lưu trữ
var properties = channel.CreateBasicProperties();
properties.Persistent = true;

channel.BasicPublish(
    exchange: "",
    routingKey: "persistent-queue",
    basicProperties: properties,
    body: body);
```

### 2. Acknowledgment

```csharp
// Tắt auto-ack để xử lý thủ công
channel.BasicConsume(
    queue: "queue-name",
    autoAck: false,  // Tắt auto-ack
    consumer: consumer);

// Xác nhận message đã được xử lý thành công
channel.BasicAck(deliveryTag, false);

// Hoặc từ chối message
channel.BasicNack(deliveryTag, false, true);  // true = requeue
```

Khi tắt auto-ack, message chỉ rời queue lúc consumer xác nhận:

```mermaid
sequenceDiagram
    participant Q as Queue
    participant C as Consumer
    Q->>C: Giao message, autoAck = false
    alt Xử lý thành công
        C->>Q: BasicAck(deliveryTag)
        Note over Q: Xoá message khỏi queue
    else Xử lý lỗi
        C->>Q: BasicNack, requeue = true
        Note over Q: Đưa message trở lại queue
    end
```

### 3. Dead Letter Exchange

```csharp
// Khai báo dead letter exchange
channel.ExchangeDeclare("dlx", ExchangeType.Direct);

// Khai báo queue với dead letter exchange
var arguments = new Dictionary<string, object>
{
    { "x-dead-letter-exchange", "dlx" },
    { "x-dead-letter-routing-key", "failed" }
};

channel.QueueDeclare(
    queue: "main-queue",
    durable: false,
    exclusive: false,
    autoDelete: false,
    arguments: arguments);
```

## Lợi ích của RabbitMQ

1. **Độ tin cậy cao**: Hỗ trợ message persistence và acknowledgment
2. **Hiệu suất tốt**: Xử lý hàng nghìn message mỗi giây
3. **Linh hoạt**: Hỗ trợ nhiều messaging patterns
4. **Khả năng mở rộng**: Dễ dàng thêm producer/consumer
5. **Monitoring**: Cung cấp web UI để quản lý

## Kết luận

RabbitMQ là một công cụ mạnh mẽ cho việc xây dựng kiến trúc microservices và xử lý message bất đồng bộ. Với .NET 8, việc tích hợp RabbitMQ trở nên đơn giản và hiệu quả hơn bao giờ hết.

Trong bài viết này, chúng ta đã tìm hiểu:
- Khái niệm cơ bản về RabbitMQ
- Cách cài đặt và sử dụng
- Ví dụ thực tế với .NET 8
- Các tính năng nâng cao

Để tìm hiểu thêm, bạn có thể tham khảo:
- [RabbitMQ Documentation](https://www.rabbitmq.com/documentation.html)
- [RabbitMQ .NET Client](https://github.com/rabbitmq/rabbitmq-dotnet-client)
- [AMQP Protocol](https://www.amqp.org/)

Trên đây là một số ví dụ cơ bản về RabbitMQ và cách sử dụng nó trong ứng dụng .NET 8, hy vọng bạn thấy hữu ích.

### RabbitMQ là gì?

RabbitMQ là một open-source message broker (còn gọi là message queue) được phát triển bởi Rabbit Technologies. Nó hỗ trợ nhiều messaging protocol như AMQP, MQTT, STOMP và HTTP thông qua các plugin, thường được dùng trong kiến trúc microservices để xử lý message bất đồng bộ.

### Producer, Consumer, Queue, Exchange, Binding và Routing Key khác nhau thế nào?

Producer là ứng dụng gửi message, Consumer là ứng dụng nhận và xử lý message, Queue là nơi lưu trữ message. Exchange nhận message từ producer và định tuyến đến queue, Binding là quy tắc kết nối exchange với queue, còn Routing Key là khóa để exchange định tuyến message.

### Cài đặt RabbitMQ nhanh nhất bằng cách nào?

Cách được khuyến nghị là dùng Docker với lệnh: docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management. Sau khi chạy, truy cập RabbitMQ Management UI tại http://localhost:15672 với username và password mặc định là guest/guest.

### Làm sao để message không bị mất khi RabbitMQ khởi động lại?

Khai báo queue với durable là true để queue được lưu trữ, đồng thời đặt thuộc tính Persistent là true cho message khi publish. Ngoài ra nên tắt auto-ack bằng autoAck false và tự gọi BasicAck sau khi xử lý xong, dùng BasicNack với requeue khi xử lý thất bại.

### Message xử lý thất bại thì đi đâu?

Bạn có thể cấu hình Dead Letter Exchange: khai báo một exchange riêng (ví dụ dlx), rồi khai báo queue chính với arguments x-dead-letter-exchange và x-dead-letter-routing-key để message lỗi được chuyển sang đó.

## 🚀 Source Code Mẫu

Để xem và chạy code mẫu hoàn chỉnh, hãy truy cập: [GitHub Repository](https://github.com/TienNHM/rabbitmq-demo-net8)

Repository bao gồm:
- **Simple Producer/Consumer**: Ví dụ cơ bản gửi/nhận message
- **Advanced Producer/Consumer**: Sử dụng Exchange với routing
- **Shared Library**: Các class và utility chung
- **Hướng dẫn chi tiết**: README.md và QUICKSTART.md
- **Script tự động**: PowerShell script để dễ dàng chạy demo

### 🎯 Cách sử dụng nhanh:

```bash
# 1. Clone repository
git clone https://github.com/TienNHM/rabbitmq-demo-net8.git
cd rabbitmq-demo-net8

# 2. Khởi động RabbitMQ
docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management

# 3. Chạy demo
cd samples
.\run-samples.ps1
```

Happy coding! 🚀

![Screenshot](./screenshot.png)

## Bài liên quan

- [M02.08 - Messaging and Queuing](https://tiennhm.io.vn/docs/aws-cloud-practitioner-essentials/compute-in-the-cloud/messaging-and-queuing) — Tìm hiểu về messaging và queuing trong AWS, bao gồm Amazon SQS, Amazon SNS và Amazon EventBridge.
- [Module 17 — Distributed Systems](https://dotnet-course.tiennhm.io.vn/lessons/stage-05-senior-engineering/module-17-distributed-systems/README) — Hệ phân tán: consistency models, message brokers, idempotency, sagas — chuẩn bị tách dịch vụ và luồng tích hợp bất đồng bộ.