Kaip veikia eilės (queues) RabbitMQ?

Question

Accepted Answer

**Eilės** RabbitMQ saugo žinutes, kol jas apdoroja vartotojai — veikdamos kaip buferiai tarp gamintojų ir vartotojų. Suprasti eilės savybes (atliekamumą, patvirtinimus ir kt.) yra svarbu patikimam žinučių siuntimui.

## Ką daro eilės

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

## Pagrindinės eilės savybės

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

## Žinučių vartojimas ir patvirtinimai

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

## Kodėl tai svarbu

Suprasti, kaip veikia eilės, yra pagrindinis dalykas, nes **eilės yra RabbitMQ centras** (žinučių laikymas ir pristatymas), todėl jų ir jų savybių supratimas yra būtinas patikimam žinučių siuntimui.

Eilės yra pagrindinė mechanika, kurioje žinutės laukia.

Suprasti **ką daro eilės** — žinučių laikymą, kol jas paima vartotojai (buferis atskiriantis gamintojo ir vartotojo greitį, sugeriantis apkrovą ir leidžiantis asinchroniškai apdoroti, maždaug FIFO) — paaiškina jų pagrindinį vaidmenį.

Suprasti **pagrindines eilės savybes** — **atliekamumą** (eilė išlieka po broker'io paleisimo iš naujo, kartu su **atliekamomis žinutėmis** taip pat išliekant, suteikiant atliekamumą), eksklyyvumą, automatinį trynimą, TTL (žinučių/eilės galiojimo pabaiga) ir maksimalų ilgį — svarbu eilėms konfigūruoti su tinkamu atliekamumu ir gyvenimo ciklu, o atliekamumas (atlekami eilės + atliekamos žinutės) ypač svarbus, kad nedingtų žinutės po paleisimo iš naujo.

Suprasti **žinučių vartojimą ir patvirtinimus** yra labai svarbu: vartotojai **patvirtinantys žinutes** (pranešantys RabbitMQ, kad žinutė buvo apdorota, todėl ji pašalinama, nepatikintos žinutės iš naujo dedamos į eilę/pristatytos, jei vartotojas nutrūksta — prevencingas žinučių praradimas), keli vartotojai vienoje eilėje **paskirstantys žinutes** (konkuruojantys vartotojai apkrovai balansuoti ir lygiagrečiam apdorojimui) ir **prefetch** (apribojantis nepatikintas žinutes per vartotoją tiesiam paskirstymui).

Patvirtinimo mechanika yra pagrindinė patikimam pristatymui (užtikrinus, kad žinutės nedingtų, jei apdorojimas nepavyks), o konkuruojantys vartotojai yra tai, kaip RabbitMQ paskirsto darbą.

Šios koncepcijos (eilės savybės atliekamumui, patvirinimai patikimumui, konkuruojantys vartotojai masteliui) yra būtinos patikimam žinučių siuntimui su RabbitMQ.

Kadangi eilės yra RabbitMQ centras (žinučių laikymas ir pristatymas) ir jų, jų savybių (ypač atliekamų) ir vartojimo/patvirtinimų (patikimam pristatymui ir apkrovos paskirstymui) supratimas yra būtinas patikimam žinučių siuntimui, eilių veikimo supratimas yra esminė, pagrindinė RabbitMQ žinios — pagrindinė tai, kaip RabbitMQ laiko ir pristatydo žinutes, kai eilės atliekamumas ir žinučių patvirinimai yra pagrindiniai patikimam žinučių siuntimui, o konkuruojantys vartotojai leidžia apkrovos paskirstymą, būtina patikimiems RabbitMQ sistemoms kurti.