Redis Streams là gì?

Question

Accepted Answer

**Redis Streams** là một cấu trúc dữ liệu log append-only — giống một message queue bền hoặc event log — hỗ trợ **consumer group**, persistence message, acknowledgment, và replay. Chúng là câu trả lời của Redis cho nhắn tin tin cậy, vững chắc hơn Pub/Sub (vốn là fire-and-forget).

## Log message append-only

```bash
# thêm entry vào một stream (mỗi cái có một ID tự động: timestamp-sequence)
XADD events * type "signup" user "ann"     # * = tự sinh ID; trả về vd 1700000000-0
XADD events * type "login" user "bob"

XLEN events                                 # số lượng entry
XRANGE events - +                           # đọc tất cả entry (- đến +)
XREAD COUNT 10 STREAMS events 0             # đọc entry (từ ID 0)
```

Streams là một **log append-only**: các entry được thêm với `XADD` (mỗi cái có một ID duy nhất, theo thứ tự thời gian) và tồn tại trong stream — khác Pub/Sub, message không bị mất; chúng được lưu và có thể đọc lại.

## Consumer group — xử lý tin cậy, có khả năng mở rộng

```bash
# tạo một consumer group để xử lý stream
XGROUP CREATE events workers 0

# consumer đọc message (mỗi message đi tới MỘT consumer trong group)
XREADGROUP GROUP workers consumer1 COUNT 1 STREAMS events >

# acknowledge một message đã xử lý (để nó không bị gửi lại)
XACK events workers 1700000000-0
# message chưa acknowledge có thể được đòi lại (XPENDING/XCLAIM) → không mất message khi crash
```

**Consumer group** phân phối message qua nhiều consumer (mở rộng xử lý), với mỗi message đi tới một consumer, **acknowledgment** (`XACK`) xác nhận xử lý, và **pending/reclaim** (`XPENDING`/`XCLAIM`) đảm bảo message không bị mất nếu một consumer crash — gửi tin tin cậy, ít nhất một lần.

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

## Tại sao điều này quan trọng

Hiểu Redis Streams là giá trị cho **nhắn tin tin cậy và xử lý sự kiện** trong Redis, nên đó là kiến thức hữu ích — đặc biệt vì Streams giải quyết các hạn chế chủ chốt của Pub/Sub.

Trong khi Pub/Sub đơn giản nhưng fire-and-forget (subscriber offline vĩnh viễn bỏ lỡ message, không persistence), **Streams cung cấp nhắn tin tin cậy**: một **log bền append-only** nơi message được lưu (không bị mất) và có thể đọc lại/replay, cộng với **consumer group** phân phối message qua nhiều consumer cho xử lý có khả năng mở rộng, **acknowledgment** (`XACK`) để xác nhận xử lý, và **đòi lại message pending** (`XPENDING`/`XCLAIM`) để message không bị mất khi một consumer crash — cung cấp xử lý message ít nhất một lần, tin cậy, có khả năng mở rộng.

Hiểu **Streams vs Pub/Sub** (Streams cho gửi tin cậy, lịch sử, và consumer có khả năng mở rộng; Pub/Sub cho broadcast real-time đơn giản nơi mất mát chấp nhận được) quan trọng để chọn đúng primitive nhắn tin Redis.

Nhận ra rằng Streams **tương tự một Kafka nhẹ** (dựa trên log với consumer group) giúp định hình vai trò của chúng — cung cấp khả năng event-streaming/message-queue trong Redis mà không cần một broker riêng cho các nhu cầu vừa phải, trong khi các broker chuyên dụng (Kafka, RabbitMQ) vẫn phù hợp cho nhắn tin quy mô lớn hơn hoặc đòi hỏi cao hơn.

Vì nhắn tin tin cậy và xử lý sự kiện là nhu cầu phổ biến, và vì Redis Streams cung cấp một giải pháp vững chắc, bền, dựa trên consumer group (vượt qua hạn chế fire-and-forget của Pub/Sub) trong Redis, hiểu Redis Streams — log append-only, consumer group với acknowledgment và reclaim, và cách chúng so với Pub/Sub và Kafka — là kiến thức giá trị, có liên quan về mặt thực hành để xây các tính năng nhắn tin tin cậy và hướng sự kiện với Redis, lựa chọn đúng khi bạn cần các đảm bảo gửi và lịch sử message mà Pub/Sub không thể cung cấp.