Redis Streams एक append-only log डेटा स्ट्रक्चर हो — एक टिकाऊ message queue वा event log जस्तो — जसले consumer groups, message persistence, acknowledgments, र replay समर्थन गर्छ। यो विश्वसनीय messaging को लागि Redis को जवाफ हो, Pub/Sub भन्दा अधिक मजबूत (जो fire-and-forget हो)।
XADD events * user
XADD events * user
XLEN events
XRANGE events - +
XREAD COUNT 10 STREAMS events 0
Streams एक append-only log हो: प्रविष्टिहरू XADD को साथ जोडिन्छन् (प्रत्येक अद्वितीय, समय-क्रमबद्ध ID को साथ) र stream मा स्थायी रहन्छन् — Pub/Sub को विपरीत, संदेशहरू हराइंदैनन्; तिनीहरू भण्डारित हुन्छन् र पुनः पढ्न सकिन्छन्।
# 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 groups ले संदेशहरूलाई एकाधिक consumers (प्रसंस्करण स्केलिङ) मा वितरण गर्दछ, प्रत्येक संदेश एक consumer मा जान्छ, acknowledgments (XACK) प्रसंस्करण पुष्टि गर्दछ, र pending/reclaim (XPENDING/XCLAIM) ले सुनिश्चित गर्दछ कि consumer क्र्यास हुँदा संदेशहरू हराइंदैनन् — विश्वसनीय, at-least-once delivery।
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 लाई बुझ्नु विश्वसनीय messaging र event processing को लागि Redis भित्र मूल्यवान छ, तसर्थ यो उपयोगी ज्ञान हो — विशेष गरी किनभने Streams ले Pub/Sub को मुख्य सीमितताहरूलाई सम्बोधन गर्दछ।
जबकि Pub/Sub साधारण तर fire-and-forget हो (अफलाइन subscribers स्थायी रूपमा संदेशहरू हराउन्छन्, कुनै persistence छैन), Streams ले विश्वसनीय messaging प्रदान गर्दछ: एक append-only persistent log जहाँ संदेशहरू भण्डारित हुन्छन् (हराइंदैनन्) र पुनः पढ्न/replay गर्न सकिन्छन्, साथै consumer groups जो एकाधिक consumers मा संदेशहरूलाई स्केलेबल प्रसंस्करणको लागि वितरण गर्दछ, acknowledgments (XACK) प्रसंस्करण पुष्टि गर्न, र pending-message reclaim (XPENDING/XCLAIM) ताकि consumer क्र्यास हुँदा संदेशहरू हराइंदैनन् — at-least-once, विश्वसनीय, स्केलेबल message processing प्रदान गरिरहेको छ।
Streams बनाम Pub/Sub बुझ्नु (Streams विश्वसनीय delivery, history, र स्केलेबल consumers को लागि; Pub/Sub साधारण real-time broadcast को लागि जहाँ loss स्वीकार्य हो) सही Redis messaging primitive छनोट गर्न महत्त्वपूर्ण हो।
Recognizing कि Streams एक lightweight Kafka जस्तो (log-based with consumer groups) हो तिनीहरूको भूमिकालाई फ्रेम गर्न मद्दत गर्दछ — Redis भित्र event-streaming/message-queue क्षमताहरू प्रदान गर्दै एक अलग broker बिना मध्यम आवश्यकताहरूको लागि, जबकि dedicated brokers (Kafka, RabbitMQ) ठूलो-स्केल वा अधिक demanding messaging को लागि उपयुक्त रहन्छन्।
चूँकि विश्वसनीय messaging र event processing सामान्य आवश्यकताहरू हुन्, र चूँकि Redis Streams एक मजबूत, persistent, consumer-group-आधारित समाधान प्रदान गर्दछ (Pub/Sub को fire-and-forget सीमितताको समाधान गर्दै) Redis भित्र, Redis Streams लाई बुझ्नु — append-only log, consumer groups with acknowledgments र reclaim को साथ, र कसरी तिनीहरू Pub/Sub र Kafka को तुलना गर्दछन् — विश्वसनीय messaging र event-driven features को साथ Redis को साथ निर्माण गर्नको लागि मूल्यवान, व्यावहारिक-सम्बन्धित ज्ञान हो, सही विकल्प जब तपाईंलाई delivery guarantees र message history चाहिन्छ जो Pub/Sub प्रदान गर्न सक्दैन।