🕤 ⏸️ 👏 MonsterMQ भाग 1 के साथ RabbitMQ का उपयोग करना 🍂 🤴🏼 ‼️

यह आलेख उन लोगों के लिए है, जो अभी तक कतारों और खरगोशों से परिचित नहीं हैं। जो लोग पहले से ही जानते हैं कि कैसे RabbitMQ के साथ काम करना है और केवल उन संभावनाओं का पता लगाना चाहते हैं जो MonsterMQ प्रदान करता है, मैं github.com पर प्रोजेक्ट पेज पर जाने की सलाह देता हूं , जहां विवरण में विस्तार से वर्णन किया गया है कि आप RabbitMQ के साथ काम करने की मूल बातें बताए बिना MonsterMQ का उपयोग कैसे कर सकते हैं। इस लेख के बाकी भाग में मूल बातें शामिल होंगी कि रैबिटएमक्यू मॉन्स्टरएमक्यू के साथ कैसे काम करता है।

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

AMQP और RabbitMQ निम्नलिखित शब्दों का उपयोग करते हैं:

उत्पादन - संदेश भेजने का मतलब है, निर्माता (आपूर्तिकर्ता) - जो संदेश भेजता है।

उपभोग करना - संदेश प्राप्त करने का मतलब है। उपभोक्ता - वह जो संदेश प्राप्त करता है।

कतार ही कतार है। उपभोक्ता तक पहुंचने से पहले और उसके बाद आपूर्तिकर्ता द्वारा भेजे जाने के बाद, संदेश RabbitMQ के अंदर एक कतार में संग्रहीत किया जाता है। कतार एक बफर है जो संदेशों को संग्रहीत करता है। कई प्रदाता एक कतार में संदेश भेज सकते हैं, और कई उपभोक्ता एक कतार से संदेश पढ़ सकते हैं।

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

नमस्ते दुनिया

इस लेख में बाद में, हम मॉन्स्टरएमक्यू पुस्तकालय का उपयोग करके पीएचपी में दो कार्यक्रम लिखेंगे, जिनमें से एक संदेश भेजेगा, और दूसरा प्राप्त करेगा और उन्हें कंसोल में आउटपुट करेगा। नीचे दिए गए आंकड़े में, "पी" प्रदाता है, "सी" उपभोक्ता है, लाल बक्से कतार है जो संदेश बफर है (प्रत्येक बॉक्स संदेश है)।

(आधिकारिक आधिकारिक वेबसाइट से ली गई छवि )

आगे के काम के लिए, हमें MonsterMQ स्थापित करने की आवश्यकता है, ऐसा करने के लिए, कंसोल में निम्नलिखित कमांड दर्ज करें:

composer require goootlib/monster-mq:dev-master

(MonsterMQ इंस्टॉल करने के बारे में अधिक जानकारी github.com पर प्रोजेक्ट पेज पर पाई जा सकती है )
यह कमांड चालू फ़ोल्डर में MonsterMQ स्थापित करेगा।

प्रस्थान

हम अपने इस फोन करेगा send.php , और प्राप्तकर्ता receive.php । प्रेषक सर्वर से जुड़ जाएगा और संदेश भेजेगा।
सर्वर से जुड़ने के लिए send.php में निम्न कोड लिखें :।

try {
   $producer = \MonsterMQ\Client\Producer();

   $producer->connect('127.0.0.1', 5672);
   $producer->logIn('guest', 'guest');
} catch(\Exception $e) {
   var_dump($e);
}

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

संदेश भेजने के लिए, हमें उस कतार को घोषित करना होगा जिसमें इसे पहले रखा जाएगा। कतार की घोषणा होने के बाद, हम एक संदेश भेज सकते हैं:

try {
   $producer = \MonsterMQ\Client\Producer();

   $producer->connect('127.0.0.1', 5672);
   $producer->logIn('guest', 'guest');

   $producer->queue('test-queue')->declare();
   $producer->publish('my-message', 'test-queue');
} catch(\Exception $e) {
   var_dump($e);
}

