调用connection.channel()时触发pike.exception.StreamLostError问题求助

• 修复代码变量名错误
  你的代码存在变量名不匹配问题：创建的连接对象是c = pika.BlockingConnection(p)，但调用channel = connection.channel()时使用了未定义的connection变量，这会直接引发异常。修正为：

  p = pika.ConnectionParameters('localhost')
  c = pika.BlockingConnection(p)
  channel = c.channel()  # 使用定义好的连接对象c
  

• 检查Erlang与RabbitMQ版本兼容性
  RabbitMQ 3.11.16的官方兼容Erlang版本范围是24.3.4.8至25.3.2.6，你使用的Erlang 26.0不在兼容列表内，这是导致连接异常的核心原因之一。解决方式二选一：

  • 降级Erlang到25.x系列（推荐25.3.2.6）
  • 升级RabbitMQ到3.12及以上版本（3.12+开始支持Erlang 26）

• 验证RabbitMQ服务状态

  • 确保RabbitMQ服务正在本地运行，可执行rabbitmqctl status命令（Windows需进入RabbitMQ安装目录的sbin文件夹执行）检查服务状态
  • 确认默认端口5672未被其他进程占用，可通过netstat -ano | findstr :5672（Windows）或lsof -i :5672（Linux）排查端口占用情况

• 优化连接参数配置
  显式配置心跳、超时等参数，提升连接稳定性：

  p = pika.ConnectionParameters(
      host='localhost',
      port=5672,
      heartbeat=600,  # 设置心跳时间为600秒
      blocked_connection_timeout=300  # 设置阻塞超时为300秒
  )
  c = pika.BlockingConnection(p)
  channel = c.channel()
  

• 排查防火墙/安全软件拦截
  本地防火墙、杀毒软件可能拦截了RabbitMQ的5672端口，需将RabbitMQ进程或5672端口加入允许列表，确保连接请求能正常收发。

• 重置RabbitMQ节点（可选）
  如果服务运行状态异常，可尝试重置节点：

  1. 停止RabbitMQ服务：rabbitmqctl stop
  2. 删除RabbitMQ数据目录（Windows默认路径：C:\Users\<你的用户名>\AppData\Roaming\RabbitMQ\db；Linux默认路径：/var/lib/rabbitmq/mnesia）
  3. 重新启动RabbitMQ服务：rabbitmq-server start

内容的提问来源于stack exchange，提问作者Rony Tesler