首先得戳中核心痛点：PM2的集群模式会启动多个完全独立的Node.js进程，每个进程跑自己的WebSocket服务器实例。用户的WebSocket连接只会和其中一个进程绑定，其他进程根本感知不到这个连接的存在——这就是你担心的资源浪费、跨实例通信障碍的根源。

要解决问题，我们完全不需要让每个实例都持有所有用户的连接（这确实是毫无意义的资源消耗），而是需要一个全局消息中间层来实现实例间的通信和连接状态同步。下面是几种成熟且实用的解决方案：

1. 用Redis Pub/Sub实现跨实例消息转发 #

Redis的发布/订阅模式是轻量级方案里的首选，它能让所有Node实例共享统一的消息通道：

• 每个Node实例启动时，都连接到同一个Redis服务器，并订阅指定的消息频道（比如ws-cross-instance）。
• 当某个实例收到用户的WebSocket消息时，先处理本地业务逻辑，再把需要跨实例传递的消息发布到Redis频道。
• 其他实例收到Redis的消息后，根据消息内容（比如目标用户ID、广播指令），推送给自己管理的客户端连接。

简单代码示例： #

const Redis = require('ioredis');
const WebSocket = require('ws');

// 分别创建发布和订阅的Redis客户端
const redisPub = new Redis();
const redisSub = new Redis();

// 订阅跨实例消息频道
redisSub.subscribe('ws-cross-instance', (err, count) => {
  if (err) console.error('Redis订阅失败:', err);
});

// 收到跨实例消息时，推送给本地对应用户
redisSub.on('message', (channel, message) => {
  const data = JSON.parse(message);
  // 用Map存储本地的用户连接：userId => ws实例
  if (userConnections.has(data.userId)) {
    userConnections.get(data.userId).send(data.content);
  }
});

// 启动WebSocket服务器
const wss = new WebSocket.Server({ port: 8080 });
const userConnections = new Map();

wss.on('connection', (ws, req) => {
  const userId = req.url.split('=')[1]; // 假设从URL参数获取用户ID
  userConnections.set(userId, ws);

  ws.on('message', (data) => {
    const message = JSON.parse(data);
    // 需要跨实例发送的消息，发布到Redis
    if (message.needCrossInstance) {
      redisPub.publish('ws-cross-instance', JSON.stringify({
        userId: message.targetUserId,
        content: message.content
      }));
    } else {
      // 仅本地处理的消息，直接回应
      ws.send(JSON.stringify({ status: 'ok', content: message.content }));
    }
  });

  ws.on('close', () => {
    userConnections.delete(userId);
  });
});

这种方案的优势是轻量、灵活，每个实例只维护自己接收的连接，资源占用和实例负责的用户数成正比，完全不会出现重复加载的问题。

2. 使用Socket.io的Redis适配器（开箱即用） #

如果你用Socket.io来实现WebSocket功能，那官方提供的@socket.io/redis-adapter适配器可以直接帮你搞定跨实例问题：

• 这个适配器会自动把所有Socket.io的连接状态、消息广播同步到Redis，让所有Node实例共享同一个连接池视图。
• 你不需要手动处理Redis的Pub/Sub逻辑，Socket.io会自动完成跨实例的消息转发。

配置示例： #

const express = require('express');
const http = require('http');
const { Server } = require('socket.io');
const { createAdapter } = require('@socket.io/redis-adapter');
const { createClient } = require('redis');

const app = express();
const server = http.createServer(app);
const io = new Server(server);

// 创建Redis客户端
const pubClient = createClient({ url: 'redis://localhost:6379' });
const subClient = pubClient.duplicate();

// 连接Redis后配置适配器
Promise.all([pubClient.connect(), subClient.connect()]).then(() => {
  io.adapter(createAdapter(pubClient, subClient));
});

// 正常使用Socket.io即可，跨实例广播自动生效
io.on('connection', (socket) => {
  console.log('用户连接:', socket.id);
  
  // 广播消息会自动发送到所有实例的客户端
  socket.broadcast.emit('user-connected', socket.id);
  
  socket.on('private-message', (data) => {
    // 给指定用户发消息，无论用户连接到哪个实例
    io.to(data.targetSocketId).emit('message', data.content);
  });
});

server.listen(8080, () => {
  console.log('服务器启动在8080端口');
});

这个方案最省心，适合用Socket.io的场景，完全不需要自己处理底层的跨实例通信逻辑。

关键注意事项 #

• 不要尝试在实例间直接共享连接对象：Node.js进程间的内存是完全隔离的，你无法把一个实例的WebSocket连接对象传递给另一个实例，必须通过中间件转发消息。
• 保证Redis的高可用性：Redis是整个系统的枢纽，建议配置Redis哨兵或集群来避免单点故障。
• 用户状态存储：如果需要精准推送消息，可以把用户ID和对应的Socket ID（或实例标识）存在Redis中，这样就能快速定位到用户所在的实例。

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