कतार की घोषणा निष्प्राण है, अर्थात यह बनाएगी नहीं और कतार को नहीं बदलेगी, यदि यह पहले से मौजूद है। हम सत्र पूरा करने और शामिल होने के बाद।

try {
   $producer = \MonsterMQ\Client\Producer();

   $producer->connect('127.0.0.1', 5672);
   $producer->logIn('guest', 'guest');

   $producer->queue('test-queue')->declare();
   $producer->publish('Test message', 'test-queue');

   $producer->disconnect();
} catch(\Exception $e) {
   var_dump($e);
}

संदेश प्राप्त करें

प्रेषक के विपरीत, प्राप्तकर्ता आने वाले संदेशों को सुनने के लिए चालू रहेगा। Rece.php कोड में, आपको पहले send.php के समान करना होगा :

try {
   $consumer = \MonsterMQ\Client\Consumer();

   $consumer->connect('127.0.0.1', 5672);
   $consumer->logIn('guest', 'guest');

   $consumer->queue('test-queue')->declare();
} catch(\Exception $e) {
   var_dump($e);
}

ध्यान दें कि में receive.php हम भी हमारे कतार घोषित, यह इतना है कि प्राप्तकर्ता कतार वाणी अगर यह इस से पहले शुरू कर दिया जाता है।
सर्वर को यह बताने के लिए कि हम उससे एक संदेश प्राप्त करना चाहते हैं, साथ ही साथ एक चक्र शुरू करना है जो प्रतीक्षा करेगा और आने वाले संदेशों को संसाधित करेगा, हम निम्नलिखित कोड लिखेंगे:

try {
   $consumer = \MonsterMQ\Client\Consumer();

   $consumer->connect('127.0.0.1', 5672);
   $consumer->logIn('guest', 'guest');

   $consumer->queue('test-queue')->declare();

   $consumer->consume('test-queue');

   $consumer->wait(function ($message, $channelNumber) use ($consumer){
      echo "Message - {$message} received on channel {$channelNumber}";
   });
} catch(\Exception $e) {
   var_dump($e);
}

प्रक्षेपण

अब हम प्राप्तकर्ता के रूप में दोनों स्क्रिप्ट चला सकते हैं:

php receive.php

इसलिए प्रेषक:

php send.php

प्राप्तकर्ता उस संदेश को कंसोल में आउटपुट करेगा जो उसे RabbitMQ से प्राप्त होगा (जो बदले में इसे send.php से प्राप्त करेगा) और उपयोग किए गए चैनल नंबर। जब तक आप टर्मिनल को बंद नहीं करते, या जब तक आप इसे Ctrl + C दबाकर निष्पादित करना बंद नहीं कर देते, तब तक इसे निष्पादित किया जाता रहेगा। प्रेषक को किसी अन्य टर्मिनल में लॉन्च करके, आप देख सकते हैं कि प्राप्तकर्ता को संदेश कैसे वितरित किए जाते हैं और कंसोल में प्रदर्शित किए जाते हैं।

यदि आप यह देखना चाहते हैं कि फिलहाल, RabbitMQ में कतारें हैं और उनमें कितने संदेश हैं, तो आप यह कर सकते हैं एक विशेषाधिकार प्राप्त उपयोगकर्ता के रूप में rabbitmqctl का उपयोग करके

sudo rabbitmqctl list_queues

खिड़कियों पर सूडो का प्रयोग न करें

rabbitmqctl.bat list_queues

अब हम अपने पाठों के अगले भाग पर आगे बढ़ने के लिए तैयार हैं ।

MonsterMQ भाग 1 के साथ RabbitMQ का उपयोग करना

नमस्ते दुनिया

प्रस्थान

संदेश प्राप्त करें

प्रक्षेपण

More articles: