RabbitMQ ट्यूटोरियल 1 - हैलो वर्ल्ड

RabbitMQ विभिन्न कार्यक्रमों को AMQP प्रोटोकॉल का उपयोग करके संवाद करने की अनुमति देता है। RabbitMQ SOA (सेवा-उन्मुख वास्तुकला) के निर्माण और आस्थगित संसाधन-गहन कार्यों के वितरण के लिए एक उत्कृष्ट समाधान है।

कटौती के तहत, आधिकारिक साइट से पहले छह पाठों का अनुवाद। उदाहरण अजगर में हैं, लेकिन यह जानना बिल्कुल भी आवश्यक नहीं है। इसी तरह के कार्यक्रमों को लगभग किसी भी लोकप्रिय वाईपी पर पुन: पेश किया जा सकता है। [अनुवादक की टिप्पणियाँ इस तरह दिखती हैं, अर्थात् मुझे]

प्रविष्टि

RabbitMQ एक मैसेज ब्रोकर है। इसका मुख्य उद्देश्य संदेश प्राप्त करना और देना है। इसे एक पोस्ट ऑफिस के रूप में कल्पना की जा सकती है: जब आप एक बॉक्स में एक पत्र छोड़ते हैं, तो आप यह सुनिश्चित कर सकते हैं कि जितनी जल्दी या बाद में डाकिया इसे पते पर पहुंचाएगा [जाहिर है, लेखक ने रूसी पोस्ट से कभी नहीं निपटा है] । इस सादृश्य में, RabbitMQ एक मेलबॉक्स, एक डाकघर और एक डाकिया दोनों है।

RabbitMQ और पोस्ट ऑफिस के बीच सबसे बड़ा अंतर यह है कि यह कागज के लिफाफे के साथ सौदा नहीं करता है - RabbitMQ द्विआधारी डेटा - संदेशों को प्राप्त करता है, संग्रहीत करता है और भेजता है।

RabbitMQ में, साथ ही साथ सामान्य रूप से संदेश भेजने के लिए, निम्नलिखित शब्दावली का उपयोग किया जाता है:

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

आपूर्तिकर्ता, ग्राहक और दलाल को एक ही भौतिक मशीन पर होना आवश्यक नहीं है, आमतौर पर वे अलग-अलग होते हैं।

नमस्ते विश्व!

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



प्रदाता कतार में नाम हैलो के साथ संदेश भेजता है, और ग्राहक इस कतार से संदेश प्राप्त करता है।

RabbitMQ लाइब्रेरी

RabbitMQ AMQP प्रोटोकॉल का उपयोग करता है। RabbitMQ का उपयोग करने के लिए, आपको एक पुस्तकालय की आवश्यकता है जो इस प्रोटोकॉल का समर्थन करता है। ऐसी लाइब्रेरी लगभग हर प्रोग्रामिंग लैंग्वेज के लिए मिल सकती है। अजगर कोई अपवाद नहीं है, इसके लिए कई पुस्तकालय हैं:

• py-amqplib
• txAMQP
• पिका

उदाहरणों में, पिका पुस्तकालय का उपयोग किया जाएगा। यह पाइप पैकेज मैनेजर का उपयोग करके स्थापित किया जा सकता है:

$ sudo pip install pika==0.9.5 

यदि पाइप या गिट-कोर गायब हैं, तो आपको पहले उन्हें स्थापित करना होगा:

• उबंटू के लिए:
  
  

   $ sudo apt-get install python-pip git-core 

  
  
• डेबियन के लिए:
  
  

   $ sudo apt-get install python-setuptools git-core $ sudo easy_install pip 

  
  
• Windows के लिए (easy_install को स्थापित करने के लिए, आपको MS Windows इंस्टालर को सेटपूल के लिए चलाना चाहिए):
  
  

   > easy_install pip > pip install pika==0.9.5 

  
  

संदेश भेजना

हमारा पहला send.py प्रोग्राम केवल एक संदेश कतार में भेज देगा।

 #!/usr/bin/env python import pika connection = pika.BlockingConnection(pika.ConnectionParameters( 'localhost')) channel = connection.channel() 

