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 ក្បួនដោះស្រាយការនាំផ្លូវសម្រាប់ topic exchange បានចាប់ផ្តើមធ្វើការរហូតដល់ 145 ដងលឿនជាង។ ពួកគេសម្រេចបាននេះដោយណែនាំវិធីសាស្រ្តមួយ។ ព្យាយាមអនុវត្តដែលពាក់ព័ន្ធនឹងការតំណាងឱ្យលំនាំជារចនាសម្ព័ន្ធដើមឈើ។ ឧទាហរណ៍គំរូ a.b.c, a.*.b.c, a.#.c и b.b.c នឹងត្រូវបានតំណាងដោយរចនាសម្ព័ន្ធដូចខាងក្រោមៈ

ការស្វែងរកការផ្គូផ្គងលំនាំត្រូវបានអនុវត្តដោយចាប់ផ្តើមពីឫស និងបន្តពីកំពូលទៅបាត។

លក្ខណៈពិសេស:

• ការប្រើប្រាស់ឧបករណ៍ផ្លាស់ប្តូរនេះអាចក្លាយជា ជម្រើសដ៏ល្អសម្រាប់ការអភិវឌ្ឍន៍កម្មវិធីនាពេលអនាគត, ដោយសារតែ គំរូអាចត្រូវបានប្ដូរតាមបំណងជានិច្ចដើម្បីឱ្យសារត្រូវបានបោះពុម្ពតាមរបៀបដូចគ្នា។ direct exchange ឬ fanout exchange
• គំរូដែលប្រើ * លឿនជាងមុនច្រើនជាងគំរូដែលប្រើ #.
• topic exchange យឺតជាង direct exchange

ការផ្លាស់ប្តូរ Fanout

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)

អាកប្បកិរិយារបស់អ្នកផ្លាស់ប្តូរទាំងអស់អាចត្រូវបានបញ្ចូលគ្នាដោយប្រើទំនាក់ទំនង ការផ្លាស់ប្តូរទៅការប្តូរប្រាក់ (ការរួមបញ្ចូលគ្នានៃការផ្លាស់ប្តូរមិនត្រូវបានរួមបញ្ចូលនៅក្នុងការបញ្ជាក់ AMQP. នេះគឺជាផ្នែកបន្ថែមនៃពិធីការពីចំហៀង RabbitMQ).

តំណាងក្រាហ្វិកនៃលំហូរសារ៖

នៅក្នុងការចំណាយនៃការ E2E យើងអាចស្វែងរកការកំណត់ដែលអាចធ្វើមាត្រដ្ឋានបានត្រឹមត្រូវ ដើម្បីបំពេញតាមតម្រូវការបច្ចុប្បន្ន និងដែលកំពុងលូតលាស់។

បង្កើតការផ្លាស់ប្តូរ

ការបង្កើតឧបករណ៍ផ្លាស់ប្តូរកើតឡើងដោយប្រើសមកាលកម្ម RPC ស្នើសុំទៅម៉ាស៊ីនមេ។ ការស្នើសុំត្រូវបានធ្វើឡើងដោយប្រើវិធីសាស្ត្រ Exchange.Declareហៅជាមួយប៉ារ៉ាម៉ែត្រ៖

• ឈ្មោះអ្នកផ្លាស់ប្តូរ
• ប្រភេទអ្នកផ្លាស់ប្តូរ
• ជម្រើសផ្សេងទៀត។

ឧទាហរណ៍នៃការបង្កើត exchange ដោយមានជំនួយពី អតិថិជន RabbitMQ:

//...
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 អាចធ្វើទៅបានបន្ទាប់មកម៉ាស៊ីនមេនឹងបញ្ជូនម៉ាស៊ីនភ្ញៀវឱ្យធ្វើសមកាលកម្ម RPC ចម្លើយ Exchange.DeclareOk. ប្រសិនបើការបង្កើត គឺមិនអាចទៅរួចទេ (មានការបដិសេធចំពោះការស្នើសុំ Exchange.Declare), បន្ទាប់មក ឆានែលនឹងបិទ ម៉ាស៊ីនមេដោយប្រើពាក្យបញ្ជាអសមកាល Channel.Close ហើយអតិថិជននឹងទទួលបានករណីលើកលែង OperationInterruptedExceptionដែលនឹងមានលេខកូដកំហុស និងការពិពណ៌នារបស់វា។

