RabbitMQ. ພາກທີ 1. ບົດແນະນຳ. Erlang, AMQP

ສະບາຍດີຕອນບ່າຍ, Habr! ຂ້ອຍຕ້ອງການແບ່ງປັນປື້ມແບບຮຽນ - ປື້ມອ້າງອີງຂອງຄວາມຮູ້ທີ່ຂ້ອຍໄດ້ເກັບກໍາຂໍ້ມູນ 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, ເຊິ່ງປະຕິບັດການກໍານົດເສັ້ນທາງ, ອາດຈະຮັບປະກັນການຈັດສົ່ງ, ແຈກຢາຍການຖ່າຍທອດຂໍ້ມູນ, ແລະຈອງປະເພດຂໍ້ຄວາມທີ່ຕ້ອງການ.

Protocol AMQP ແນະ​ນໍາ​ສາມ​ແນວ​ຄວາມ​ຄິດ​:

• exchange (ຈຸດແລກປ່ຽນຫຼືການແລກປ່ຽນ) - ຂໍ້ຄວາມຖືກສົ່ງໄປຫາມັນ. ຈຸດແລກປ່ຽນ ແຈກຢາຍຂໍ້ຄວາມ ໃນໜຶ່ງ ຫຼືຫຼາຍຄິວ. ນາງ ເສັ້ນທາງຂໍ້ຄວາມໄປຫາຄິວ ອີງໃສ່ການເຊື່ອມຕໍ່ທີ່ສ້າງຂຶ້ນ (binding) ລະຫວ່າງເຂົາແລະແຖວ
• queue (ຄິວ) - ໂຄງສ້າງຂໍ້ມູນໃນແຜ່ນ ຫຼືໃນ RAM ນັ້ນ ເກັບຮັກສາການເຊື່ອມຕໍ່ກັບຂໍ້ຄວາມແລະໃຫ້ສໍາເນົາຂໍ້ຄວາມ consumers (ເຖິງຜູ້ບໍລິໂພກ)
• binding (binding) — ກົດ​ລະ​ບຽບ​ທີ່​ ບອກຈຸດແລກປ່ຽນທີ່ແຖວຂໍ້ຄວາມເຫຼົ່ານີ້ຄວນຈະເຂົ້າໄປໃນ

ໂປໂຕຄອນແລ່ນຢູ່ເທິງ TCP / IP.

ໂດຍຫຍໍ້ກ່ຽວກັບ Erlang

ລະຫັດແຫຼ່ງຂອງໂຄງການແມ່ນຢູ່ໃນ repository ທີ່ GitHub. ສະຖາປັດຕະຍະກໍາ RabbitMQ-ເຊີບເວີ ອີງໃສ່ ເອີລັງ ແລະ BEAM.

Erlang ພັດທະນາໂດຍບໍລິສັດ Ericsson ໃນກາງຊຸມປີ 1980 ເປັນລະບົບເວລາຈິງທີ່ແຈກຢາຍ, ທົນທານຕໍ່ຄວາມຜິດ, ສໍາລັບແອັບພລິເຄຊັນທີ່ຕ້ອງການເວລາເຮັດວຽກ 99,999%. Erlang ໃຊ້ໃນອຸດສາຫະກໍາຕ່າງໆແລະຄໍາຮ້ອງສະຫມັກທີ່ທັນສະໄຫມ, e.g. WhatsApp. ທ່ານສາມາດອ່ານເພີ່ມເຕີມໃນບົດຄວາມ ສະຖາປັດຕະຍະກຳ WhatsApp, ເຊິ່ງ Facebook ຊື້ໃນລາຄາ 19 ຕື້ໂດລາ

ໂດຍຫຍໍ້ກ່ຽວກັບ RabbitMQ

ກະຕ່າຍ ເປັນນາຍຫນ້າຂໍ້ຄວາມແຫຼ່ງເປີດ. ມັນສົ່ງຂໍ້ຄວາມຕາມຫຼັກການພື້ນຖານທັງຫມົດຂອງອະນຸສັນຍາ AMQP ອະທິບາຍໃນ ຂໍ້ສະເພາະ. RabbitMQ ປະຕິບັດ ແລະເສີມອະນຸສັນຍາ AMQP.

