RabbitMQ। भाग 2. एक्सचेन्जहरू बुझ्दै

Exchange - एक्सचेंजर वा विनिमय बिन्दु। यसमा सन्देशहरू पठाइन्छ। Exchange सन्देश वितरण गर्दछ एक वा बढी लाइनमा। उहाँले सन्देशहरूलाई लाइनमा पठाउँछ सिर्जना गरिएको जडानहरूमा आधारित (bindings) उहाँ र लाम बीचमा।

Exchange होईन Erlang प्रक्रिया। स्केलेबिलिटी कारणहरूको लागि exchange - यो एक लाइन हो (कोडको साथ एक मोड्युलको लिङ्क जहाँ रूटिङ तर्क हुन्छ) निर्मित डाटाबेसमा मेनेसिया। १ हजार एक्सचेन्जरले १ एमबी मेमोरी मात्र खपत गर्नेछ।

सामग्रीको तालिका

• RabbitMQ। भाग १. परिचय। Erlang, AMQP र RPC
• RabbitMQ। भाग 2. एक्सचेन्जहरू बुझ्दै
• RabbitMQ। भाग 3. लामहरू र बाइन्डिङहरू बुझ्दै
• RabbitMQ। भाग 4. सन्देश र फ्रेमहरू के हो बुझ्दै
• RabbitMQ। भाग ५: सन्देश प्रकाशन र उपभोग कार्यसम्पादन
• RabbitMQ। भाग 6. महासंघ र फावडा मोड्युलहरूको समीक्षा
• RabbitMQ। भाग 7. जडान र च्यानल बारे विवरणहरू
• RabbitMQ। भाग 8. .NET मा RabbitMQ
• 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 एक्सचेन्ज

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.Client:

//...
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 र ग्राहक एक अपवाद प्राप्त हुनेछ Operation InterruptedException, जसमा त्रुटि कोड र यसको विवरण समावेश हुनेछ।

सन्देशहरू पोस्ट गर्नु अघि एक्सचेन्जर सिर्जना गर्नुपर्छ। यदि तपाइँ केहि अस्तित्वहीन एक्सचेन्जरलाई सन्देश प्रकाशित गर्नुहुन्छ - 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 र लाइनहरू मार्गहरूको संख्याको तुलनामा न्यूनतम हुनुपर्छ।

अर्को लेखमा हामी थप विवरणमा लाम र बाइन्डिङहरू बुझ्न सुरु गर्नेछौं।

सन्दर्भ

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

स्रोत: www.habr.com