rabbitmq - 服务器在 pika.exceptions.StreamLostError : Stream connection lost 后关闭

Question

我的队列中有一些图像，我将每个图像传递到我的 flask 服务器，在那里完成图像处理并在我的 rabbitmq 服务器中收到响应。收到响应后，我收到此错误“pika.exceptions.StreamLostError: Stream connection lost(104,'Connection reset by peer')”。当 rabbitmq channel 再次开始使用连接时会发生这种情况。我不明白为什么会发生这种情况。如果此错误仍然存​​在，我还想自动重新启动服务器。有没有办法做到这一点？

Answer 1

您的消费过程可能需要太多时间才能完成并将 Ack/Nack 发送到服务器。因此，服务器不会从您的客户端收到心跳，从而停止服务。然后，在客户端，您会收到:

pika.exceptions.StreamLostError: Stream connection lost(104,'Connection reset by peer')

您还应该看到服务器日志。大概是这样的:

missed heartbeats from client, timeout: 60s

见 this issue更多信息。