如何解决如何使用 pika 1.2.0 发送 RabbitMQ 心跳帧?
我正在使用 pika.BlockingConnection
。我使用 basic_publish
和 channel.consume
来发布和使用消息。
当 heartbeat
设置为 0
时一切正常,但是当我设置任何值(例如 60)时,RabbitMQ 会引发错误: missed heartbeats from client,timeout: 60s
。如何发送心跳帧?
我使用 pika==1.2.0
版本。
更新:是否需要任何其他信息?
解决方法
您可以使用以下方法之一手动发送心跳:
from pika import BlockingConnection
connection = BlockingConnection(*args,**kwargs)
connection._heartbeat_checker._send_heartbeat()
from pika import frame
connection._send_frame(frame.Heartbeat())
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。