RabbitMQ အပိုင်း ၁။ နိဒါန်း။ Erlang၊ AMQP

မင်္ဂလာရှိသောနေ့လည်ခင်းပါ Habr! ကျွန်တော်စုဆောင်းထားခဲ့သော ဗဟုသုတစာအုပ်လေးတစ်အုပ်ကို မျှဝေပေးချင်ပါတယ်။ RabbitMQ အကြံပြုချက်များနှင့် နိဂုံးချုပ်ချက်များအဖြစ် ပေါင်းစည်းပါ။

မာတိကာ

• RabbitMQ အပိုင်း ၁။ နိဒါန်း။ Erlang၊ AMQP နှင့် RPC
• RabbitMQ အပိုင်း 2။ နားလည်မှုဖလှယ်မှုများ
• RabbitMQ အပိုင်း ၃။ တန်းစီခြင်းနှင့် စည်းနှောင်ခြင်းကို နားလည်ခြင်း။
• RabbitMQ အပိုင်း 4။ မက်ဆေ့ချ်များနှင့် ဘောင်များကို နားလည်ခြင်း။
• RabbitMQ အပိုင်း 5- ထုတ်ဝေခြင်းနှင့် အသုံးပြုခြင်း မက်ဆေ့ချ်စွမ်းဆောင်ရည်
• RabbitMQ အပိုင်း 6။ အသင်းချုပ်နှင့် ဂေါ်ပြား မော်ဂျူးများ၏ ခြုံငုံသုံးသပ်ချက်
• RabbitMQ အပိုင်း ၇။ ချိတ်ဆက်မှုနှင့် Chanel အကြောင်းအသေးစိတ်
• RabbitMQ အပိုင်း ၈။ .NET တွင် RabbitMQ
• RabbitMQ အပိုင်း ၉။ စောင့်ကြည့်လေ့လာခြင်း။

AMQP အကြောင်း အတိုချုပ်

AMQP (Advanced Message Queuing Protocol) သည် စနစ်အစိတ်အပိုင်းများအကြား မက်ဆေ့ချ်များ ပို့လွှတ်ခြင်းအတွက် အဖွင့်ပရိုတိုကောတစ်ခုဖြစ်သည်။ အခြေခံအယူအဆမှာ တစ်ဦးချင်းစနစ်ခွဲများ (သို့မဟုတ် သီးခြားအပလီကေးရှင်းများ) သည် လမ်းကြောင်းလမ်းကြောင်းကိုလုပ်ဆောင်ပေးသည့် AMQP ပွဲစားမှတစ်ဆင့် မက်ဆေ့ချ်များကို မထင်သလို ဖလှယ်နိုင်သည်၊ ပေးပို့မှုကို အာမခံနိုင်သည်၊ ဒေတာစီးကြောင်းများကို ဖြန့်ဝေပေးပြီး လိုချင်သောမက်ဆေ့ချ်အမျိုးအစားများသို့ စာရင်းပေးသွင်းနိုင်ပါသည်။

protocol ကို AMQP အယူအဆသုံးခုကို မိတ်ဆက်ပေးသည်-

• exchange ( exchange point or exchange ) - မက်ဆေ့ချ်များ ပေးပို့သည်။ လဲလှယ်ပွိုင့် သတင်းစကားဖြန့်ဝေသည်။ တစ်ခု သို့မဟုတ် တစ်ခုထက်ပိုသော တန်းစီခြင်းတွင် သူမ စာတိုများကို တန်းစီရန် လမ်းကြောင်းပေးသည်။ ဖန်တီးထားသောလင့်ခ်များကို အခြေခံ၍ (binding) သူနဲ့ လူတန်းကြား
• queue (Queue) - ဒစ်ခ် သို့မဟုတ် RAM တွင် ဒေတာဖွဲ့စည်းပုံ မက်ဆေ့ခ်ျများသို့ လင့်ခ်များကို သိမ်းဆည်းထားပြီး မက်ဆေ့ချ်များကို ကော်ပီများ ပေးသည်။ consumers (စားသုံးသူများအတွက်)
• binding (binding) - စည်းမျဥ်းတစ်ခု ဤစာတိုများထံ တန်းစီရမည့်နေရာကို ချိန်းဆိုသည်။

ပရိုတိုကောသည် အပေါ်မှ လည်ပတ်သည်။ TCP / IP.

Erlang အကြောင်း အတိုချုပ်

ပရောဂျက်၏ အရင်းအမြစ်ကုဒ်သည် သိုလှောင်ရာနေရာ၌ ရှိနေသည်။ GitHub. ဗိသုကာပညာ RabbitMQ-ဆာဗာ ပေါ်အခြေခံကာ erlang နှင့် BEAM

