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

नमस्ते, हबर! मैले जम्मा गरेको ज्ञानको एउटा पाठ्यपुस्तक-सन्दर्भ पुस्तक म तपाईंलाई बाँड्न चाहन्छु। RabbitMQ र छोटो सिफारिस र निष्कर्षमा संक्षिप्त गर्नुहोस्।

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

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

AMQP को बारेमा संक्षिप्तमा

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

प्रोटोकल AMQP तीन अवधारणाहरू प्रस्तुत गर्दछ:

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

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

एर्लाङको बारेमा संक्षिप्तमा

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

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

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