RabbitMQ. ພາກທີ 2. ຄວາມເຂົ້າໃຈກ່ຽວກັບການແລກປ່ຽນ

Exchange — ຈຸດ​ແລກ​ປ່ຽນ​ຫຼື​ຈຸດ​ແລກ​ປ່ຽນ​. ຂໍ້ຄວາມຖືກສົ່ງໄປຫາມັນ. Exchange ແຈກຢາຍຂໍ້ຄວາມ ໃນໜຶ່ງ ຫຼືຫຼາຍຄິວ. ລາວ ເສັ້ນທາງຂໍ້ຄວາມໄປຫາຄິວ ອີງໃສ່ການເຊື່ອມຕໍ່ທີ່ສ້າງຂຶ້ນ (bindings) ລະຫວ່າງເຂົາແລະແຖວ.

Exchange ບໍ່ແມ່ນ ຂະບວນການ Erlang. ສໍາລັບເຫດຜົນການຂະຫຍາຍ exchange - ນີ້​ແມ່ນ​ເສັ້ນ (ການ​ເຊື່ອມ​ຕໍ່​ກັບ​ໂມ​ດູນ​ທີ່​ມີ​ລະ​ຫັດ​ທີ່​ມີ​ເຫດ​ຜົນ​ການ​ກໍາ​ນົດ​ເສັ້ນ​ທາງ​ຢູ່​) ໃນ​ຖານ​ຂໍ້​ມູນ​ທີ່​ມີ​ຢູ່​ໃນ ພະຍາດເບົາຫວານ. 1 ພັນຕົວແລກປ່ຽນຈະໃຊ້ພຽງແຕ່ 1MB ຂອງຫນ່ວຍຄວາມຈໍາ.

ຕາຕະລາງເນື້ອຫາ

• 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. ການຕິດຕາມ

ແລກປ່ຽນໂດຍກົງ

Direct exchange - ນໍາ​ໃຊ້​ໃນ​ເວ​ລາ​ທີ່​ຈໍາ​ເປັນ​ ສົ່ງຂໍ້ຄວາມໄປຫາຄິວສະເພາະ. ຂໍ້ຄວາມຖືກເຜີຍແຜ່ໃຫ້ຜູ້ແລກປ່ຽນໂດຍສະເພາະ ກະແຈກຳນົດເສັ້ນທາງ ແລະເຂົ້າໄປໃນຄິວທັງຫມົດທີ່ເຊື່ອມຕໍ່ກັບຕົວແລກປ່ຽນນີ້ດ້ວຍລະຫັດເສັ້ນທາງທີ່ຄ້າຍຄືກັນ. ປຸ່ມກຳນົດເສັ້ນທາງແມ່ນສາຍສະຕຣິງ. ການຈັບຄູ່ແມ່ນພົບເຫັນໂດຍໃຊ້ ກວດ​ສອບ​ສາຍ​ສໍາ​ລັບ​ການ​ທຽບ​ເທົ່າ​.

ການສະແດງກາຟິກຂອງກະແສຂໍ້ຄວາມ:

В rabbitmq ມີແນວຄວາມຄິດ ຕົວແລກປ່ຽນຄ່າເລີ່ມຕົ້ນທີ່ຢູ່ ມັນແມ່ນ direct exchange ບໍ່​ມີ​ຊື່. ຖ້າຕົວແລກປ່ຽນເລີ່ມຕົ້ນຖືກນໍາໃຊ້, ຂໍ້ຄວາມຈະຖືກສົ່ງໄປຫາແຖວທີ່ມີຊື່ເທົ່າກັບ ລະຫັດເສັ້ນທາງຂໍ້ຄວາມ.

ແລກປ່ຽນຫົວຂໍ້

Topic exchange - ຄ້າຍຄືກັນ direct exchange ເປີດໃຊ້ການເລືອກເສັ້ນທາງໂດຍການປຽບທຽບປຸ່ມກຳນົດເສັ້ນທາງ. ແຕ່, ໃນກໍລະນີນີ້, ກຸນແຈແມ່ນໃຫ້ ອີງຕາມແມ່ແບບ. ເມື່ອສ້າງແມ່ແບບ, ໃຫ້ໃຊ້ 0 ຫຼືຫຼາຍຄໍາສັບ (ຕົວອັກສອນ AZ и az ແລະຕົວເລກ 0-9), ແຍກໂດຍຈຸດ, ເຊັ່ນດຽວກັນກັບສັນຍາລັກ * и #.