Erlang ကုမ္ပဏီမှတီထွင်သည်။ Ericsson 1980% uptime လိုအပ်သော application များအတွက် ဖြန့်ဝေမှု၊ အမှား-ခံနိုင်ရည်ရှိသော၊ real-time စနစ်အဖြစ် 99,999 ခုနှစ်များအလယ်ပိုင်းတွင်။ Erlang စက်မှုလုပ်ငန်းအမျိုးမျိုးနှင့် ခေတ်မီအသုံးချပရိုဂရမ်များတွင် အသုံးပြုသော၊ ဥပမာ၊ WhatsApp. ဆောင်းပါးတွင် သင်ပိုမိုဖတ်ရှုနိုင်ပါသည်။ Facebook က ဒေါ်လာ ၁၉ ဘီလီယံနဲ့ ဝယ်ယူထားတဲ့ WhatsApp တည်ဆောက်မှုပါ။

RabbitMQ အကြောင်း အကျဉ်းချုပ်

ယုန် MQ open source message ပွဲစားတစ်ခုဖြစ်သည်။ ၎င်းသည် ပရိုတိုကော၏ အခြေခံမူများအားလုံးတစ်လျှောက် မက်ဆေ့ချ်များကို လမ်းကြောင်းပေးသည်။ AMQP တွင်ဖော်ပြထားသည်။ သတ်မှတ်ချက်များ. RabbitMQ ပရိုတိုကောကို အကောင်အထည်ဖော်ပြီး ဖြည့်စွက်ပါ။ AMQP.

စာတိုပေးပို့မှုပုံစံ၏ အဓိက စိတ်ကူးဖြစ်သည်။ RabbitMQ အရာဖြစ်တယ် producer (ထုတ်ဝေသူ) သည် တန်းစီရန် စာတိုများကို တိုက်ရိုက်မပို့ပါ။ တကယ်တော့၊ မကြာခဏဆိုသလို၊ ထုတ်ဝေသူသည် မက်ဆေ့ချ်ကို မည်သည့်စာရင်းသို့ ပေးပို့မည်ဆိုသည်ကိုပင် မသိပါ။

ယင်းအစား၊ ထုတ်ဝေသူသည် ဖလှယ်မှုထံသို့ မက်ဆေ့ချ်များသာ ပေးပို့နိုင်သည်။ တစ်ဖက်တွင်၊ လဲလှယ်သူသည် ထုတ်ဝေသူများထံမှ မက်ဆေ့ချ်များကို လက်ခံရရှိပြီး တစ်ဖက်တွင် ၎င်းတို့အား တန်းစီရန် ပေးပို့သည်။ လဲလှယ်သူသည် လက်ခံရရှိသော မက်ဆေ့ချ်နှင့် ဘာလုပ်ရမည်ကို အတိအကျ သိရပါမည်။ သတ်မှတ်ထားသော တန်းစီတစ်ခုသို့ ထည့်သင့်ပါသလား။ ၎င်းကို တန်းစီအများအပြားတွင် ထည့်သင့်ပါသလား။ သို့မဟုတ် မက်ဆေ့ချ်ကို လစ်လျူရှုသင့်သည်။

အလုပ်အကျဉ်း RabbitMQ အောက်ပါအတိုင်း ဖော်ပြနိုင်ပါသည်။

1. ထုတ်ဝေသူသည် သီးခြားဖလှယ်မှုတစ်ခုထံ မက်ဆေ့ချ်ပေးပို့သည်။
2. မက်ဆေ့ချ်လက်ခံရရှိပြီးနောက် ဖလှယ်မှုတစ်ခုသည် ၎င်းနှင့် တန်းစီကြားတွင် စည်းနှောင်ထားသော စည်းမျဉ်းများနှင့်အညီ တစ်ခု သို့မဟုတ် တစ်ခုထက်ပိုသော တန်းစီများသို့ လမ်းကြောင်းပေးသည်
3. တန်းစီသည် ဤမက်ဆေ့ဂျ်အတွက် ရည်ညွှန်းချက်ကို သိမ်းဆည်းထားသည်။ မက်ဆေ့ချ်ကို RAM သို့မဟုတ် ဒစ်ခ်တွင် သိမ်းဆည်းထားသည်။
4. စားသုံးသူသည် တန်းစီနေသည့် မက်ဆေ့ချ်ကို လက်ခံရန် အဆင်သင့်ဖြစ်သောအခါ၊ ဆာဗာသည် လင့်ခ်မှတစ်ဆင့် မက်ဆေ့ချ်တစ်စောင်ကို ဖန်တီးပြီး ပေးပို့သည်
5. စားသုံးသူသည် မက်ဆေ့ခ်ျကို လက်ခံရရှိပြီး ပွဲစားထံ အတည်ပြုချက် ပေးပို့သည်။
6. ပွဲစားသည် အတည်ပြုချက်ရရှိပြီးနောက် တန်းစီဇယားမှ စာတစ်စောင်ကို ဖယ်ရှားသည်။ ထို့နောက် RAM နှင့် disk မှဖျက်ပစ်သည်။

CPR

