Πώς παράγετε και καταναλώνετε μηνύματα στο RabbitMQ (βασική χρήση);

Question

Accepted Answer

Η βασική χρήση του RabbitMQ περιλαμβάνει **δημοσίευση** μηνυμάτων σε ένα exchange/queue και **κατανάλωσή** τους — συνήθως μέσω ενός client library (χρησιμοποιώντας το πρωτόκολλο AMQP). Η κατανόηση της βασικής ροής παραγωγής/κατανάλωσης είναι το πρακτικό σημείο εισόδου.

## Παραγωγή (δημοσίευση) μηνυμάτων

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

## Κατανάλωση μηνυμάτων

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

## Σημαντικά πρακτικά σημεία

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

## Γιατί έχει σημασία

Η κατανόηση της βασικής χρήσης παραγωγής/κατανάλωσης είναι πολύτιμη επειδή είναι το **πρακτικό σημείο εισόδου για τη χρήση του RabbitMQ**, επομένως είναι απαραίτητη πρακτική γνώση.

Η γνώση του τρόπου δημοσίευσης και κατανάλωσης μηνυμάτων είναι η θεμελιώδης δεξιότητα για τη χρήση του RabbitMQ σε εφαρμογές.

Η κατανόηση της **παραγωγής μηνυμάτων** — σύνδεση, δημιουργία ενός channel, δήλωση ενός queue και δημοσίευση μηνυμάτων (με persistence για ανθεκτικότητα) — είναι η βασική λειτουργία εγγραφής.

Η κατανόηση της **κατανάλωσης μηνυμάτων** — δήλωση του queue, ορισμός prefetch, κατανάλωση μηνυμάτων, επεξεργασία τους και **αναγνώριση** μετά την επεξεργασία (με manual acks για αξιοπιστία) — είναι η βασική λειτουργία ανάγνωσης που περιλαμβάνει τις σημαντικές πρακτικές αξιοπιστίας.

Η κατανόηση των **σημαντικών πρακτικών σημείων** — χρήση ενός client library (amqplib, pika, κ.λπ.), χρήση **channels** (ελαφρές συνδέσεις για λειτουργίες, επαναχρησιμοποίηση της σύνδεσης), **durable queues συν persistent messages** για επιβίωση σε επανεκκινήσεις, **manual acks** για αξιόπιστη επεξεργασία και **prefetch** για δίκαιη κατανομή εργασίας, και χειρισμό σφαλμάτων/επανασύνδεσης και χρήση exchanges/bindings για δρομολόγηση — αντικατοπτρίζει τις πρακτικές ενδείξεις για πραγματική χρήση του RabbitMQ.

Αυτά τα πρακτικά σημεία (channels, durability, manual acks, prefetch) συνδέουν τη θεωρητική γνώση (queues, acknowledgments, durability) με πραγματικό κώδικα και αντικατοπτρίζουν την κατασκευή αξιόπιστων εφαρμογών RabbitMQ.

Επειδή η παραγωγή και κατανάλωση μηνυμάτων είναι η θεμελιώδης πρακτική δεξιότητα για τη χρήση του RabbitMQ σε εφαρμογές, και επειδή η κατανόηση της βασικής ροής και των πρακτικών σημείων (channels, durability, manual acks, prefetch) είναι απαραίτητη πρακτική γνώση, η κατανόηση της βασικής χρήσης παραγωγής/κατανάλωσης του RabbitMQ είναι πολύτιμη, πρακτικά σχετική γνώση — το πρακτικό σημείο εισόδου για τη χρήση του RabbitMQ, σύνδεση των εννοιών με τον κώδικα (με τις πρακτικές αξιοπιστίας των durable queues, persistent messages και manual acks), και απαραίτητη για όποιον κατασκευάζει πραγματικές εφαρμογές με το RabbitMQ.