为什么RabbitMQ升级到4.0版本后会频繁断连？如何解决？-Python教程-PHP中文网

为什么RabbitMQ升级到4.0版本后会频繁断连？如何解决？

心靈之曲

发布： 2025-04-24 20:56:01

原创

258人浏览过

为什么rabbitmq升级到4.0版本后会频繁断连？如何解决？

探讨RabbitMQ 4.0升级后频繁断连的问题

在使用RabbitMQ时，升级到4.0版本后，许多用户可能会遇到AMQP连接每3分钟重连一次的问题。之前使用RabbitMQ 3.x时，连接是稳定的，但在升级到4.x后，使用nameko eventlet kombu amqp的组合时，会频繁出现断连情况，尽管有自动重连机制，但依然令人烦恼。

问题描述

断连日志显示了两种情况：

第一种情况：

<code>尝试连接到代理时出错，地址为amqp://ponponon:********@192.168.38.223:5672// ([Errno 104] ECONNRESET)。
将在2.0秒后重试。
尝试连接到代理时出错，地址为amqp://ponponon:********@192.168.38.223:5672// ([Errno 104] ECONNRESET)。
将在2.0秒后重试。
尝试连接到代理时出错，地址为amqp://ponponon:********@192.168.38.223:5672// ([Errno 104] ECONNRESET)。
将在2.0秒后重试。
尝试连接到代理时出错，地址为amqp://ponponon:********@192.168.38.223:5672// ([Errno 104] ECONNRESET)。</code>

登录后复制

第二种情况：

<code>与代理的连接丢失，正在尝试重新建立连接...
Traceback (最近的调用堆栈):
  File "/home/pon/.local/share/virtualenvs/parser-szge04QH/lib/python3.10/site-packages/kombu/mixins.py", line 174, in run
    for _ in self.consume(limit=None, **kwargs):
  File "/home/pon/.local/share/virtualenvs/parser-szge04QH/lib/python3.10/site-packages/kombu/mixins.py", line 196, in consume
    conn.drain_events(timeout=safety_interval)
  File "/home/pon/.local/share/virtualenvs/parser-szge04QH/lib/python3.10/site-packages/kombu/connection.py", line 341, in drain_events
    return self.transport.drain_events(self.connection, **kwargs)
  File "/home/pon/.local/share/virtualenvs/parser-szge04QH/lib/python3.10/site-packages/kombu/transport/pyamqp.py", line 171, in drain_events
    return connection.drain_events(**kwargs)
  File "/home/pon/.local/share/virtualenvs/parser-szge04QH/lib/python3.10/site-packages/amqp/connection.py", line 526, in drain_events
    while not self.blocking_read(timeout):
  File "/home/pon/.local/share/virtualenvs/parser-szge04QH/lib/python3.10/site-packages/amqp/connection.py", line 531, in blocking_read
    frame = self.transport.read_frame()
  File "/home/pon/.local/share/virtualenvs/parser-szge04QH/lib/python3.10/site-packages/amqp/transport.py", line 294, in read_frame
    frame_header = read(7, True)
  File "/home/pon/.local/share/virtualenvs/parser-szge04QH/lib/python3.10/site-packages/amqp/transport.py", line 637, in _read
    raise OSError('服务器意外关闭连接')
OSError: 服务器意外关闭连接</code>

登录后复制

RabbitMQ是通过Docker Compose启动的，相关的配置如下：

<code>services:
  rabbitmq3-management:
    restart: always
    container_name: rabbitmq3-management
    image: rabbitmq:4.0.5-management
    hostname: rabbitmq3-management-standalone
    logging:
      driver: json-file
      options:
        max-size: "100m"
        max-file: "1"
    environment:
      - RABBITMQ_DEFAULT_USER=ponponon
      - RABBITMQ_DEFAULT_PASS=ponponon
    volumes:
      - "./volumes:/var/lib/rabbitmq"
      - "./rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf"
    ports:
      - "5672:5672"
      - "15672:15672"
      - "15692:15692"</code>

登录后复制

问题分析

从日志和配置来看，这种频繁断连的问题可能与RabbitMQ 4.0版本的某些新特性或变更有关。心跳机制已经设置好，但依然出现这种情况，可能是以下原因导致的：

心跳超时设置：RabbitMQ 4.0可能对心跳超时的处理有所改变，导致连接每隔一段时间就被关闭。可以尝试调整心跳超时时间，看是否能解决问题。
网络问题：虽然没有明确的网络问题，但ECONNRESET错误可能与网络连接不稳定有关。检查网络环境是否稳定，以及是否有防火墙或网络设备导致连接中断。
客户端库问题：使用nameko eventlet kombu amqp的组合，可能存在与RabbitMQ 4.0不兼容的问题。检查这些库的最新版本是否有针对RabbitMQ 4.0的更新。
RabbitMQ配置问题：检查RabbitMQ的配置文件，看是否有与连接相关的设置需要调整。例如，检查是否有关于连接超时或心跳的配置项。

解决方案

调整心跳超时：在RabbitMQ的配置文件中，尝试增加心跳超时时间。例如，可以在rabbitmq.conf中添加：

PPT.CN,PPTCN,PPT.CN是什么,PPT.CN官网,PPT.CN如何使用
一键操作，智能生成专业级PPT

37

查看详情
```
<code> heartbeat = 60</code>
```
登录后复制
这将心跳间隔设置为60秒，尝试是否能改善连接稳定性。
升级客户端库：确保使用的最新版本的nameko、eventlet、kombu和amqp库。这些库可能已经修复了与RabbitMQ 4.0相关的问题。
网络环境检查：排查网络环境，确保没有防火墙或其他网络设备导致连接中断的问题。
RabbitMQ日志分析：查看RabbitMQ的日志，了解是否有其他与连接相关的信息，这些信息可能有助于进一步诊断问题。