निवासियों की प्रसंस्करण प्रणाली में खरगोश एमक्यू

हाल ही में, उन्होंने नागरिकों के लिए उपयोगकर्ता प्रसंस्करण प्रणाली को सफलतापूर्वक चालू किया। मुद्दा यह है कि जब आपके घर के पास सड़क में पानी, हीटिंग या एक बड़ा छेद नहीं होता है, तो आप सरकारी एजेंसियों में समस्या के बारे में शिकायत कर सकते हैं। विभिन्न प्लेटफ़ॉर्म हैं जहां आप शिकायत दर्ज कर सकते हैं: राज्य संस्थानों की वेबसाइट, सोशल नेटवर्क पर पेज, कॉल सेंटर।

हमारा कार्य सभी विभागों के लिए प्रसंस्करण अनुप्रयोगों के लिए एक एकल पाइपलाइन बनाना था।
सिस्टम का मुख्य लक्ष्य प्रसंस्करण कॉल की प्रक्रिया को यथासंभव तेज करना है: स्वचालित रूप से सब कुछ स्वचालित करें, प्रक्रिया के प्रत्येक चरण पर समय को नियंत्रित करें, प्रत्येक चरण के बारे में निवासियों को सूचित करें।

परियोजना के विशिष्ट कार्यों में से एक बड़ी संख्या में बाहरी प्रणालियों के साथ एकीकरण का मुद्दा था।

• शिकायतों के पूरे विवरण को स्पष्ट करने के लिए, विभिन्न साइटों से सीखना आवश्यक था कि वे शिकायतों के पूरे प्रवाह को चुन सकें, आवेदनों के साथ सभी परिवर्तनों पर उनके साथ संवाद कर सकें, सरकारी अधिकारियों और नागरिकों के बीच पत्राचार कर सकें।
• इसके अतिरिक्त, हमने कुछ कार्यों को तृतीय-पक्ष सेवाओं को दे दिया।

क्योंकि बहुत सारे डेटा आए, अक्सर अतुल्यकालिक मोड में काम करना पड़ा, फिर प्रोजेक्ट टीम को समस्या को हल करना पड़ा, ताकि खुद को और तीसरे पक्ष के सिस्टम को गला न दें। समाधान सॉफ्टवेयर संदेश दलाल खरगोश एमक्यू में पाया गया था। यह उस समय टीम के लिए एक नई तकनीक थी।

नीचे प्रोजेक्ट बैकएंड के डेवलपर अलेक्जेंडर शेक्लोव , विलीलीनक्स के साथ एक साक्षात्कार है, जिसने इस मुद्दे से निपटा और एकीकरण को लागू किया।

- साशा, नमस्ते! कृपया हमें संक्षेप में बताएं कि खरगोश MQ क्या है?

सॉफ्टवेयर मुख्य रूप से विभिन्न ग्राहकों के बीच विलंबित संदेश के कार्यान्वयन के लिए अभिप्रेत है, अर्थात्। जब आपको अभी उत्तर की आवश्यकता नहीं है।

- मैं सही ढंग से समझता हूं कि सामान्य तौर पर यह इस तरह काम करता है: बनाई गई कतार में भेजने वाली सेवा डेटा को उत्पन्न करती है, प्राप्त करने वाली सेवा इस जानकारी को आवश्यक रूप से लेती है?

ठीक यही काम करता है।

- आपने (विकास टीम) ने परियोजना के लिए इस समाधान को क्यों चुना?

कई कारणों से। सबसे पहले, हमारे मामले में, तुल्यकालिक प्रसंस्करण (एक ही समय में प्राप्त और संसाधित) महत्वपूर्ण नहीं है, अर्थात्। संदेश कुछ देर के लिए कतार में लटका रह सकता है। इसके अलावा, उपयोग में आसानी: संदेश प्राप्त करने के लिए आपको केवल कतार का नाम घोषित करने की आवश्यकता है और अपनी सेवाओं को लिखने की कोई आवश्यकता नहीं है। खैर, आम YP के लिए पुस्तकालयों की उपलब्धता। RabbitMQ के साथ काम करने के लिए कुछ भी आविष्कार करने की आवश्यकता नहीं है।

- मैं सही ढंग से समझता हूं कि खरगोश एमक्यू आपको सिस्टम और वेब सेवाओं के बीच डेटा के आदान-प्रदान को नियंत्रित करने की अनुमति देता है?

बल्कि, हम अभी भी एक्सचेंज का प्रबंधन करते हैं, लेकिन "खरगोश" इस एक्सचेंज के आयोजन के लिए एक उत्कृष्ट उपकरण है। यहां आपके पास कतारों में संदेशों का जीवन काल, और अधिकतम कतार की लंबाई, और एक्सेस सेटिंग्स, और क्लस्टरिंग, और विभिन्न एक्सचेंज प्रोटोकॉल, और एक प्लग-इन सिस्टम और बहुत कुछ है।

- यह कैसे निर्धारित किया जाता है कि संदेश वितरित किया गया है? - अर्थात्, यह कैसे निर्धारित किया जाता है कि ग्राहक ने रसीद के बाद कुछ बढ़ाया है या प्रक्रिया में लटका दिया है?

