खरगोशएमक्यू। भाग 2. आदान-प्रदान को समझना

Exchange — एक्सचेंजर या विनिमय बिंदु। इसमें संदेश भेजे जाते हैं. Exchange संदेश वितरित करता है एक या अधिक कतारों में. वह संदेशों को एक कतार में रूट करता है बनाए गए कनेक्शन के आधार पर (bindings) उसके और कतार के बीच।

Exchange नहीं है एर्लांग प्रक्रिया. स्केलेबिलिटी कारणों से exchange - यह अंतर्निहित डेटाबेस में एक लाइन (कोड वाले मॉड्यूल से लिंक जहां रूटिंग लॉजिक निहित है) है मेनेशिया. 1 हजार एक्सचेंजर्स केवल 1MB मेमोरी की खपत करेंगे।

लेख-सूची

• खरगोशएमक्यू। भाग 1. परिचय. एरलांग, एएमक्यूपी और आरपीसी
• खरगोशएमक्यू। भाग 2. आदान-प्रदान को समझना
• खरगोशएमक्यू। भाग 3. कतारों और बंधनों को समझना
• खरगोशएमक्यू। भाग 4. यह समझना कि संदेश और फ़्रेम क्या हैं
• खरगोशएमक्यू। भाग 5: संदेश प्रकाशन और उपभोग प्रदर्शन
• खरगोशएमक्यू। भाग 6. फेडरेशन और फावड़ा मॉड्यूल की समीक्षा
• खरगोशएमक्यू। भाग 7. कनेक्शन और चैनल के बारे में विवरण
• खरगोशएमक्यू। भाग 8. .NET में RabbitMQ
• खरगोशएमक्यू। भाग 9. निगरानी

प्रत्यक्ष विनिमय

Direct exchange - जरूरत पड़ने पर उपयोग किया जाता है विशिष्ट कतारों को संदेश पहुँचाएँ. संदेश एक्सचेंजर को एक विशिष्ट के साथ प्रकाशित किया जाता है रूटिंग कुंजी और उन सभी कतारों में शामिल हो जाता है जो समान रूटिंग कुंजी के साथ इस एक्सचेंजर से जुड़े हुए हैं। रूटिंग कुंजी एक स्ट्रिंग है. का प्रयोग करके मिलान पाया जाता है समतुल्यता के लिए स्ट्रिंग की जाँच करना.

संदेश प्रवाह का चित्रमय प्रतिनिधित्व:

В rabbitmq एक अवधारणा है डिफ़ॉल्ट एक्सचेंजर. यह direct exchange कोई नाम नहीं। यदि डिफ़ॉल्ट एक्सचेंजर का उपयोग किया जाता है, तो संदेश को इसके बराबर नाम वाली एक कतार में भेज दिया जाएगा संदेश रूटिंग कुंजी.

विषय विनिमय

Topic exchange - समान direct exchange रूटिंग कुंजी की तुलना करके चयनात्मक रूटिंग को सक्षम बनाता है। लेकिन, इस मामले में, कुंजी दी गई है टेम्पलेट के अनुसार. टेम्प्लेट बनाते समय, उपयोग करें 0 या अधिक शब्द (अक्षर) AZ и az और संख्याएँ 0-9), एक बिंदु, साथ ही प्रतीकों द्वारा अलग किया गया * и #.

• * - बिल्कुल बदला जा सकता है 1 शब्द
• # - द्वारा प्रतिस्थापित किया जा सकता है 0 या अधिक शब्द

संदेश प्रवाह का चित्रमय प्रतिनिधित्व:

संस्करण के बाद से RabbitMQ 2.4.0 के लिए रूटिंग एल्गोरिदम topic exchange तक काम करना शुरू कर दिया 145 कई गुना तेज. उन्होंने एक दृष्टिकोण पेश करके इसे हासिल किया कार्यान्वयन का प्रयास करें, जिसमें एक वृक्ष संरचना के रूप में पैटर्न का प्रतिनिधित्व करना शामिल है। उदाहरण के लिए टेम्पलेट्स a.b.c, a.*.b.c, a.#.c и b.b.c निम्नलिखित संरचना द्वारा दर्शाया जाएगा:

किसी पैटर्न के मिलान की खोज जड़ से शुरू करके ऊपर से नीचे तक की जाती है।

विशेषताएं:

• इस एक्सचेंजर का उपयोग बन सकता है एप्लिकेशन के संभावित भविष्य के विकास के लिए एक अच्छा विकल्प, क्योंकि टेम्प्लेट को हमेशा अनुकूलित किया जा सकता है ताकि संदेश उसी तरह प्रकाशित हो direct exchange या fanout exchange
• टेम्प्लेट जो उपयोग करते हैं * बहुत तेजी सेउपयोग किए जाने वाले टेम्प्लेट की तुलना में #.
• topic exchange और धीमा direct exchange

