Socket.io客户端在Node.js长耗时任务处理时自动断开问题咨询

根因定位 #

最核心的触发原因是Heroku平台的路由层闲置超时规则：Heroku公共路由对所有WebSocket连接默认设置了55秒闲置超时，只要连接在55秒内没有双向通信，路由就会主动切断连接，完全符合你遇到的无规律断开、无固定触发节点、非客户端主动断开的特征。
另外有两个常见诱因会放大该问题：

• Socket.io服务端、客户端的心跳保活参数配置不合理，没有在Heroku超时阈值前完成保活交互
• 任务处理过程中Node.js事件循环被异常代码阻塞，无法及时响应Socket.io心跳请求，被判定为连接失效

修复步骤 #

1. 调整Socket.io心跳配置 #

服务端初始化时显式配置心跳参数，将保活周期控制在Heroku的55秒阈值以内：

const io = require('socket.io')(server, {
  pingInterval: 25000, // 每25秒主动向客户端发心跳包
  pingTimeout: 20000, // 超过20秒没收到客户端心跳响应则判定连接断开
});

Swift客户端同步调整配置，强制使用WebSocket协议避免被降级为长轮询，同时保持心跳响应逻辑：

self.manager = SocketManager(socketURL: URL(string: socketUrlString)!, config: [
  .log(false), 
  .reconnects(true), 
  .extraHeaders(["header": "customheader"]),
  .forceWebsockets(true) // 强制走WebSocket协议，避免长轮询被路由主动切断
])

2. 补充业务层兼容逻辑 #

你的任务最长执行时间为15秒，现有逐阶段发送Processing事件的机制理论上已经能满足保活要求，补充两个兜底逻辑即可覆盖异常场景：

• 客户端重连后主动上报关联任务：Socket重连成功后，客户端将本地存储的待处理jobID和新的SocketID发送到服务端，服务端更新ID映射，避免任务执行完成后向失效的旧SocketID发通知
• 接口轮询兜底：客户端拿到jobID后，就算Socket断开也启动定时轮询，每2秒调用一次/poll接口拉取结果，不唯一依赖Socket的完成事件通知

3. 修复代码已知异常 #

现有队列处理逻辑中存在数组操作bug，可能触发死循环、内存溢出，阻塞Node.js事件循环导致心跳无法响应：

// 原有问题代码
for (a of array) {
  let difference = getDifference(title, subtitle, a.title, a.subtitle)
  if (difference <= 10) {
    array.push(a) // 向正在遍历的数组中插入元素，会导致遍历无限进行
  }
}
// 修复为向结果数组中插入
for (a of array) {
  let difference = getDifference(title, subtitle, a.title, a.subtitle)
  if (difference <= 10) {
    array2.push(a)
  }
}

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