RabbitMQ ट्यूटोरियल 5 - विषय

मैं आधिकारिक साइट से पाठों के अनुवाद की श्रृंखला जारी रखता हूं। उदाहरण php में होंगे, लेकिन उन्हें अधिकांश लोकप्रिय भाषाओं पर लागू किया जा सकता है।

पिछले लेख में, हमने लॉगिंग सिस्टम में सुधार किया। फैनआउट एक्सेस प्वाइंट (जो केवल संदेशों के प्राथमिक प्रसारण के लिए उपयुक्त है) के बजाय, हमने प्रत्यक्ष का उपयोग किया - और कुछ चयनों के माध्यम से संदेश प्राप्त करने में सक्षम थे।

यद्यपि प्रत्यक्ष ने हमारी प्रणाली में सुधार किया है, फिर भी इसकी एक खामी है - यह कई मानदंडों के अनुसार एक मार्ग नहीं बना सकता है।

उदाहरण के लिए, हमें लॉग को न केवल उसके प्रकार के महत्व से, बल्कि लॉग के स्रोत से भी अलग करने की आवश्यकता है। आप शायद syslog यूनिक्स टूल में इस तरह की अवधारणा के पार आए हैं, जो लॉग को उनके महत्व प्रकार (जानकारी / चेतावनी / समीक्षक ...) और उनकी वस्तु (विशेषाधिकार / क्रॉन / कर्नेल ...) से अलग करता है।

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

विषय

विषय पहुंच बिंदु पर भेजे गए संदेश एक यादृच्छिक कुंजी रूटिंग_की के साथ नहीं भेजे जा सकते हैं - यह एक अवधि द्वारा अलग किए गए शब्दों की एक सूची होनी चाहिए। शब्द किसी भी हो सकते हैं, लेकिन वे आमतौर पर कुछ संदेश गुणों से जुड़े होते हैं। यहाँ सही मार्ग_के उदाहरण हैं: "stock.usd.nyse", "nyse.vmw", "quick.orange.rabbit"। कुंजी लंबाई 255 बाइट्स से अधिक नहीं होनी चाहिए।

बाध्यकारी कुंजी उसी नियम के अनुसार बनाई गई है। विषय का तर्क प्रत्यक्ष के लिए समान है - संदेश उन कतारों तक पहुंचते हैं जिनकी बाध्यकारी कुंजी संदेश की रूटिंग कुंजी से मेल खाती है। लेकिन विषय के लिए 2 विशेष विशेषताएं हैं:

• * (तारा) को ठीक 1 शब्द से बदला जा सकता है;
• # (हैश) को 0 या अधिक शब्दों से बदला जा सकता है।

यह आंकड़ा में स्पष्ट हो जाएगा:



इस उदाहरण में, हम सभी दिए गए जानवरों को पत्र भेजते हैं। संदेशों में एक राउटिंग कुंजी होती है जिसमें 3 शब्द (दो बिंदुओं के साथ) होते हैं। पहला शब्द गति, दूसरा रंग और तीसरा प्रकार है: "speed.colour.species"।

कतार Q1 कुंजी "* .orange। *" के साथ संबद्ध होगी, और कतार Q2 कुंजियों के साथ * *। *। * खरगोश "और" आलसी #। "

लिंक को संक्षेप में प्रस्तुत किया जा सकता है:

1. कतार Q1 सभी नारंगी जानवरों में रुचि रखता है;
2. क्यू 2 लाइन खरगोश और आलसी जानवरों के बारे में सब कुछ जानना चाहती है।

