RabbitMQ ट्यूटोरियल 4 - रूटिंग

मैं आधिकारिक साइट से पाठों के अनुवाद की श्रृंखला जारी रखता हूं। उदाहरण php में होंगे, लेकिन उन्हें अधिकांश लोकप्रिय भाषाओं पर लागू किया जा सकता है।
पिछले लेख में, हमने एक लॉगिंग सिस्टम विकसित किया था। हम कई प्राप्तकर्ताओं को संदेश भेजने में सक्षम थे। इस लेख में हम अपने कार्यक्रम का आधुनिकीकरण करेंगे - हम प्राप्तकर्ता को केवल संदेशों का हिस्सा भेजेंगे। उदाहरण के लिए, हम डिस्क पर महत्वपूर्ण त्रुटियों के साथ केवल संदेशों को बचा सकते हैं (डिस्क स्थान की बचत), और हम कंसोल में सभी संदेश प्रदर्शित करेंगे।

बाइंडिंग

पिछले लेख में, हमने बाइंडिंग बनाई। कोड याद करें:

$channel->queue_bind($queue_name, 'logs'); 

बाइंडिंग एक्सेस प्वाइंट और कतार के बीच का संबंध है। इसकी व्याख्या इस प्रकार की जा सकती है: कतार पहुँच बिंदु से संदेश प्राप्त करना चाहती है।
बाइंडिंग राउटिंग_की पैरामीटर ले सकती है। पैरामीटर $ चैनल के साथ भ्रमित न होने के लिए :: बेसिक_प्रकाश (इसमें राउटिंग_की पैरामीटर भी शामिल है), हम इसे बाइंडिंग जेक कहते हैं। बाइंडिंग_के साथ बाइंडिंग बनाने पर विचार करें:

 $binding_key = 'black'; $channel->queue_bind($queue_name, $exchange_name, $binding_key); 

इस कुंजी का मान एक्सेस बिंदु के प्रकार पर निर्भर करता है। प्रकार के प्रशंसक का एक पहुंच बिंदु बस इसे अनदेखा करेगा।

डायरेक्ट एक्सेस प्वाइंट

पिछले लेख में हमारी लॉगिंग प्रणाली ने सभी ग्राहकों को सभी संदेश भेजे थे। हम संदेशों को महत्व देने के लिए अपनी प्रणाली का विस्तार करना चाहते हैं। उदाहरण के लिए, हम इसे बना देंगे ताकि लॉग को डिस्क पर लिखने वाली स्क्रिप्ट चेतावनी या सूचना प्रकार के संदेशों पर अपनी जगह बर्बाद न करे।
इससे पहले हमने टाइप फैनआउट के साथ एक एक्सेस प्वाइंट का उपयोग किया, जो हमें पूर्ण लचीलापन नहीं देता है - यह केवल सरल प्रसारण के लिए उपयुक्त है।
इसके बजाय, हम प्रत्यक्ष प्रकार का उपयोग करेंगे। इसका एल्गोरिथ्म बहुत सरल है - संदेश कतार में जाते हैं जिसका बाइंडिंग_की संदेश की रूटिंग कुंजी से मेल खाता है।
चित्र में आरेख पर विचार करें:

आरेख एक्स से पता चलता है और इसके साथ दो कतारें जुड़ी हुई हैं। पहला चरण बाध्यकारी कुंजी = नारंगी के साथ जुड़ा हुआ है, और दूसरे चरण में दो कनेक्शन हैं। एक कुंजी बंधन कुंजी के साथ = काला, और दूसरा कुंजी के साथ हरा है।
रूटिंग कुंजी वाले संदेश = नारंगी को Q1 में रूट किया जाएगा, और काले या हरे रंग के साथ संदेशों को Q2 में रूट किया जाएगा। अन्य सभी संदेश हटा दिए जाएंगे।

एकाधिक बाँध

