使用MQTT.js建立MQTT over WS连接RabbitMQ数分钟后断开问题咨询

问题根因 #

该问题是浏览器端MQTT.js的常见场景问题，和Node端运行逻辑的差异主要来自两个方面：

1. 浏览器后台标签页的定时器降频策略：当标签页被切到后台时，浏览器为了节省资源会将setTimeout/setInterval的最小执行间隔限制为1分钟，如果你设置的keepalive低于30秒，后台定时器触发延迟会导致ping发送间隔超过RabbitMQ的超时阈值。
2. MQTT.js浏览器端的ping调度逻辑缺陷：v4.2.x~v4.3.1版本的默认配置下，每次收到服务端消息就会重置ping定时器，高频消息场景下会出现定时器始终无法触发，导致ping停止发送的问题。

可用解决方案 #

按优先级选择即可：

• 调整配置参数：连接时将reschedulePings设为false，关闭收到消息重置ping定时器的逻辑，同时将keepalive调整为45秒以上，适配浏览器后台定时器的最小间隔限制。参考连接配置：

const mqttClient = mqtt.connect('ws://RabbitMQ服务地址:15675/ws', {
  keepalive: 45,
  reschedulePings: false,
  // 其他鉴权、clientId等配置保持不变
})

同时建议将RabbitMQ web_mqtt插件的超时阈值调整为keepalive值的1.5倍，避免网络波动导致的误判。

• 升级依赖版本：将MQTT.js升级到v4.3.2以上版本，该版本修复了浏览器端ping定时器调度异常的已知bug。
• 自定义ping逻辑：如果必须使用低于30秒的keepalive，可将MQTT.js的keepalive参数设为0关闭自带保活，改用Web Worker独立运行ping定时器（Web Worker的定时器不受标签页后台降频影响），主动调用client.ping()发送保活请求。

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