ဖြစ်စဉ် RPC (အဝေးမှ ခေါ်ဆိုမှု) နျူကလိယနှင့် ဆက်စပ်မှုအားလုံးနီးပါးကို အခြေခံထားသည်။ RabbitMQ. ဥပမာအားဖြင့်၊ ဖောက်သည်၏ အသုံးအနှုန်းများနှင့် ပတ်သက်၍ ကနဦး ဆွေးနွေးမှုများ RabbitMQအချို့သော လုပ်ငန်းစဉ်ကို သရုပ်ပြသည်။ RPC. ဤအစီအစဥ်ပြီးသည်နှင့်၊ RabbitMQ ဖောက်သည်ထံမှ တောင်းဆိုချက်များကို လက်ခံရန် အဆင်သင့်ဖြစ်လိမ့်မည်-

သတ်မှတ်ချက်ထဲမှာလည်းပါတယ်။ AMQP client နှင့် server နှစ်ခုလုံးသည် command များကိုထုတ်ပေးနိုင်သည်။ ဆိုလိုသည်မှာ client သည် server နှင့် ဆက်သွယ်ရန် စောင့်ဆိုင်းနေပါသည်။ Command များသည် class နှင့် method များဖြစ်သည်။ ဥပမာအားဖြင့်, Connection.Start - နည်းလမ်းခေါ်ဆိုမှု Start класса Connection.

ချိတ်ဆက်မှုနှင့် ချန်နယ်များ

client နှင့် server အကြား သတင်းအချက်အလက် ဖလှယ်ရန်အတွက်၊ လိုင်းများ. ချန်နယ်များကို အတွင်းတွင် ဖန်တီးထားသည်။ သီးခြားချိတ်ဆက်မှု. ချန်နယ်တစ်ခုစီကို အခြားချန်နယ်များမှ သီးခြားခွဲထားသည်။ synchronous case တွင်၊ တုံ့ပြန်မှုမရရှိမချင်း နောက် command ကို execute လုပ်၍မရပါ။

မျဉ်းပြိုင်များ ပေးပို့နိုင်ရန်၊ လိုင်းများစွာကို ဖွင့်ရပါမည်။ ချန်နယ်တစ်ခုစီသည် သီးခြားဖန်တီးသည်။ Erlang လုပ်ငန်းစဉ်။ ချိတ်ဆက်မှုတစ်ခုတွင် ချန်နယ်များစွာရှိနိုင်သည် (multiplexing) ချန်နယ်တစ်ခုစီအတွက် memory ထဲတွင် အချို့သော တည်ဆောက်ပုံများနှင့် အရာဝတ္ထုများ ရှိပါသည်။ ထို့ကြောင့် ချိတ်ဆက်မှုတစ်ခုအတွင်း ချန်နယ်များ များလေလေ၊ RabbitMQ သည် memory ပိုများသည်။ ထိုသို့သောချိတ်ဆက်မှုကိုစီမံခန့်ခွဲရန်။

ချိတ်ဆက်မှုနှင့် ချန်နယ်ကို အသုံးပြုခြင်း၏ ရိုးရှင်းသော ဥပမာတစ်ခု 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 ကို ဘယ်မှာသုံးတာလဲ။

microservices ၏အခြေအနေတွင်၊ ပရိုတိုကော AMQP နှင့်၎င်း၏အကောင်အထည်ဖော်မှုအတွက် RabbitMQ မကြာခဏအသုံးပြုသည်။ အပြိုင်အဆိုင် အပြန်အလှန်တုံ့ပြန်မှု ဝန်ဆောင်မှုများအကြား။

စကားစပ်မိသည် IIOT ပရိုတိုကော AMQP နှင့်၎င်း၏အကောင်အထည်ဖော်မှုအတွက် RabbitMQ ဆာဗာများ (ဆာဗာ-ဆာဗာ) များအကြား ဒေတာဖလှယ်ရန်အတွက် အသုံးပြုသည်။ ပလပ်အင်ကိုလည်း သုံးပါ။ MQTT Plugin RabbitMQ ၎င်းသည် protocol ၏အကောင်အထည်ဖော်မှုတစ်ခုဖြစ်သည်။ MQTT အာရုံခံကိရိယာနှင့် ဆာဗာကြားတွင် မြန်နှုန်းနိမ့်၊ မြင့်မားသော latency ပတ်ဝန်းကျင်များတွင် ဒေတာပေးပို့ခြင်းအတွက် (ပံ့ပိုးပေးထားသော ပရိုတိုကောများစာရင်း အပြည့်အစုံကို တွင် ဖော်ပြထားပါသည်။ ပရောဂျက်ဝက်ဘ်ဆိုက်).

နောက်ဆောင်းပါးတွင် ကျွန်ုပ်တို့သည် Exchanges ကို ပိုမိုအသေးစိတ်နားလည်ရန် စတင်ပါမည်။

ကိုးကား

• RabbitMQ ပရောဂျက်ဝက်ဘ်ဆိုက်

source: www.habr.com