Redis Streams คืออะไร?

Question

Accepted Answer

**Redis Streams** เป็นโครงสร้างข้อมูลแบบ append-only log — เหมือน message queue หรือ event log ที่มีความทนทาน — รองรับ **consumer group**, การคงอยู่ของข้อความ, การ acknowledge และการ replay มันเป็นคำตอบของ Redis สำหรับการส่งข้อความที่เชื่อถือได้ ซึ่งแข็งแกร่งกว่า Pub/Sub (ที่เป็นแบบ fire-and-forget)

## append-only log ของข้อความ

```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 เป็น **append-only log**: เพิ่ม entry ด้วย `XADD` (แต่ละรายการมี ID ที่ไม่ซ้ำและเรียงตามเวลา) และคงอยู่ใน stream — ต่างจาก Pub/Sub ตรงที่ข้อความไม่สูญหาย แต่ถูกเก็บไว้และอ่านซ้ำได้

## Consumer group — การประมวลผลที่เชื่อถือได้และขยายตัวได้

```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** กระจายข้อความไปยังหลาย consumer (ขยายการประมวลผล) โดยแต่ละข้อความไปยัง consumer เดียว, **การ acknowledge** (`XACK`) ยืนยันการประมวลผล และ **pending/reclaim** (`XPENDING`/`XCLAIM`) รับประกันว่าข้อความจะไม่สูญหายหาก consumer crash — การส่งมอบแบบ at-least-once ที่เชื่อถือได้

## Streams เทียบกับ 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).
```

## ทำไมจึงสำคัญ

การเข้าใจ Redis Streams มีค่าสำหรับการ **ส่งข้อความและประมวลผล event ที่เชื่อถือได้** ภายใน Redis จึงเป็นความรู้ที่มีประโยชน์ — โดยเฉพาะเพราะ Streams แก้ข้อจำกัดสำคัญของ Pub/Sub

ในขณะที่ Pub/Sub เรียบง่ายแต่เป็นแบบ fire-and-forget (subscriber ที่ออฟไลน์จะพลาดข้อความถาวร ไม่มีการคงอยู่) **Streams ให้การส่งข้อความที่เชื่อถือได้**: เป็น **append-only persistent log** ที่ข้อความถูกเก็บไว้ (ไม่สูญหาย) และอ่านซ้ำ/replay ได้ พร้อม **consumer group** ที่กระจายข้อความไปยังหลาย consumer เพื่อการประมวลผลที่ขยายตัวได้, **การ acknowledge** (`XACK`) เพื่อยืนยันการประมวลผล และ **การ reclaim ข้อความที่ค้าง** (`XPENDING`/`XCLAIM`) เพื่อให้ข้อความไม่สูญหายเมื่อ consumer crash — มอบการประมวลผลข้อความแบบ at-least-once ที่เชื่อถือได้และขยายตัวได้

การเข้าใจ **Streams เทียบกับ Pub/Sub** (Streams สำหรับการส่งมอบที่เชื่อถือได้ ประวัติ และ consumer ที่ขยายตัวได้; Pub/Sub สำหรับการ broadcast แบบเรียลไทม์เรียบง่ายที่ยอมรับการสูญหายได้) สำคัญต่อการเลือก primitive การส่งข้อความของ Redis ที่เหมาะสม

การตระหนักว่า Streams **คล้ายกับ Kafka แบบเบา** (อิงบน log พร้อม consumer group) ช่วยกำหนดบทบาทของมัน — มอบความสามารถ event-streaming/message-queue ภายใน Redis โดยไม่ต้องมี broker แยกต่างหากสำหรับความต้องการระดับปานกลาง ขณะที่ broker เฉพาะทาง (Kafka, RabbitMQ) ยังคงเหมาะสมสำหรับการส่งข้อความระดับใหญ่กว่าหรือที่มีความต้องการสูงกว่า

เนื่องจากการส่งข้อความและประมวลผล event ที่เชื่อถือได้เป็นความต้องการที่พบบ่อย และเนื่องจาก Redis Streams ให้โซลูชันที่แข็งแกร่ง คงอยู่ และอิง consumer group (เอาชนะข้อจำกัด fire-and-forget ของ Pub/Sub) ภายใน Redis การเข้าใจ Redis Streams — append-only log, consumer group พร้อมการ acknowledge และ reclaim และการเปรียบเทียบกับ Pub/Sub และ Kafka — จึงเป็นความรู้ที่มีค่าและเกี่ยวข้องในทางปฏิบัติสำหรับการสร้างฟีเจอร์การส่งข้อความและ event-driven ที่เชื่อถือได้ด้วย Redis ซึ่งเป็นตัวเลือกที่เหมาะเมื่อคุณต้องการการรับประกันการส่งมอบและประวัติข้อความที่ Pub/Sub ให้ไม่ได้