
探讨RabbitMQ 4.0升级后频繁断连的问题
在使用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 4.0可能对心跳超时的处理有所改变,导致连接每隔一段时间就被关闭。可以尝试调整心跳超时时间,看是否能解决问题。网络问题:虽然没有明确的网络问题,但ECONNRESET错误可能与网络连接不稳定有关。检查网络环境是否稳定,以及是否有防火墙或网络设备导致连接中断。客户端库问题:使用nameko eventlet kombu amqp的组合,可能存在与RabbitMQ 4.0不兼容的问题。检查这些库的最新版本是否有针对RabbitMQ 4.0的更新。RabbitMQ配置问题:检查RabbitMQ的配置文件,看是否有与连接相关的设置需要调整。例如,检查是否有关于连接超时或心跳的配置项。
解决方案
调整心跳超时:在RabbitMQ的配置文件中,尝试增加心跳超时时间。例如,可以在rabbitmq.conf中添加:
heartbeat = 60
这将心跳间隔设置为60秒,尝试是否能改善连接稳定性。
升级客户端库:确保使用的最新版本的nameko、eventlet、kombu和amqp库。这些库可能已经修复了与RabbitMQ 4.0相关的问题。
网络环境检查:排查网络环境,确保没有防火墙或其他网络设备导致连接中断的问题。
RabbitMQ日志分析:查看RabbitMQ的日志,了解是否有其他与连接相关的信息,这些信息可能有助于进一步诊断问题。
通过以上步骤,应该能够找到导致RabbitMQ 4.0版本升级后频繁断连的原因,并采取相应的措施解决问题。
以上就是为什么RabbitMQ升级到4.0版本后会频繁断连?如何解决?的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1360668.html
微信扫一扫
支付宝扫一扫