អ្នកផ្លាស់ប្តូរត្រូវតែត្រូវបានបង្កើតមុនពេលបង្ហោះសារ។ ប្រសិនបើអ្នកបោះផ្សាយសារទៅអ្នកផ្លាស់ប្តូរដែលមិនមានស្រាប់ - RabbitMQ នឹងដកវាចេញដោយស្ងៀមស្ងាត់។

បង្កើតការផ្លាស់ប្តូរតាមរយៈ GUI

ចូលទៅកាន់ផ្ទាំងគ្រប់គ្រង RabbitMQ នៅក្រោមអ្នកប្រើប្រាស់ guest (ឈ្មោះ​អ្នកប្រើប្រាស់: guest និងពាក្យសម្ងាត់៖ guest) សូមចំណាំថាអ្នកប្រើប្រាស់ guest អាចភ្ជាប់បានតែពី localhost ប៉ុណ្ណោះ។ ឥឡូវនេះសូមចូលទៅកាន់ផ្ទាំង Exchanges ហើយចុចលើ Add a new exchange. បំពេញលក្ខណៈសម្បត្តិ៖

ភាគច្រើននៃលក្ខណៈសម្បត្តិត្រូវបានពិពណ៌នាខាងលើ។ នៅទីនេះយើងកត់សំគាល់ថាប្រសិនបើយើងកំណត់ Internalបន្ទាប់មក ការផ្លាស់ប្តូរអាចប្រើសម្រាប់តែ E2E. Producer នឹងមិនអាចផ្ញើសារទៅកាន់ការផ្លាស់ប្តូរបែបនេះបានទេ។

សេចក្តីសន្និដ្ឋាន

នៅពេលបង្កើតប្រព័ន្ធ វាងាយស្រួលក្នុងការពិពណ៌នាអំពី topology ផ្លូវ ដោយប្រើក្រាហ្វ។ ប៉ុន្តែមុនពេលអ្នកចាប់ផ្តើមបង្កើតក្រាហ្វ វាពិតជាមានតម្លៃក្នុងការគូសបញ្ជាក់ផ្លូវដែលមានចរាចរណ៍ខ្ពស់ ពីព្រោះ ពួកគេជាអ្នកទាមទារ លំហូរខ្ពស់ជាង (ការសម្តែង) ។ បន្ទាប់អ្នកអាចចាត់ថ្នាក់ចរាចរណ៍។ ហើយបន្ទាប់មកចាប់ផ្តើមសាងសង់។

ប្រសិនបើនៅក្នុងក្រាហ្វដែលបានសាងសង់មាន សំណុំកំណត់ គ្រាប់ចុចកំណត់ផ្លូវ បន្ទាប់មកវាមានតម្លៃសម្លឹងឆ្ពោះទៅរកជាច្រើន។ fanout exchangeដែលមាន 1:1 ទាក់ទងនឹងគន្លឹះផ្លូវ។ យើងចាំថា fanout exchange លឿនបំផុត។

ប្រសិនបើចំនួនផ្លូវ ទំនោរទៅរកភាពគ្មានទីបញ្ចប់បន្ទាប់មកអ្នកគួរតែយកចិត្តទុកដាក់ topic exchange ឬប្រសិនបើគំរូមិនត្រូវការ អ្នកអាចជ្រើសរើស direct exchnge, ដោយសារតែ គាត់លឿនជាង topic exchange.

ការរួមបញ្ចូលគ្នានៃភាពខុសគ្នា exchange គួរតែជួយអ្នកស្វែងរកត្រឹមត្រូវ។ ការកំណត់រចនាសម្ព័ន្ធដែលអាចធ្វើមាត្រដ្ឋានបាន។ដែលបំពេញតាមតម្រូវការប្រព័ន្ធបច្ចុប្បន្ន និងដែលកំពុងលូតលាស់។

ចំនួន exchange ហើយជួរគួរតែមានតិចតួចបើប្រៀបធៀបទៅនឹងចំនួនផ្លូវ។

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

សេចក្តីយោង

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

ប្រភព: www.habr.com