Mik a Redis Streams?

Question

Accepted Answer

**Redis Streams** egy csak-hozzáfűzésű log adatstruktúra — mint egy tartós üzenetsor vagy eseménynapló — amely támogatja a **fogyasztói csoportokat**, az üzenetek tárolását, a nyugtázásokat és az ismétlést. Ez a Redis válasza a megbízható üzenetkezelésre, robusztusabb, mint a Pub/Sub (amely fire-and-forget típusú).

## Csak-hozzáfűzésű üzenetnapló

```bash
# add entries to a stream (each gets an auto ID: timestamp-sequence)
XADD events * type "signup" user "ann"     # * = auto-generate ID; returns e.g. 1700000000-0
XADD events * type "login" user "bob"

XLEN events                                 # number of entries
XRANGE events - +                           # read all entries (- to +)
XREAD COUNT 10 STREAMS events 0             # read entries (from ID 0)
```

A Streams egy **csak-hozzáfűzésű log**: bejegyzéseket adnak hozzá az `XADD` paranccsal (mindegyik egyedi, időrendben ordenált azonosítóval), és az üzenetek a streamben maradnak — a Pub/Sub-kal ellentétben az üzenetek nem vesznek el; tárolódnak és újra olvashatók.

## Fogyasztói csoportok — megbízható, skálázható feldolgozás

```bash
# create a consumer group to process the stream
XGROUP CREATE events workers 0

# consumers read messages (each message goes to ONE consumer in the group)
XREADGROUP GROUP workers consumer1 COUNT 1 STREAMS events >

# acknowledge a processed message (so it's not redelivered)
XACK events workers 1700000000-0
# unacknowledged messages can be reclaimed (XPENDING/XCLAIM) → no message lost on crash
```

A **fogyasztói csoportok** több fogyasztó között osztják el az üzeneteket (feldolgozás skálázása), mindegyik üzenet egy fogyasztóhoz kerül, a **nyugtázások** (`XACK`) megerősítik a feldolgozást, és a **függőben lévő üzenetek/visszaigénylés** (`XPENDING`/`XCLAIM`) biztosítja, hogy az üzenetek nem vesznek el, ha egy fogyasztó összeomlik — megbízható, legalább egyszer történő kézbesítés.

## Streams vs Pub/Sub

```text
PUB/SUB  → fire-and-forget; offline subscribers MISS messages; no persistence/replay
STREAMS  → PERSISTENT log; messages stored; consumer groups; acknowledgments; replay
  → Streams = when you need RELIABLE delivery, message history, and scalable consumers
  → Pub/Sub = simple real-time broadcast where missing messages is OK
Streams are similar to a lightweight Kafka (log + consumer groups).
```

## Miért fontos

A Redis Streams megértése értékes a **megbízható üzenetkezelés és eseményfeldolgozás** szempontjából a Redisben, így hasznos ismeret — különösen azért, mert a Streams a Pub/Sub főbb korlátait orvosolják.

Míg a Pub/Sub egyszerű, de fire-and-forget típusú (az offline feliratkozók véglegesen lemaradnak az üzenetekről, nincs tárolás), a **Streams megbízható üzenetkezelést biztosítanak**: egy **csak-hozzáfűzésű tartós log**, ahol az üzenetek tárolódnak (nem vesznek el) és újra olvashatók/ismételhetők, valamint **fogyasztói csoportok**, amelyek több fogyasztó között osztják el az üzeneteket a skálázható feldolgozáshoz, **nyugtázások** (`XACK`) a feldolgozás megerősítésére, és **függőben lévő üzenetek visszaigénylése** (`XPENDING`/`XCLAIM`), így az üzenetek nem vesznek el, ha egy fogyasztó összeomlik — legalább egyszer történő, megbízható, skálázható üzenetfeldolgozást biztosítva.

A **Streams vs Pub/Sub** (Streams a megbízható kézbesítéshez, történethez és skálázható fogyasztóhoz; Pub/Sub az egyszerű valós idejű szóráshoz, ahol az üzenetvesztés elfogadható) megértése fontos a helyes Redis üzenetkezelési primitív kiválasztásához.

Az a felismerés, hogy a Streams **hasonlóak egy könnyűsúlyú Kafkához** (log-alapú fogyasztói csoportokkal), segít keretezni szerepüket — eseményfolyam/üzenetsor képességeket biztosítva a Redisben, egy külön közvetítő nélkül mérsékelt igényekhez, miközben az olyan dedikált közvetítők (Kafka, RabbitMQ) a nagyobb léptékű vagy több igényt támasztó üzenetkezeléshez maradnak megfelelőek.

Mivel a megbízható üzenetkezelés és eseményfeldolgozás gyakori igények, és mivel a Redis Streams egy robusztus, tartós, fogyasztó-csoport-alapú megoldást biztosítanak (leküzdve a Pub/Sub fire-and-forget korlátját) a Redisben, a Redis Streams megértése — a csak-hozzáfűzésű log, a nyugtázásokkal és visszaigényleléssel rendelkező fogyasztói csoportok, és a Pub/Sub-hoz és Kafkához való viszonyuk — értékes, gyakorlatilag releváns ismeret a megbízható üzenetkezelés és eseményvezérelt funkciók összeállításához a Redisben, a helyes választás, amikor szüksége van kézbesítési garanciákra és üzenethistóriára, amelyeket a Pub/Sub nem tud biztosítani.