• * - ສາມາດທົດແທນໄດ້ຢ່າງແນ່ນອນ 1 ຄໍາວ່າ
• # - ສາ​ມາດ​ທົດ​ແທນ​ໂດຍ​ 0 ຫຼືຫຼາຍຄໍາ

ການສະແດງກາຟິກຂອງກະແສຂໍ້ຄວາມ:

ຕັ້ງ​ແຕ່​ສະ​ບັບ​ RabbitMQ 2.4.0 algorithm routing ສໍາລັບ topic exchange ເລີ່ມເຮັດວຽກຈົນກ່ວາ 145 ເວລາໄວ. ພວກເຂົາເຈົ້າບັນລຸໄດ້ໂດຍການແນະນໍາວິທີການ ພະ​ຍາ​ຍາມ​ປະ​ຕິ​ບັດ​, ເຊິ່ງກ່ຽວຂ້ອງກັບການເປັນຕົວແທນຂອງຮູບແບບເປັນໂຄງສ້າງຕົ້ນໄມ້. ຕົວຢ່າງເຊັ່ນແມ່ແບບ a.b.c, a.*.b.c, a.#.c и b.b.c ຈະຖືກສະແດງໂດຍໂຄງສ້າງຕໍ່ໄປນີ້:

ການຄົ້ນຫາສໍາລັບການຈັບຄູ່ຮູບແບບແມ່ນດໍາເນີນການເລີ່ມຕົ້ນຈາກຮາກແລະດໍາເນີນການຈາກເທິງລົງລຸ່ມ.

ຄຸນ​ນະ​ສົມ​ບັດ​:

• ການນໍາໃຊ້ຂອງການແລກປ່ຽນນີ້ສາມາດກາຍເປັນ ເປັນທາງເລືອກທີ່ດີສໍາລັບການພັດທະນາຄໍາຮ້ອງສະຫມັກໃນອະນາຄົດທີ່ເປັນໄປໄດ້, ເນື່ອງຈາກວ່າ ແມ່ແບບສາມາດຖືກປັບແຕ່ງໄດ້ຕະຫຼອດເວລາເພື່ອໃຫ້ຂໍ້ຄວາມຖືກເຜີຍແຜ່ໃນທາງດຽວກັນ direct exchange ຫຼື fanout exchange
• ແມ່ແບບທີ່ໃຊ້ * ໄວຫຼາຍກ່ວາແມ່ແບບທີ່ໃຊ້ #.
• topic exchange ຊ້າກວ່າ direct exchange

Fanout Exchange

Fanout exchange - ຂໍ້ຄວາມທັງຫມົດແມ່ນຖືກສົ່ງໄປຫາຄິວທັງຫມົດ ເຖິງແມ່ນວ່າຈະລະບຸລະຫັດເສັ້ນທາງໃນຂໍ້ຄວາມ.

ຄຸນ​ນະ​ສົມ​ບັດ​:

• RabbitMQ ບໍ່ເຮັດວຽກກັບກະແຈກຳນົດເສັ້ນທາງ ແລະແມ່ແບບ ເຊິ່ງມີຜົນກະທົບທາງບວກຕໍ່ຜົນຜະລິດ. ນີ້ແມ່ນໄວທີ່ສຸດ exchange;
• ຜູ້ບໍລິໂພກທັງຫມົດຕ້ອງສາມາດປຸງແຕ່ງຂໍ້ຄວາມທັງຫມົດ;

ການສະແດງກາຟິກຂອງກະແສຂໍ້ຄວາມ:

ການແລກປ່ຽນຫົວ

Headers exchange - ເສັ້ນທາງຂໍ້ຄວາມໄປຫາແຖວທີ່ກ່ຽວຂ້ອງໂດຍອີງໃສ່ການປຽບທຽບ (ຄີ, ມູນຄ່າ) ຊັບສິນຄູ່ headers ການຜູກມັດແລະຄຸນສົມບັດຂໍ້ຄວາມທີ່ຄ້າຍຄືກັນ. headers ແມ່ນຫນຶ່ງ Dictionary<ключ, значение>.

