RabbitMQ. भाग 1. परिचय. एर्लांग, एएमक्यूपी

शुभ दुपार, हॅब्र! मला एक पाठ्यपुस्तक-संदर्भ पुस्तक सामायिक करायचे आहे जे मी संग्रहित केले RabbitMQ आणि लहान शिफारसी आणि निष्कर्षांमध्ये संक्षिप्त करा.

सामग्री सारणी

• RabbitMQ. भाग 1. परिचय. Erlang, AMQP आणि RPC
• RabbitMQ. भाग 2. एक्सचेंजेस समजून घेणे
• RabbitMQ. भाग 3. रांगा आणि बंधने समजून घेणे
• RabbitMQ. भाग 4. संदेश आणि फ्रेम्स काय आहेत हे समजून घेणे
• RabbitMQ. भाग 5: संदेश कार्यप्रदर्शन प्रकाशित करणे आणि वापरणे
• RabbitMQ. भाग 6. फेडरेशन आणि फावडे मॉड्यूलचे विहंगावलोकन
• RabbitMQ. भाग 7. कनेक्शन आणि चॅनेल बद्दल तपशील
• RabbitMQ. भाग 8. .NET मध्ये RabbitMQ
• RabbitMQ. भाग 9. देखरेख

AMQP बद्दल थोडक्यात

AMQP (Advanced Message Quueing Protocol) हा सिस्टम घटकांमधील संदेश प्रसारित करण्यासाठी एक खुला प्रोटोकॉल आहे. मूळ कल्पना अशी आहे की वैयक्तिक उपप्रणाली (किंवा स्वतंत्र अनुप्रयोग) AMQP ब्रोकरद्वारे अनियंत्रित पद्धतीने संदेशांची देवाणघेवाण करू शकतात, जे रूटिंग करते, शक्यतो वितरणाची हमी देते, डेटा प्रवाह वितरित करते आणि इच्छित संदेश प्रकारांचे सदस्यत्व घेते.

प्रोटोकॉल AMQP तीन संकल्पना सादर करते:

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

प्रोटोकॉल वर चालतो टीसीपी / आयपी.

एरलांग बद्दल थोडक्यात

प्रकल्पाचा स्त्रोत कोड येथे रेपॉजिटरीमध्ये आहे GitHub. आर्किटेक्चर RabbitMQ-सर्व्हर आधारीत अर्लंग आणि बीम.

Erlang कंपनीने विकसित केले आहे Ericsson 1980 च्या दशकाच्या मध्यात 99,999% अपटाइम आवश्यक असलेल्या अनुप्रयोगांसाठी वितरित, दोष-सहिष्णु, रिअल-टाइम सिस्टम म्हणून. Erlang विविध उद्योग आणि आधुनिक अनुप्रयोगांमध्ये वापरले जाते, उदा. WhatsApp. आपण लेखात अधिक वाचू शकता WhatsApp आर्किटेक्चर, जे Facebook ने $19 बिलियन मध्ये विकत घेतले

RabbitMQ बद्दल थोडक्यात

ससा MQ एक मुक्त स्रोत संदेश दलाल आहे. हे प्रोटोकॉलच्या सर्व मूलभूत तत्त्वांसह संदेशांना रूट करते एमक्यूपी मध्ये वर्णन केले आहे तपशील. RabbitMQ प्रोटोकॉलची अंमलबजावणी आणि पूरक AMQP.

मधील संदेशन मॉडेलची मुख्य कल्पना RabbitMQ गोष्ट आहे producer (प्रकाशक) थेट रांगेत संदेश पाठवत नाही. खरं तर, आणि बर्‍याचदा, प्रकाशकाला हे देखील माहित नसते की संदेश कोणत्याही रांगेत वितरित केला जाईल की नाही.

त्याऐवजी, प्रकाशक केवळ एक्सचेंजला संदेश पाठवू शकतो. एकीकडे, एक्सचेंजला प्रकाशकांकडून संदेश प्राप्त होतात आणि दुसरीकडे, ते त्यांना रांगेत पाठवते. एक्सचेंजला मिळालेल्या संदेशाचे नेमके काय करावे हे माहित असणे आवश्यक आहे. ते एका विशिष्ट रांगेत जोडले जावे का? ते एकाधिक रांगांमध्ये जोडले जावे का? किंवा संदेशाकडे दुर्लक्ष केले पाहिजे.

