Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) · पाठ

उपभोक्ता समूह तर्क लागू करना

समूह बनाना, `XREADGROUP` का उपयोग करके संदेश पढ़ना और `XACK` से संसाधन की पुष्टि करना सीखिए।

पाठ 2, कुल 4 में से12 चरण

उपभोक्ता समूह तर्क लागू करना, CoddyKit पर Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) का एक निःशुल्क पाठ है। यह 4 में से 2वाँ पाठ है। इस अध्ययन पथ के 3 तक कोई भी पाठ पूरा पढ़ना निःशुल्क है — इसके बाद CoddyKit PRO हर पाठ अनलॉक करता है, साथ ही अंतर्निर्मित कोड संपादक और चौबीसों घंटे एआई शिक्षक के साथ व्यावहारिक अभ्यास भी उपलब्ध कराता है। यह Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) सीखने के मार्ग का हिस्सा है और आपकी प्रगति वेब तथा CoddyKit ऐप पर सिंक होती रहती है। Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) पाठ्यक्रम में कुल 4 पाठ शामिल हैं।

उपभोक्ता समूहों में आपका स्वागत है!

पिछले पाठ में हमने सीखा था कि Redis स्ट्रीम क्या होती हैं। अब आइए उपभोक्ता समूहों को विस्तार से समझते हैं! यह एक शक्तिशाली सुविधा है, जो कई क्लाइंट को किसी स्ट्रीम के संदेशों को मिलकर संसाधित करने देती है।

कल्पना कीजिए कि कर्मचारियों की एक टीम कामों की एक साझा सूची से कार्य कर रही है। प्रत्येक कर्मचारी को अलग-अलग काम मिलते हैं और यदि कोई एक कर्मचारी विफल हो जाए, तो अन्य कर्मचारी लंबित काम संभाल सकते हैं। उपभोक्ता समूह यही संभव बनाते हैं!

अपना समूह सेट अप करें

उपभोक्ताओं के शामिल होने से पहले, आपको अपनी स्ट्रीम के लिए एक उपभोक्ता समूह बनाना होगा। यह काम XGROUP CREATE कमांड का उपयोग करके किया जाता है।

यह Redis को बताता है: "इस स्ट्रीम के लिए एक नया समूह बनाएँ।" आप एक आईडी भी निर्धारित करते हैं, जो आमतौर पर स्ट्रीम की शुरुआत या अंत से पढ़ना शुरू करने के लिए 0 या $ होती है।

अपना पहला समूह बनाएँ!

आइए mystream नाम की स्ट्रीम के लिए mygroup नाम का समूह बनाएँ। $ का अर्थ है "नवीनतम प्रविष्टि से पढ़ना शुरू करें।" MKSTREAM विकल्प अत्यंत महत्वपूर्ण है: यदि स्ट्रीम पहले से मौजूद न हो, तो यह उसे बना देता है!

इसे आज़माएँ:

XGROUP CREATE mystream mygroup $ MKSTREAM

`XREADGROUP` के साथ पढ़ना

समूह बन जाने के बाद, उपभोक्ता XREADGROUP कमांड का उपयोग करके संदेश पढ़ना शुरू कर सकते हैं। यह कमांड विशेष रूप से उपभोक्ता समूहों के लिए बनाई गई है।

यह सुनिश्चित करती है कि समूह के भीतर प्रत्येक संदेश केवल एक उपभोक्ता को वितरित किया जाए। यदि कोई उपभोक्ता किसी संदेश की पुष्टि करने में विफल रहता है, तो वह लंबित रहता है और बाद में उसे प्राप्त किया जा सकता है।

`XREADGROUP` को समझना

XREADGROUP कमांड में कई महत्वपूर्ण पैरामीटर होते हैं:

GROUP <groupname> <consumername>: यह निर्धारित करता है कि कौन-सा समूह और उपभोक्ता पढ़ रहा है।
COUNT <N>: वैकल्पिक। पढ़े जाने वाले संदेशों की संख्या सीमित करता है।
BLOCK <milliseconds>: वैकल्पिक। यदि कोई संदेश उपलब्ध न हो, तो क्लाइंट को रोककर रखता है।
STREAMS <streamname> <ID>: वह स्ट्रीम और आईडी जिससे पढ़ना है। ऐसे नए संदेश पाने के लिए > का उपयोग करें, जिन्हें समूह के किसी अन्य उपभोक्ता को अभी तक वितरित नहीं किया गया है।

कुछ संदेश पढ़ें!

सबसे पहले, अपनी mystream में कुछ संदेश जोड़ते हैं:

XADD mystream * event start task:1
XADD mystream * event process task:1

उपभोक्ता नए संदेश पढ़ता है

अब mygroup का consumer-1 नामक उपभोक्ता mystream से पढ़ेगा। > आईडी का अर्थ है "नए, अपठित संदेश।"

XREADGROUP GROUP mygroup consumer-1 STREAMS mystream >

संदेश संसाधन की पुष्टि

किसी उपभोक्ता द्वारा संदेश को सफलतापूर्वक संसाधित करने के बाद, उसकी पुष्टि करना अत्यंत महत्वपूर्ण है। इससे Redis को पता चलता है कि संदेश संभाल लिया गया है और उसे उपभोक्ता की लंबित प्रविष्टियों की सूची (PEL) से हटाया जा सकता है।