ຖ້າທ່ານເພີ່ມລະຫັດພິເສດໃສ່ວັດຈະນານຸກົມ x-match ທີ່​ມີ​ຄວາມ​ຫມາຍ​ any, ຫຼັງຈາກນັ້ນ, ຂໍ້ຄວາມຈະຖືກສົ່ງຕໍ່ຖ້າມີການຈັບຄູ່ບາງສ່ວນຂອງ (ຄີ, ຄ່າ) ຄູ່. ພຶດຕິກໍານີ້ແມ່ນຄ້າຍຄືກັນກັບຜູ້ປະກອບການ or.

var bindingArguments = new Dictinary<String, Object>();
bindingArguments.add("x-match", "any");

ລະຫັດເລີ່ມຕົ້ນ x-match ມີຄ່າ all. ນີ້ຫມາຍຄວາມວ່າຂໍ້ຄວາມຖືກສົ່ງຕໍ່ຖ້າຄູ່ (ຄີ, ຄ່າ) ກົງກັນແທ້. ພຶດຕິກໍານີ້ແມ່ນຄ້າຍຄືກັນກັບຜູ້ປະກອບການ and.

ການສະແດງກາຟິກຂອງກະແສຂໍ້ຄວາມ:

ຄຸນ​ນະ​ສົມ​ບັດ​:

• ຄວາມຍືດຫຍຸ່ນເພີ່ມເຕີມ
• ດ້ານການຄິດໄລ່ເພີ່ມເຕີມ. ທັງໝົດ (ຄີ, ຄ່າ) ຄູ່ຂອງຄຸນລັກສະນະ headers ຕ້ອງໄດ້ຮັບການຈັດຮຽງຕາມຊື່ທີ່ສໍາຄັນກ່ອນທີ່ຈະຄິດໄລ່ຄ່າເສັ້ນທາງຂໍ້ຄວາມ. ຊ້າກວ່າການແລກປ່ຽນປະເພດອື່ນໆ.

Consistent-Hashing Exchange

ການແລກປ່ຽນນີ້ແມ່ນ ປລັກອິນ и ບໍ່ໄດ້ສ້າງຂຶ້ນໃນ в RabbitMQ.

Consistent-hashing exchange (ແລກປ່ຽນກັບ hashing ສອດຄ່ອງ) - ນໍາໃຊ້ໃນເວລາທີ່ມີແຖວຫຼາຍທີ່ມີທ່າແຮງຜູ້ຮັບຂໍ້ຄວາມ, ແລະໃນເວລາທີ່ທ່ານຕ້ອງການດຸ່ນດ່ຽງການໂຫຼດລະຫວ່າງເຂົາເຈົ້າ. ການ​ເຊື່ອມ​ຕໍ່​ຂອງ​ຂໍ້​ຄວາມ​ທີ່​ມີ​ແຖວ​ເກີດ​ຂຶ້ນ​ໂດຍ​ນ​້​ໍ​າ (ຄ່າ​ສະ​ຕ​ຣິ​ງ​ເງື່ອນ​ໄຂ​ຈາກ​ 0 - n).

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

ການສະແດງກາຟິກຂອງກະແສຂໍ້ຄວາມ:

Hash ຄິດໄລ່ໂດຍອີງໃສ່ລະຫັດເສັ້ນທາງຫຼືຊັບສິນ headers ຂໍ້ຄວາມ. ຖ້າຂໍ້ຄວາມທີ່ຖືກເຜີຍແຜ່ທັງຫມົດມີປຸ່ມກໍານົດເສັ້ນທາງທີ່ແຕກຕ່າງກັນຫຼື headers, ຫຼັງຈາກນັ້ນການແຜ່ກະຈາຍຈະເກີດຂຶ້ນໂດຍນ້ໍາຫນັກ. ຖ້າບໍ່ດັ່ງນັ້ນ, ລະຫັດເສັ້ນທາງຈະຖືກນໍາໃຊ້ຫຼື headers.

ຄວນຊ່ວຍໃນເວລາທີ່ການບໍລິໂພກຂອງຜູ້ບໍລິໂພກຕ້ອງເຕີບໂຕສູງກວ່າການແກ້ໄຂທີ່ມີຜູ້ບໍລິໂພກຫຼາຍຄົນໂດຍໃຊ້ຄິວດຽວ.

ການລວມຕົວແລກປ່ຽນ (E2E)

