Redis Streams ni nini?

Question

Accepted Answer

**Redis Streams** ni muundo wa data wa kumbukumbu ya ziada tu — kama foleni salama ya ujumbe au kumbukumbu ya matukio — inayotumia **vikundi vya watumiaji**, uweka ujumbe, uthibitisho, na uajabu. Ni jibu la Redis kwa ujumbe salama, thabiti zaidi kuliko Pub/Sub (ambayo ni "pokea na sahau").

## Kumbukumbu ya ziada tu ya ujumbe

```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 ni **kumbukumbu ya ziada tu**: entries zinaongezwa na `XADD` (kila moja ina kitambulisho cha kipekee, kilichoagizwa kwa wakati) na kubaki katika stream — tofauti na Pub/Sub, ujumbe hauzezekangi; umehifadhiwa na unaweza kusomwa tena.

## Vikundi vya watumiaji — usindikaji salama na wa kuongeza

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

**Vikundi vya watumiaji** husambaza ujumbe kwa watumiaji wengi (kuongeza usindikaji), kila ujumbe ukienda kwa mtumiaji mmoja, **uthibitisho** (`XACK`) kuthibitisha usindikaji, na **inayosubiri/kukamatia** (`XPENDING`/`XCLAIM`) kuhakikisha ujumbe hauzezekangi ikiwa mtumiaji anaanguka — usambazaji salama, angalau-mara moja.

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

## Kwa nini ni muhimu

Kufahamu Redis Streams ni muhimu kwa **ujumbe salama na usindikaji wa matukio** ndani ya Redis, kwa hivyo ni ujumbe maalum wa kujifunza — hasa kwa sababu Streams zinashitaki vikwazo kuu vya Pub/Sub.

Hadhi Pub/Sub ni rahisi lakini "pokea na sahau" (watumiaji wa mtandao hawapati ujumbe kwa sunila, hakuna uhifadhi), **Streams hutoa ujumbe salama**: **kumbukumbu ya ziada iliyokamatia** ambapo ujumbe umehifadhiwa (sio kuzezekangi) na unaweza kusomwa tena/kuonyeshwa, pamoja na **vikundi vya watumiaji** ambavyo husambaza ujumbe kwa watumiaji wengi kwa usindikaji wa kuongeza, **uthibitisho** (`XACK`) kuthibitisha usindikaji, na **kamatia ujumbe inayosubiri** (`XPENDING`/`XCLAIM`) kwa hivyo ujumbe hauzezekangi wakati mtumiaji anaanguka — kutoa angalau-mara moja, salama, kuongeza ujumbe usindikaji.

Kufahamu **Streams dhidi ya Pub/Sub** (Streams kwa usambazaji salama, historia, na watumiaji wasifu; Pub/Sub kwa kutangazia rahisi halisi ambapo kupoteza ni kinywaji) ni muhimu kwa kuchagua mkakati sahihi wa ujumbe wa Redis.

Kutambua kuwa Streams ni **sawa na Kafka nyepesi** (log-based na vikundi vya watumiaji) husaidia kugawanya jukumu lao — kutoa uwezo wa matukio-mtiririko/foleni-ujumbe ndani ya Redis bila nchi tofauti kwa haja za kawaida, hadhi nchi zilizojitolea (Kafka, RabbitMQ) zinabaki zinazofaa kwa usambazaji mkubwa au ujumbe umeokoaoza zaidi.

Kwa sababu ujumbe salama na usindikaji wa matukio ni mahitaji ya kawaida, na kwa sababu Redis Streams hutoa suluhisho thabiti, lililokamatia, linalotumia kibendera-na-watumiaji (inayoshitaki mapungufu ya "pokea na sahau" ya Pub/Sub) ndani ya Redis, kufahamu Redis Streams — kumbukumbu ya ziada, vikundi vya watumiaji na uthibitisho na kamatia, na jinsi inavyolinganisha na Pub/Sub na Kafka — ni maarifa yenye mataji, sana maalum kwa ajili ya kujenga ujumbe salama na sifa za matukio na Redis, kuchagua kinzani wakati unahitaji dhamana ya utoaji na historia ya ujumbe ambayo Pub/Sub haiwezi kutoa.