Ce sunt Redis Streams?

Question

Accepted Answer

**Redis Streams** sunt o structură de date de jurnal doar-adăugare — ca o coadă de mesaje durabilă sau jurnal de evenimente — care susțin **grupuri de consumatori**, persistență de mesaje, confirmări și redare. Sunt răspunsul Redis la mesajerie fiabilă, mai robust decât Pub/Sub (care este „fire-and-forget").

## Jurnal doar-adăugire de mesaje

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

Streamurile sunt un **jurnal doar-adăugire**: intrările sunt adăugate cu `XADD` (fiecare cu un ID unic, ordonat cronologic) și persistă în stream — spre deosebire de Pub/Sub, mesajele nu sunt pierdute; sunt stocate și pot fi recitite.

## Grupuri de consumatori — procesare fiabilă și scalabilă

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

**Grupurile de consumatori** distribuie mesajele între mai mulți consumatori (scalând procesarea), fiecare mesaj mergând la un consumator, **confirmări** (`XACK`) confirmare procesării, și **în așteptare/revendicare** (`XPENDING`/`XCLAIM`) asigurând că mesajele nu sunt pierdute dacă un consumator se prăbușește — livrare fiabilă, cel puțin o dată.

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

## De ce contează

Înțelegerea Redis Streams este valoroasă pentru **mesajerie fiabilă și procesarea evenimentelor** în Redis, deci este cunoaștere utilă — în special pentru că Streams adresează limitările cheie ale Pub/Sub.

Deși Pub/Sub este simplu dar fire-and-forget (abonații offline pierd permanent mesajele, fără persistență), **Streams oferă mesajerie fiabilă**: un **jurnal persistent doar-adăugire** în care mesajele sunt stocate (nu se pierd) și pot fi relcitite/redate, plus **grupuri de consumatori** care distribuie mesajele între mai mulți consumatori pentru procesare scalabilă, **confirmări** (`XACK`) pentru a confirma procesarea, și **revendicare de mesaje în așteptare** (`XPENDING`/`XCLAIM`) pentru ca mesajele să nu fie pierdute când un consumator se prăbușește — furnizând procesare fiabilă, scalabilă, cu livrare cel puțin o dată.

Înțelegerea **Streams vs Pub/Sub** (Streams pentru livrare fiabilă, istoric și consumatori scalabili; Pub/Sub pentru broadcast real-time simplu în care pierderea este acceptabilă) este importantă pentru alegerea primitivei Redis de mesajerie potrivite.

Recunoașterea că Streamurile sunt **similare cu un Kafka ușor** (bazat pe jurnal cu grupuri de consumatori) ajută la înțelegerea rolului lor — furnizând capacități de streaming de evenimente/coadă de mesaje în Redis fără un broker separat pentru nevoile moderate, în timp ce brokerii dedicați (Kafka, RabbitMQ) rămân potriviți pentru mesajeria la scară mai mare sau mai exigentă.

Deoarece mesajeria fiabilă și procesarea evenimentelor sunt nevoi comune, și deoarece Redis Streams oferă o soluție robustă, persistentă, bazată pe grupuri de consumatori (depășind limitarea fire-and-forget a Pub/Sub) în Redis, înțelegerea Redis Streams — jurnalul doar-adăugire, grupurile de consumatori cu confirmări și revendicare, și modul în care se compară cu Pub/Sub și Kafka — este cunoaștere valoroasă, practic relevantă pentru construirea caracteristicilor fiabile de mesajerie și conduse de evenimente cu Redis, alegerea potrivită atunci când aveți nevoie de garanții de livrare și istoric de mesaje pe care Pub/Sub nu le poate oferi.