كيف تنتج وتستهلك الرسائل في RabbitMQ (الاستخدام الأساسي)؟

Question

Accepted Answer

يتضمن الاستخدام الأساسي لـ RabbitMQ **نشر** الرسائل إلى exchange/queue و**استهلاكها** — عادةً عبر مكتبة عميل (باستخدام بروتوكول 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 في التطبيقات.

فهم **إنتاج الرسائل** — الاتصال، وإنشاء قناة، والإعلان عن قائمة انتظار، ونشر الرسائل (مع المثابرة من أجل الاستقرار) — هو العملية الكتابية الأساسية.

فهم **استهلاك الرسائل** — الإعلان عن قائمة الانتظار، وتعيين prefetch، واستهلاك الرسائل، ومعالجتها، و**الإقرار** بعد المعالجة (مع الإقرارات اليدوية لزيادة الموثوقية) — هي عملية القراءة الأساسية التي تتضمن ممارسات الموثوقية المهمة.

فهم **النقاط العملية الرئيسية** — استخدام مكتبة عميل (amqplib, pika, إلخ)، استخدام **القنوات** (اتصالات خفيفة الوزن للعمليات، إعادة استخدام الاتصال)، **قوائم الانتظار الدائمة بالإضافة إلى الرسائل الدائمة** من أجل البقاء عند إعادة التشغيل، **الإقرارات اليدوية** من أجل المعالجة الموثوقة و**prefetch** من أجل توزيع العمل بشكل عادل، ومعالجة الأخطاء/إعادة الاتصال واستخدام exchanges/bindings للتوجيه — يعكس الاعتبارات العملية لاستخدام RabbitMQ الفعلي.

هذه النقاط العملية (القنوات، الاستقرار، الإقرارات اليدوية، prefetch) تربط المعرفة المفاهيمية (قوائم الانتظار، الإقرارات، الاستقرار) بالكود الفعلي وتعكس بناء تطبيقات RabbitMQ الموثوقة.

بما أن إنتاج واستهلاك الرسائل هي المهارة العملية الأساسية لاستخدام RabbitMQ في التطبيقات، وبما أن فهم التدفق الأساسي والنقاط العملية (القنوات، الاستقرار، الإقرارات اليدوية، prefetch) هي معرفة عملية ضرورية، فإن فهم الاستخدام الأساسي لإنتاج/استهلاك RabbitMQ هي معرفة قيّمة وذات صلة عملياً — نقطة الدخول العملية لاستخدام RabbitMQ، وربط المفاهيم بالكود (مع ممارسات الموثوقية الخاصة بقوائم الانتظار الدائمة والرسائل الدائمة والإقرارات اليدوية)، وضرورية لأي شخص يبني تطبيقات فعلاً باستخدام RabbitMQ.