Kako proizvodite i konzumirate poruke u RabbitMQ-u (osnovna upotreba)?

Question

Accepted Answer

Osnovna RabbitMQ upotreba uključuje **objavljivanje** poruka na exchange/red čekanja i **konzumiranje** njih — obično preko client biblioteke (koristeći AMQP protokol). Razumijevanje osnovnog toka proizvodnje/konzumiranja je praktičan početak.

## Proizvodnja (objavljivanje) poruka

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

## Konzumiranje poruka

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

## Ključne praktične točke

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

## Zašto je to važno

Razumijevanje osnovne upotrebe proizvodnje/konzumiranja je vrijednost jer je to **praktičan početak korištenja RabbitMQ-a**, pa je to potrebno praktično znanje.

Znanje kako objavljivati i konzumirati poruke je temeljna vještina za korištenje RabbitMQ-a u aplikacijama.

Razumijevanje **proizvodnje poruka** — povezivanja, kreiranja kanala, deklariranja reda čekanja i objavljivanja poruka (s perzistentnošću za trajnost) — je osnovna operacija pisanja.

Razumijevanje **konzumiranja poruka** — deklariranja reda čekanja, postavljanja prefetch-a, konzumiranja poruka, obrade njih i **potvrđivanja** nakon obrade (s ručnim potvrđivanjima za pouzdanost) — je osnovna operacija čitanja koja uključuje važne praktike pouzdanosti.

Razumijevanje **ključnih praktičnih točaka** — korištenja client biblioteke (amqplib, pika, itd.), korištenja **kanala** (laganих veza za operacije, ponovna upotreba veze), **trajnih redova čekanja plus perzistentnih poruka** za preživljavanje ponovnog pokretanja, **ručnog potvrđivanja** za pouzdanu obradu i **prefetch-a** za poštenu distribuciju rada, te rukovanja greškama/ponovna konekcija i korištenja exchange-a/bindings-a za usmjeravanje — odražava praktične razmatranja za stvarnu RabbitMQ upotrebu.

Ete praktične točke (kanali, trajnost, ručno potvrđivanje, prefetch) povezuju konceptualno znanje (redovi čekanja, potvrđivanja, trajnost) na stvarni kod i odražavaju izgradnju pouzdanih RabbitMQ aplikacija.

Budući da je proizvodnja i konzumiranje poruka temeljna praktična vještina za korištenje RabbitMQ-a u aplikacijama, i budući da je razumijevanje osnovnog toka i praktičnih točaka (kanali, trajnost, ručno potvrđivanje, prefetch) potrebno praktično znanje, razumijevanje osnovne RabbitMQ upotrebe proizvodnje/konzumiranja je vrijednost, praktično relevantno znanje — praktičan početak korištenja RabbitMQ-a, povezivanje koncepata s kodom (s praksama pouzdanosti trajnih redova čekanja, perzistentnih poruka i ručnog potvrđivanja), i potrebno je za sve one koji zaista grade aplikacije s RabbitMQ-om.