python消费rabbitmq

2023-12-26 19:38:17

队列经常用,能保持信息一致性。也能跨语言,java写的生产者,推到队列中,python写的消费者消费。

这里,生成者,我们是java,已经发了一条消息了。

python是使用pika来链接rabbitmq

安装pika

pip install pika

代码

import pika
#用户名密码,没有设置的可以省略这一步
credentials = pika.PlainCredentials('xxx','xxx')
connection = pika.BlockingConnection(pika.ConnectionParameters(
    host = "xxx",port = 5672, credentials = credentials
))
channel = connection.channel()

channel.queue_declare(queue = "xxx",durable=True)#如果是持久化队列就是True

def callback(ch,method,properties,body):
    body_parse=body.decode('utf-8')
    print("内容是"+body_parse)
    ch.basic_ack(delivery_tag=method.delivery_tag)

channel.basic_consume("auto_train_kantts", callback)
print("开始消费")
channel.start_consuming()

文章来源:https://blog.csdn.net/qq_38403590/article/details/135227484
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。