在使用RabbitMQ时,升级到4.0版本后,许多用户可能会遇到AMQP连接每3分钟重连一次的问题。之前使用RabbitMQ 3.x时,连接是稳定的,但在升级到4.x后,使用nameko eventlet kombu amqp的组合时,会频繁出现断连情况,尽管有自动重连机制,但依然令人烦恼。
断连日志显示了两种情况:
第一种情况:
尝试连接到代理时出错,地址为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)。
第二种情况:
与代理的连接丢失,正在尝试重新建立连接... 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: 服务器意外关闭连接
RabbitMQ是通过Docker Compose启动的,相关的配置如下:
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"
从日志和配置来看,这种频繁断连的问题可能与RabbitMQ 4.0版本的某些新特性或变更有关。心跳机制已经设置好,但依然出现这种情况,可能是以下原因导致的:
调整心跳超时:在RabbitMQ的配置文件中,尝试增加心跳超时时间。例如,可以在rabbitmq.conf中添加:
heartbeat = 60
这将心跳间隔设置为60秒,尝试是否能改善连接稳定性。
升级客户端库:确保使用的最新版本的nameko、eventlet、kombu和amqp库。这些库可能已经修复了与RabbitMQ 4.0相关的问题。
网络环境检查:排查网络环境,确保没有防火墙或其他网络设备导致连接中断的问题。
RabbitMQ日志分析:查看RabbitMQ的日志,了解是否有其他与连接相关的信息,这些信息可能有助于进一步诊断问题。
通过以上步骤,应该能够找到导致RabbitMQ 4.0版本升级后频繁断连的原因,并采取相应的措施解决问题。
以上就是为什么RabbitMQ升级到4.0版本后会频繁断连?如何解决?的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号