ແນວຄວາມຄິດຕົ້ນຕໍຂອງຮູບແບບການສົ່ງຂໍ້ຄວາມໃນ RabbitMQ ສິ່ງທີ່ເປັນ producer (ຜູ້ເຜີຍແຜ່) ບໍ່ໄດ້ສົ່ງຂໍ້ຄວາມໂດຍກົງຫາຄິວ. ໃນຄວາມເປັນຈິງ, ແລະເລື້ອຍໆ, ຜູ້ເຜີຍແຜ່ຍັງບໍ່ຮູ້ວ່າຂໍ້ຄວາມຈະຖືກສົ່ງໄປຫາແຖວໃດ.

ແທນທີ່ຈະ, ຜູ້ເຜີຍແຜ່ສາມາດສົ່ງຂໍ້ຄວາມໄປຫາການແລກປ່ຽນເທົ່ານັ້ນ. ໃນທາງກົງກັນຂ້າມ, ການແລກປ່ຽນໄດ້ຮັບຂໍ້ຄວາມຈາກຜູ້ເຜີຍແຜ່, ແລະອີກດ້ານຫນຶ່ງ, ມັນສົ່ງພວກເຂົາໄປຫາແຖວ. ການແລກປ່ຽນຕ້ອງຮູ້ຢ່າງແນ່ນອນວ່າຈະເຮັດແນວໃດກັບຂໍ້ຄວາມທີ່ມັນໄດ້ຮັບ. ມັນຄວນຈະຖືກເພີ່ມໃສ່ຄິວສະເພາະບໍ? ມັນຄວນຈະຖືກເພີ່ມເຂົ້າໄປໃນຫຼາຍຄິວບໍ? ຫຼືຂໍ້ຄວາມຄວນຖືກລະເລີຍ.

ວຽກສັ້ນໆ RabbitMQ ສາ​ມາດ​ອະ​ທິ​ບາຍ​ດັ່ງ​ຕໍ່​ໄປ​ນີ້​:

1. ຜູ້ເຜີຍແຜ່ສົ່ງຂໍ້ຄວາມໄປຫາການແລກປ່ຽນສະເພາະ
2. ການແລກປ່ຽນ, ໄດ້ຮັບຂໍ້ຄວາມ, ເສັ້ນທາງມັນໄປຫາຫນຶ່ງຫຼືຫຼາຍຄິວຕາມກົດລະບຽບຜູກມັດລະຫວ່າງມັນແລະຄິວ.
3. ແຖວເກັບຂໍ້ມູນອ້າງອີງເຖິງຂໍ້ຄວາມນີ້. ຂໍ້ຄວາມຕົວມັນເອງຖືກເກັບໄວ້ໃນ RAM ຫຼືໃນແຜ່ນ
4. ເມື່ອຜູ້ບໍລິໂພກພ້ອມທີ່ຈະໄດ້ຮັບຂໍ້ຄວາມຈາກແຖວ, ເຄື່ອງແມ່ຂ່າຍຈະສ້າງສໍາເນົາຂໍ້ຄວາມໂດຍຜ່ານການເຊື່ອມຕໍ່ແລະສົ່ງ.
5. ຜູ້ບໍລິໂພກໄດ້ຮັບຂໍ້ຄວາມແລະສົ່ງການຢືນຢັນກັບນາຍຫນ້າ
6. ນາຍຫນ້າ, ເມື່ອໄດ້ຮັບການຢືນຢັນ, ເອົາສໍາເນົາຂໍ້ຄວາມອອກຈາກແຖວ. ຫຼັງຈາກນັ້ນ, ລຶບອອກຈາກ RAM ແລະແຜ່ນ

CPR

