Socket.io Redis适配器中fetchSockets方法的使用注意事项

在使用Socket.io的Redis适配器时，开发者可能会遇到一个常见问题：当多个服务器实例连接到同一个Redis集群时，调用fetchSockets方法可能无法正确返回所有连接的客户端。这个问题看似复杂，但其实原因很简单，解决方案也很直接。

问题现象

在多服务器部署场景下，开发者期望通过fetchSockets方法获取所有服务器上的客户端连接信息。然而实际测试发现，该方法只返回了当前服务器上的连接信息，而没有包含其他服务器上的连接。

问题根源

这个问题的根本原因在于Redis客户端实例的共享。很多开发者会创建一个全局的Redis客户端实例，然后在所有服务器实例间共享使用。这种做法会导致Redis适配器无法正确区分不同服务器实例的消息。

解决方案

正确的做法是为每个Socket.io服务器实例创建独立的Redis客户端连接。具体实现方式如下：

async function createSocketServer() {
    // 为每个服务器实例创建独立的Redis客户端
    const pubClient = new Redis(process.env.REDIS_EXT_URL);
    const subClient = pubClient.duplicate();
    
    const httpServer = createServer();
    const io = new Server(httpServer, {
        adapter: createAdapter(pubClient, subClient)
    });
    
    // 其他服务器初始化代码...
}

技术原理

Redis适配器通过发布/订阅机制实现多服务器间的通信。当使用共享的Redis客户端时：

1. 消息路由会变得混乱
2. 服务器无法正确识别消息来源
3. 响应消息可能被错误处理

为每个服务器创建独立连接确保了：

1. 消息通道隔离
2. 响应能正确路由回请求方
3. 服务器实例间的通信清晰有序

对比PostgreSQL适配器

有趣的是，这个问题在使用PostgreSQL适配器时不会出现。这是因为PostgreSQL适配器的实现机制不同：

1. 使用表存储而非发布/订阅
2. 消息处理方式更加结构化
3. 天然支持多消费者模式

最佳实践

1. 始终为每个服务器实例创建独立的Redis连接
2. 避免在服务器间共享Redis客户端
3. 合理配置连接池大小
4. 注意连接资源的释放

总结

通过为每个Socket.io服务器实例创建独立的Redis连接，可以确保fetchSockets方法在多服务器环境下正常工作。这个解决方案不仅简单有效，也符合分布式系统设计的基本原则。理解不同适配器的实现差异，有助于开发者在不同场景下做出正确的技术选择。