यदि वर्तमान उपभोक्ता काम पूरा करने से पहले क्रैश हो जाए या ऑफ़लाइन हो जाए, तो पुष्टि उसी संदेश को किसी अन्य उपभोक्ता को दोबारा वितरित होने से रोकती है।

`XACK` का उपयोग कैसे करें

संदेशों की पुष्टि करने वाली कमांड XACK है। इसका सिंटैक्स सरल है:

XACK <streamname> <groupname> <ID> [ID ...]

आप स्ट्रीम का नाम, उपभोक्ता समूह का नाम और सफलतापूर्वक संसाधित किए गए एक या अधिक संदेशों की आईडी देते हैं।

`XACK` का अभ्यास करें

मान लीजिए कि पिछले पठन से आपको संदेश आईडी 1678881234567-0 और 1678881234568-0 मिली हैं। आप उनकी पुष्टि इस प्रकार करेंगे (अपनी वास्तविक आईडी से बदलें):

XACK mystream mygroup 1678881234567-0 1678881234568-0

अपनी जानकारी जाँचें

आपने समूह बनाना, संदेश पढ़ना और उनकी पुष्टि करना सीख लिया है। Redis के उपभोक्ता समूहों के बारे में निम्नलिखित में से कौन-सा कथन TRUE है?

इंटरैक्टिव पाठ में इसका उत्तर दें

पुनरावलोकन: उपभोक्ता समूह का तर्क

बहुत बढ़िया! आपने Redis के उपभोक्ता समूह का तर्क लागू करने की मूल बातें सीख ली हैं:

हमने स्ट्रीम के लिए नया समूह सेट अप करने हेतु XGROUP CREATE का उपयोग किया।
आपने XREADGROUP के साथ उपभोक्ता के रूप में मिलकर संदेश पढ़ना सीखा।
हमने देखा कि संसाधित संदेशों की पुष्टि करने और लंबित प्रविष्टियों की सूची (PEL) को प्रबंधित करने के लिए XACK कितना महत्वपूर्ण है।

अगले चरण में, हम लंबित संदेशों और उपभोक्ता विफलताओं को अधिक मज़बूती से संभालना सीखेंगे!

शुरुआत निःशुल्क

एआई शिक्षक के साथ Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) सीखें — निःशुल्क

अपने ब्राउज़र में वास्तविक कोड लिखें और चलाएँ, चौबीसों घंटे एआई शिक्षक से तुरंत सहायता पाएँ, और वेब या ऐप पर वहीं से शुरू करें जहाँ आपने छोड़ा था।

पाठ्यक्रम: 12
पाठ: 48

निःशुल्क सीखना शुरू करें पूरा पाठ्यक्रम देखें

अक्सर पूछे जाने वाले प्रश्न

क्या “उपभोक्ता समूह तर्क लागू करना” पाठ निःशुल्क है?

हाँ — Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) अध्ययन पथ के 3 तक कोई भी पाठ, जिसमें “उपभोक्ता समूह तर्क लागू करना” भी शामिल है, यहाँ वेब पर पूरा पढ़ना निःशुल्क है। इसके बाद CoddyKit PRO हर पाठ अनलॉक करता है, साथ ही अंतर्निर्मित कोड संपादक और चौबीसों घंटे एआई शिक्षक के साथ इंटरैक्टिव अभ्यास भी उपलब्ध कराता है। Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) पाठ्यक्रम में कुल 4 पाठ शामिल हैं।

“उपभोक्ता समूह तर्क लागू करना” में मैं क्या सीखूँगा?

समूह बनाना, `XREADGROUP` का उपयोग करके संदेश पढ़ना और `XACK` से संसाधन की पुष्टि करना सीखिए। आप ब्राउज़र में सीधे चलाए जाने वाले व्यावहारिक कोड के साथ Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) का अभ्यास करते हैं, और पाठ पूरा करते समय 24/7 एआई ट्यूटर आपके प्रश्नों के उत्तर देता है।

क्या Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) शुरू करने के लिए मुझे किसी अनुभव की आवश्यकता है?

पहले के अनुभव की आवश्यकता नहीं है। CoddyKit पर Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) शुरुआती से लेकर उन्नत शिक्षार्थियों तक सभी के लिए व्यवस्थित किया गया है, इसलिए आप यहीं से या शुरुआत से सीखना शुरू कर सकते हैं और अपनी गति से आगे बढ़ सकते हैं। यह 4 में से 2वाँ पाठ है।

“उपभोक्ता समूह तर्क लागू करना” पाठ पूरा करने में कितना समय लगता है?

CoddyKit का अधिकांश पाठ लगभग 5–10 मिनट में पूरा हो जाता है। हर पाठ छोटा और संवादात्मक है, इसलिए आप लगातार प्रगति करते हैं और वेब या ऐप पर वहीं से सीखना जारी रख सकते हैं जहाँ आपने छोड़ा था।

क्या मैं इस Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) पाठ में कोड लिख और चला सकता हूँ?

हाँ। हर Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) पाठ में एक अंतर्निर्मित कोड संपादक शामिल है, जिससे आप सीधे अपने ब्राउज़र में वास्तविक कोड लिख और चला सकते हैं और तुरंत एआई प्रतिक्रिया पा सकते हैं—स्थानीय सेटअप की आवश्यकता नहीं है।

इस पाठ्यक्रम के सभी पाठ

← Redis कैशिंग और संदेश-विनिमय (Pub/Sub, Streams) पर वापस जाएँ