थोडक्यात काम RabbitMQ खालीलप्रमाणे वर्णन केले जाऊ शकते:

1. प्रकाशक विशिष्ट एक्सचेंजला संदेश पाठवतो
2. एक एक्सचेंज, संदेश प्राप्त झाल्यानंतर, तो आणि रांगेतील बंधनकारक नियमांनुसार एक किंवा अधिक रांगेत तो मार्गस्थ करतो.
3. रांग या संदेशाचा संदर्भ संग्रहित करते. संदेश स्वतः RAM मध्ये किंवा डिस्कवर संग्रहित केला जातो
4. ग्राहक रांगेतून संदेश प्राप्त करण्यास तयार झाल्यानंतर, सर्व्हर दुव्याद्वारे संदेशाची एक प्रत तयार करतो आणि पाठवतो.
5. ग्राहकाला संदेश प्राप्त होतो आणि ब्रोकरला पुष्टीकरण पाठवते
6. ब्रोकर, पुष्टीकरण मिळाल्यावर, रांगेतून संदेशाची एक प्रत काढून टाकतो. नंतर रॅम आणि डिस्कमधून हटवते

जनता सरकारच्या

प्रक्रिया RPC (दूरस्थ प्रक्रिया कॉल) न्यूक्लियससह जवळजवळ सर्व परस्परसंवादांना अधोरेखित करते RabbitMQ. उदाहरणार्थ, सह क्लायंटच्या अटींबद्दल प्रारंभिक चर्चा RabbitMQ, एक विशिष्ट प्रक्रिया प्रदर्शित करते RPC. हा क्रम पूर्ण झाल्यावर, RabbitMQ क्लायंटकडून विनंत्या स्वीकारण्यास तयार असेल:

तसेच स्पेसिफिकेशन मध्ये AMQP क्लायंट आणि सर्व्हर दोन्ही कमांड जारी करू शकतात. याचा अर्थ क्लायंट सर्व्हरशी संवाद साधण्याची वाट पाहत आहे. आज्ञा वर्ग आणि पद्धती आहेत. उदाहरणार्थ, Connection.Start - पद्धत कॉल Start वर्ग Connection.

कनेक्शन आणि चॅनेल

क्लायंट आणि सर्व्हर दरम्यान अशा माहितीच्या देवाणघेवाणसाठी, चॅनेल. आत चॅनेल तयार केले जातात विशिष्ट कनेक्शन. प्रत्येक चॅनेल इतर वाहिन्यांपासून वेगळे केले जाते. सिंक्रोनस प्रकरणात, प्रतिसाद प्राप्त होईपर्यंत पुढील आदेश कार्यान्वित करणे शक्य नाही.

समांतर आदेश पाठविण्यास सक्षम होण्यासाठी, तुम्हाला अनेक चॅनेल उघडावे लागतील. प्रत्येक चॅनेल स्वतंत्र तयार करतो Erlang प्रक्रिया एका कनेक्शनमध्ये अनेक चॅनेल असू शकतात (मल्टिप्लेक्सिंग). प्रत्येक चॅनेलसाठी मेमरीमध्ये विशिष्ट संरचना आणि वस्तू असतात. म्हणून, कनेक्शनमध्ये जितके अधिक चॅनेल आहेत, तितके RabbitMQ अधिक मेमरी वापरते असे कनेक्शन व्यवस्थापित करण्यासाठी.

वापरून कनेक्शन आणि चॅनेल तयार करण्याचे एक साधे उदाहरण RabbitMQ.Client:

// ...
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 जे प्रोटोकॉलची अंमलबजावणी आहे एमक्यूटीटी कमी-स्पीड, उच्च-विलंब वातावरणात सेन्सर आणि सर्व्हर दरम्यान डेटा प्रसारित करण्यासाठी (समर्थित प्रोटोकॉलची संपूर्ण यादी येथे सूचीबद्ध आहे प्रकल्प वेबसाइट).

पुढील लेखात आपण एक्सचेंजेस अधिक तपशीलवार समजून घेण्यास सुरुवात करू.

संदर्भ

• RabbitMQ प्रकल्प साइट

स्त्रोत: www.habr.com