RabbitMQ'da mesajları nasıl üretir ve tüketirsiniz (temel kullanım)?

Question

Accepted Answer

Temel RabbitMQ kullanımı, bir exchange/queue'ya mesaj **yayınlamayı** ve bunları **tüketmeyi** içerir — tipik olarak bir istemci kütüphanesi aracılığıyla (AMQP protokolünü kullanarak). Temel üret/tüket akışını anlamak pratik giriş noktasıdır.

## Mesajları üretme (yayınlama)

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

## Mesajları tüketme

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

## Önemli pratik noktalar

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

## Neden önemli

Temel üret/tüket kullanımını anlamak değerlidir çünkü bu **RabbitMQ kullanmanın pratik giriş noktasıdır**, bu nedenle gerekli uygulamalı bilgidir.

Mesajları yayınlamayı ve tüketmeyi bilmek RabbitMQ'yu uygulamalarda kullanmak için temel beceridir.

**Mesaj üretmeyi anlamak** — bağlanmak, bir kanal oluşturmak, bir queue bildirmek ve mesajları yayınlamak (dayanıklılık için kalıcılıkla) — temel yazma işlemidir.

**Mesajları tüketmeyi anlamak** — queue'yu bildirmek, prefetch'i ayarlamak, mesajları tüketmek, bunları işlemek ve işlemden sonra **onaylamak** (güvenilirlik için manuel acks) — güvenilirlik uygulamalarını içeren temel okuma işlemidir.

**Önemli pratik noktaları anlamak** — bir istemci kütüphanesi kullanmak (amqplib, pika, vb.), **kanalları** kullanmak (işlemler için hafif bağlantılar, bağlantıyı yeniden kullanmak), **dayanıklı queue'lar artı kalıcı mesajlar** yeniden başlatmalardan kurtulmak için, **manuel acks** güvenilir işleme için ve adil iş dağılımı için **prefetch**, ve hataları/yeniden bağlanmayı yönetmek ve yönlendirme için exchange'ler/binding'ler kullanmak — gerçek RabbitMQ kullanımı için pratik hususları yansıtır.

Bu pratik noktalar (kanallar, dayanıklılık, manuel acks, prefetch) kavramsal bilgiyi (queue'lar, onaylamalar, dayanıklılık) gerçek koda bağlar ve güvenilir RabbitMQ uygulamaları oluşturmayı yansıtır.

Mesajları üretmek ve tüketmek RabbitMQ'yu uygulamalarda kullanmak için temel pratik beceri olduğundan ve temel akışı ve pratik noktaları (kanallar, dayanıklılık, manuel acks, prefetch) anlamanın gerekli uygulamalı bilgi olduğundan, temel RabbitMQ üret/tüket kullanımını anlamak değerli, pratik olarak ilgili bilgidir — RabbitMQ'yu kullanmanın pratik giriş noktası, kavramları koda bağlamak (dayanıklı queue'lar, kalıcı mesajlar ve manuel acks güvenilirlik uygulamalarıyla), ve RabbitMQ ile uygulamalar oluşturan herkes için gereklidir.