फैनआउट एक्सचेंज

Fanout exchange - सभी संदेश सभी कतारों में पहुंचा दिए जाते हैं भले ही संदेश में एक रूटिंग कुंजी निर्दिष्ट हो।

विशेषताएं:

• RabbitMQ रूटिंग कुंजियों और टेम्पलेट्स के साथ काम नहीं करता जिसका उत्पादकता पर सकारात्मक प्रभाव पड़ता है। ये सबसे तेज़ है exchange;
• सभी उपभोक्ताओं को सभी संदेशों को संसाधित करने में सक्षम होना चाहिए;

संदेश प्रवाह का चित्रमय प्रतिनिधित्व:

हेडर एक्सचेंज

Headers exchange - (कुंजी, मूल्य) संपत्ति जोड़े की तुलना के आधार पर संदेशों को संबंधित कतारों में रूट करता है headers बाइंडिंग और समान संदेश गुण। headers यह प्रतिनिधित्व करता है Dictionary<ключ, значение>.

यदि आप शब्दकोश में एक विशेष कुंजी जोड़ते हैं x-match अर्थ सहित any, तो यदि (कुंजी, मान) जोड़े का आंशिक मिलान होता है तो संदेश रूट किया जाता है। यह व्यवहार ऑपरेटर के समान है or.

var bindingArguments = new Dictinary<String, Object>();
bindingArguments.add("x-match", "any");

डिफ़ॉल्ट कुंजी x-match मूल्य समाहित है all. इसका मतलब यह है कि यदि (कुंजी, मान) जोड़े बिल्कुल मेल खाते हैं तो संदेश रूट हो जाता है। यह व्यवहार ऑपरेटर के समान है and.

संदेश प्रवाह का चित्रमय प्रतिनिधित्व:

विशेषताएं:

• अतिरिक्त लचीलापन
• अतिरिक्त कम्प्यूटेशनल ओवरहेड। किसी विशेषता के सभी (कुंजी, मान) जोड़े headers संदेश रूटिंग मानों की गणना करने से पहले कुंजी नाम के अनुसार क्रमबद्ध किया जाना चाहिए। अन्य विनिमय प्रकारों की तुलना में धीमा.

लगातार-हैशिंग एक्सचेंज

यह एक्सचेंजर है लगाना и में निर्मित नहीं है в RabbitMQ.

Consistent-hashing exchange (सुसंगत हैशिंग के साथ विनिमय) - इसका उपयोग तब किया जाता है जब कई कतारें होती हैं जो किसी संदेश के संभावित प्राप्तकर्ता होते हैं, और जब आपको उनके बीच लोड को संतुलित करने की आवश्यकता होती है। कतार के साथ एक संदेश का कनेक्शन वजन (सशर्त स्ट्रिंग मान से) द्वारा होता है 0 - n).

कतारों का समतुल्य भार - इंगित करता है कि प्रत्येक कतार को प्राप्त होगा लगभग इतनी ही राशि संदेश (प्रत्येक संदेश केवल एक कतार में रखा जाएगा)। संदेशों के समान वितरण की कोई पूर्ण गारंटी नहीं है.

संदेश प्रवाह का चित्रमय प्रतिनिधित्व:

Hash रूटिंग कुंजी या संपत्ति के आधार पर गणना की गई headers संदेश. यदि सभी प्रकाशित संदेशों में अलग-अलग रूटिंग कुंजियाँ हों या headers, तो वितरण वजन के आधार पर होगा। अन्यथा, रूटिंग कुंजी का उपयोग किया जाएगा या headers.

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

एक्सचेंजर्स का संयोजन (E2E)

संचार का उपयोग करके सभी एक्सचेंजर्स के व्यवहार को जोड़ा जा सकता है विनिमय-से-विनिमय (विनिमयकर्ताओं का संयोजन विनिर्देश में शामिल नहीं है AMQP. यह ओर से प्रोटोकॉल का विस्तार है RabbitMQ).

संदेश प्रवाह का चित्रमय प्रतिनिधित्व:

के माध्यम से E2E हम वर्तमान और बढ़ती दोनों आवश्यकताओं को पूरा करने के लिए सही स्केलेबल कॉन्फ़िगरेशन पा सकते हैं।

एक्सचेंज बनाएं

एक्सचेंजर का निर्माण सिंक्रोनस का उपयोग करके होता है RPC सर्वर से अनुरोध करें. अनुरोध विधि का उपयोग करके किया जाता है Exchange.Declareपैरामीटर के साथ बुलाया गया:

• एक्सचेंजर का नाम
• एक्सचेंजर प्रकार
• अन्य पैरामीटर

रचना उदाहरण exchange के द्वारा RabbitMQ.ग्राहक:

