أرنب MQ. الجزء 1. مقدمة. إرلانج ، AMQP

مساء الخير يا هبر! أريد أن أشارك كتاب المعرفة المرجعية الذي تمكنت من جمعه RabbitMQوضغطه في توصيات واستنتاجات قصيرة.

جدول المحتويات

• أرنب MQ. الجزء 1. مقدمة. ارلانغ ، AMQP و RPC
• أرنب MQ. الجزء 2. فهم التبادلات
• أرنب MQ. الجزء 3. فهم قوائم الانتظار والارتباطات
• أرنب MQ. الجزء 4. تفاصيل حول الاتصال وشانيل
• أرنب MQ. الجزء 5. فهم ما هي الرسائل والإطارات
• أرنب MQ. الجزء 6. نشر الرسائل وأداء الاستهلاك
• أرنب MQ. الجزء 7. نظرة عامة على وحدات الاتحاد والمجرفة
• أرنب MQ. الجزء 8. RabbitMQ في .NET
• أرنب MQ. الجزء 9. المراقبة

باختصار حول AMQP

AMQP (بروتوكول وضع الرسائل المتقدم في قائمة الانتظار) هو بروتوكول مفتوح لنقل الرسائل بين مكونات النظام. الفكرة الرئيسية هي أن الأنظمة الفرعية الفردية (أو التطبيقات المستقلة) يمكنها تبادل الرسائل بطريقة عشوائية من خلال وسيط AMQP الذي يوفر التوجيه ، وربما يضمن التسليم ، وتوزيع تدفقات البيانات ، والاشتراك في الأنواع الضرورية من الرسائل.

يقدم البروتوكول AMQPثلاثة مفاهيم:

• exchange ( ) — . . (binding)
• queue () — , consumers ().
• binding () — , .

TCP/IP.

Erlang

GitHub. RabbitMQ-server Erlang BEAM.

Erlang Ericsson 1980-x , , , 99,999%. Erlang , WhatsApp. WhatsApp, Facebook $19

RabbitMQ

RabbitMQ – . AMQP . . RabbitMQ AMQP.

RabbitMQ , producer () . , - .

. , , — . , . ? ? .

RabbitMQ :

2. , ,
3. .
4. ,
6. , , .

RPC

RPC (remote procedure call) RabbitMQ. , RabbitMQ, RPC. , RabbitMQ :

AMQP . , . — . , Connection.Start – Start Connection.

. . . , .

. Erlang . (multiplexing). . , 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 CreateChannel()
{
    _channel = _connection.CreateModel();
    // other options 
}

, , . , , , .

RabbitMQ?

AMQP RabbitMQ .

IIOT AMQP RabbitMQ (-). MQTT Plugin RabbitMQ MQTT ( ).

Exchanges.

• RabbitMQ