Czym są Redis Streams?

Question

Accepted Answer

**Redis Streams** to struktura danych będąca logiem tylko do dodawania (append-only log) — jak trwała kolejka wiadomości lub dziennik zdarzeń — wspierająca **grupy konsumentów**, trwałość wiadomości, potwierdzenia i odtwarzanie. To odpowiedź Redis na niezawodną obsługę wiadomości, bardziej solidna niż Pub/Sub (który jest fire-and-forget).

## Dziennik wiadomości tylko do dodawania

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

Streamy to **log tylko do dodawania**: wpisy są dodawane za pomocą `XADD` (każdy z unikalnym, uporządkowanym czasowo ID) i pozostają w strumieniu — w przeciwieństwie do Pub/Sub, wiadomości nie są tracone; są przechowywane i mogą być ponownie czytane.

## Grupy konsumentów — niezawodne, skalowalne przetwarzanie

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

**Grupy konsumentów** dystrybuują wiadomości między wielu konsumentów (skalując przetwarzanie), przy czym każda wiadomość trafia do jednego konsumenta, **potwierdzenia** (`XACK`) potwierdzające przetworzenie, oraz **zawieszenie/odzyskiwanie** (`XPENDING`/`XCLAIM`) zapewniające, że wiadomości nie są tracone, jeśli konsument się zawali — niezawodne, gwarantowane dostarczenie co najmniej raz.

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

## Dlaczego to ważne

Zrozumienie Redis Streams jest wartościowe dla **niezawodnej obsługi wiadomości i przetwarzania zdarzeń** w Redis, więc to przydatna wiedza — szczególnie dlatego, że Streams rozwiązują kluczowe ograniczenia Pub/Sub.

Chociaż Pub/Sub jest prosty, ale fire-and-forget (subskrybenci w trybie offline na stałe tracą wiadomości, brak trwałości), **Streams zapewniają niezawodną obsługę wiadomości**: **trwały log tylko do dodawania** gdzie wiadomości są przechowywane (nie tracone) i mogą być ponownie czytane/odtwarzane, plus **grupy konsumentów** dystrybuujące wiadomości między wielu konsumentów do skalowanego przetwarzania, **potwierdzenia** (`XACK`) potwierdzające przetworzenie, oraz **odzyskiwanie zawieszonych wiadomości** (`XPENDING`/`XCLAIM`) aby wiadomości nie były tracone gdy konsument się zawali — dostarczając niezawodne, skalowalne przetwarzanie wiadomości gwarantowane co najmniej raz.

Zrozumienie **Streams vs Pub/Sub** (Streams dla niezawodnego dostarczenia, historii i skalowanych konsumentów; Pub/Sub dla prostego nadawania w czasie rzeczywistym gdzie utrata jest do zaakceptowania) jest ważne dla wyboru odpowiedniego mechanizmu obsługi wiadomości Redis.

Zauważenie, że Streams są **podobne do lekkiego Kafki** (log-based z grupami konsumentów) pomaga umieścić ich rolę — zapewniając możliwości event-streaming/message-queue w Redis bez oddzielnego brokera na potrzeby umiarkowane, podczas gdy dedykowane brokery (Kafka, RabbitMQ) pozostają odpowiednie dla większej skali lub bardziej wymagających wymagań obsługi wiadomości.

Ponieważ niezawodna obsługa wiadomości i przetwarzanie zdarzeń są powszechnymi potrzebami, a Redis Streams zapewniają solidne, trwałe, oparte na grupach konsumentów rozwiązanie (przezwyciężające ograniczenie fire-and-forget Pub/Sub) w Redis, zrozumienie Redis Streams — loga tylko do dodawania, grup konsumentów z potwierdzeniami i odzyskiwaniem, oraz jak się porównują do Pub/Sub i Kafki — jest wartościową, praktycznie istotną wiedzą do budowania niezawodnych funkcji obsługi wiadomości i event-driven'ych z Redis, właściwym wyborem gdy potrzebujesz gwarancji dostarczenia i historii wiadomości których Pub/Sub nie może zapewnić.