Si prodhoni dhe konsumoni mesazhe në RabbitMQ (përdorimi bazik)?

Question

Accepted Answer

Përdorimi bazik i RabbitMQ përfshin **publikimin** e mesazheve në një exchange/queue dhe **konsumimin** e tyre — zakonisht përmes një biblioteke klientit (duke përdorur protokollin AMQP). Të kuptuar rrjedhën bazike të prodhimit/konsumit është pika praktike e hyrjes.

## Prodhimi (publikimi) i mesazheve

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

## Konsumimi i mesazheve

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

## Pikat praktike kyçe

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

## Pse ka rëndësi

Të kuptuar përdorimin bazik të prodhimit/konsumit është i vlefshëm sepse ai është **pika praktike e hyrjes në përdorimin e RabbitMQ**, kështu që është njohuri e domosdoshme praktike.

Të dini se si të publikoni dhe konsumoni mesazhe është aftësia themelare për përdorimin e RabbitMQ në aplikacione.

Të kuptuar **prodhimin e mesazheve** — lidhjen, krijimin e një kanali, deklarimin e një queue-je dhe publikimin e mesazheve (me qëndrueshmëri për jetëgjatësi) — është operacioni bazik i shkrimit.

Të kuptuar **konsumimin e mesazheve** — deklarimin e queue-je, vendosjen e prefetch, konsumimin e mesazheve, përpunimin e tyre, dhe **miratimin** pas përpunimit (me acks manuale për besueshmëri) — është operacioni bazik i leximit që përfshin praktikat e rëndësishme të besueshmërisë.

Të kuptuar **pikat praktike kyçe** — përdorimin e një biblioteke klientu (amqplib, pika, etj.), përdorimin e **kanaleve** (lidhje të lehta për operacione, ringajtje të lidhjes), **queue-t qëndruese plus mesazhe të qëndrueshme** për të mbijetuar rinisjet, **acks manuale** për përpunimin e besueshëm dhe **prefetch** për shpërndarjen e drejtë të punës, dhe trajtimin e gabimeve/rikonektimit dhe përdorimin e exchange-ve/bindingeve për rutimin — pasqyron konsideratat praktike për përdorimin e vërtetë të RabbitMQ.

Këto pika praktike (kanalet, qëndrueshmëria, acks manuale, prefetch) lidhin njohuritë konceptuale (queue-t, miratimin, qëndrueshmërinë) me kodin aktual dhe pasqyrojnë ndërtimin e aplikacioneve të besueshme të RabbitMQ.

Dhe meqenëse prodhimi dhe konsumimi i mesazheve është aftësia themelare praktike për përdorimin e RabbitMQ në aplikacione, dhe meqenëse të kuptuar rrjedhën bazike dhe pikat praktike (kanalet, qëndrueshmëria, acks manuale, prefetch) është njohuri e domosdoshme praktike, të kuptuar përdorimin bazik të prodhimit/konsumit të RabbitMQ është njohuri e vlefshme, praktike dhe relevante — pika praktike e hyrjes në përdorimin e RabbitMQ, lidhja e koncepteve me kodin (me praktikat e besueshmërisë të queue-ve të qëndrueshme, mesazheve të qëndrueshme, dhe acks manuale), dhe e domosdoshme për këdo që në të vërtetë ndërton aplikacione me RabbitMQ.