Redis Streams হল একটি append-only log ডেটা স্ট্রাকচার — একটি টেকসই মেসেজ কিউ বা ইভেন্ট লগের মতো — যা consumer groups, মেসেজ persistence, acknowledgments, এবং replay সমর্থন করে। এটি reliable messaging এর জন্য Redis এর উত্তর, Pub/Sub এর চেয়ে বেশি robust (যা 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 এ persist থাকে — 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 crash হয় — নির্ভরযোগ্য, 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 বোঝা মূল্যবান Redis এর মধ্যে reliable messaging এবং event processing এর জন্য, তাই এটি উপকারী জ্ঞান — বিশেষত কারণ Streams Pub/Sub এর মূল সীমাবদ্ধতাগুলি সমাধান করে।
যদিও Pub/Sub সহজ কিন্তু fire-and-forget (অফলাইন subscribers স্থায়ীভাবে মেসেজ মিস করে, কোনো persistence নেই), Streams নির্ভরযোগ্য messaging প্রদান করে: একটি append-only persistent log যেখানে মেসেজগুলি সংরক্ষিত থাকে (হারিয়ে যায় না) এবং পুনরায় পড়া/পুনরায় চালানো যায়, সাথে consumer groups যা একাধিক consumers জুড়ে মেসেজ বিতরণ করে স্কেলেবল প্রসেসিং এর জন্য, acknowledgments (XACK) প্রসেসিং নিশ্চিত করতে, এবং pending-message reclaim (XPENDING/XCLAIM) যাতে মেসেজগুলি হারিয়ে না যায় যখন একটি consumer crashes — at-least-once, নির্ভরযোগ্য, স্কেলেবল মেসেজ প্রসেসিং প্রদান করে।
Streams vs Pub/Sub বোঝা (reliable delivery, history, এবং স্কেলেবল consumers এর জন্য Streams; সাধারণ real-time broadcast এর জন্য Pub/Sub যেখানে loss গ্রহণযোগ্য) সঠিক Redis messaging primitive নির্বাচন করার জন্য গুরুত্বপূর্ণ।
স্বীকৃতি যে Streams একটি lightweight Kafka এর মতো (log-based with consumer groups) তাদের ভূমিকা ফ্রেম করতে সাহায্য করে — moderate প্রয়োজনের জন্য একটি পৃথক broker ছাড়াই Redis এর মধ্যে event-streaming/message-queue ক্ষমতা প্রদান করে, যখন dedicated brokers (Kafka, RabbitMQ) বৃহত্তর-স্কেল বা আরও দাবিদার messaging এর জন্য উপযুক্ত থাকে।
যেহেতু নির্ভরযোগ্য messaging এবং event processing সাধারণ প্রয়োজন, এবং যেহেতু Redis Streams একটি robust, persistent, consumer-group-based সমাধান প্রদান করে (Pub/Sub এর fire-and-forget সীমাবদ্ধতা অতিক্রম করে) Redis এর মধ্যে, Redis Streams বোঝা — append-only log, consumer groups with acknowledgments এবং reclaim, এবং কীভাবে তারা Pub/Sub এবং Kafka এর তুলনায় করে — মূল্যবান, ব্যবহারিকভাবে প্রাসঙ্গিক জ্ঞান Redis দিয়ে নির্ভরযোগ্য messaging এবং event-driven বৈশিষ্ট্য তৈরি করার জন্য, সঠিক পছন্দ যখন আপনার delivery guarantees এবং message history প্রয়োজন যা Pub/Sub প্রদান করতে পারে না।