यह माना जाता है कि अगर, एक निश्चित अवधि के भीतर, ग्राहक की प्रतिक्रिया आती है। यह, वास्तव में, कहता है कि वह प्राप्त हुआ और जीवन से प्रसन्न था। ग्राहक प्राप्त होते ही प्रतिक्रिया भेज सकता है, और फिर संदेश को संसाधित करने का प्रयास कर सकता है। हो सकता है, इसके विपरीत, पहले प्रक्रिया करने की कोशिश करें और, यदि सफल हो, तो प्रतिक्रिया भेजें। या आप खरगोश को पहले से बता सकते हैं ताकि वह आपसे डिलीवरी की पुष्टि का इंतजार न करे और सिर्फ संदेश प्राप्त करे। सभी भेजे गए आइटमों को स्वचालित रूप से वितरित माना जाएगा।

- क्या यह संभव है, उदाहरण के लिए, किसी भी तरह से सभी संदेश प्राप्त नहीं करना है, लेकिन उदाहरण के लिए केवल एक विशिष्ट एप्लिकेशन पर संदेशों की सदस्यता के लिए?

थोड़ी अलग स्थिति है। संदेश भेजने का एक विकल्प है जिसमें सभी ग्राहकों के लिए संदेश आते हैं। इस विकल्प को "प्रकाशित / सदस्यता" कहा जाता है। एक अच्छा उदाहरण: आपकी जनता में एक नया संदेश। आपने भेजा, सभी हस्ताक्षरकर्ता प्राप्त हुए। और पहले से ही रसीद पर वे पढ़ने के लिए या पढ़ने के लिए नहीं सोचा था। सामान्य तौर पर, कोई भी आपको अपने लिए एक अलग कतार बनाने और केवल इसके साथ काम करने के लिए परेशान नहीं करता है। इस मामले में, रूटिंग पहले से ही आवेदन स्तर पर होगा, और खरगोश एक संचार चैनल के रूप में।

- साशा, मुझे बताओ, क्या हजारों कतार बनाने का विकल्प नहीं है, लेकिन एक के लिए फ़िल्टरिंग और रूट करना है?

एक से यह काम नहीं करेगा, लेकिन खरगोश कुछ रूटिंग करने की अनुमति देगा।

- कृपया हमें और बताएँ।

उनमें से एक नहीं है, लेकिन "विनिमय" और "रूटिंग कुंजी" जैसी अवधारणाएं हैं:

पी - निर्माता, बदले में संदेश भेजने वाला
एक्स - एक्सचेंज ही
लाल धारियाँ - रेखाएँ
C1 और C2 - प्राप्तकर्ता



पैबिट एक निश्चित कुंजी (उदाहरण के लिए, त्रुटि / जानकारी / चेतावनी) के बदले में एक संदेश भेज सकता है। और जैसा कि आप देख सकते हैं, अलग-अलग प्राप्तकर्ता विभिन्न रूटिंग कुंजी के साथ संदेश प्राप्त करने की दिशा में सक्षम हैं। इसके अलावा, केवल C2 को "जानकारी" कुंजी के साथ एक संदेश प्राप्त होगा, और दोनों को "त्रुटि" कुंजी के साथ एक संदेश प्राप्त होगा। कुंजी के लिए टेम्प्लेट के अनुसार संदेश प्राप्त करना भी संभव है। यह एक अन्य प्रकार के "प्रकाशित / सदस्यता" एक्सचेंज के लिए है, जिसका मैंने पहले उल्लेख किया था।



जैसा कि आप किसी भी मामले में देख सकते हैं, इन प्रकार के आदान-प्रदानों में से प्रत्येक के लिए एक मोड़ है, लेकिन अंत तक हम अभी भी फ़िल्टरिंग / रूटिंग के कुछ उदाहरण हैं।

- खरगोश के अध्ययन और कार्यान्वयन के दौरान आने वाली समस्याओं को आप क्या याद कर सकते हैं?

आलस्य के अलावा, नहीं। गंभीरता से, स्पष्ट दस्तावेज, उदाहरणों की एक बड़ी संख्या।

- क्या आपने सेवाओं और बाहरी प्रणालियों के साथ सभी एक्सचेंजों को पहले ही स्थानांतरित कर दिया है?

अब हमारे पास 38 कतारें हैं: सर्किट, बाहरी सिस्टम, बीआई के बीच विनिमय। लेकिन दुर्भाग्य से, कुछ सेवाएं (विभाग पढ़ें) विरोध कर रही हैं। क्योंकि उन्होंने आराम लागू किया है। इसके अलावा, कुछ प्रकार के इंटरैक्शन में अनुरोधों की प्रतिक्रियाओं की एक साथ प्राप्ति शामिल है।

- आपको क्या लगता है, यह निर्णय कितना सफल रहा?

अंतर-सहयोग के लिए जिसे एक तुल्यकालिक प्रतिक्रिया की आवश्यकता नहीं है? मेरे लिए, यह एक बढ़िया विकल्प है।

प्रयुक्त सामग्री की सूची