RabbitMQ। भाग १. परिचय। Erlang, AMQP

शुभ दिउँसो, Habr! म ज्ञानको पाठ्यपुस्तक-सन्दर्भ पुस्तक साझा गर्न चाहन्छु जुन मैले संग्रह गर्न व्यवस्थित गरेको छु RabbitMQ र छोटो सिफारिसहरू र निष्कर्षहरूमा गाढा।

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

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

AMQP को बारेमा छोटकरीमा

AMQP (Advanced Message Quueing Protocol) प्रणाली कम्पोनेन्टहरू बीच सन्देशहरू पठाउनको लागि खुला प्रोटोकल हो। आधारभूत विचार यो हो कि व्यक्तिगत उपप्रणालीहरू (वा स्वतन्त्र अनुप्रयोगहरू) AMQP ब्रोकर मार्फत स्वेच्छाचारी रूपमा सन्देशहरू आदानप्रदान गर्न सक्छन्, जसले राउटिङ कार्य गर्दछ, सम्भवतः डेलिभरीको ग्यारेन्टी दिन्छ, डाटा स्ट्रिमहरू वितरण गर्दछ, र इच्छित सन्देश प्रकारहरूमा सदस्यता लिन्छ।

प्रोटोकल AMQP तीन अवधारणाहरू परिचय:

• exchange (विनिमय बिन्दु वा विनिमय) - सन्देशहरू यसलाई पठाइन्छ। विनिमय बिन्दु सन्देश वितरण गर्दछ एक वा बढी लाइनमा। तिनी सन्देशहरूलाई लाइनमा पठाउँछ सिर्जना गरिएको जडानहरूमा आधारित (binding) उहाँ र लाम बीचमा
• queue (पंक्ति) - डिस्क वा RAM मा डाटा संरचना सन्देशहरूमा लिङ्कहरू भण्डारण गर्दछ र सन्देशहरूको प्रतिलिपिहरू दिन्छ consumers (उपभोक्ताहरूलाई)
• binding (बाध्यकारी) - एक नियम कि यी सन्देशहरू कुन लाममा जानुपर्दछ भन्ने विनिमय बिन्दुलाई बताउँछ

प्रोटोकल माथि चल्छ टीसीपी / आईपी.

Erlang को बारे मा छोटकरीमा

परियोजनाको स्रोत कोड रिपोजिटरी मा छ GitHub। वास्तुकला RabbitMQ-सर्भर मा आधारित एरलाlang र बीम।

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

RabbitMQ को बारेमा छोटकरीमा

खरगोश MQ खुला स्रोत सन्देश ब्रोकर हो। यसले प्रोटोकलका सबै आधारभूत सिद्धान्तहरूसँग सन्देशहरू मार्ग गर्दछ AMQP मा वर्णन गरिएको छ विशिष्टताहरु. RabbitMQ प्रोटोकल लागू र पूरक AMQP.

मा सन्देश मोडेल को मुख्य विचार RabbitMQ कुरा हो producer (प्रकाशक) ले लाममा सीधै सन्देशहरू पठाउँदैन। वास्तवमा, र प्रायः, प्रकाशकलाई यो पनि थाहा छैन कि सन्देश कुनै पनि लाममा डेलिभर गरिनेछ।

यसको सट्टा, प्रकाशकले एक्सचेन्जमा सन्देशहरू मात्र पठाउन सक्छ। एकातिर, एक्सचेन्जले प्रकाशकहरूबाट सन्देशहरू प्राप्त गर्दछ, र अर्कोतर्फ, यसले तिनीहरूलाई लाममा पठाउँछ। एक्सचेन्जले ठ्याक्कै थाहा पाउनु पर्छ कि यसले प्राप्त गरेको सन्देशलाई के गर्ने। के यो एक विशिष्ट लाममा थप्नु पर्छ? के यो धेरै लामहरूमा थप्नु पर्छ? वा सन्देशलाई बेवास्ता गर्नुपर्छ।

छोटो काम RabbitMQ निम्नानुसार वर्णन गर्न सकिन्छ:

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

Rpc

प्रक्रिया 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 जुन प्रोटोकलको कार्यान्वयन हो MQTT कम-स्पीड, उच्च-विलम्बता वातावरणमा सेन्सर र सर्भर बीच डाटा प्रसारणको लागि (समर्थित प्रोटोकलहरूको पूर्ण सूचीमा सूचीबद्ध छ। परियोजना वेबसाइट).

अर्को लेखमा हामी एक्सचेन्जलाई थप विस्तारमा बुझ्न सुरु गर्नेछौं।

सन्दर्भ

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

स्रोत: www.habr.com