यह एक ही बाध्यकारी कुंजी के साथ कई कतारों को बांधने के लिए पूरी तरह से स्वीकार्य है। इस उदाहरण में, हम एक्सेस प्वाइंट X और कतार Q1 को समान क्यू 2 क्यू के साथ जोड़ते हैं। इस उदाहरण में, प्रत्यक्ष प्रशंसक की तरह व्यवहार करता है: सभी संबंधित कतारों को संदेश भेजता है। कुंजी काले रंग के संदेश Q1 और Q2 दोनों कतारों में पड़ेंगे।

सबमिशन लॉग करें

हम संदेश भेजने के लिए एक एल्गोरिथ्म का निर्माण करेंगे। फैनआउट के बजाय, हम पहुंच बिंदु के लिए प्रत्यक्ष प्रकार का उपयोग करेंगे। रूटिंग कुंजी लॉग प्रकार के नाम से मेल खाएगी। मान लीजिए कि लॉग भेजने वाली स्क्रिप्ट लॉग के प्रकार को जान जाएगी।
सबसे पहले, एक पहुंच बिंदु बनाएँ:

 $channel->exchange_declare('direct_logs', 'direct', false, false, false); 

अब एक संदेश भेजें:

 $channel->exchange_declare('direct_logs', 'direct', false, false, false); $channel->basic_publish($msg, 'direct_logs', $severity); 

लॉग में 3 प्रकार होंगे: 'जानकारी', 'चेतावनी', 'त्रुटि'।

अंशदान

संदेश भेजना पिछले लेख के उदाहरण के समान होगा, एक शर्त के साथ - आपको प्रत्येक प्रकार के लॉग के लिए अपना खुद का बंधन संबंध बनाने की आवश्यकता है।

 foreach($severities as $severity) { $channel->queue_bind($queue_name, 'direct_logs', $severity); } 

कुल हमें मिलता है

निर्माता स्क्रिप्ट कोड emit_log_direct.php:

 <?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPConnection; use PhpAmqpLib\Message\AMQPMessage; $connection = new AMQPConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->exchange_declare('direct_logs', 'direct', false, false, false); $severity = $argv[1]; if(empty($severity)) $severity = "info"; $data = implode(' ', array_slice($argv, 2)); if(empty($data)) $data = "Hello World!"; $msg = new AMQPMessage($data); $channel->basic_publish($msg, 'direct_logs', $severity); echo " [x] Sent ",$severity,':',$data," \n"; $channel->close(); $connection->close(); ?> 

Receive_logs_direct.php सब्सक्राइबर स्क्रिप्ट कोड:

 <?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPConnection; $connection = new AMQPConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->exchange_declare('direct_logs', 'direct', false, false, false); list($queue_name, ,) = $channel->queue_declare("", false, false, true, false); $severities = array_slice($argv, 1); if(empty($severities )) { file_put_contents('php://stderr', "Usage: $argv[0] [info] [warning] [error]\n"); exit(1); } foreach($severities as $severity) { $channel->queue_bind($queue_name, 'direct_logs', $severity); } echo ' [*] Waiting for logs. To exit press CTRL+C', "\n"; $callback = function($msg){ echo ' [x] ',$msg->delivery_info['routing_key'], ':', $msg->body, "\n"; }; $channel->basic_consume($queue_name, '', false, true, false, false, $callback); while(count($channel->callbacks)) { $channel->wait(); } $channel->close(); $connection->close(); ?> 

यदि आप फ़ाइल में त्रुटि और चेतावनी प्रकार के केवल लॉग को सहेजना चाहते हैं, तो कंसोल में टाइप करें:

$ php receive_logs_direct.php warning error > logs_from_rabbit.log

यदि आप स्क्रीन पर सभी लॉग प्रदर्शित करना चाहते हैं, तो कंसोल में टाइप करें

 $ php receive_logs_direct.php info warning error [*] Waiting for logs. To exit press CTRL+C 

या केवल त्रुटि लॉग निकालने के लिए:

 $ php emit_log_direct.php error "Run. Run. Or it will explode." [x] Sent 'error':'Run. Run. Or it will explode.' 

(स्रोत (emit_log_direct.php स्रोत) और (get_logs_direct.php स्रोत) )

अगले लेख में, कुछ पैटर्न के अनुरूप संदेशों के वायरटैपिंग पर विचार किया जाएगा।