Bagaimana queue berfungsi dalam RabbitMQ?

Question

Accepted Answer

**Queue** dalam RabbitMQ menyimpan mesej sehingga consumer memprosesnya — bertindak sebagai buffer antara producer dan consumer. Memahami sifat queue (durability, acknowledgment, dll.) adalah penting untuk pemesejan yang boleh dipercayai.

## Apa yang queue lakukan

```text
A QUEUE holds messages until a consumer takes them:
  → messages wait in the queue (a buffer) → decouples producer speed from consumer speed
  → consumers receive messages (push or pull), process them, and ACKNOWLEDGE
  → roughly FIFO (first-in, first-out) order
→ the buffer between producers and consumers (absorbs load, enables async)
```

## Sifat utama queue

```text
DURABLE → the queue survives a broker RESTART (the queue definition persists)
  (+ PERSISTENT messages → messages also survive restart → durability)
EXCLUSIVE → used by only one connection; deleted when that connection closes
AUTO-DELETE → deleted when the last consumer disconnects
TTL → messages (or the queue) can expire after a time
MAX LENGTH → limit queue size (drop/overflow when full)
→ configure based on durability and lifecycle needs
```

## Penggunaan (consumption) dan acknowledgment

```text
✓ Consumers ACKNOWLEDGE messages → tells RabbitMQ the message was processed (then it's
  removed); if not acked (consumer dies) → REQUEUED/redelivered (no loss)
✓ Multiple consumers on a queue → messages DISTRIBUTED among them (competing consumers →
  load balancing/parallel processing)
✓ PREFETCH → limit unacknowledged messages per consumer (fair distribution)
```

## Mengapa ia penting

Memahami cara queue berfungsi adalah asas kerana **queue ialah teras RabbitMQ** (menyimpan dan menghantar mesej), jadi menguasainya serta sifat-sifatnya adalah penting untuk pemesejan yang boleh dipercayai.

Queue ialah mekanisme teras tempat mesej menunggu.

Memahami **apa yang queue lakukan** — menyimpan mesej sehingga consumer mengambilnya (buffer yang menyahgandingkan kelajuan producer dan consumer, menyerap beban dan membolehkan pemprosesan tak segerak, lebih kurang FIFO) — menjelaskan peranan asasnya.

Memahami **sifat utama queue** — **durable** (queue bertahan apabila broker dimulakan semula, digabungkan dengan **persistent message** supaya mesej juga bertahan, menyediakan durability), exclusive, auto-delete, TTL (luput mesej/queue), dan max length — adalah penting untuk mengkonfigurasi queue bagi durability dan kitar hayat yang betul, dengan durability (durable queue + persistent message) menjadi sangat penting untuk tidak kehilangan mesej apabila dimulakan semula.

Memahami **consumption dan acknowledgment** adalah penting: consumer **mengakui mesej** (memberitahu RabbitMQ bahawa mesej telah diproses supaya ia dibuang, dengan mesej yang tidak diakui di-requeue/dihantar semula jika consumer mati — menghalang kehilangan mesej), beberapa consumer pada satu queue **mengagihkan mesej** (competing consumer untuk load balancing dan pemprosesan selari), dan **prefetch** (mengehadkan mesej yang belum diakui setiap consumer untuk pengagihan adil).

Mekanisme acknowledgment ialah kunci kepada penghantaran yang boleh dipercayai (memastikan mesej tidak hilang jika pemprosesan gagal), dan competing consumer ialah cara RabbitMQ mengagihkan kerja.

Konsep-konsep ini (sifat queue untuk durability, acknowledgment untuk kebolehpercayaan, competing consumer untuk penskalaan) adalah penting untuk membina pemesejan yang boleh dipercayai dengan RabbitMQ.

Memandangkan queue ialah teras RabbitMQ (menyimpan dan menghantar mesej) dan memahaminya, sifat-sifatnya (terutamanya durability), serta consumption/acknowledgment (untuk penghantaran yang boleh dipercayai dan pengagihan beban) adalah penting untuk pemesejan yang boleh dipercayai, memahami cara queue berfungsi merupakan pengetahuan asas RabbitMQ yang penting — teras kepada cara RabbitMQ menyimpan dan menghantar mesej, dengan durability queue dan acknowledgment mesej menjadi kunci kepada pemesejan yang boleh dipercayai, serta competing consumer membolehkan pengagihan beban, perlu untuk membina sistem RabbitMQ yang boleh dipercayai.