खरगोशएमक्यू। भाग 1. परिचय. एरलांग, एएमक्यूपी

शुभ दोपहर, हबर! मैं ज्ञान की एक पाठ्यपुस्तक-संदर्भ पुस्तक साझा करना चाहता हूं जिसे मैं एकत्र करने में कामयाब रहा RabbitMQ और संक्षिप्त अनुशंसाओं और निष्कर्षों में संक्षेपित करें।

लेख-सूची

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

एएमक्यूपी के बारे में संक्षेप में

एएमक्यूपी (एडवांस्ड मैसेज क्यूइंग प्रोटोकॉल) सिस्टम घटकों के बीच संदेश प्रसारित करने के लिए एक खुला प्रोटोकॉल है। मूल विचार यह है कि व्यक्तिगत सबसिस्टम (या स्वतंत्र एप्लिकेशन) एएमक्यूपी ब्रोकर के माध्यम से मनमाने ढंग से संदेशों का आदान-प्रदान कर सकते हैं, जो रूटिंग करता है, संभवतः डिलीवरी की गारंटी देता है, डेटा स्ट्रीम वितरित करता है, और वांछित संदेश प्रकारों की सदस्यता लेता है।

प्रोटोकॉल AMQP तीन अवधारणाओं का परिचय देता है:

• exchange (विनिमय बिंदु या विनिमय) - इस पर संदेश भेजे जाते हैं। विनिमय बिंदु संदेश वितरित करता है एक या अधिक कतारों में. वह संदेशों को एक कतार में रूट करता है बनाए गए कनेक्शन के आधार पर (binding) उसके और कतार के बीच
• queue (कतार) - डिस्क पर या रैम में एक डेटा संरचना संदेशों के लिंक संग्रहीत करता है और संदेशों की प्रतियां देता है consumers (उपभोक्ताओं के लिए)
• binding (बाध्यकारी) - एक नियम कि विनिमय बिंदु को बताता है कि इन संदेशों को किस कतार में जाना चाहिए

प्रोटोकॉल शीर्ष पर चलता है टीसीपी / आईपी.

एर्लांग के बारे में संक्षेप में

प्रोजेक्ट का सोर्स कोड रिपॉजिटरी में है GitHub. वास्तुकला RabbitMQ-सर्वर पर आधारित Erlang और बीम.

Erlang कंपनी द्वारा विकसित Ericsson 1980 के दशक के मध्य में 99,999% अपटाइम की आवश्यकता वाले अनुप्रयोगों के लिए एक वितरित, दोष-सहिष्णु, वास्तविक समय प्रणाली के रूप में। Erlang विभिन्न उद्योगों और आधुनिक अनुप्रयोगों में उपयोग किया जाता है, जैसे WhatsApp. आप लेख में और अधिक पढ़ सकते हैं व्हाट्सएप आर्किटेक्चर, जिसे फेसबुक ने 19 बिलियन डॉलर में खरीदा था

RabbitMQ के बारे में संक्षेप में

RabbitMQ एक खुला स्रोत संदेश दलाल है। यह प्रोटोकॉल के सभी बुनियादी सिद्धांतों के साथ संदेशों को रूट करता है एएमक्यूपी वर्णन करें विनिर्देश. RabbitMQ प्रोटोकॉल को लागू और पूरक करता है AMQP.

मैसेजिंग मॉडल का मुख्य विचार RabbitMQ बात ऐसी है producer (प्रकाशक) सीधे कतार में संदेश नहीं भेजता है। वास्तव में, और अक्सर, प्रकाशक को यह भी नहीं पता होता है कि संदेश किसी कतार में वितरित किया जाएगा या नहीं।

इसके बजाय, प्रकाशक केवल एक्सचेंज को संदेश भेज सकता है। एक ओर, एक्सचेंज प्रकाशकों से संदेश प्राप्त करता है, और दूसरी ओर, यह उन्हें कतार में भेजता है। एक्सचेंज को ठीक-ठीक पता होना चाहिए कि उसे प्राप्त संदेश के साथ क्या करना है। क्या इसे किसी विशिष्ट कतार में जोड़ा जाना चाहिए? क्या इसे एकाधिक कतारों में जोड़ा जाना चाहिए? या संदेश को नजरअंदाज कर देना चाहिए.

संक्षिप्त कार्य RabbitMQ इस प्रकार वर्णित किया जा सकता है:

