如何使用 pika 1.2.0 发送 RabbitMQ 心跳帧？

大佬教程收集整理的这篇文章主要介绍了如何使用 pika 1.2.0 发送 RabbitMQ 心跳帧？，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决如何使用 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())

大佬总结

以上是大佬教程为你收集整理的如何使用 pika 1.2.0 发送 RabbitMQ 心跳帧？全部内容，希望文章能够帮你解决如何使用 pika 1.2.0 发送 RabbitMQ 心跳帧？所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。