RabbitMQ ክፍል 2. ልውውጦችን መረዳት

Exchange — የመለዋወጫ ወይም የመለዋወጫ ነጥብ። መልዕክቶች ወደ እሱ ይላካሉ። Exchange መልእክቱን ያሰራጫል በአንድ ወይም ከዚያ በላይ ወረፋዎች ውስጥ። እሱ መልዕክቶችን ወደ ወረፋ ያደርሳል በተፈጠሩ አገናኞች ላይ የተመሠረተ (bindings) በእሱ እና በወረፋው መካከል።

Exchange አይደለም የኤርላንግ ሂደትለተስፋፊነት ምክንያቶች exchange — ይህ አብሮ በተሰራው የውሂብ ጎታ ውስጥ ሕብረቁምፊ (የማዞሪያ ሎጂክ የሚገኝበት ኮድ ያለው ሞጁል የሚወስድ አገናኝ) ነው የአእምሮ ማጣት. 1 ሺህ የሚለዋወጡ ሰዎች 1 ሜባ ማህደረ ትውስታ ብቻ ይወስዳሉ።

ማውጫ

• RabbitMQ ክፍል 1. መግቢያ. Erlang፣ AMQP እና RPC
• RabbitMQ ክፍል 2. ልውውጦችን መረዳት
• RabbitMQ ክፍል 3. ወረፋዎችን እና ማሰሪያዎችን መረዳት
• RabbitMQ ክፍል 4. መልዕክቶች እና ፍሬሞች ምንድን ናቸው ጋር ማስተናገድ
• RabbitMQ ክፍል 5፡ የመልዕክት ስራን ማተም እና መጠቀም
• RabbitMQ ክፍል 6. የፌዴሬሽኑ እና የአካፋ ሞጁሎች አጠቃላይ እይታ
• RabbitMQ ክፍል 7. ስለ ግንኙነት እና ቻኔል ዝርዝሮች
• RabbitMQ ክፍል 8. RabbitMQ በ NET
• RabbitMQ ክፍል 9. ክትትል

ቀጥታ ልውውጥ

Direct exchange - አስፈላጊ በሚሆንበት ጊዜ ጥቅም ላይ ይውላል ለተወሰኑ ወረፋዎች መልእክት ማድረስመልእክቱ በ exchanger ውስጥ ታትሟል እና ልዩ በሆነ መልኩ ታትሟል የማዞሪያ ቁልፍ እና ከዚህ ልውውጥ ጋር በተገናኙ ሁሉም ወረፋዎች ውስጥ ተመሳሳይ የማዞሪያ ቁልፍ አለው። የማዞሪያ ቁልፉ ሕብረቁምፊ ነውየማዛመጃ ፍለጋ የሚከናወነው በሚከተለው በመጠቀም ነው የእኩልነትን ሕብረቁምፊዎች መፈተሽ.

የመልእክት ፍሰት ግራፊክ ውክልና፡

В 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 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 የመልእክት ማስተላለፊያ እሴቶችን ከማስላትዎ በፊት በቁልፍ ስም መደርደር አለበት። ከሌሎች የልውውጥ ዓይነቶች ይልቅ ቀርፋፋ.

ወጥ የሆነ የሃሺንግ ልውውጥ

ይህ ልውውጥ መሰካት и አብሮ የተሰራ አይደለም в RabbitMQ.

Consistent-hashing exchange (በተከታታይ ሃሽ መለዋወጥ) - የመልእክት ተቀባይ ሊሆኑ የሚችሉ በርካታ ወረፋዎች ሲኖሩ እና በመካከላቸው የጭነት ሚዛን ሲያስፈልግ ጥቅም ላይ ይውላል። መልእክት ከክብደቱ (ከተለመደው የሕብረቁምፊ እሴት) ጋር የተያያዘ ነው። 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 እና ደንበኛው የተለየ ሁኔታ ያገኛል ኦፕሬሽን የተቋረጠ ልዩየስህተት ኮድ እና መግለጫውን የያዘ።

መልዕክቶችን ከመለጠፍዎ በፊት መለዋወጫው መፈጠር አለበት። ወደማይኖር መለዋወጫ ከላኩ፣ RabbitMQ በጸጥታ ያስወግደዋል።

በ GUI በኩል ልውውጥ መፍጠር

ወደ የአስተዳዳሪ ፓነል ይሂዱ RabbitMQ በተጠቃሚው ስር guest (የተጠቃሚ ስም፡- guest እና የይለፍ ቃል፡ guest). እባክዎን ተጠቃሚው መሆኑን ያስተውሉ guest መገናኘት የሚችለው ከ localhost ብቻ ነው። አሁን ወደ ትሩ እንሂድ Exchanges እና ጠቅ ያድርጉ Add a new exchange. ንብረቶቹን ይሙሉ:

አብዛኛዎቹ ባህሪያት ከላይ ተገልጸዋል። እዚህ ላይ ካስቀመጥን እናስተውላለን። Internalከዚያ ልውውጡ ጥቅም ላይ ሊውል የሚችለው ለ E2E. Producer ወደ እንደዚህ አይነት ልውውጥ መልዕክቶችን መላክ አይችልም።

መደምደሚያ

ስርዓት ሲገነቡ፣ ቶፖሎጂውን ለመግለጽ ምቹ ነው ማስተላለፊያ ግራፍ መጠቀም። ነገር ግን ግራፍ መገንባት ከመጀመርዎ በፊት፣ ብዙ ትራፊክ ያለባቸውን መንገዶች መለየት ጠቃሚ ነው፣ ምክንያቱም የሚያስፈልጋቸው ከፍተኛ የመተላለፊያ ይዘት (አፈጻጸም)። በመቀጠል፣ ትራፊኩን መመደብ ይችላሉ። እና ከዚያ በኋላ ብቻ መገንባት ይጀምሩ።

ግራፍ የተገነባ ከሆነ የተወሰነ ስብስብ የማዞሪያ ቁልፎችን መመልከት ጠቃሚ ነው፣ ከዚያ በርካታ fanout exchange, ይህም ከርዕሰ ጉዳዩ ቁልፍ ጋር የተያያዘ 1:1 ነው። ያንን ያስታውሱ። fanout exchange በጣም ፈጣኑ።

የመንገዶች ብዛት ከሆነ ወደ ማለቂያ የሌለው ዝንባሌከዚያ ትኩረት መስጠት ተገቢ ነው topic exchange ወይም፣ አብነቱ አስፈላጊ ካልሆነ፣ መምረጥ ይችላሉ direct exchngeምክንያቱም ፈጣን ስለሆነ topic exchange.

የተለያዩ ውህዶች exchange ትክክለኛውን ለማግኘት ሊረዳ ይገባል ሊሰፋ የሚችል ውቅር, ይህም የአሁኑን እና እያደገ የመጣውን የስርዓት መስፈርቶችን የሚያሟላ ነው።

ՔԱՆԱԿ exchange እና ከመንገዶች ብዛት ጋር ሲነጻጸር ቢያንስ ወረፋዎች ሊኖሩ ይገባል።

በሚቀጥለው ጽሑፍ፣ ስለ ወረፋዎች እና ስለ ማያያዣዎች በዝርዝር መመርመር እንጀምራለን።

ማጣቀሻዎች

• RabbitMQ ፕሮጀክት ድር ጣቢያ

ምንጭ: hab.com