ພຶດຕິກໍາຂອງຜູ້ແລກປ່ຽນທັງຫມົດສາມາດຖືກລວມເຂົ້າກັນໂດຍໃຊ້ການສື່ສານ Exchange-to-Exchange (ການລວມຕົວແລກປ່ຽນບໍ່ໄດ້ຖືກລວມຢູ່ໃນຂໍ້ກໍານົດ AMQP. ນີ້ແມ່ນສ່ວນຂະຫຍາຍຂອງໂປໂຕຄອນຈາກດ້ານຂ້າງ RabbitMQ).

ການສະແດງກາຟິກຂອງກະແສຂໍ້ຄວາມ:

ໃນຄ່າໃຊ້ຈ່າຍຂອງ E2E ພວກເຮົາສາມາດຊອກຫາການຕັ້ງຄ່າທີ່ສາມາດຂະຫຍາຍໄດ້ທີ່ເຫມາະສົມເພື່ອຕອບສະຫນອງຄວາມຕ້ອງການໃນປະຈຸບັນແລະການຂະຫຍາຍຕົວ.

ສ້າງການແລກປ່ຽນ

ການສ້າງຕົວແລກປ່ຽນເກີດຂຶ້ນໂດຍໃຊ້ synchronous RPC ຮ້ອງຂໍໃຫ້ເຄື່ອງແມ່ຂ່າຍ. ການຮ້ອງຂໍແມ່ນເຮັດໂດຍໃຊ້ວິທີການ Exchange.Declareເອີ້ນດ້ວຍຕົວກໍານົດການ:

• ຊື່​ຜູ້​ແລກ​ປ່ຽນ
• ປະເພດແລກປ່ຽນ
• ຕົວກໍານົດການອື່ນໆ

ຕົວຢ່າງການສ້າງ exchange ໂດຍການຊ່ວຍເຫຼືອ RabbitMQ.Client:

//...
channel.ExchangeDeclare(
    exchange: "my_exchange",
    type: "direct",
    durable: "false",
    autoDelete: "false",
    arguments: null
);
//...

• exchange — ຊື່​ຂອງ​ຜູ້​ແລກ​ປ່ຽນ​ທີ່​ພວກ​ເຮົາ​ຕ້ອງ​ການ​ທີ່​ຈະ​ສ້າງ​. ຊື່ຕ້ອງເປັນເອກະລັກ
• type - ປະ​ເພດ​ຂອງ​ການ​ແລກ​ປ່ຽນ​
• durable - ຖ້າ​ຫາກ​ວ່າ​ຕິດ​ຕັ້ງ​ true, ຫຼັງຈາກນັ້ນ, exchange ຈະຖາວອນ. ມັນຈະຖືກເກັບໄວ້ໃນດິສກ໌ ແລະສາມາດຢູ່ລອດຈາກການຣີສະຕາດເຊີບເວີ/ນາຍໜ້າ. ຖ້າມູນຄ່າ false, ຫຼັງຈາກນັ້ນ, exchange ແມ່ນຊົ່ວຄາວ ແລະຈະຖືກລຶບເມື່ອເຊີບເວີ/ນາຍໜ້າຖືກປິດເປີດໃໝ່
• autoDelete - ການ​ໂຍກ​ຍ້າຍ​ອັດ​ຕະ​ໂນ​ມັດ​. Exchange ຈະຖືກລຶບເມື່ອຄິວທັງໝົດທີ່ກ່ຽວຂ້ອງກັບມັນຖືກລຶບ
• arguments - ການໂຕ້ຖຽງທາງເລືອກ. ສ່ວນຫຼາຍມັກ, ພວກເຂົາເຈົ້າລະບຸໂດຍຜ່ານການໂຕ້ຖຽງ alternative exchange (ຕົວ​ແລກ​ປ່ຽນ​ທາງ​ເລືອກ​). ຖ້າຂໍ້ຄວາມບໍ່ສາມາດເດີນທາງໄປຕາມເສັ້ນທາງຕົ້ນສະບັບ, ມັນສາມາດຖືກສົ່ງໄປຫາຕົວແລກປ່ຽນທາງເລືອກທີ່ຈະສົ່ງໄປຕາມເສັ້ນທາງທີ່ແຕກຕ່າງກັນ.

