RabbitMQ मा सन्देशहरु कसरी उत्पादन र उपभोग गर्नुहुन्छ (आधारभूत प्रयोग)?

Question

Accepted Answer

आधारभूत RabbitMQ प्रयोगमा **प्रकाशन** सन्देशहरु exchange/queue मा गरी र तिनलाई **उपभोग** गर्ने समावेश हुन्छ — सामान्यतः client library द्वारा (AMQP protocol प्रयोग गरी)। आधारभूत produce/consume flow बुझ्नु व्यावहारिक प्रवेश बिन्दु हो।

## सन्देशहरु उत्पादन गरिहाँल (प्रकाशन)

```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 प्रयोगको मौलिक सीप हो।

**सन्देशहरु उत्पादन गरिहाँल** बुझ्नु — जडान गर्नु, channel सिर्जना गर्नु, queue घोषणा गर्नु, र सन्देशहरु प्रकाशन गर्नु (स्थায়ित्वको लागि persistence सहित) — आधारभूत लेखन सञ्चालन हो।

**सन्देशहरु उपभोग गरिहाँल** बुझ्नु — queue घोषणा गर्नु, prefetch सेट गर्नु, सन्देशहरु उपभोग गर्नु, तिनलाई प्रक्रिया गर्नु, र प्रसंस्करण गरिसकेपछी **acknowledgment** गर्नु (विश्वसनीयताको लागि manual acks सहित) — आधारभूत पढन सञ्चालन हो जसमा महत्त्वपूर्ण विश्वसनीयता अभ्यासहरु समावेश छन्।

**मुख्य व्यावहारिक बिन्दुहरु** बुझ्नु — client library (amqplib, pika, आदि) प्रयोग गर्नु, **channels** प्रयोग गर्नु (सञ्चालनको लागि हल्के जडानहरु, जडानलाई पुनः प्रयोग गर्नु), **durable queues अतिरिक्त persistent messages** पुनरारम्भ गरेर बचाउनको लागि, **manual acks** विश्वसनीय प्रसंस्करणको लागि र **prefetch** निष्पक्ष काम वितरणको लागि, र त्रुटि/पुनः जडान सम्हालनु र routing को लागि exchanges/bindings प्रयोग गर्नु — वास्तविक RabbitMQ प्रयोगको व्यावहारिक विचारहरु प्रतिबिम्बित गर्दछ।

यी व्यावहारिक बिन्दुहरु (channels, durability, manual acks, prefetch) वैचारिक ज्ञान (queues, acknowledgments, durability) लाई वास्तविक कोड र विश्वसनीय RabbitMQ अनुप्रयोगहरु निर्माण गर्न गरिहाँल प्रतिबिम्बित गर्दछन्।

सन्देशहरु उत्पादन गर्नु र उपभोग गर्नु अनुप्रयोगहरुमा RabbitMQ प्रयोग गरिहाँलको मौलिक व्यावहारिक सीप भएकोले, र आधारभूत flow र व्यावहारिक बिन्दुहरु (channels, durability, manual acks, prefetch) को समझ आवश्यक हातेहाते ज्ञान भएकोले, आधारभूत RabbitMQ produce/consume प्रयोग बुझ्नु मूल्यवान, व्यावहारिक-सम्बन्धित ज्ञान हो — RabbitMQ को व्यावहारिक प्रवेश बिन्दु, अवधारणाहरुलाई कोड (durable queues, persistent messages, र manual acks को विश्वसनीयता अभ्यासहरु सहित) मा जोडिहाँल, र RabbitMQ सहित अनुप्रयोगहरु निर्माण गर्दै गरेको कोहीको लागि आवश्यक।