本文主要是介绍使用python的pika链接rabbitMq断裂,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
比如我们执行一个很长的任务的时候,执行结束ack确认发现确认失败,mq都断了。
只要是使用pyhon的pika都会出现这个问题,因为pika本身是没有主动发送心跳机制的(你用java的话是没问题的)
解决方式:
在链接中heartbeat=0
credentials = pika.PlainCredentials('xxx','xxx')
connection = pika.BlockingConnection(pika.ConnectionParameters(
host = "xxxx",port = 5672, credentials = credentials , heartbeat=0
))
这篇关于使用python的pika链接rabbitMq断裂的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!