ຖ້າ​ຫາກ​ວ່າ​ການ​ສ້າງ​ exchange ອາດຈະເປັນ, ຫຼັງຈາກນັ້ນເຄື່ອງແມ່ຂ່າຍຈະສົ່ງລູກຄ້າ synchronous RPC ຕອບ Exchange.DeclareOk. ຖ້າ​ຫາກ​ວ່າ​ການ​ສ້າງ​ ແມ່ນບໍ່ເປັນໄປໄດ້ (ຄໍາ​ຮ້ອງ​ສະ​ຫມັກ​ຖືກ​ປະ​ຕິ​ເສດ​ Exchange.Declare), ແລ້ວ ຊ່ອງທາງຈະປິດ ເຊີບເວີໂດຍໃຊ້ຄໍາສັ່ງ asynchronous Channel.Close ແລະລູກຄ້າຈະໄດ້ຮັບຂໍ້ຍົກເວັ້ນ ຂໍ້ຍົກເວັ້ນການປະຕິບັດການຂັດຂວາງ, ເຊິ່ງຈະປະກອບດ້ວຍລະຫັດຄວາມຜິດພາດແລະຄໍາອະທິບາຍຂອງມັນ.

ການແລກປ່ຽນຕ້ອງຖືກສ້າງຂຶ້ນກ່ອນທີ່ຈະປະກາດຂໍ້ຄວາມ. ຖ້າ​ຫາກ​ວ່າ​ທ່ານ​ເຜີຍ​ແຜ່​ຂໍ້​ຄວາມ​ກັບ​ຜູ້​ແລກ​ປ່ຽນ​ທີ່​ບໍ່​ມີ​ຢູ່​ບາງ - RabbitMQ ຈະເອົາມັນອອກຢ່າງງຽບໆ.

ການສ້າງການແລກປ່ຽນຜ່ານ GUI

ໄປທີ່ກະດານ admin RabbitMQ ພາຍໃຕ້ຜູ້ໃຊ້ guest (ຊື່ຜູ້ໃຊ້: guest ແລະລະຫັດຜ່ານ: guest). ກະລຸນາສັງເກດວ່າຜູ້ໃຊ້ guest ສາມາດເຊື່ອມຕໍ່ຈາກ localhost ເທົ່ານັ້ນ. ຕອນນີ້ໃຫ້ໄປທີ່ແຖບ Exchanges ແລະໃຫ້ຄລິກໃສ່ Add a new exchange. ຕື່ມຂໍ້ມູນໃສ່ໃນຄຸນສົມບັດ:

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

ສະຫລຸບ

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

ຖ້າຢູ່ໃນກາຟທີ່ສ້າງຂຶ້ນມີ ກໍານົດຂອບເຂດຈໍາກັດ routing keys, ຫຼັງຈາກນັ້ນມັນຄຸ້ມຄ່າທີ່ຈະຊອກຫາຫຼາຍ fanout exchange, ຊຶ່ງເປັນ 1:1 ກ່ຽວຂ້ອງກັບລະຫັດການກໍານົດເສັ້ນທາງ. ພວກເຮົາຈື່ໄດ້ວ່າ fanout exchange ໄວທີ່ສຸດ.

ຖ້າຈໍານວນເສັ້ນທາງ ແນວໂນ້ມທີ່ຈະ infinity, ຫຼັງຈາກນັ້ນທ່ານຄວນເອົາໃຈໃສ່ກັບ topic exchange ຫຼື, ຖ້າແມ່ແບບບໍ່ຈໍາເປັນ, ທ່ານສາມາດເລືອກ direct exchnge, ເນື່ອງຈາກວ່າ ລາວໄວຂຶ້ນ topic exchange.

ການ​ປະ​ສົມ​ຂອງ​ທີ່​ແຕກ​ຕ່າງ​ກັນ​ exchange ຄວນຊ່ວຍໃຫ້ທ່ານຊອກຫາທີ່ຖືກຕ້ອງ ການຕັ້ງຄ່າທີ່ສາມາດຂະຫຍາຍໄດ້, ເຊິ່ງຕອບສະຫນອງຄວາມຕ້ອງການລະບົບໃນປະຈຸບັນແລະການຂະຫຍາຍຕົວ.

ຈໍານວນຂອງ exchange ແລະຄິວຄວນຈະມີຫນ້ອຍເມື່ອປຽບທຽບກັບຈໍານວນເສັ້ນທາງ.

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

ເອກະສານ

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

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