如何解决Rabbitmq pika缺少心跳
以下是我的要求。
- 拥有一个可重复用于跨多个线程发布的连接池
- 在单独的连接上使用
所以我尝试测试一些构建连接池的解决方案。
import pika
import time
import threading
def test_run_on_thread():
print("connecting")
connection = pika.BlockingConnection(parameters=pika.URLParameters(url='amqp://guest:guest@localhost:5672'))
t = threading.Thread(target=test_run_on_thread)
t.start()
time.sleep(1000)
当我运行上面的连接时,连接被创建并且它保持空闲直到主线程完成。所以它有效,但我检查了rabbitmq日志,它显示了以下内容
2021-03-17 20:00:09.006 [info] <0.3946.1> connection <0.3946.1> (127.0.0.1:34702 -> 127.0.0.1:5672): user 'guest' authenticated and granted access to vhost '/'
2021-03-17 20:01:20.720 [error] <0.3946.1> closing AMQP connection <0.3946.1> (127.0.0.1:34702 -> 127.0.0.1:5672):
missed heartbeats from client,timeout: 60s
所以这里发生的是连接关闭,因为客户端没有发送心跳。当我尝试实现连接池时,这会产生问题。当我创建连接池时,它会自动关闭。
我能找到的解决方法是将心跳设置为 0,这意味着我正在禁用心跳检查(不推荐)。有没有人对此有解决方法?
提前致谢
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。