比如我们执行一个很长的任务的时候,执行结束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
))