Apakah itu Redis Streams?

Question

Accepted Answer

**Redis Streams** ialah struktur data log append-only — seperti baris gilir mesej (message queue) yang tahan lama atau log peristiwa — menyokong **consumer group**, kepersistenan mesej, acknowledgment, dan replay. Ia merupakan jawapan Redis kepada pemesejan yang boleh dipercayai, lebih teguh daripada Pub/Sub (yang bersifat fire-and-forget).

## Log mesej append-only

```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 ialah **log append-only**: entri ditambah dengan `XADD` (setiap satu dengan ID unik yang tersusun mengikut masa) dan kekal dalam stream — tidak seperti Pub/Sub, mesej tidak hilang; ia disimpan dan boleh dibaca semula.

## Consumer group — pemprosesan yang boleh dipercayai dan boleh diskala

```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 group** mengagihkan mesej merentas berbilang consumer (menskalakan pemprosesan), dengan setiap mesej pergi ke satu consumer, **acknowledgment** (`XACK`) mengesahkan pemprosesan, dan **pending/reclaim** (`XPENDING`/`XCLAIM`) memastikan mesej tidak hilang jika consumer ranap — penghantaran at-least-once yang boleh dipercayai.

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

## Mengapa ia penting

Memahami Redis Streams adalah berharga untuk **pemesejan dan pemprosesan peristiwa yang boleh dipercayai** dalam Redis, jadi ia merupakan pengetahuan yang berguna — terutamanya kerana Streams menangani batasan utama Pub/Sub.

Walaupun Pub/Sub ringkas tetapi fire-and-forget (subscriber luar talian terlepas mesej secara kekal, tiada kepersistenan), **Streams menyediakan pemesejan yang boleh dipercayai**: sebuah **log append-only yang persisten** di mana mesej disimpan (tidak hilang) dan boleh dibaca semula/dimainkan semula (replay), serta **consumer group** yang mengagihkan mesej merentas berbilang consumer untuk pemprosesan yang boleh diskala, **acknowledgment** (`XACK`) untuk mengesahkan pemprosesan, dan **reclaim mesej tertangguh** (`XPENDING`/`XCLAIM`) supaya mesej tidak hilang apabila consumer ranap — menyampaikan pemprosesan mesej at-least-once yang boleh dipercayai dan boleh diskala.

Memahami **Streams lawan Pub/Sub** (Streams untuk penghantaran yang boleh dipercayai, sejarah, dan consumer yang boleh diskala; Pub/Sub untuk siaran masa nyata yang ringkas di mana kehilangan boleh diterima) adalah penting untuk memilih primitif pemesejan Redis yang betul.

Mengiktiraf bahawa Streams adalah **serupa dengan Kafka yang ringan** (berasaskan log dengan consumer group) membantu membingkaikan peranannya — menyediakan keupayaan event-streaming/message-queue dalam Redis tanpa broker berasingan untuk keperluan yang sederhana, manakala broker khusus (Kafka, RabbitMQ) kekal sesuai untuk pemesejan berskala lebih besar atau lebih mencabar.

Memandangkan pemesejan dan pemprosesan peristiwa yang boleh dipercayai ialah keperluan yang biasa, dan memandangkan Redis Streams menyediakan penyelesaian yang teguh, persisten, dan berasaskan consumer group (mengatasi batasan fire-and-forget Pub/Sub) dalam Redis, memahami Redis Streams — log append-only, consumer group dengan acknowledgment dan reclaim, serta bagaimana ia dibandingkan dengan Pub/Sub dan Kafka — merupakan pengetahuan yang berharga dan relevan secara praktikal untuk membina ciri pemesejan dan dipacu peristiwa yang boleh dipercayai dengan Redis, pilihan yang tepat apabila anda memerlukan jaminan penghantaran dan sejarah mesej yang tidak dapat disediakan oleh Pub/Sub.