तुम्ही RabbitMQ मध्ये संदेश कसे तयार करता आणि वापरता (मूलभूत वापर)?

Question

Accepted Answer

मूलभूत RabbitMQ वापरामध्ये **प्रकाशन** (publishing) exchange/queue मध्ये संदेश आणि **वापर** (consuming) करणे समाविष्ट असते — सामान्यत: क्लायंट लायब्ररी द्वारे (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 जाहीर करणे, आणि संदेश प्रकाशित करणे (टिकाऊपणासाठी स्थिरतेसह) — हे मूलभूत लेखन ऑपरेशन आहे.

**संदेश वापरणे** समजून घेणे — queue जाहीर करणे, prefetch सेट करणे, संदेश वापरणे, त्यांची प्रक्रिया करणे, आणि प्रक्रियेनंतर **स्वीकृतीद्वारे** (विश्वसनीयतेसाठी manual acks सह) — हे मूलभूत वाचन ऑपरेशन आहे ज्यामध्ये महत्वाचे विश्वसनीयता अभ्यास समाविष्ट आहेत.

**मुख्य व्यावहारिक बिंदू** समजून घेणे — क्लायंट लायब्ररी वापरणे (amqplib, pika, इत्यादी), **चॅनेल** वापरणे (ऑपरेशनसाठी हलके जुळवणी, जुळवणी पुन्हा वापरणे), **टिकाऊ queue आणि स्थिर संदेश** पुनः सुरू होण्यासाठी, **manual acks** विश्वसनीय प्रक्रियेसाठी आणि **prefetch** न्याय्य कार्य वितरणासाठी, आणि त्रुटी/पुनर्जुळवणी हाताळणे आणि रूटिंगसाठी exchanges/bindings वापरणे — वास्तविक RabbitMQ वापरण्यासाठी व्यावहारिक विचारांचे प्रतिबिंब आहेत.

हे व्यावहारिक बिंदू (चॅनेल, टिकाऊपणा, manual acks, prefetch) संकल्पनात्मक ज्ञान (queues, acknowledgments, durability) आणि वास्तविक कोड यांना जोडतात आणि विश्वसनीय RabbitMQ अनुप्रयोग तयार करण्याचे प्रतिबिंब आहेत.

संदेश तयार आणि वापरणे हे RabbitMQ अनुप्रयोगांमध्ये वापरण्याचे मूलभूत व्यावहारिक कौशल्य असल्याने, आणि मूलभूत प्रवाह आणि व्यावहारिक बिंदू (चॅनेल, टिकाऊपणा, manual acks, prefetch) समजून घेणे आवश्यक व्यावहारिक ज्ञान असल्याने, मूलभूत RabbitMQ produce/consume वापर समजून घेणे मूल्यवान, व्यावहारिकदृष्ट्या प्रासंगिक ज्ञान आहे — RabbitMQ वापरण्याचा व्यावहारिक प्रवेशद्वार, संकल्पना कोडशी जोडणे (टिकाऊ queue, स्थिर संदेश, आणि manual acks च्या विश्वसनीयता अभ्यासांसह), आणि RabbitMQ सह अनुप्रयोग तयार करणार्‍या कोणासाठीही आवश्यक आहे.