RabbitMQ ផ្នែកទី 1. សេចក្តីផ្តើម។ Erlang, AMQP

អរុណសួស្តី ហាប! ខ្ញុំចង់ចែករំលែកសៀវភៅសិក្សា-ឯកសារយោងនៃចំណេះដឹងដែលខ្ញុំបានគ្រប់គ្រងដើម្បីប្រមូលនៅលើ RabbitMQ និងបង្រួមចូលទៅក្នុងអនុសាសន៍ខ្លីៗ និងការសន្និដ្ឋាន។

តារាងមាតិកា

• RabbitMQ ផ្នែកទី 1. សេចក្តីផ្តើម។ Erlang, AMQP និង RPC
• RabbitMQ ផ្នែកទី 2. ការយល់ដឹងអំពីការផ្លាស់ប្តូរ
• RabbitMQ ផ្នែកទី 3. ការយល់ដឹងអំពីជួរ និងការចង
• RabbitMQ ផ្នែកទី 4. ការយល់ដឹងអំពីសារ និងស៊ុម
• RabbitMQ ផ្នែកទី 5៖ ការបោះពុម្ព និងការប្រើប្រាស់សារដែលមានប្រសិទ្ធភាព
• RabbitMQ ផ្នែកទី 6. ទិដ្ឋភាពទូទៅនៃម៉ូឌុលសហព័ន្ធនិង Shovel
• RabbitMQ ផ្នែកទី 7. ព័ត៌មានលម្អិតអំពីការតភ្ជាប់និងម៉ាក Chanel
• RabbitMQ ផ្នែកទី 8. RabbitMQ នៅក្នុង .NET
• RabbitMQ ផ្នែកទី 9. ការត្រួតពិនិត្យ

សង្ខេបអំពី AMQP

AMQP (Advanced Message Queuing Protocol) គឺជាពិធីការបើកចំហសម្រាប់បញ្ជូនសាររវាងសមាសធាតុប្រព័ន្ធ។ គំនិតជាមូលដ្ឋានគឺថាប្រព័ន្ធរងនីមួយៗ (ឬកម្មវិធីឯករាជ្យ) អាចផ្លាស់ប្តូរសារតាមអំពើចិត្តតាមរយៈឈ្មួញកណ្តាល AMQP ដែលអនុវត្តការបញ្ជូន ដែលអាចធានាការដឹកជញ្ជូន ចែកចាយការផ្សាយទិន្នន័យ និងជាវប្រភេទសារដែលចង់បាន។

ពិធីការ AMQP ណែនាំគោលគំនិតបី៖

• exchange (ចំណុចផ្លាស់ប្តូរឬផ្លាស់ប្តូរ) - សារត្រូវបានផ្ញើទៅវា។ ចំណុចផ្លាស់ប្តូរ ចែកចាយសារ នៅក្នុងជួរមួយ ឬច្រើន។ នាង បញ្ជូនសារទៅជួរ ផ្អែកលើការតភ្ជាប់ដែលបានបង្កើត (binding) រវាងគាត់និងជួរ
• queue (ជួរ) - រចនាសម្ព័ន្ធទិន្នន័យនៅលើថាសឬក្នុង RAM នោះ។ រក្សាទុកតំណភ្ជាប់ទៅសារ និងផ្តល់ច្បាប់ចម្លងនៃសារ consumers (ដល់អ្នកប្រើប្រាស់)
• binding (ការ​ចង​) - ច្បាប់​មួយ​ថា​ ប្រាប់ចំណុចផ្លាស់ប្តូរដែលតម្រង់ជួរសារទាំងនេះគួរតែចូលទៅក្នុង

ពិធីការដំណើរការនៅខាងលើ TCP / IP.

សង្ខេបអំពី Erlang

កូដប្រភពរបស់គម្រោងគឺនៅក្នុងឃ្លាំងនៅ GitHub. ស្ថាបត្យកម្ម ម៉ាស៊ីនមេ RabbitMQ អាស្រ័យ​លើ អេលឡាំង និង BEAM ។

Erlang បង្កើតឡើងដោយក្រុមហ៊ុន Ericsson នៅពាក់កណ្តាលទសវត្សរ៍ឆ្នាំ 1980 ជាប្រព័ន្ធពេលវេលាពិតប្រាកដដែលចែកចាយ និងអត់ឱនចំពោះកំហុសសម្រាប់កម្មវិធីដែលទាមទារម៉ោងធ្វើការ 99,999%។ Erlang ប្រើក្នុងឧស្សាហកម្មផ្សេងៗ និងកម្មវិធីទំនើប ឧ. WhatsApp. អ្នកអាចអានបន្ថែមនៅក្នុងអត្ថបទ ស្ថាបត្យកម្ម WhatsApp ដែល Facebook ទិញក្នុងតម្លៃ ១៩ ពាន់លានដុល្លារ

សង្ខេបអំពី RabbitMQ

RabbitMQ គឺជាឈ្មួញកណ្តាលសារប្រភពបើកចំហ។ វាបញ្ជូនសារតាមគោលការណ៍ជាមូលដ្ឋានទាំងអស់នៃពិធីការ អេអឹមខេភី បានពិពណ៌នានៅក្នុង លក្ខណៈបច្ចេកទេស. 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:

// ...
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 ប្រើសម្រាប់ការផ្លាស់ប្តូរទិន្នន័យរវាងម៉ាស៊ីនមេ (server-server)។ ប្រើកម្មវិធីជំនួយផងដែរ។ កម្មវិធីជំនួយ MQTT RabbitMQ ដែលជាការអនុវត្តពិធីការ ម៉ាចធីធី។ សម្រាប់ការបញ្ជូនទិន្នន័យរវាងឧបករណ៍ចាប់សញ្ញា និងម៉ាស៊ីនមេក្នុងបរិស្ថានដែលមានល្បឿនយឺត និងយឺតខ្ពស់ (បញ្ជីពេញលេញនៃពិធីការដែលគាំទ្រត្រូវបានរាយនៅ គេហទំព័រគម្រោង).

នៅក្នុងអត្ថបទបន្ទាប់ យើងនឹងចាប់ផ្តើមស្វែងយល់អំពី Exchanges ឱ្យបានលម្អិតបន្ថែមទៀត។

សេចក្តីយោង

• គេហទំព័រគម្រោង RabbitMQ

ប្រភព: www.habr.com