सर्वर दुनिया | गोपनीयता नीति | सहायता / संपर्क करें |
5738 / 118084268
|
RabbitMQ : Python पर प्रयोग करें2024/07/22 |
यह Python पर RabbitMQ का उपयोग करने का एक उदाहरण है।
|
|
[1] | AMQP क्लाइंट लाइब्रेरी स्थापित करें। |
root@dlp:~# apt -y install python3-pika
|
[2] | यह Python पर संदेश भेजने का एक उदाहरण है। उदाहरण के लिए, एक उपयोगकर्ता [serverworld], वर्चुअलहोस्ट [my_vhost] के साथ [localhost] पर RabbitMQ से जुड़ें। |
ubuntu@dlp:~$
vi send_msg.py import pika credentials = pika.PlainCredentials( 'serverworld', 'password' ) connection = pika.BlockingConnection( pika.ConnectionParameters( 'localhost', 5672, '/my_vhost', credentials ) ) channel = connection.channel() channel.queue_declare(queue='Hello_World') channel.basic_publish( exchange='', routing_key='Hello_World', body='Hello RabbitMQ World!' ) print(" [x] Sent 'Hello_World'") connection.close() python3 send_msg.py [x] Sent 'Hello_World' |
[3] | यह Python पर संदेश प्राप्त करने का एक उदाहरण है। |
ubuntu@node01:~$
vi receive_msg.py import signal import pika signal.signal(signal.SIGPIPE, signal.SIG_DFL) signal.signal(signal.SIGINT, signal.SIG_DFL) credentials = pika.PlainCredentials( 'serverworld', 'password' ) connection = pika.BlockingConnection( pika.ConnectionParameters( '10.0.0.30', 5672, '/my_vhost', credentials ) ) channel = connection.channel() channel.queue_declare(queue='Hello_World') def callback(ch, method, properties, body): print(" [x] Received %r" % body ) channel.basic_consume('Hello_World', callback, auto_ack=True) print(' [*] Waiting for messages. To exit press CTRL+C') channel.start_consuming() python3 receive_msg.py [*] Waiting for messages. To exit press CTRL+C [x] Received b'Hello RabbitMQ World!' |
Sponsored Link |