ຂະບວນການ RPC (ການໂທຫາຂັ້ນຕອນໄລຍະໄກ) underlies ເກືອບທັງຫມົດປະຕິສໍາພັນກັບແກນ RabbitMQ. ຕົວຢ່າງ, ການສົນທະນາເບື້ອງຕົ້ນກ່ຽວກັບເງື່ອນໄຂຂອງລູກຄ້າກັບ RabbitMQ, ສະແດງໃຫ້ເຫັນເຖິງຂະບວນການສະເພາະໃດຫນຶ່ງ RPC. ເມື່ອລໍາດັບນີ້ສໍາເລັດ, RabbitMQ ຈະພ້ອມທີ່ຈະຍອມຮັບຄໍາຮ້ອງຂໍຈາກລູກຄ້າ:

ຍັງຢູ່ໃນສະເພາະ AMQP ທັງລູກຄ້າແລະເຄື່ອງແມ່ຂ່າຍສາມາດອອກຄໍາສັ່ງ. ນີ້ຫມາຍຄວາມວ່າລູກຄ້າກໍາລັງລໍຖ້າຕິດຕໍ່ສື່ສານກັບເຄື່ອງແມ່ຂ່າຍ. ຄໍາສັ່ງແມ່ນຫ້ອງຮຽນແລະວິທີການ. ຍົກ​ຕົວ​ຢ່າງ, Connection.Start - ວິ​ທີ​ການ​ໂທ​ Start ຫ້ອງ​ຮຽນ Connection.

ການເຊື່ອມຕໍ່ແລະຊ່ອງທາງ

ສໍາລັບການແລກປ່ຽນຂໍ້ມູນດັ່ງກ່າວລະຫວ່າງລູກຄ້າແລະເຄື່ອງແມ່ຂ່າຍ, ຊ່ອງທາງ. ຊ່ອງຖືກສ້າງຂື້ນພາຍໃນ ການເຊື່ອມຕໍ່ສະເພາະ. ແຕ່ລະຊ່ອງແມ່ນໂດດດ່ຽວຈາກຊ່ອງອື່ນ. ໃນກໍລະນີ synchronous, ມັນເປັນໄປບໍ່ໄດ້ທີ່ຈະປະຕິບັດຄໍາສັ່ງຕໍ່ໄປຈົນກ່ວາໄດ້ຮັບການຕອບສະຫນອງ.

ເພື່ອໃຫ້ສາມາດສົ່ງຄໍາສັ່ງໃນຂະຫນານ, ທ່ານຕ້ອງເປີດຫຼາຍຊ່ອງທາງ. ແຕ່ລະຊ່ອງສ້າງແຍກຕ່າງຫາກ 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 ໃຊ້ສໍາລັບການແລກປ່ຽນຂໍ້ມູນລະຫວ່າງເຄື່ອງແມ່ຂ່າຍ (server-server). ຍັງໃຊ້ plugin ໄດ້ MQTT Plugin RabbitMQ ຊຶ່ງເປັນການປະຕິບັດຂອງອະນຸສັນຍາ MQTT ສໍາ​ລັບ​ການ​ສົ່ງ​ຂໍ້​ມູນ​ລະ​ຫວ່າງ​ເຊັນ​ເຊີ​ແລະ​ເຄື່ອງ​ແມ່​ຂ່າຍ​ໃນ​ສະ​ພາບ​ແວດ​ລ້ອມ​ທີ່​ມີ​ຄວາມ​ໄວ​ຕ​່​ໍ​າ​, latency ສູງ (ບັນ​ຊີ​ລາຍ​ຊື່​ເຕັມ​ຂອງ​ໂປ​ຣ​ໂຕ​ຄອນ​ສະ​ຫນັບ​ສະ​ຫນູນ​ແມ່ນ​ລະ​ບຸ​ໄວ້​ທີ່ ເວັບໄຊທ໌ຂອງໂຄງການ).

ໃນບົດຄວາມຕໍ່ໄປພວກເຮົາຈະເລີ່ມຕົ້ນເຂົ້າໃຈການແລກປ່ຽນໃນລາຍລະອຽດເພີ່ມເຕີມ.

ເອກະສານ

• ເວັບໄຊທ໌ໂຄງການ RabbitMQ

ແຫຼ່ງຂໍ້ມູນ: www.habr.com