कुंजी "quick.orange.rabbit" के साथ एक संदेश दोनों कतारों तक पहुंच जाएगा। कुंजी "lazy.orange.elephant" के साथ एक संदेश भी दोनों कतारों में आ जाएगा। "Quick.orange.fox" प्रकार वाला एक संदेश केवल 1 कतार तक पहुंच जाएगा, और "lazy.brown.fox" प्रकार के साथ यह केवल दूसरे तक पहुंच जाएगा। "Lazy.pink.rabbit" प्रकार के साथ एक संदेश केवल 1 बार दूसरी पंक्ति तक पहुंच जाएगा, हालांकि यह दो कनेक्शनों से मेल खाता है। "Quick.brown.fox" प्रकार के साथ एक संदेश किसी भी कतार तक नहीं पहुंचेगा।

यदि आप एक कुंजी के साथ एक संदेश भेजते हैं तो क्या होता है जो किसी भी नियम का पालन नहीं करता है: 1 या 4 शब्दों के साथ (उदाहरण के लिए, "quick.orange.male.rabbit")। ऐसा मैसेज कहीं नहीं आएगा और निकल जाएगा।

लेकिन कुंजी के साथ संदेश "lazy.orange.male.rabbit, हालांकि इसमें 4 शब्द हैं, अंतिम कनेक्शन से मेल खाता है और दूसरे स्थान पर आएगा।

टॉपिक एक बहुत शक्तिशाली एक्सेस प्वाइंट है। यह अन्य पहुंच बिंदुओं की तरह काम कर सकता है। यदि आप बाध्यकारी कुंजी में "#" डालते हैं, तो यह एक प्रशंसक की तरह व्यवहार करेगा। और यदि आप "*" और "#" प्रतीकों का उपयोग नहीं करते हैं, तो यह प्रत्यक्ष की तरह व्यवहार करेगा।

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

हम अपने लॉगिंग सिस्टम के लिए विषय पहुंच बिंदु का उपयोग करेंगे। हम यह अनुमान लगाते हैं कि लॉग की रूटिंग कुंजी में 2 शब्द शामिल हैं: 'सुविधा। सेवरिटी'। कोड लगभग पिछले लेख की तरह ही है ।

स्क्रिप्ट emit_log_topic.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('topic_logs', 'topic', false, false, false); $routing_key = $argv[1]; if(empty($routing_key)) $routing_key = "anonymous.info"; $data = implode(' ', array_slice($argv, 2)); if(empty($data)) $data = "Hello World!"; $msg = new AMQPMessage($data); $channel->basic_publish($msg, 'topic_logs', $routing_key); echo " [x] Sent ",$routing_key,':',$data," \n"; $channel->close(); $connection->close(); ?> 

स्क्रिप्ट प्राप्त_लॉग्स_टॉपिक। एफपी (ग्राहक):

 <?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPConnection; $connection = new AMQPConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel(); $channel->exchange_declare('topic_logs', 'topic', false, false, false); list($queue_name, ,) = $channel->queue_declare("", false, false, true, false); $binding_keys = array_slice($argv, 1); if( empty($binding_keys )) { file_put_contents('php://stderr', "Usage: $argv[0] [binding_key]\n"); exit(1); } foreach($binding_keys as $binding_key) { $channel->queue_bind($queue_name, 'topic_logs', $binding_key); } 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_topic.php "#" 

Kern ऑब्जेक्ट के सभी लॉग प्राप्त करने के लिए:

 $ phpreceive_logs_topic.php "kern.*" 

यदि आप केवल महत्वपूर्ण प्रकारों के साथ लॉग सुनना चाहते हैं:

 $ php receive_logs_topic.php "*.critical" 

कई कनेक्शन बनाएं:

 $ php receive_logs_topic.php "kern.*" "*.critical" 

"Kern.critical" कुंजी के साथ संदेश प्राप्त करने के लिए:

 $ php emit_log_topic.php "kern.critical" "A critical kernel error" 

ध्यान दें कि कोड रूटिंग कुंजी और बाइंडिंग कुंजी के लिए कोई नियम नहीं बनाता है। आप कुंजी में दो से अधिक शब्दों को दर्ज करने का प्रयास कर सकते हैं।

पूर्ण स्क्रिप्ट कोड है emit_log_topic.php और get_logs_topic.php ।