Kako produciraš in konzumiraš sporočila v RabbitMQ-ju (osnovna uporaba)?

Question

Accepted Answer

Osnovna uporaba RabbitMQ-ja vključuje **objavljanje** sporočil na exchange/vrsto in **konzumiranje** le-teh — tipično preko odjemalske knjižnice (z uporabo AMQP protokola). Razumevanje osnovnega toka produciranja/konzumiranja je praktični vstopni punkt.

## Produciranje (objavljanje) sporočil

```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 sporočil

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

## Zakaj je to pomembno

Razumevanje osnovne uporabe produciranja/konzumiranja je dragoceno, ker je to **praktični vstopni punkt za uporabo RabbitMQ-ja**, zato je potrebno praktično znanje.

Znanje, kako objavljati in konzumirati sporočila, je temeljna veščina za uporabo RabbitMQ-ja v aplikacijah.

Razumevanje **produciranja sporočil** — povezovanje, ustvarjanje kanala, razglasitev vrste in objavljanje sporočil (s stanjem trajnosti za obstojnost) — je osnovna operacija pisanja.

Razumevanje **konzumiranja sporočil** — razglasitev vrste, nastavitev prefetch, konzumiranje sporočil, njihova obdelava in **potrjevanje** po obdelavi (z ročnim potvrjevanjem za zanesljivost) — je osnovna operacija branja, ki vključuje pomembne prakse zanesljivosti.

Razumevanje **ključnih praktičnih točk** — uporaba odjemalske knjižnice (amqplib, pika, itd.), uporaba **kanalov** (lahkotne povezave za operacije, ponovno uporabo povezave), **trajne vrste skupaj s trajnimi sporočili** za preživetje ponovnih zagonov, **ročno potrjevanje** za zanesljivo obdelavo in **prefetch** za pravično porazdelitev dela, ter obravnavanje napak/ponovno povezovanje in uporaba exchange/povezav za usmerjanje — odraža praktične vidike za pravo uporabo RabbitMQ-ja.

Te praktične točke (kanali, trajnost, ročno potrjevanje, prefetch) povezujejo konceptualno znanje (vrste, potrdila, trajnost) s pravim kodom in odražajo gradnjo zanesljivih RabbitMQ aplikacij.

Ker je produciranje in konzumiranje sporočil temeljna praktična veščina za uporabo RabbitMQ-ja v aplikacijah, in ker je razumevanje osnovnega toka in praktičnih točk (kanali, trajnost, ročno potrjevanje, prefetch) potrebno praktično znanje, je razumevanje osnovne uporabe RabbitMQ produciranja/konzumiranja dragoceno, praktično relevantno znanje — praktični vstopni punkt za uporabo RabbitMQ-ja, povezovanje konceptov s kodom (s praksami zanesljivosti trajnih vrst, trajnih sporočil in ročnega potrjevanja), in potrebno za vsakogar, ki dejansko gradi aplikacije z RabbitMQ-jem.