今天小编就为大家分享一篇解决python3 pika之连接断开的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

问题描述 在消费rabbitMQ队列时, 每次进入回调函数内需要进行一些比较耗时的操作;操作完成后给rabbitMQ server发送ack信号以dequeue本条消息。 问题就发生在发送ack操作时, 程序提示链接已被断开或socket error。 源码示例 #!/usr/bin #coding: utf-8 import pika import time USER = 'guest' PWD = 'guest' TEST_QUEUE = 'just4test' def callback(