Kaip gaminate ir vartojate pranešimus RabbitMQ (pagrindinė naudojimo forma)?

Question

Accepted Answer

Pagrindinė RabbitMQ naudojimo forma apima **pranešimų publikavimą** į mainų tarpą/eilę ir jų **vartojimą** — paprastai naudojant kliento biblioteką (AMQP protokolą). Pagrindinės gaminio/vartotojo srauto supratimas yra praktinis įėjimo taškas.

## Pranešimų gamyba (publikavimas)

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

## Pranešimų vartojimas

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

## Pagrindiniai praktiniai punktai

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

## Kodėl tai svarbu

Pagerindinės gaminio/vartotojo naudojimo supratimas yra vertingas, nes tai yra **praktinis RabbitMQ naudojimo įėjimo taškas**, todėl reikalingos praktinės žinios.

Žinojimas, kaip publikuoti ir vartoti pranešimus, yra pagrindinė RabbitMQ naudojimo programose įgūdis.

Pagerindinių **pranešimų gamybos** supratimas — ryšio sukūrimas, kanalo kūrimas, eilės deklaravimas ir pranešimų publikavimas (naudojant pastovumą dėl patvarumo) — yra pagrindinė rašymo operacija.

Pagerindinių **pranešimų vartojimo** supratimas — eilės deklaravimas, išankstinio nusikrautos nustatymas, pranešimų vartojimas, jų apdorojimas ir **patvirtinimas** po apdorojimo (rankiniai patvirtinimai patikimumui) — yra pagrindinė skaitymo operacija, kuri apima svarbias patikimumo praktikas.

Pagerindinių **praktinių punktų** supratimas — kliento bibliotekos naudojimas (amqplib, pika ir kt.), **kanalų** naudojimas (lengvi ryšiai operacijoms, pakartotinis ryšio naudojimas), **patvarūs failai ir nuolatiniai pranešimai** pertvaroms išlaikyti, **rankiniai patvirtinimai** patikimam apdorojimui ir **išankstinis nusikrautos** dėl sąžiningo darbo paskirstymo, bei klaidų/pakartotinio ryšio tvarkymas ir mainų erdvės/susietų naudojimas maršrutizavimui — atspindi praktinius svarstymus dėl tikro RabbitMQ naudojimo.

Šie praktiniai punktai (kanalai, patvarumas, rankiniai patvirtinimai, išankstinis nusikrautos) susieja konceptualines žinias (eilės, patvirtinimai, patvarumas) su tikriniu kodu ir atspindi patikimų RabbitMQ programų kūrimą.

Cadre pranešimų gamyba ir vartojimas yra pagrindinė praktinė RabbitMQ naudojimo programose įgūdis, ir kadangi pagrindinio srauto supratimas bei praktinių punktų (kanalai, patvarumas, rankiniai patvirtinimai, išankstinis nusikrautos) supratimas yra reikalinga praktinė žinojimas, pagrindinio RabbitMQ gaminio/vartotojo naudojimo supratimas yra vertinga, praktiškai aktuali žinojimas — praktinis RabbitMQ naudojimo įėjimo taškas, sąvokų susietas su kodu (naudojant patikimų praktikas iš patvarių eilių, nuolatinių pranešimų ir rankinių patvirtinimų), ir reikalinga visiems, kurie iš tikrųjų kurie programas su RabbitMQ.