Mitä ovat Redis Streams?

Question

Accepted Answer

**Redis Streams** ovat append-only log -tietorakenne — kuten kestävä viestijonoa tai tapahtumalokin — joilla on tuki **consumer groupsille**, viestien persistensseille, vahvistuksille ja toistamiselle. Ne ovat Redisin vastaus luotettavaan viestintään, paljon robustimpia kuin Pub/Sub (joka on fire-and-forget -tyylinen).

## Append-only lokin viesteihin

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

Streamit ovat **append-only log**: merkinnät lisätään `XADD`:lla (jokainen omalla aikaperustaisella, aikamukaalla ID:llä) ja ne pysyvät streamissa — toisin kuin Pub/Subissa, viestit eivät häviä; ne tallennetaan ja voidaan lukea uudelleen.

## Consumer groupit — luotettava, skaalautuva käsittely

```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 groupit** jakavat viestit useiden kuluttajien kesken (skaalaten käsittelyä), jokainen viesti menee yhdelle kuluttajalle, **vahvistukset** (`XACK`) vahvistavat käsittelyn, ja **pending/reclaim** (`XPENDING`/`XCLAIM`) varmistavat, että viestit eivät häviä, jos kuluttaja kaatuu — luotettava, at-least-once-toimitus.

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

## Miksi sillä on merkitystä

Redis Streamsien ymmärtäminen on arvokasta **luotettavalle viestinnälle ja tapahtumakäsittelylle** Redisissa, joten se on hyödyllistä osaamista — erityisesti koska Streams ratkaistkeisia Pub/Subin rajoituksia.

Vaikka Pub/Sub on yksinkertainen mutta fire-and-forget (offline-tilaajat menettävät viestit pysyvästi, ei persistenssiä), **Streamit tarjoavat luotettavaa viestintää**: **append-only persistent log**, jossa viestit tallennetaan (eivät häviä) ja voidaan lukea/toistaa uudelleen, plus **consumer groupit**, jotka jakavat viestit useiden kuluttajien kesken skaalautuvan käsittelyn varalle, **vahvistukset** (`XACK`) käsittelyn vahvistamiseen, ja **pending-viestin reclaim** (`XPENDING`/`XCLAIM`) niin että viestit eivät häviä, kun kuluttaja kaatuu — tarjoaen at-least-once, luotettavan, skaalautuvan viestinkäsittelyn.

**Streamit vs Pub/Sub** -ymmärtäminen (Streamit luotettavalle toimitulle, historialle ja skaalautuville kuluttajille; Pub/Sub yksinkertaiselle reaaliaikaiselle lähettämiselle, jossa menetys on hyväksyttävää) on tärkeää oikean Redis-viestintäprimiitin valitsemiseksi.

Se, että Streamit ovat **samanlaisia kuin kevyt Kafka** (log-pohjainen consumer groupseilla), auttaa hahmottamaan niiden roolin — tarjoten event-streaming/message-queue -kyvyt Redisissa ilman erillistä välittäjää kohtalaisiin tarpeisiin, kun taas dedikoidut välittäjät (Kafka, RabbitMQ) pysyvät sopivina suuremmissa tai vaativammissa viestintätilanteissa.

Koska luotettava viestintä ja tapahtumakäsittely ovat yleisiä tarpeita, ja koska Redis Streams tarjoavat robusti, persistent, consumer-group-pohjaisen ratkaisun (voittaen Pub/Subin fire-and-forget-rajoituksen) Redisissa, Redis Streamien ymmärtäminen — append-only log, consumer groupit vahvistuksilla ja reclamilla, ja miten ne vertautuvat Pub/Subiin ja Kafkaan — on arvokasta, käytännöllisesti olennaista osaamista luotettavien viestintä- ja event-driven -ominaisuuksien rakentamiseksi Redisin kanssa, oikea valinta kun tarvitset toimintatakuita ja viestihistoriaa, joita Pub/Sub ei voi tarjota.