Kas yra Redis Streams?

Question

Accepted Answer

**Redis Streams** yra tik-papildant-iš-galo (append-only) žurnalinė duomenų struktūra — kaip patvarūs pranešimų eilė ar įvykio žurnalas — palaikanti **vartotojų grupes**, pranešimų išsaugojimą, patvirtinimus ir pakartotinį atkūrimą. Tai Redis atsakas į patikimą pranešimų perdavimą, daug solidesnis nei Pub/Sub (kuris yra tik-siunti-ir-pamiršti).

## Tik-papildant-iš-galo pranešimų žurnalas

```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 yra **tik-papildant-iš-galo žurnalas**: įrašai pridedami su `XADD` (kiekvienas turi unikalų, laiku suulenintą ID) ir išlieka sraute — skirtingai nei Pub/Sub, pranešimai nėra prarasti; jie saugomi ir gali būti perskaityti iš naujo.

## Vartotojų grupės — patikimas, mastelinis apdorojimas

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

**Vartotojų grupės** paskirsto pranešimus keliems vartotojams (masteliuodamos apdorojimą), kai kiekvienas pranešimas eina vienam vartotojui, **patvirtinimai** (`XACK`) patvirtindami apdorojimą, o **laukiantys/sugrąžinti** (`XPENDING`/`XCLAIM`) užtikrindami, kad pranešimai nėra prarasti, jei vartotojas sugriūva — patikimas, bent-vienu-kart-pristatymas.

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

## Kodėl tai svarbu

Supratimas apie Redis Streams yra vertingas **patikimam pranešimų ir įvykių apdorojimui** Redis viduje, todėl tai naudingas žinios — ypač nes Streams sprendžia pagrindinius Pub/Sub apribojimus.

Nors Pub/Sub yra paprastas, bet tik-siunti-ir-pamiršti (neprisijungę prenumeratoriai visam laikui praleistų pranešimus, nėra išsaugojimo), **Streams suteikia patikimą pranešimų perdavimą**: **tik-papildant-iš-galo patvarų žurnalą**, kuriame pranešimai saugomi (ne prarasti) ir gali būti perskaityti/pakartotinai atkurti, be to **vartotojų grupės**, kurios paskirsto pranešimus keliems vartotojams masteliuojamam apdorojimui, **patvirtinimai** (`XACK`), patvirtinantys apdorojimą, ir **laukiančio pranešimo sugrąžinimas** (`XPENDING`/`XCLAIM`), kad pranešimai nėra prarasti, kai vartotojas sugriūva — suteikiantys bent-vienu-kart, patikimą, mastelinį pranešimų apdorojimą.

Supratimas apie **Streams vs Pub/Sub** (Streams patikimam pristatyti, istorijoje ir masteliniam vartotojams; Pub/Sub paprastam realaus laiko transliavimui, kai nuostoliai priimtini) yra svarbus, norint pasirinkti teisingą Redis pranešimų primitivą.

Pripažinimas, kad Streams yra **panašūs į šiurkštų Kafka** (žurnalu pagrįsti su vartotojų grupėmis) padeda apibrėžti jų vaidmenį — suteikiantys įvykių-srautų/pranešimų-eilės galimybes Redis viduje be atskiro brokerio vidutiniams poreikiams, o dedikuoti brokeriai (Kafka, RabbitMQ) lieka tinkami didesnio masto ar reiklesniems pranešimų poreikiams.

Kadangi patikimas pranešimų perdavimas ir įvykių apdorojimas yra dažni poreikiai, o kadangi Redis Streams suteikia patikimą, patvarų, vartotojų-grupiniu pagrįstą sprendimą (nugalintis Pub/Sub tik-siunti-ir-pamiršti apribojimą) Redis viduje, supratimas apie Redis Streams — tik-papildant-iš-galo žurnalą, vartotojų grupes su patvirtinimais ir sugrąžinimu, ir kaip jie lyginasi su Pub/Sub ir Kafka — yra vertingas, praktiškai susijęs žinios kurti patikimus pranešimų ir įvykių pagrįstus ypatumus su Redis, tinkama pasirinkti, kai reikia pristatymo garantijų ir pranešimų istorijos, kurių Pub/Sub negali suteikti.