多Node.js实例下跨实例查找Socket的问题及postgres-adapter使用疑问

• 单实例下用内存Map存储用户与Socket的映射，所有连接都在同一个进程内存里，能直接读取。但多实例部署时，每个Node.js实例都有独立的内存空间，各自的socketTracker完全隔离，当用户连接到实例A，实例B、C、D根本不知道这个映射关系，自然找不到目标Socket ID。

Socket.io的适配器（Adapter）就是专门解决多实例消息同步的组件，postgres-adapter会把实例间需要共享的连接信息、消息通过Postgres的通知机制（LISTEN/NOTIFY）同步，不需要你自己维护跨实例的映射。

1. 配置postgres-adapter #

先安装依赖：

npm install @socket.io/postgres-adapter pg

然后在Socket.io服务初始化时绑定适配器：

const { Server } = require("socket.io");
const { createAdapter } = require("@socket.io/postgres-adapter");
const { Pool } = require("pg");

// 初始化Postgres连接池
const pool = new Pool({
  user: "你的数据库用户名",
  host: "数据库地址",
  database: "数据库名",
  password: "数据库密码",
  port: 5432,
});

// 创建Socket.io服务器
const io = new Server({
  cors: {
    origin: "*", // 根据实际业务配置跨域规则
  },
});

// 绑定postgres适配器，实现实例间同步
io.adapter(createAdapter(pool));

2. 用房间机制替代自定义Map #

postgres-adapter会自动同步所有实例的连接信息，你只需要用Socket.io内置的房间（Room）关联用户ID和Socket：

io.on("connection", (socket) => {
  // 假设用户连接时通过握手参数传递用户ID
  const userId = socket.handshake.auth.userId;
  // 将当前Socket加入以用户ID命名的专属房间
  socket.join(`user:${userId}`);

  // 断开连接时无需手动清理，Socket.io会自动处理房间退出
  socket.on("disconnect", () => {
    console.log(`用户 ${userId} 已断开连接`);
  });
});

3. 跨实例消息转发 #

当需要给目标用户发消息时，直接向对应的用户房间发送即可，postgres-adapter会自动把消息路由到目标用户所在的实例：

io.on("connection", (socket) => {
  socket.on("send_message", (data) => {
    const { targetUserId, content } = data;
    // 向目标用户的专属房间发送消息
    io.to(`user:${targetUserId}`).emit("receive_message", {
      from: socket.handshake.auth.userId,
      content: content,
    });
  });
});

4. 为什么不用自己维护Map？ #

postgres-adapter会在Postgres中统一维护所有实例的连接和房间信息，当某个实例收到消息需要转发时，适配器会通过Postgres的NOTIFY机制通知所有实例，只有持有目标Socket的实例会实际发送消息，其他实例自动忽略。

• 确保Postgres版本在9.0及以上（支持LISTEN/NOTIFY机制）
• 合理配置Postgres连接池参数，避免连接耗尽
• 如果需要更复杂的用户在线状态管理，可以结合Postgres存储状态，但基础的消息转发用适配器+房间机制完全足够

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