Node.js用sticky-session时Worker崩溃致全局崩溃，报错ERR_IPC_CHANNEL_CLOSED

我来帮你梳理这个问题的排查思路和解决方案——你遇到的情况是sticky-session没有在Worker进程退出时自动重启新进程，还触发了ERR_IPC_CHANNEL_CLOSED错误，导致整个应用崩溃。下面是具体的分析和修复步骤：

一、核心问题：主进程未正确监听Worker退出事件 #

很多时候sticky-session不会自动处理Worker的重启逻辑，需要你在主进程中显式监听exit事件并手动fork新的Worker。

修复后的主进程+Worker示例代码 #

const cluster = require('cluster');
const sticky = require('sticky-session');
const express = require('express');

// 初始化服务器
const app = express();
const server = require('http').Server(app);

if (!sticky.listen(server, 3000)) {
  // 主进程逻辑：负责管理Worker
  console.log(`Master process ${process.pid} started`);

  // 监听Worker退出事件，立即重启新Worker
  cluster.on('exit', (worker, code, signal) => {
    console.log(`Worker ${worker.process.pid} exited (code: ${code}, signal: ${signal})`);
    console.log('Starting new worker...');
    cluster.fork();
  });

  // 捕获主进程未处理的异常，避免整个应用崩溃
  process.on('uncaughtException', (err) => {
    console.error(`Master process uncaught exception:`, err);
  });

} else {
  // Worker进程逻辑：启动socket.io和业务代码
  const io = require('socket.io')(server);

  console.log(`Worker process ${process.pid} started`);

  io.on('connection', (socket) => {
    console.log(`emitting message: adad . socket.id=${socket.id} . pid = ${process.pid}`);
    // 你的业务逻辑...
  });

  // Worker进程捕获异常，主动退出触发主进程重启
  process.on('uncaughtException', (err) => {
    console.error(`Worker ${process.pid} uncaught exception:`, err);
    process.exit(1);
  });
}

二、解决ERR_IPC_CHANNEL_CLOSED错误 #

这个错误是因为主进程尝试和已经退出的Worker进行IPC通信导致的。你需要在发送IPC消息前检查Worker的存活状态：

// 假设你有向Worker发送消息的逻辑
if (worker.isConnected()) {
  worker.send('your-message');
} else {
  console.log(`Worker ${worker.process.pid} is disconnected, skipping message`);
}

三、额外优化建议 #

1. 升级sticky-session版本
   旧版本的sticky-session可能存在Worker重启的兼容性bug，执行npm update sticky-session升级到最新版。

2. 配置socket.io优先使用WebSocket
   sticky-session基于IP哈希绑定连接到Worker，轮询模式可能导致连接错乱，建议强制使用WebSocket传输：

   const io = require('socket.io')(server, {
     transports: ['websocket']
   });
   

3. 测试验证
   手动杀死某个Worker进程后，查看主进程日志是否输出Worker xxx exited和Starting new worker...，同时检查系统进程列表是否有新的Worker进程启动。

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