Bagaimana anda menghasilkan dan menggunakan mesej dalam RabbitMQ (penggunaan asas)?

Question

Accepted Answer

Penggunaan asas RabbitMQ melibatkan **penerbitan (publishing)** mesej kepada exchange/queue dan **menggunakannya (consuming)** — biasanya melalui client library (menggunakan protokol AMQP). Memahami aliran produce/consume asas ialah titik masuk praktikalnya.

## Menghasilkan (menerbitkan) mesej

```js
// connect, create a channel, declare a queue, publish
const channel = await connection.createChannel();
await channel.assertQueue('tasks', { durable: true });   // ensure the queue exists
channel.sendToQueue('tasks',
  Buffer.from(JSON.stringify({ task: 'send-email' })),
  { persistent: true }                                    // persistent message (survives restart)
);
// → publishes a message (here directly to a queue via the default exchange)
```

## Menggunakan mesej

```js
await channel.assertQueue('tasks', { durable: true });
channel.prefetch(1);   // process one at a time (fair dispatch)
channel.consume('tasks', (msg) => {
  const data = JSON.parse(msg.content.toString());
  // process the task...
  channel.ack(msg);     // ACKNOWLEDGE after processing (reliable)
}, { noAck: false });   // manual acks (reliable)
```

## Poin praktikal utama

```text
✓ Use a CLIENT LIBRARY (amqplib for Node, pika for Python, Java client, etc.)
✓ CHANNELS → lightweight connections for operations (reuse the connection, use channels)
✓ DURABLE queues + PERSISTENT messages → survive broker restart (durability)
✓ MANUAL acks → reliable processing; PREFETCH → fair work distribution
✓ Handle errors, reconnection; use exchanges/bindings for routing (beyond the default exchange)
```

## Mengapa ia penting

Memahami penggunaan produce/consume asas adalah berharga kerana ia merupakan **titik masuk praktikal untuk menggunakan RabbitMQ**, jadi ia merupakan pengetahuan praktikal yang perlu.

Mengetahui cara menerbitkan dan menggunakan mesej ialah kemahiran asas untuk menggunakan RabbitMQ dalam aplikasi.

Memahami **menghasilkan mesej** — menyambung, mencipta channel, mengisytiharkan queue, dan menerbitkan mesej (dengan persistence untuk durability) — ialah operasi tulis asas.

Memahami **menggunakan mesej** — mengisytiharkan queue, menetapkan prefetch, menggunakan mesej, memprosesnya, dan **mengakui** selepas pemprosesan (dengan manual ack untuk kebolehpercayaan) — ialah operasi baca asas yang merangkumi amalan kebolehpercayaan yang penting.

Memahami **poin praktikal utama** — menggunakan client library (amqplib, pika, dll.), menggunakan **channel** (sambungan ringan untuk operasi, menggunakan semula sambungan), **durable queue serta persistent message** untuk bertahan apabila dimulakan semula, **manual ack** untuk pemprosesan yang boleh dipercayai dan **prefetch** untuk pengagihan kerja yang adil, serta mengendalikan ralat/penyambungan semula dan menggunakan exchange/binding untuk routing — mencerminkan pertimbangan praktikal untuk penggunaan RabbitMQ sebenar.

Poin praktikal ini (channel, durability, manual ack, prefetch) menghubungkan pengetahuan konseptual (queue, acknowledgment, durability) dengan kod sebenar dan mencerminkan pembinaan aplikasi RabbitMQ yang boleh dipercayai.

Memandangkan menghasilkan dan menggunakan mesej ialah kemahiran praktikal asas untuk menggunakan RabbitMQ dalam aplikasi, dan memandangkan memahami aliran asas serta poin praktikalnya (channel, durability, manual ack, prefetch) merupakan pengetahuan praktikal yang perlu, memahami penggunaan produce/consume asas RabbitMQ merupakan pengetahuan yang berharga dan relevan secara praktikal — titik masuk praktikal untuk menggunakan RabbitMQ, menghubungkan konsep dengan kod (dengan amalan kebolehpercayaan iaitu durable queue, persistent message, dan manual ack), serta perlu untuk sesiapa sahaja yang benar-benar membina aplikasi dengan RabbitMQ.