0

以下是我的要求。

  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，这意味着我正在禁用心跳检查（不推荐）。有没有人有解决方法？

提前致谢

4

0 回答 0