RabbitMQ-Stomp插件搭配Spring Stomp应用内存异常高问题求助

核心原因定位 #

119225个队列远超预期，这是内存居高不下的直接原因。RabbitMQ的Stomp插件会为每个Stomp订阅创建专属临时队列（默认自动删除，但前提是订阅者正常断开），如果客户端连接异常中断、订阅未正常取消，这些队列可能无法被自动清理，长期积累就会占用大量内存。

排查步骤 #

1. 确认队列类型与归属 #

• 用RabbitMQ命令行工具查看队列详情：

  rabbitmqctl list_queues name auto_delete exclusive
  

  重点看auto_delete是否为true（Stomp订阅默认创建自动删除队列），如果大量队列auto_delete为false，说明订阅逻辑可能存在自定义配置问题。
• 关联队列到Stomp连接：

  rabbitmqctl list_connections name protocol peer_host
  rabbitmqctl list_queues name owner_pid
  

  通过owner_pid匹配连接，确认是否有大量僵尸连接对应的队列未被清理。

2. 检查Spring Stomp客户端的连接/订阅释放逻辑 #

• 确认客户端断开时是否主动取消订阅：Spring Stomp的StompSession必须调用unsubscribe()取消订阅，否则服务器不会触发队列删除。
• 检查异常场景处理：客户端崩溃、网络中断时，RabbitMQ的连接超时配置是否生效。在rabbitmq.conf中确认：

  heartbeat = 60
  connection_timeout = 3600000
  

  心跳超时设置过长的话，服务器无法及时检测到死连接，队列会一直保留。

3. 验证Stomp插件的队列清理机制 #

Stomp插件的临时队列默认满足以下条件会自动删除：

• 队列是auto_delete且最后一个消费者断开
• 队列是exclusive且创建它的连接关闭
  如果队列未被清理，大概率是：
• 连接未被正确标记为关闭（Erlang进程泄漏）
• 队列被意外设置为非自动删除（比如客户端订阅时指定了持久化队列）

临时解决与长期优化 #

临时释放内存 #

• 批量清理无消费者的自动删除队列：

  rabbitmqctl list_queues name consumers | grep -E '^\S+\s+0$' | awk '{print $1}' | xargs -I {} rabbitmqctl delete_queue {}
  

  注意：仅清理确认无业务价值的队列，避免误删正在使用的队列。

长期优化 #

1. 客户端订阅规范：
   • 所有Stomp订阅必须在断开前主动取消，Spring应用中可通过@PreDestroy或Disconnect事件触发unsubscribe。
   • 除非业务明确需要，否则不要创建持久化Stomp队列。
2. RabbitMQ配置调优：
   • 缩短心跳超时时间，让服务器更快检测死连接：

     heartbeat = 30
     connection_timeout = 1800000
     

   • 启用队列自动过期：为Stomp队列设置x-expires参数（可通过插件或客户端订阅时指定），比如1小时无消费者则自动删除：

     // Spring Stomp客户端订阅时指定队列参数
     StompHeaders headers = new StompHeaders();
     headers.setDestination("/topic/your-topic");
     headers.set("x-expires", "3600000");
     session.subscribe(headers, new YourStompFrameHandler());
     

3. 监控告警：
   • 配置RabbitMQ监控，当队列数量超过阈值（比如1万）时触发告警，及时发现异常。
   • 定期检查Erlang进程数量，排查是否存在连接/队列进程泄漏。

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