Rabbitmq pika缺少心跳

问题描述

以下是我的要求。

1. 拥有一个可重复用于跨多个线程发布的连接池
2. 在单独的连接上使用

所以我尝试测试一些构建连接池的解决方案。

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 (将#修改为@）