为什么WebSocket（ws）会自动断开重连、甚至意外启动多个连接？

问题根因分析 #

1. 多连接触发的核心原因 #

• RxJS 默认创建的是冷Observable：你当前返回的observerStomp没有做共享逻辑，每被subscribe一次就会完整执行一次创建回调里的connect()逻辑，如果项目里有多个地方订阅这个stomp实例，或者同一订阅逻辑被重复触发，就会创建多个WS连接。
• 全局STOMP实例被覆盖：代码里的client、connect()看起来是全局/模块外层定义的变量，不是每次创建连接时内部初始化的独立实例。每次执行Observable创建逻辑时都会覆盖全局的回调函数，导致前面创建的旧连接回调失效，所以只有最后一个连接能正常处理订阅、收发消息，前面的连接会处于无消息传输的悬空状态。
• 销毁逻辑缺失：Observable返回的清理函数只打印了日志，没有实际执行client.disconnect()。如果订阅被取消（比如关联的页面/组件销毁），旧的WS连接不会被主动关闭，还会因为你设置的reconnect_delay=1000自动触发重连，进一步堆积无效连接。

2. 无触发条件重连、订阅丢失的核心原因 #

• STOMP自带的自动重连逻辑未适配业务：你开启了客户端自动重连，但订阅逻辑没有和重连回调绑定，重连后旧的订阅关系不会自动恢复，看起来就像是订阅被凭空取消。
• 上层订阅逻辑被重复执行：如果redux中调用createStompConnection的逻辑没有做单例限制，当redux状态变更、相关逻辑被重复执行时，会直接创建新的连接实例，替换掉旧的连接，导致旧连接的订阅全部失效。

修复建议 #

• 给Observable加共享操作符：用share()或者shareReplay(1)操作符包装返回的observerStomp，让多个订阅共享同一个连接实例，避免重复触发连接逻辑。
• 完善销毁逻辑：把清理函数里的日志替换为client.disconnect()，订阅取消时主动断开连接，避免自动重连堆积。
• 连接实例单例化：要么把client实例的创建放到createStompConnection内部，保证每次调用返回的是独立实例；要么全局只初始化一次连接实例，避免重复创建覆盖回调。
• 重连时自动恢复订阅：把订阅逻辑放到连接成功的回调里，每次重连完成后自动重新执行订阅，避免订阅丢失。

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