Jak produkujete a konzumujete zprávy v RabbitMQ (základní použití)?

Question

Accepted Answer

Základní použití RabbitMQ zahrnuje **publikování** zpráv do exchange/fronty a jejich **konzumaci** — typicky prostřednictvím klientské knihovny (využívající protokol AMQP). Pochopení základního toku produkce/konzumace je praktickým vstupním bodem.

## Produkce (publikování) zpráv

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

## Konzumace zpráv

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

## Klíčové praktické body

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

## Proč je to důležité

Pochopení základního použití produkce/konzumace je cenné, protože je to **praktický vstupní bod do používání RabbitMQ**, a je tedy nezbytnou praktickou znalostí.

Vědět, jak publikovat a konzumovat zprávy, je základní dovedností pro používání RabbitMQ v aplikacích.

Pochopení **produkce zpráv** — připojení, vytvoření kanálu, deklarace fronty a publikování zpráv (s perzistencí pro trvanlivost) — je základní operace zápisu.

Pochopení **konzumace zpráv** — deklarace fronty, nastavení prefetch, konzumace zpráv, jejich zpracování a **potvrzování** po zpracování (s manuálním potvrzováním pro spolehlivost) — je základní operace čtení, která zahrnuje důležité praktiky spolehlivosti.

Pochopení **klíčových praktických bodů** — používání klientské knihovny (amqplib, pika, atd.), používání **kanálů** (lehké připojení pro operace, opakované používání připojení), **trvalých front plus perzistentních zpráv** pro přežití restartů, **manuálního potvrzování** pro spolehlivé zpracování a **prefetch** pro spravedlivé rozdělení práce, a zpracování chyb/opětovného připojení a používání exchange/vazeb pro směrování — odráží praktické úvahy pro skutečné používání RabbitMQ.

Tyto praktické body (kanály, trvanlivost, manuální potvrzování, prefetch) propojují koncepční znalosti (fronty, potvrzování, trvanlivost) s aktuálním kódem a odrážejí vytváření spolehlivých aplikací RabbitMQ.

Pavždy se produkce a konzumace zpráv je základní praktickou dovedností pro používání RabbitMQ v aplikacích, a protože pochopení základního toku a praktických bodů (kanály, trvanlivost, manuální potvrzování, prefetch) je nezbytnou praktickou znalostí, pochopení základního použití produkce/konzumace RabbitMQ je cenná, prakticky relevantní znalost — praktický vstupní bod do používání RabbitMQ, propojení konceptů s kódem (s praktikami spolehlivosti trvalých front, perzistentních zpráv a manuálního potvrzování) a nezbytné pro každého, kdo skutečně vytváří aplikace s RabbitMQ.