//...
channel.ExchangeDeclare(
    exchange: "my_exchange",
    type: "direct",
    durable: "false",
    autoDelete: "false",
    arguments: null
);
//...

• exchange - एक्सचेंजर का नाम जिसे हम बनाना चाहते हैं। नाम अद्वितीय होना चाहिए
• type — एक्सचेंजर का प्रकार
• durable - यदि स्थापित है true, तो exchange स्थायी होगा. इसे डिस्क पर संग्रहीत किया जाएगा और सर्वर/ब्रोकर पुनरारंभ से बच सकता है। यदि मान false, तो exchange अस्थायी है और सर्वर/ब्रोकर के रीबूट होने पर हटा दिया जाएगा
• autoDelete - स्वचालित निष्कासन। Exchange जब इससे जुड़ी सभी कतारें हटा दी जाएंगी तो हटा दिया जाएगा
• arguments - वैकल्पिक तर्क. अधिकतर, वे तर्कों के माध्यम से निर्दिष्ट करते हैं alternative exchange (वैकल्पिक एक्सचेंजर). यदि कोई संदेश मूल मार्ग के साथ यात्रा नहीं कर सकता है, तो इसे एक अलग मार्ग के साथ रूट करने के लिए वैकल्पिक एक्सचेंजर को भेजा जा सकता है।

यदि सृजन exchange शायद, तो सर्वर क्लाइंट को एक सिंक्रोनस भेजेगा RPC जवाब Exchange.DeclareOk. यदि सृजन असंभव है (अनुरोध अस्वीकार कर दिया गया Exchange.Declare), फिर चैनल बंद हो जायेगा सर्वर एक एसिंक्रोनस कमांड का उपयोग कर रहा है Channel.Close और ग्राहक को एक अपवाद प्राप्त होगा ऑपरेशनइंटरप्टेडएक्सेप्शन, जिसमें त्रुटि कोड और उसका विवरण होगा।

संदेश पोस्ट करने से पहले एक एक्सचेंजर बनाया जाना चाहिए। यदि आप किसी गैर-मौजूद एक्सचेंजर को संदेश प्रकाशित करते हैं - RabbitMQ चुपचाप हटा देंगे.

GUI के माध्यम से एक्सचेंज बनाना

एडमिन पैनल पर जाएं RabbitMQ उपयोगकर्ता के अंतर्गत guest (उपयोगकर्ता नाम: guest और पासवर्ड: guest). कृपया ध्यान दें कि उपयोगकर्ता guest केवल लोकलहोस्ट से ही कनेक्ट हो सकता है। अब टैब पर चलते हैं Exchanges और क्लिक करें Add a new exchange. गुण भरें:

अधिकांश संपत्तियों का वर्णन ऊपर किया जा चुका है। यहां हम ध्यान दें कि यदि हम सेट करते हैं Internal, तो विनिमय का उपयोग केवल के लिए किया जा सकता है E2E. Producer ऐसे एक्सचेंज को संदेश नहीं भेज पाएंगे।

निष्कर्ष

सिस्टम विकसित करते समय टोपोलॉजी का वर्णन करना सुविधाजनक होता है मार्ग एक ग्राफ़ का उपयोग करना। लेकिन इससे पहले कि आप एक ग्राफ़ बनाना शुरू करें, यह उच्च ट्रैफ़िक वाले पथों को उजागर करने के लायक है, क्योंकि वे ही हैं जो मांग करते हैं उच्चतर थ्रूपुट (प्रदर्शन)। इसके बाद, आप ट्रैफ़िक को वर्गीकृत कर सकते हैं। और उसके बाद ही निर्माण शुरू करें।

यदि निर्मित ग्राफ़ में है परिमित सेट रूटिंग कुंजियाँ, तो यह कई की ओर देखने लायक है fanout exchange, जो रूटिंग कुंजी से संबंधित 1:1 हैं। हमें वह याद है fanout exchange सबसे तेज।

यदि मार्गों की संख्या अनन्त की ओर प्रवृत्त होता है, तो आपको ध्यान देना चाहिए topic exchange या, यदि टेम्पलेट की आवश्यकता नहीं है, तो आप चयन कर सकते हैं direct exchnge, क्योंकि वह तेज़ है topic exchange.

विभिन्न के संयोजन exchange आपको सही खोजने में मदद करनी चाहिए स्केलेबल कॉन्फ़िगरेशन, जो वर्तमान और बढ़ती दोनों सिस्टम आवश्यकताओं को पूरा करता है।

संख्या exchange और मार्गों की संख्या की तुलना में कतारें न्यूनतम होनी चाहिए।

अगले लेख में हम Queues और बाइंडिंग्स को और अधिक विस्तार से समझना शुरू करेंगे।

संदर्भों

• RabbitMQ परियोजना वेबसाइट

स्रोत: www.habr.com