Socket.IO配置PostgreSQL适配器跨节点不同步、关联表无数据排查

首先纠正核心认知偏差：

socket_io_attachments 表长期为空属于正常运行状态，绝非同步失效的表现。
该表的作用不是持久化全量房间、连接映射数据，仅用于临时存储单条大小超过PostgreSQL NOTIFY通道载荷上限（默认8000字节）的大消息二进制分片。常规尺寸的实时消息、事件通知全部走PG的LISTEN/NOTIFY内存级发布订阅通道传输，完全不会写入磁盘表；即便是大消息分片，投递完成后也会被适配器立即清理，你观察到的定期DELETE操作就是清理逻辑在正常运行。

你代码中存在的明确问题 #

• 异步建表未等待完成：你调用sequelize.query执行建表语句时没有加await，存在启动时序问题——适配器初始化时表可能还未创建完成，会触发适配器静默初始化失败，不会抛出显性错误。
  修复方式：建表逻辑加await，确认表创建完成后再初始化适配器：

  const startSocketIo = async function (server) { // 函数改为async
    await sequelize.query(`
    CREATE TABLE IF NOT EXISTS socket_io_attachments (
        id          bigserial UNIQUE,
        created_at  timestamptz DEFAULT NOW(),
        payload     bytea
    );
  `);
    io = new Server(server);
    io.adapter(createAdapter(sequelize));
    // 剩余原有逻辑...
  

• 跨节点房间/客户端查询方式完全错误：你通过const clients = await io.sockets.adapter.rooms获取全量映射的写法，拿到的永远是当前服务器节点本地内存维护的房间与Socket ID关系，适配器不会主动把其他节点的连接数据同步到这个本地属性里。
  要获取集群全量数据必须调用适配器提供的专用异步API：
  • 获取全集群所有房间列表：await io.of('/').adapter.allRooms()
  • 获取指定房间内全集群所有Socket ID：await io.in(目标房间ID).allSockets()
    直接读取本地rooms属性永远看不到其他节点的连接信息，这也是你误以为同步失效的核心误判原因。

剩余配置排查项 #

如果修复以上问题后仍不通，逐一核对以下配置：

• 两台业务服务器传入createAdapter的配置参数必须完全一致：包括自定义通道名（默认值为socket.io，未修改则无需处理）、表名配置（默认和你手动建的socket_io_attachments一致即可）、Sequelize连接的数据库与schema必须完全相同，不要出现连同一个PG实例但逻辑库不同的情况。
• 验证功能不要靠查表、读本地rooms属性判断，直接做端到端测试：在A服务器节点连接一个客户端加入房间cross_node_test，在B服务器节点执行io.to('cross_node_test').emit('test', 'hello')，查看A节点的客户端是否能收到消息。PostgreSQL适配器不会主动同步全量连接元数据到所有节点，只有在发送消息时才会通过NOTIFY通道广播事件，持有对应房间连接的节点收到事件后会在本地完成消息投递。
• 确认两台服务器的Sequelize连接都没有禁用LISTEN/NOTIFY相关权限，PG的发布订阅功能需要连接拥有对应权限才能正常工作。

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