Làm thế nào để produce và consume message trong RabbitMQ (cách dùng cơ bản)?

Question

Accepted Answer

Cách dùng RabbitMQ cơ bản bao gồm **publish** message đến một exchange/queue và **consume** chúng — thường thông qua một thư viện client (dùng giao thức AMQP). Hiểu luồng produce/consume cơ bản là điểm khởi đầu thực tế.

## Producing (publishing) message

```js
// kết nối, tạo một channel, khai báo một queue, publish
const channel = await connection.createChannel();
await channel.assertQueue('tasks', { durable: true });   // đảm bảo queue tồn tại
channel.sendToQueue('tasks',
  Buffer.from(JSON.stringify({ task: 'send-email' })),
  { persistent: true }                                    // message persistent (tồn tại qua restart)
);
// → publish một message (ở đây trực tiếp đến một queue qua default exchange)
```

## Consuming message

```js
await channel.assertQueue('tasks', { durable: true });
channel.prefetch(1);   // xử lý từng cái một (fair dispatch)
channel.consume('tasks', (msg) => {
  const data = JSON.parse(msg.content.toString());
  // xử lý task...
  channel.ack(msg);     // ACKNOWLEDGE sau khi xử lý (đáng tin cậy)
}, { noAck: false });   // manual ack (đáng tin cậy)
```

## Các điểm thực tế chính

```text
✓ Dùng một THƯ VIỆN CLIENT (amqplib cho Node, pika cho Python, Java client, v.v.)
✓ CHANNEL → connection nhẹ cho các thao tác (tái sử dụng connection, dùng channel)
✓ DURABLE queue + PERSISTENT message → tồn tại qua restart broker (durability)
✓ MANUAL ack → xử lý đáng tin cậy; PREFETCH → phân phối công việc công bằng
✓ Xử lý lỗi, kết nối lại; dùng exchange/binding cho định tuyến (ngoài default exchange)
```

## Tại sao điều này quan trọng

Hiểu cách dùng produce/consume cơ bản là điều có giá trị bởi vì đó là **điểm khởi đầu thực tế để dùng RabbitMQ**, nên đó là kiến thức thực hành cần thiết.

Biết cách publish và consume message là kỹ năng cơ bản để dùng RabbitMQ trong các ứng dụng.

Hiểu **producing message** — kết nối, tạo một channel, khai báo một queue, và publish message (với persistence cho durability) — là thao tác ghi cơ bản.

Hiểu **consuming message** — khai báo queue, đặt prefetch, consume message, xử lý chúng, và **acknowledge** sau khi xử lý (với manual ack cho độ tin cậy) — là thao tác đọc cơ bản bao gồm các thực hành độ tin cậy quan trọng.

Hiểu các **điểm thực tế chính** — dùng một thư viện client (amqplib, pika, v.v.), dùng **channel** (connection nhẹ cho các thao tác, tái sử dụng connection), **durable queue cùng persistent message** để tồn tại qua restart, **manual ack** cho xử lý đáng tin cậy và **prefetch** cho phân phối công việc công bằng, và xử lý lỗi/kết nối lại và dùng exchange/binding cho định tuyến — phản ánh các cân nhắc thực tế cho việc dùng RabbitMQ thực sự.

Các điểm thực tế này (channel, durability, manual ack, prefetch) kết nối kiến thức khái niệm (queue, acknowledgment, durability) với code thực tế và phản ánh việc xây dựng các ứng dụng RabbitMQ đáng tin cậy.

Vì produce và consume message là kỹ năng thực tế cơ bản để dùng RabbitMQ trong các ứng dụng, và vì hiểu luồng cơ bản và các điểm thực tế (channel, durability, manual ack, prefetch) là kiến thức thực hành cần thiết, nên hiểu cách dùng produce/consume RabbitMQ cơ bản là kiến thức có giá trị, liên quan thực tế — điểm khởi đầu thực tế để dùng RabbitMQ, kết nối khái niệm với code (với các thực hành độ tin cậy là durable queue, persistent message, và manual ack), và cần thiết cho bất kỳ ai thực sự xây dựng ứng dụng với RabbitMQ.