首页 / RABBITMQ / python使用消息队列RabbitMq（进阶）

python使用消息队列RabbitMq（进阶）

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了python使用消息队列RabbitMq（进阶），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2388字，纯文字阅读大概需要4分钟。

内容图文

技术分享图片 技术分享图片 
                import
                 pika
  
connection = pika.BlockingConnection(pika.ConnectionParameters(
               ‘localhost‘))
channel = connection.channel()
  
#声明queue
channel.queue_declare(queue=‘hello‘)
  
# RabbitMQ a message can never be sent directly to the queue, it always needs to go through an exchange.
channel.basic_publish(exchange=‘‘,
                      routing_key=‘hello‘,
                      body=‘Hello World!‘)
print(" [x] Sent ‘Hello World!‘")
connection.close()
发送
技术分享图片 技术分享图片 
                __author__ = ‘hardy‘import pika
  
connection = pika.BlockingConnection(pika.ConnectionParameters(
               ‘localhost‘))
channel = connection.channel()
  
  
#You may ask why we declare the queue again ? we have already declared it in our previous code.
# We could avoid that if we were sure that the queue already exists. For example if send.py program
#was run before. But we‘re not yet sure which program to run first. In such cases it‘s a good
# practice to repeat declaring the queue in both programs.
channel.queue_declare(queue=‘hello‘)
  
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
  
channel.basic_consume(callback,
                      queue=‘hello‘,
                      no_ack=True)
  
print(‘ [*] Waiting for messages. To exit press CTRL+C‘)
channel.start_consuming()
接收

消息队列的发送端流程

　　1、连接

connection = pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))
channel = connection.channel()

　　2、声明queue

channel.queue_declare(queue=‘hello‘)

　　队列持久化

channel.queue_declare(queue=‘hello‘, durable=True)

　　3、发送消息

channel.basic_publish(exchange=‘‘,
                      routing_key=‘hello‘,
                      body=‘Hello World!‘)

　　消息持久化（必须队列持久化）

channel.basic_publish(exchange=‘‘,
                      routing_key="hello",
                      body=message,
                      properties=pika.BasicProperties(
                         delivery_mode = 2, # make message persistent
                      ))

 

　　4、关闭

connection.close()

消息队列接收端流程

　　1、连接

connection = pika.BlockingConnection(pika.ConnectionParameters(
               ‘localhost‘))
channel = connection.channel()

　　2、声明queue

channel.queue_declare(queue=‘hello‘)

　　3、创建回调函数（处理数据）

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

　　4、设置

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

　　5、开始接收数据

channel.start_consuming()

　　6、确认消息被消费

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
    time.sleep(body.count(b‘.‘))
    print(" [x] Done")
    ch.basic_ack(delivery_tag = method.delivery_tag)


channel.basic_consume(callback,
                       queue=‘task_queue‘,
                       no_ack=True  #no_ack=True消息不需要确认，默认no_ack=false，消息需要确认
                       )

 

原文：https://www.cnblogs.com/hardykay/p/10207953.html

内容总结

以上是互联网集市为您收集整理的python使用消息队列RabbitMq（进阶）全部内容，希望文章能够帮你解决python使用消息队列RabbitMq（进阶）所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1147711.html

来源：【匿名】