Socket.IO客户端重连后无法接收事件的问题求助

核心问题说明 #

Socket.IO v4 默认仅在客户端侧实现了离线消息缓存（即客户端离线时发送的消息会被暂存，重连后自动提交到服务端），但服务端没有内置的针对单个客户端的发送缓冲区。所以客户端离线期间，服务端主动推送的消息会直接丢弃，重连后无法收到。

解决方案 #

要实现离线消息的可靠投递，需要自行实现消息持久化与重连后的补发逻辑，具体步骤如下：

1. 为客户端绑定稳定唯一标识 #

给每个客户端分配一个不会随重连变化的唯一ID（比如用户登录后的UID），用来关联对应的离线消息队列。避免依赖socket.id，因为重连后该值会改变。

示例代码（服务端）：

io.on('connection', (socket) => {
  // 客户端登录时提交用户UID
  socket.on('login', (userUid) => {
    socket.data.userUid = userUid;
    // 重连后立即补发离线消息
    pushOfflineMessages(userUid, socket);
  });
});

2. 实现离线消息存储逻辑 #

当检测到目标客户端离线时，将需要推送的消息存储到持久化介质中（小体量服务可用内存缓存，生产环境推荐用Redis或数据库）。

示例代码（服务端，基于Redis）：

const redis = require('redis');
const redisClient = redis.createClient();

async function sendToUser(userUid, eventName, payload) {
  // 先查询该用户的在线Socket连接
  const onlineSockets = getOnlineSocketsByUid(userUid);
  if (onlineSockets.length > 0) {
    onlineSockets.forEach(socket => socket.emit(eventName, payload));
  } else {
    // 客户端离线，将消息存入Redis队列
    await redisClient.rPush(`offline:${userUid}`, JSON.stringify({
      event: eventName,
      data: payload,
      timestamp: Date.now()
    }));
  }
}

3. 重连时补发离线消息 #

客户端重连并完成身份绑定后，服务端从存储介质中取出该用户的离线消息，逐一推送，推送完成后清空对应的离线队列。

示例代码（服务端）：

async function pushOfflineMessages(userUid, socket) {
  const messageKey = `offline:${userUid}`;
  const offlineMessages = await redisClient.lRange(messageKey, 0, -1);
  
  if (offlineMessages.length > 0) {
    offlineMessages.forEach(msgStr => {
      const { event, data } = JSON.parse(msgStr);
      socket.emit(event, data);
    });
    // 清空已推送的离线消息
    await redisClient.del(messageKey);
  }
}

4. 关键优化点 #

• 消息过期策略：为离线消息设置过期时间（比如Redis的EXPIRE命令），避免存储大量无效历史消息。
• 幂等性处理：给每个消息添加唯一ID，客户端本地记录已处理的消息ID，避免重复处理。
• 在线状态维护：监听socket.disconnect事件标记用户为离线，socket.connect事件标记为在线，确保消息存储逻辑触发准确。
• 批量推送控制：若离线消息过多，分批次推送，避免一次性发送大量消息导致连接不稳定。

补充说明 #

官方聊天示例中客户端离线发送的消息能重连后送达，是因为Socket.IO客户端默认开启了reconnection和autoConnect，客户端会将离线期间的socket.emit()调用缓存到本地队列，重连成功后自动提交给服务端。但该逻辑仅针对客户端发往服务端的消息，服务端到客户端的推送没有内置缓存机制，因此需要自行实现离线消息补发逻辑。

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