使用Node.js Cluster模块扩展WebSocket服务器多核性能利用方法【教程】-js教程-PHP中文网

node.js cluster模块可扩展websocket服务器，但必须在每个worker中显式监听upgrade事件、独立创建ws.server实例，并借助redis等外部存储实现跨进程状态共享与消息广播，否则将出现400错误、心跳中断或连接不均等问题。

使用node.js cluster模块扩展websocket服务器多核性能利用方法【教程】

直接上结论：Node.js cluster 模块能扩展 WebSocket 服务器，但必须绕过默认的连接分发陷阱——否则会出现连接被拒绝、升级失败、心跳中断等现象。关键不是“能不能用”，而是“怎么让每个 worker 正确处理 upgrade 事件”。

WebSocket 服务器在 cluster 下报 EADDRINUSE 或 400 错误

这是最常见症状：启动多个 worker 后，客户端发起 ws:// 连接时返回 400，或日志里反复出现 Error: listen EADDRINUSE: address already in use :::3000。根本原因不是端口冲突，而是 HTTP 服务器在收到 Upgrade 请求时，没有在所有 worker 中统一注册监听逻辑。

HTTP 服务可以靠操作系统自动负载均衡，但 WebSocket 升级请求（Connection: upgrade + Upgrade: websocket）必须由**同一个 worker 完成整个生命周期**：从接收 upgrade、握手、到后续帧收发
如果主进程把 upgrade 请求随机分给某个 worker，而该 worker 没有绑定 server.on('upgrade', ...)，就会直接返回 400
http.createServer() 默认不处理 upgrade，必须显式监听；且这个监听必须在每个 worker 内部完成，不能只在 master 做

worker 中必须手动监听 upgrade 事件并透传给 ws.Server

使用 ws 库（如 ws 或 uWebSockets.js）时，不能只靠 wsServer = new WebSocketServer({ server }) 就完事。因为 server 是共享的，但 upgrade 事件不会自动广播到所有 worker —— 它只会触发在实际接收到该请求的那个 worker 上。

Wjs Uploading Video

将一个或多个视频上传至YouTube。当用户想“上传到YouTube”“发YouTube”“批量上传”“upload to YouTube”“post videos to YouTube”或发布到YouTube时使用此技能。

下载

每个 worker 都要独立创建 ws.Server 实例，并在自己的 http.Server 上监听 upgrade
正确写法是：在 else 分支（worker 进程）中，先调用 server.on('upgrade', (req, socket, head) => { ... })，再把 socket 和 req 手动传给 wsServer.handleUpgrade()
示例片段（基于官方 ws）：

const WebSocket = require('ws');
const http = require('http');

if (cluster.isMaster) {
  // fork logic...
} else {
  const server = http.createServer();
  const wss = new WebSocket.Server({ noServer: true });

  server.on('upgrade', (req, socket, head) => {
    wss.handleUpgrade(req, socket, head, (ws) => {
      wss.emit('connection', ws, req);
    });
  });

  server.listen(3000);
}

stateless 设计 + 外部 session 共享是 cluster 下 WebSocket 的硬性前提

每个 worker 有独立内存，无法靠 Map 或全局变量存 client 列表。一旦你尝试在某个 worker 里 broadcast()，其他 worker 的连接就收不到消息 —— 这不是 bug，是 cluster 的设计事实。

所有会话状态（用户 ID、房间归属、心跳时间戳）必须落地到外部存储：Redis 是最常用选择，用 redis-pubsub 或 redis-streams 实现跨 worker 广播
避免在 worker 内部做“全量 client 遍历”，改用 Redis 的 PUBLISH/PSUBSCRIBE 机制中转消息
连接数统计、踢人、房间列表等操作，必须通过原子命令（如 INCR, SADD, SMEMBERS）协调，不能依赖本地缓存
如果用了 ws 库的 wss.clients，它只返回当前 worker 的连接，对集群无效