Kaj so Redis Streams?

Question

Accepted Answer

**Redis Streams** so prilagodljiva podatkovna struktura tipa »append-only log« — kot trajne red čakanja za sporočila ali dnevnik dogodkov — s podporo za **consumer groups**, trajnostjo sporočil, potvrjami in ponovitvami. Predstavljajo Redisov odgovor na zanesljivo pošiljanje sporočil, bolj robustni kot Pub/Sub (ki je »sprosti in pozabi«).

## Append-only dnevnik sporočil

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

Streams so **append-only dnevnik**: vnosi se dodajo z `XADD` (vsak z edinstvenim, časovno urejenim ID-jem) in vztrajajo v toku — za razliko od Pub/Suba sporočila niso izgubljena; shranjujejo se in jih je mogoče ponovno prebrati.

## Consumer groups — zanesljiva in skalabilna obdelava

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

**Consumer groups** porazdelijo sporočila med več porabnikov (skaliraju obdelavo), pri čemer gre vsako sporočilo enemu porabniku, **potvrde** (`XACK`) potrdijo obdelavo in **pending/reclaim** (`XPENDING`/`XCLAIM`) zagotovijo, da sporočila niso izgubljena, če porabnik pada — zanesljiva dostava »vsaj enkrat«.

## Streams v primerjavi s 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).
```

## Zakaj je to pomembno

Razumevanje Redis Streams je dragoceno za **zanesljivo pošiljanje sporočil in obdelavo dogodkov** v Redisu, zato je to koristno znanje — še posebej ker Streams odpravijo ključne omejitve Pub/Suba.

Če je Pub/Sub preprost, a »sprosti in pozabi« (nepovezani naročniki trajno zamujajo sporočila, ni trajnosti), **Streams zagotavljajo zanesljivo pošiljanje**: **append-only trajen dnevnik**, kjer se sporočila shranijo (niso izgubljena) in jih je mogoče ponovno prebrati/ponoviti, plus **consumer groups**, ki porazdelijo sporočila med več porabnikov za skalabilno obdelavo, **potvrde** (`XACK`) za potrditev obdelave in **reclaim neodvisnih sporočil** (`XPENDING`/`XCLAIM`), tako da sporočila niso izgubljena, ko porabnik pada — kar omogoča zanesljivo, skalabilno obdelavo sporočil »vsaj enkrat«.

Razumevanje **Streams v primerjavi s Pub/Sub** (Streams za zanesljivo dostavo, zgodovino in skalabilne porabnike; Pub/Sub za enostaven prenos v realnem času, kjer je izguba sprejemljiva) je pomembno za izbiro prave Redisove primitiva za pošiljanje sporočil.

Prepoznavanje, da so Streams **podobni lahkotnem Kafki** (dnevnik s consumer groups), pomaga opredeliti njihovo vlogo — zagotavljajo zmožnosti pretoka dogodkov/red čakanja v Redisu brez ločenega brokerjja za zmerne potrebe, medtem ko ostanejo namenske brokerje (Kafka, RabbitMQ) primerni za večje ali zahtevnejše pošiljanje.

Ker so zanesljivo pošiljanje in obdelava dogodkov pogoste potrebe, in ker Streams zagotavljajo robustno, trajno, rešitev s consumer groups (premagujejo »sprosti in pozabi« omejitev Pub/Suba) v Redisu, je razumevanje Redis Streams — append-only dnevnika, consumer groups s potvrjami in reclaimom, in kako se primerjajo s Pub/Sub in Kafko — dragoceno, praktično relevantno znanje za izgradnjo zanesljive pošiljanja in funkcij voženih po dogodkih s Redisem, pravo izbiro, ko potrebujete jamstva dostave in zgodovino sporočil, ki jih Pub/Sub ne more zagotoviti.