हम स्थानीय होस्ट पर स्थित एक संदेश ब्रोकर से जुड़े हैं। किसी अन्य मशीन पर स्थित ब्रोकर से कनेक्ट करने के लिए, इस मशीन के आईपी पते के साथ "लोकलहोस्ट" को बदलना पर्याप्त है।

संदेश भेजने से पहले, हमें यह सुनिश्चित करना चाहिए कि संदेश प्राप्त करने वाली कतार मौजूद है। यदि आप एक संदेश को किसी गैर-पंक्तिबद्ध कतार में भेजते हैं, तो RabbitMQ इसे अनदेखा कर देगा। आइए एक कतार बनाएं जिससे संदेश भेजा जाएगा, इसे "हैलो" कहें:

 channel.queue_declare(queue='hello') 

अब आप संदेश भेजने के लिए तैयार हैं। हमारे पहले संदेश में "हैलो वर्ल्ड!" स्ट्रिंग शामिल होगी और इसे "हैलो" नाम के साथ कतार में भेजा जाएगा।

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

 channel.basic_publish(exchange='', routing_key='hello', body='Hello World!') print " [x] Sent 'Hello World!'" 

कार्यक्रम से बाहर निकलने से पहले, सुनिश्चित करें कि बफर साफ हो गया है और संदेश RabbitMQ तक पहुंच गया है। यदि आप ब्रोकर के साथ कनेक्शन को बंद करने का उपयोग करते हैं, तो आप इसके बारे में सुनिश्चित हो सकते हैं।

 connection.close() 

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

हमारा दूसरा रीएम्फ़्लो कार्यक्रम कतार से संदेश प्राप्त करेगा और उन्हें स्क्रीन पर प्रदर्शित करेगा।

पहले कार्यक्रम की तरह, आपको सबसे पहले RabbitMQ से कनेक्ट करना होगा। ऐसा करने के लिए, पहले जैसा ही कोड इस्तेमाल करें। अगला चरण, पहले की तरह, यह सुनिश्चित करना है कि कतार मौजूद है। यदि यह पहले से ही मौजूद है, तो कोई भी पंक्ति कितनी बार बनाई जाएगी, इस पर कोई भी पंक्ति नहीं बनेगी , तो कतार_declare कमांड नई कतार नहीं बनाएगी।

 channel.queue_declare(queue='hello') 

आप आश्चर्यचकित हो सकते हैं कि हम कतार की फिर से घोषणा क्यों करते हैं, क्योंकि पहले ही कार्यक्रम में इसकी घोषणा की जा चुकी है। यह सुनिश्चित करने के लिए आवश्यक है कि कतार मौजूद है, इसलिए यह होगा यदि Send.py पहले चलाया जाता है। लेकिन हम यह नहीं जानते हैं कि कौन सा प्रोग्राम पहले लॉन्च किया जाएगा। ऐसे मामलों में, दोनों कार्यक्रमों में कतार लगाना बेहतर है।

कतार की निगरानी

यदि आप यह देखना चाहते हैं कि वर्तमान में RabbitMQ में क्या कतारें मौजूद हैं, तो आप इसे खरगोशमक्कल कमांड ( सुपरसुअर अधिकारों की आवश्यकता होगी) के साथ कर सकते हैं:

 $ sudo rabbitmqctl list_queues Listing queues ... hello 0 ...done. 

(विंडोज के लिए - sudo के बिना)

[हमारी कंपनी एक अधिक सुविधाजनक निगरानी स्क्रिप्ट का उपयोग करती है:]

 watch 'sudo /usr/sbin/rabbitmqctl list_queues name messages_unacknowledged messages_ready messages durable auto_delete consumers | grep -v "\.\.\." | sort | column -t;' 

