RabbitMQ pika心跳异常：ConnectionClosed及AssertionError求助

这种间歇性的连接问题真的挺闹心的，尤其是已经试了常见方案还没解决的情况下，咱们一步步来拆解排查：

一、先解决核心矛盾：RabbitMQ日志的「心跳超时」vs 你设置的心跳为0 #

你已经把心跳设为0（禁用心跳），但RabbitMQ日志却提示因心跳超时关闭连接，这本身就很反常，先从这里突破：

• 确认心跳参数真的生效了：检查代码里创建ConnectionParameters时，heartbeat=0是不是正确传入的，有没有被其他配置覆盖？如果用URL连接字符串，要确保URL里加了heartbeat=0参数，比如amqp://user:pass@host:port/%2F?heartbeat=0。
• 检查RabbitMQ服务器的全局心跳配置：RabbitMQ默认心跳是60秒，如果服务器端通过policy或者配置文件强制设置了心跳时间，会覆盖客户端的设置。可以登录RabbitMQ管理后台，进入「Admin > Policies」看看有没有带heartbeat的规则；或者查看服务器的rabbitmq.conf里的heartbeat配置项。

二、针对ConnectionResetError(104)的排查 #

这个错误本质是TCP连接被主动重置，你的怀疑——和本地电脑有关——是完全合理的，可以从这些方向查：

• 本地网络稳定性：
  • 排查防火墙/杀毒软件：有些安全软件会把闲置的长连接判定为“可疑连接”直接切断，试试临时关闭防火墙和杀毒软件，跑一段时间看问题是否消失。
  • 检查网络环境：如果用Wi-Fi，试试换成有线网络；看看路由器有没有「闲置超时断网」这类设置，有的话暂时关掉。
• 本地进程资源与阻塞：
  • 问题出现时，立刻看本地CPU、内存占用：如果你的应用或者其他进程占满了资源，pika客户端可能连心跳包（哪怕是TCP层面的保活包）都发不出去，最后被RabbitMQ超时断开。
  • 检查代码里的阻塞操作：哪怕你在循环里调用connection.process_data_events()，如果循环里有其他耗时的同步任务（比如大文件读写、复杂计算），也会导致心跳处理被卡住，错过RabbitMQ的心跳检查窗口。

三、处理异常时触发AssertionError的问题 #

这大概率是你在捕获ConnectionClosed异常后，还在操作已经失效的连接/通道对象。给你个优化思路：

• 捕获异常后立刻销毁旧连接：不要复用已经关闭的连接，哪怕你觉得“可能还能用”。
• 重新建立连接时走完整流程：从创建Connection、Channel，到声明队列/交换机，一步都不能省。
• 给你个参考的异常处理代码片段：

  try:
      # 你的消息消费/生产逻辑
      connection.process_data_events(time_limit=1)
  except pika.exceptions.ConnectionClosed as e:
      print(f"连接意外关闭: {e}")
      # 安全关闭旧连接
      if 'connection' in locals() and connection.is_open:
          connection.close()
      # 调用你的重连逻辑
      connection = get_new_connection()
  except AssertionError as ae:
      print(f"断言错误触发: {ae}")
      # 同样清理无效连接
      if 'connection' in locals() and hasattr(connection, 'is_open') and connection.is_open:
          connection.close()
  

四、进阶排查手段 #

• 开启pika调试日志：把pika的日志级别调到DEBUG，能看到客户端和RabbitMQ之间的心跳交互细节，确认心跳包是不是真的没发，或者有没有其他隐藏的连接问题：

  import logging
  logging.basicConfig(level=logging.DEBUG)
  

• 抓包分析：用tcpdump或者Wireshark抓本地5672端口的数据包，看TCP连接的状态变化，有没有FIN/RST包，心跳帧（AMQP协议的心跳包）是不是正常传输。这能直接定位是客户端没发心跳、网络丢包，还是服务器主动断开。
• 跨机器测试：如果条件允许，把代码部署到另一台机器（比如云服务器）连接同一个RabbitMQ实例，看问题会不会复现。如果其他机器上没问题，那基本可以确定是本地电脑的环境/网络问题。

总结 #

优先排查这几个方向：心跳配置是否真的生效、本地网络/安全软件是否拦截连接、代码里有没有阻塞心跳处理的耗时操作。从易到难一步步来，应该能找到问题根源。

内容的提问来源于stack exchange，提问作者Alan Abishev