Bagaimana cara Anda memproduksi dan mengonsumsi pesan di RabbitMQ (penggunaan dasar)?

Question

Accepted Answer

Penggunaan dasar RabbitMQ melibatkan **menerbitkan** pesan ke exchange/queue dan **mengonsumsi** mereka — biasanya melalui pustaka klien (menggunakan protokol AMQP). Memahami alur produksi/konsumsi dasar adalah titik masuk praktis.

## Memproduksi (menerbitkan) pesan

```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)
```

## Mengonsumsi pesan

```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-poin praktis kunci

```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 ini penting

Memahami penggunaan produksi/konsumsi dasar sangat berharga karena ini adalah **titik masuk praktis untuk menggunakan RabbitMQ**, jadi ini adalah pengetahuan praktis yang diperlukan.

Mengetahui cara menerbitkan dan mengonsumsi pesan adalah keterampilan fundamental untuk menggunakan RabbitMQ dalam aplikasi.

Memahami **memproduksi pesan** — menghubungkan, membuat channel, mendeklarasikan queue, dan menerbitkan pesan (dengan persistensi untuk durabilitas) — adalah operasi penulisan dasar.

Memahami **mengonsumsi pesan** — mendeklarasikan queue, mengatur prefetch, mengonsumsi pesan, memproses mereka, dan **mengakui** setelah pemrosesan (dengan acks manual untuk keandalan) — adalah operasi pembacaan dasar yang mencakup praktik keandalan penting.

Memahami **poin-poin praktis kunci** — menggunakan pustaka klien (amqplib, pika, dll), menggunakan **channels** (koneksi ringan untuk operasi, menggunakan kembali koneksi), **queue tahan lama plus pesan persisten** untuk bertahan dari restart, **acks manual** untuk pemrosesan yang andal dan **prefetch** untuk distribusi pekerjaan yang adil, serta menangani kesalahan/koneksi ulang dan menggunakan exchanges/bindings untuk routing — mencerminkan pertimbangan praktis untuk penggunaan RabbitMQ nyata.

Poin-poin praktis ini (channels, durabilitas, acks manual, prefetch) menghubungkan pengetahuan konseptual (queues, acknowledgments, durabilitas) ke kode aktual dan mencerminkan pembangunan aplikasi RabbitMQ yang andal.

Karena memproduksi dan mengonsumsi pesan adalah keterampilan praktis fundamental untuk menggunakan RabbitMQ dalam aplikasi, dan karena memahami alur dasar dan poin-poin praktis (channels, durabilitas, acks manual, prefetch) adalah pengetahuan praktis yang diperlukan, memahami penggunaan produksi/konsumsi RabbitMQ dasar sangat berharga, pengetahuan yang relevan secara praktis — titik masuk praktis untuk menggunakan RabbitMQ, menghubungkan konsep ke kode (dengan praktik keandalan queue tahan lama, pesan persisten, dan acks manual), dan diperlukan bagi siapa pun yang benar-benar membangun aplikasi dengan RabbitMQ.