2

我有一个 Twisted 应用程序(Python 2.7),它使用 kombu 模块与 RabbitMQ 消息服务器进行通信。

我们在关闭连接时遇到问题(可能与防火墙相关),我正在尝试实现heartbeat_check()处理此问题的方法。我在连接上设置了 10 的心跳值,并且我有一个 Twisted ,它每 5 秒LoopingCall调用一次该方法。heartbeat_check(rate=2)

但是,一旦事情进展顺利,我就会在其他所有调用中抛出一个异常heartbeat_check()(基于我在LoopingCall调用的函数中获得的日志信息,其中包括对 的调用heartbeat_check)。我尝试了各种心跳和速率值的变化,但似乎没有任何帮助。当我调试它时,heartbeat_call()它看起来像是在来回发送一些次要的消息流量,我应该在我的消息使用者中对此做出响应吗?

任何提示或指示都会非常有帮助,在此先感谢!!

道格

4

0 回答 0