首页 / RABBITMQ / RabbitMQ之pika模块

RabbitMQ之pika模块

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了RabbitMQ之pika模块，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1149字，纯文字阅读大概需要2分钟。

内容图文

发布/订阅 系统

send.py

        import pika
import time
s_conn = pika.BlockingConnection(pika.ConnectionParameters('127.0.0.1'))  # 创建连接
chan = s_conn.channel()  # 在连接上创建一个频道

chan.queue_declare(queue='hello')  # 声明一个队列，生产者和消费者都要声明一个相同的队列，用来防止万一某一方挂了，另一方能正常运行

while 1:
    time.sleep(1)
    chan.basic_publish(exchange='',  # 交换机
                       routing_key='hello',  # 路由键，写明将消息发往哪个队列，本例是将消息发往队列hello
                       body='Ye:当前时间%s ' % time.strftime('%m-%d %H:%M:%S'))  # 生产者要发送的消息
    print("[生产者] send 'hello world")

s_conn.close()  # 当生产者发送完消息后，可选择关闭

recv.py

        import pika

s_conn = pika.BlockingConnection(pika.ConnectionParameters('127.0.0.1'))  # 创建连接
chan = s_conn.channel()  # 在连接上创建一个频道

chan.queue_declare(queue='hello')  # 声明一个队列，生产者和消费者都要声明一个相同的队列，用来防止万一某一方挂了，另一方能正常运行


def callback(ch, method, properties, body):  # 定义一个回调函数，用来接收生产者发送的消息
    print(ch, method, properties, )
    print(body.decode('utf8'))


chan.basic_consume('hello',  # 指定取消息的队列名,
                   callback,  # 调用回调函数，从队列里取消息
                   auto_ack=True)  # 取完一条消息后，给生产者发送确认消息，默认是False的，即  默认不给rabbitmq发送一个收到消息的确认
# 如果auto_ack=True则消失接收之后就会删除也就是只能取一次
print('[消费者] waiting for msg .')
chan.start_consuming()  # 开始循环取消息

原文：https://www.cnblogs.com/qq752059037/p/10819740.html

内容总结

以上是互联网集市为您收集整理的RabbitMQ之pika模块全部内容，希望文章能够帮你解决RabbitMQ之pika模块所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

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

内容手机端

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

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

来源：【匿名】