使pika BlockingConnection保持活动状态而不会禁用心跳

Question

我正在使用pika 0.10.0和python 2.7版本开发RabbitMQ使用者。在我的使用者客户端中，我有一个进程会运行一段时间，具体取决于输入消息。它可能在3到40分钟之间变化。我不想禁用心跳。取而代之的是，我正在寻找某种collback机制，该机制可以保持连接有效，直到delivery_tag被发送回。那可能吗？

我得到的链接很少，所有人都建议禁用心跳作为解决方法。但是我不想禁用它。

参考：

套接字错误：104使用消耗时间较长的任务的消息＃753

BlockingConnection意外关闭＃734

另外，请让我知道是否需要其他信息。提前致谢。

Answer 1

唯一的解决方案是定期发送心跳帧。

使用a时BlockingConnection，必须process_data_events足够频繁地调用该函数（a time_limit可以为零）。使用a SelectConnection或其他异步适配器时，必须确保没有任何进程被阻塞，以便可以发送帧。

如果您的任务长时间运行，并且由于某种原因您不能轻易中断或拆分进程，则可以在另一个线程/进程中运行该任务，并且仍然有pika从主线程发送帧。请记住，您应该避免在线程之间使用pika连接（pika目前不是线程安全的）。