RabbitMQ-তে আপনি কীভাবে বার্তা তৈরি এবং ভোগ করেন (মৌলিক ব্যবহার)?

Question

Accepted Answer

মৌলিক RabbitMQ ব্যবহার **বার্তা প্রকাশ** করা এবং **ভোগ** করার সাথে জড়িত — সাধারণত একটি ক্লায়েন্ট লাইব্রেরির মাধ্যমে (AMQP প্রোটোকল ব্যবহার করে)। মৌলিক produce/consume প্রবাহ বোঝা হল ব্যবহারিক প্রবেশদ্বার।

## বার্তা উৎপাদন (প্রকাশ)

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

## এটি কেন গুরুত্বপূর্ণ

মৌলিক produce/consume ব্যবহার বোঝা মূল্যবান কারণ এটি **RabbitMQ ব্যবহারের ব্যবহারিক প্রবেশদ্বার**, তাই এটি প্রয়োজনীয় হাতে-কলমে জ্ঞান।

বার্তা প্রকাশ এবং ভোগ করতে জানা RabbitMQ ব্যবহারের মৌলিক দক্ষতা।

**বার্তা উৎপাদন** বোঝা — সংযোগ, চ্যানেল তৈরি, queue ঘোষণা এবং বার্তা প্রকাশ করা (স্থায়িত্বের জন্য persistence সহ) — হল মৌলিক লেখার অপারেশন।

**বার্তা ভোগ** বোঝা — queue ঘোষণা, prefetch সেট করা, বার্তা ভোগ করা, তাদের প্রক্রিয়াজাত করা এবং প্রক্রিয়াকরণের পরে **স্বীকৃতি** দেওয়া (নির্ভরযোগ্যতার জন্য manual acks সহ) — হল মৌলিক পড়ার অপারেশন যা গুরুত্বপূর্ণ নির্ভরযোগ্যতা অনুশীলনগুলি অন্তর্ভুক্ত করে।

**মূল ব্যবহারিক পয়েন্ট** বোঝা — একটি ক্লায়েন্ট লাইব্রেরি ব্যবহার করা (amqplib, pika, ইত্যাদি), **চ্যানেল** ব্যবহার করা (অপারেশনের জন্য হালকা সংযোগ, সংযোগ পুনর্ব্যবহার), **durable queues প্লাস persistent messages** রিস্টার্টের পরে বেঁচে থাকার জন্য, **manual acks** নির্ভরযোগ্য প্রক্রিয়াকরণের জন্য এবং **prefetch** ন্যায্য কাজের বিতরণের জন্য, এবং ত্রুটি/পুনরায় সংযোগ পরিচালনা এবং রুটিং এর জন্য exchanges/bindings ব্যবহার করা — প্রকৃত RabbitMQ ব্যবহারের জন্য ব্যবহারিক বিবেচনাগুলি প্রতিফলিত করে।

এই ব্যবহারিক পয়েন্টগুলি (চ্যানেল, স্থায়িত্ব, manual acks, prefetch) ধারণাগত জ্ঞানকে (queue, স্বীকৃতি, স্থায়িত্ব) প্রকৃত কোডের সাথে সংযুক্ত করে এবং নির্ভরযোগ্য RabbitMQ অ্যাপ্লিকেশন তৈরি করা প্রতিফলিত করে।

যেহেতু বার্তা উৎপাদন এবং ভোগ RabbitMQ ব্যবহারের মৌলিক ব্যবহারিক দক্ষতা, এবং যেহেতু মৌলিক প্রবাহ এবং ব্যবহারিক পয়েন্ট (চ্যানেল, স্থায়িত্ব, manual acks, prefetch) বোঝা প্রয়োজনীয় হাতে-কলমে জ্ঞান, RabbitMQ produce/consume ব্যবহার বোঝা মূল্যবান, ব্যবহারিকভাবে প্রাসঙ্গিক জ্ঞান — RabbitMQ ব্যবহারের ব্যবহারিক প্রবেশদ্বার, ধারণাকে কোডের সাথে সংযুক্ত করা (durable queues, persistent messages এবং manual acks এর নির্ভরযোগ্যতা অনুশীলনের সাথে), এবং RabbitMQ দিয়ে প্রকৃতপক্ষে অ্যাপ্লিকেশন তৈরি করছে এমন যে কাউকে জন্য প্রয়োজনীয়।