ਤੁਸੀਂ 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 ਸੈੱਟ ਕਰਨਾ, ਸੁਨੇਹੇ ਖਾਪਣਾ, ਉਹਨਾਂ ਦੀ ਪ੍ਰਕਿਰਿਆ ਕਰਨਾ, ਅਤੇ ਪ੍ਰਕਿਰਿਆ ਤੋਂ ਬਾਅਦ **ਸਵੀਕ੍ਰਿਤੀ** ਦੇਣਾ (ਭਰੋਸੇਮੰਦਤਾ ਲਈ ਸਧਾਰਨ acks ਦੇ ਨਾਲ) — ਬੁਨਿਆਦੀ ਪੜ੍ਹਨ ਕਾਰਜ ਹੈ ਜੋ ਮਹੱਤਵਪੂਰਨ ਭਰੋਸੇਮੰਦਤਾ ਰਵਈਆ ਸ਼ਾਮਲ ਕਰਦਾ ਹੈ।

**ਮਾਮੂਲੀ ਵਿਹਾਰਕ ਬਿੰਦੂਆਂ** ਨੂੰ ਸਮਝਣਾ — ਕਲਾਇਂਟ ਲਾਇਬ੍ਰੇਰੀ ਦੀ ਵਰਤੋਂ ਕਰਨਾ (amqplib, pika, ਆਦਿ), **ਚੈਨਲ** ਦੀ ਵਰਤੋਂ ਕਰਨਾ (ਕਾਰਜਾਂ ਲਈ ਹਲਕੇ ਕਨੈਕਸ਼ਨ, ਜੋੜ ਦੀ ਪੁਨਰ ਵਰਤੋਂ), **ਸਥਾਈ ਕਿਊ ਅਤੇ ਮਾਸ਼ਟਰ ਸੁਨੇਹੇ** ਪੁਨਰ ਸ਼ੁਰਆਤ ਤੋਂ ਬਚੀ ਰੱਖਣ ਲਈ, **ਸਧਾਰਨ acks** ਭਰੋਸੇਮੰਦ ਪ੍ਰਕਿਰਿਆ ਲਈ ਅਤੇ **prefetch** ਨਿਆਮ ਕੰਮ ਵੰਡ ਲਈ, ਅਤੇ ਗਲਤੀਆਂ/ਮੁੜ-ਸੰਪਰਕ ਸੰਭਾਲਣਾ ਅਤੇ routing ਲਈ exchanges/bindings ਦੀ ਵਰਤੋਂ — ਅਸਲ RabbitMQ ਵਰਤੋਂ ਲਈ ਵਿਹਾਰਕ ਵਿਚਾਰ ਪ੍ਰਤੀਬਿੰਬਿਤ ਕਰਦਾ ਹੈ।

ਇਹ ਵਿਹਾਰਕ ਬਿੰਦੂ (ਚੈਨਲ, ਸਥਿਤੀ, ਸਧਾਰਨ acks, prefetch) ਸੰਕਲਪਾਤਮਕ ਗਿਆਨ (ਕਿਊ, ਸਵੀਕ੍ਰਿਤੀ, ਸਥਿਤੀ) ਨੂੰ ਅਸਲ ਕੋਡ ਨਾਲ ਜੋੜਦੇ ਹਨ ਅਤੇ ਭਰੋਸੇਮੰਦ RabbitMQ ਐਪਲੀਕੇਸ਼ਨਾਂ ਨਿਰਮਾਣ ਨੂੰ ਪ੍ਰਤੀਬਿੰਬਿਤ ਕਰਦੇ ਹਨ।

ਕਿਉਂਕਿ ਸੁਨੇਹੇ ਪ੍ਰਾਪਤ ਅਤੇ ਖਪਤ ਕਰਨਾ RabbitMQ ਨੂੰ ਐਪਲੀਕੇਸ਼ਨਾਂ ਵਿੱਚ ਵਰਤਣ ਲਈ ਮੌਲਿਕ ਵਿਹਾਰਕ ਹੁਨਰ ਹੈ, ਅਤੇ ਕਿਉਂਕਿ ਬੁਨਿਆਦੀ ਵਹਾਅ ਅਤੇ ਵਿਹਾਰਕ ਬਿੰਦੂ (ਚੈਨਲ, ਸਥਿਤੀ, ਸਧਾਰਨ acks, prefetch) ਨੂੰ ਸਮਝਣਾ ਜ਼ਰੂਰੀ ਹੱਥਾਂ-ਤੋਂ ਗਿਆਨ ਹੈ, RabbitMQ ਪ੍ਰਾਪਤ/ਖਪਤ ਵਰਤੋਂ ਨੂੰ ਸਮਝਣਾ ਕੀਮਤੀ, ਵਿਹਾਰਕ-ਸੰਬੰਧਿਤ ਗਿਆਨ ਹੈ — RabbitMQ ਦੀ ਵਰਤੋਂ ਦਾ ਵਿਹਾਰਕ ਪ੍ਰਵੇਸ਼ ਬਿੰਦੂ, ਸੰਕਲਪਾਂ ਨੂੰ ਕੋਡ (ਸਥਿਰ ਕਿਊ, ਸਥਿਰ ਸੁਨੇਹੇ, ਅਤੇ ਸਧਾਰਨ acks ਦੀ ਭਰੋਸੇਮੰਦਤਾ ਪ੍ਰਾਇਓਰਿਟੀ ਦੇ ਨਾਲ) ਨਾਲ ਜੋੜਨਾ, ਅਤੇ RabbitMQ ਦੇ ਨਾਲ ਐਪਲੀਕੇਸ਼ਨਾਂ ਨਿਰਮਾਣ ਕਰਨ ਵਾਲਿਆਂ ਲਈ ਜ਼ਰੂਰੀ ਹੈ।