[स्क्रिप्ट कतार की एक सूची के साथ हर 2 सेकंड में एक तालिका प्रदर्शित और अपडेट करती है: कतार का नाम; प्रसंस्करण में संदेशों की संख्या; प्रसंस्करण के लिए तैयार संदेशों की संख्या; संदेशों की कुल संख्या; सेवा को पुनरारंभ करने के लिए कतार की स्थिरता; क्या यह एक अस्थायी कतार है; ग्राहकों की संख्या]

कतार से संदेश प्राप्त करना भेजने की तुलना में अधिक जटिल प्रक्रिया है। कॉलबैक फ़ंक्शन का उपयोग करके सदस्यता के माध्यम से हो रही है। प्रत्येक संदेश प्राप्त होने पर, पिका पुस्तकालय इस कॉलबैक फ़ंक्शन को कॉल करता है। हमारे उदाहरण में, यह संदेश पाठ प्रदर्शित करेगा।

 def callback(ch, method, properties, body): print " [x] Received %r" % (body,) 

अगला, हमें यह इंगित करने की आवश्यकता है कि कॉलबैक फ़ंक्शन को "हैलो" नाम के साथ कतार से संदेश प्राप्त होगा।

 channel.basic_consume(callback, queue='hello', no_ack=True) 

यहां आपको यह सुनिश्चित करने की आवश्यकता है कि जिस कतार की हम सदस्यता लेना चाहते हैं, उसकी घोषणा की गई है। हमने यह पहले कतार_डेकलेयर कमांड के साथ किया था।

No_ack पैरामीटर पर बाद में [ दूसरे पाठ में ] चर्चा की जाएगी।
और अंत में, एक अंतहीन प्रक्रिया शुरू करें जो कतार से संदेशों की प्रतीक्षा करता है और आवश्यक होने पर कॉलबैक फ़ंक्शन को कॉल करता है।

 print ' [*] Waiting for messages. To exit press CTRL+C' channel.start_consuming() 

खैर, अब सब साथ हैं

पूर्ण प्रेषित कोड:

 #!/usr/bin/env python import pika connection = pika.BlockingConnection(pika.ConnectionParameters( host='localhost')) channel = connection.channel() channel.queue_declare(queue='hello') channel.basic_publish(exchange='', routing_key='hello', body='Hello World!') print " [x] Sent 'Hello World!'" connection.close() 

पूर्ण रसीद कोड:

 #!/usr/bin/env python import pika connection = pika.BlockingConnection(pika.ConnectionParameters( host='localhost')) channel = connection.channel() channel.queue_declare(queue='hello') print ' [*] Waiting for messages. To exit press CTRL+C' def callback(ch, method, properties, body): print " [x] Received %r" % (body,) channel.basic_consume(callback, queue='hello', no_ack=True) channel.start_consuming() 

अब हम टर्मिनल में अपने कार्यक्रम चलाने की कोशिश कर सकते हैं। सबसे पहले, Send.py प्रोग्राम का उपयोग करके एक संदेश भेजें:

 $ python send.py [x] Sent 'Hello World!' 

प्रत्येक संदेश भेजने के बाद यह कार्यक्रम समाप्त हो जाएगा। अब संदेश प्राप्त करने की आवश्यकता है:

 $ python receive.py [*] Waiting for messages. To exit press CTRL+C [x] Received 'Hello World!' 

बहुत बढ़िया! हमने अपना पहला संदेश RabbitMQ के माध्यम से भेजा। जैसा कि आपने देखा होगा, रिसीव्डरो प्रोग्राम का निष्पादन समाप्त नहीं हुआ। वह निम्नलिखित संदेशों की प्रतीक्षा करेगा, लेकिन आप Ctrl + C दबाकर उसे रोक सकते हैं ।
एक नई टर्मिनल विंडो में फिर से भेजने का प्रयास करें।

हमने नामांकित कतारों के माध्यम से संदेश भेजने और प्राप्त करने का तरीका सीखा। अगले पाठ में, हम एक सरल [संसाधन-गहन] कार्य कतार बनाएंगे।

UPD: RabbitMQ के साथ काम करने वाला एक पुस्तकालय, अपने पसंदीदा PL के लिए आप यहाँ आधिकारिक वेबसाइट पर पा सकते हैं।