1. प्रकाशक एक विशिष्ट एक्सचेंज को एक संदेश भेजता है
2. एक एक्सचेंज, एक संदेश प्राप्त करने के बाद, इसे इसके और कतार के बीच बाध्यकारी नियमों के अनुसार एक या अधिक कतारों में रूट करता है
3. कतार इस संदेश का संदर्भ संग्रहीत करती है। संदेश स्वयं रैम या डिस्क पर संग्रहीत होता है
4. एक बार जब उपभोक्ता कतार से संदेश प्राप्त करने के लिए तैयार हो जाता है, तो सर्वर लिंक के माध्यम से संदेश की एक प्रति बनाता है और भेजता है
5. उपभोक्ता संदेश प्राप्त करता है और ब्रोकर को पुष्टि भेजता है
6. ब्रोकर, पुष्टि प्राप्त करने पर, संदेश की एक प्रति कतार से हटा देता है। फिर RAM और डिस्क से डिलीट हो जाता है

आरपीसी

प्रक्रिया आरपीसी (दूरस्थ प्रक्रिया कॉल) नाभिक के साथ लगभग सभी अंतःक्रियाओं का आधार बनता है RabbitMQ. उदाहरण के लिए, ग्राहक की शर्तों के बारे में प्रारंभिक चर्चा RabbitMQ, एक निश्चित प्रक्रिया को प्रदर्शित करता है RPC. एक बार यह क्रम पूरा हो गया तो RabbitMQ ग्राहक से अनुरोध स्वीकार करने के लिए तैयार होगा:

स्पेसिफिकेशन में भी AMQP क्लाइंट और सर्वर दोनों कमांड जारी कर सकते हैं। इसका मतलब है कि क्लाइंट सर्वर से संचार करने की प्रतीक्षा कर रहा है। आदेश वर्ग और विधियाँ हैं। उदाहरण के लिए, Connection.Start - विधि कॉल Start वर्ग Connection.

कनेक्शन और चैनल

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

समानांतर में कमांड भेजने में सक्षम होने के लिए, आपको कई चैनल खोलने होंगे। प्रत्येक चैनल एक अलग बनाता है Erlang प्रक्रिया। एक कनेक्शन में कई चैनल हो सकते हैं (बहुसंकेतन). प्रत्येक चैनल के लिए मेमोरी में कुछ संरचनाएं और ऑब्जेक्ट होते हैं। इसलिए, एक कनेक्शन के भीतर जितने अधिक चैनल होंगे RabbitMQ अधिक मेमोरी का उपयोग करता है ऐसे कनेक्शन को प्रबंधित करने के लिए.

कनेक्शन और चैनल बनाने का एक सरल उदाहरण RabbitMQ.ग्राहक:

// ...
private void TryConnect()
{
    var factory = new ConnectionFactory() 
    {
        HostName = "host_name",
        UserName = "user_name",
        Password = "p@ssword",
        // Включение автоматичекого восстановления
        // соединения после сбоев сети 
        AutomaticRecoveryEnabled = true
    };
    _connection = factory.CreateConnection();
}
// ...
public void CreateChanel()
{
    _channel = _connection.CreateModel();
    // other options 
}

प्रत्येक ऑपरेशन के लिए एक नया कनेक्शन खोलना दृढ़ता से हतोत्साहित किया जाता है उच्च लागत को बढ़ावा मिलेगा. चैनल भी लगातार बने रहने चाहिए, लेकिन कई प्रोटोकॉल त्रुटियों के कारण चैनल बंद हो जाता है, इसलिए चैनल का जीवनकाल कनेक्शन की तुलना में कम हो सकता है।

RabbitMQ का उपयोग कहाँ किया जाता है?

माइक्रोसर्विसेज के संदर्भ में, प्रोटोकॉल AMQP और इसका कार्यान्वयन RabbitMQ अक्सर के लिए उपयोग किया जाता है अतुल्यकालिक बातचीत सेवाओं के बीच.

के संदर्भ में IIOT प्रोटोकॉल AMQP और इसका कार्यान्वयन RabbitMQ सर्वर (सर्वर-सर्वर) के बीच डेटा विनिमय के लिए उपयोग किया जाता है। प्लगइन का भी उपयोग करें एमक्यूटीटी प्लगइन रैबिटएमक्यू जो प्रोटोकॉल का कार्यान्वयन है MQTT कम गति, उच्च विलंबता वातावरण में सेंसर और सर्वर के बीच डेटा संचारित करने के लिए (समर्थित प्रोटोकॉल की पूरी सूची यहां सूचीबद्ध है) परियोजना स्थल).

अगले लेख में हम एक्सचेंजों को और अधिक विस्तार से समझना शुरू करेंगे।

संदर्भों

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

स्रोत: www.habr.com