允许RabbitMQ和Pika始终保持连接开放

Question

我有一个Python脚本，它从流中读取内容，当一个新字符串被读取时，它将其内容（字符串）推送到RabbitMQ队列。在

问题是流可能不会在1、2或9小时内发送消息，所以我希望RabbitMQ连接始终打开。在

问题是当我创建连接和通道时：

self.connection = pika.BlockingConnection(pika.ConnectionParameters(host=self.host, credentials=self.credentials))
channel = self.connection.channel()
channel.exchange_declare(exchange=self.exchange_name, exchange_type='fanout')

。。。如果一小时后有消息到达，我会得到这个错误：

^{pr2}$

我认为rabbitmq服务器和客户机之间的连接已经关闭。在

我怎样才能避免这种情况？我想要一个“请保持连接始终有效”。也许在Pika的连接参数中设置了一个超大的心跳？像这样：

self.connection = pika.BlockingConnection(pika.ConnectionParameters(host=self.host, credentials=self.credentials, heartbeat=6000))

如果有其他更酷的解决方案，我们将不胜感激。在

提前谢谢

Answer 1

我建议你每次发送消息前都要检查连接，如果连接被关闭，那么只需重新连接。在

if not self.connection or self.connection.is_closed:
    self.connection = pika.BlockingConnection(pika.ConnectionParameters(host=self.host, credentials=self.credentials))
    channel = self.connection.channel()
    channel.exchange_declare(exchange=self.exchange_name, exchange_type='fanout')