Hogyan állítasz elő és fogyasztasz üzeneteket a RabbitMQ-ban (alapszintű használat)?

Question

Accepted Answer

A RabbitMQ alapszintű használata az üzenetek **közzétételét** egy exchange-hez vagy sorhoz és **fogyasztásukat** jelenti — tipikusan egy kliens könyvtár segítségével (az AMQP protokoll használatával). Az alapszintű termelés/fogyasztás folyamatának megértése a gyakorlati belépési pont.

## Üzenetek termelése (közzététele)

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

## Üzenetek fogyasztása

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

## Fő gyakorlati pontok

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

## Miért számít

Az alapszintű termelés/fogyasztás használatának megértése értékes, mert ez **a RabbitMQ használatának gyakorlati belépési pontja**, így szükséges gyakorlati tudás.

Az üzenetek közzétételének és fogyasztásának módjának ismerete a RabbitMQ alkalmazásokban való használatának alapvető készségét jelenti.

**Az üzenetek termelésének** megértése — csatlakozás, csatorna létrehozása, sor deklarálása és üzenetek közzététele (a tartósság érdekében való megőrzéssel) — az alapszintű írási művelet.

A **fogyasztási üzenetek** megértése — sor deklarálása, prefetch beállítása, üzenetek fogyasztása, feldolgozása és **nyugtázása** feldolgozás után (kézi nyugták a megbízhatósághoz) — az alapszintű olvasási művelet, amely magában foglalja a fontos megbízhatósági gyakorlatokat.

A **fő gyakorlati pontok** megértése — kliens könyvtár használata (amqplib, pika, stb.), **csatornák** használata (könnyű kapcsolatok műveletek végzéséhez, a kapcsolat újrafelhasználása), **tartós sorok plusz kitartó üzenetek** az újraindítások túléléséhez, **kézi nyugták** a megbízható feldolgozáshoz és **prefetch** a tisztességes munkamegosztáshoz, valamint hibakezelés/újracsatlakozás és exchange-ek/bindingjok használata az útválasztáshoz — a valódi RabbitMQ-használat gyakorlati szempontjaira utal.

Ezek a gyakorlati pontok (csatornák, tartósság, kézi nyugták, prefetch) a fogalmi tudást (sorok, nyugták, tartósság) a tényleges kódhoz és a megbízható RabbitMQ-alkalmazások felépítésének gyakorlati szempontjaihoz kapcsolják.

Mivel az üzenetek termelése és fogyasztása a RabbitMQ alkalmazásokban való használatának alapvető gyakorlati készségét jelenti, és mivel az alapszintű folyamat és a gyakorlati pontok (csatornák, tartósság, kézi nyugták, prefetch) megértése szükséges gyakorlati tudás, a RabbitMQ alapszintű termelés/fogyasztás használatának megértése értékes, gyakorlatilag releváns tudás — a RabbitMQ használatának gyakorlati belépési pontja, a fogalmak és a kód összekapcsolása (tartós sorok, kitartó üzenetek és kézi nyugták megbízhatósági gyakorlataival), valamint szükséges mindazok számára, akik valóban RabbitMQ-val alkalmazásokat építenek.