多用户同时登录时私有消息列表显示异常问题排查

问题描述 #

我开发了一款私有消息应用，用户登录后可查看私有消息。当前遇到的问题是：同一时间仅能显示一位登录用户的消息列表。例如用户A登录后显示其消息列表，当用户B登录后，A和B都会显示用户B的消息列表。

后端使用Express，获取指定用户聊天记录的服务端代码如下：

io.on('connection', socket => {
  socket.on('findAllChatsByUserId', (userId) => {
    socket.userId = userId
    socket.join(socket.userId)
    ChatModel.aggregate([{$match: {$or:[{senderId: userId},{receiver: userId}]}}, {$group: {_id:     '$chatId', 'data': {$last: '$$ROOT'}}}]).exec(function(error, data) {
      if (error) {
        return error
      } else {
        data.sort(function (a, b) {
          return b.data.date - a.data.date;
        });
        io.to(socket.userId).emit('findAllChatsByUserId', data);
      }
    })
  })
});

前端使用Vue.js，客户端代码如下：

mounted () {
  this.loading = true
  this.socket.emit('findAllChatsByUserId', this.getUserId) // this calls the socket to get the chats for the given user Id
  this.loading = false
},

我尝试通过userId创建Socket.io房间来确保仅传递对应用户的数据，但似乎同一时间仅能有一位用户使用socket。本以为房间能解决该问题，请问是否需要为每个用户创建单独的socket？如果需要，该如何实现？我参考过Socket.io私有消息教程，但该教程仅以两位用户互发消息为例进行说明。

问题根源 #

不需要为每个用户创建单独的Socket.io连接——Socket.io本身会为每个客户端连接生成独立的socket实例。你遇到的串号问题，核心原因有两个：

1. 消息发送目标错误：使用io.to(socket.userId).emit会把消息发送到所有加入该userId房间的socket，若同一个socket被多个用户复用（比如单页应用切换账号未断开旧连接），旧用户的socket会留在新用户的房间里，导致收到不属于自己的消息。
2. 前端socket连接未清理：单页应用中切换账号时，若未断开旧的socket连接，后端的socket.userId会被新用户的ID覆盖，且旧socket未离开原房间，最终导致消息串流。

解决方案 #

1. 后端代码优化：精准发送消息+清理房间 #

修改后端逻辑，直接给发起请求的socket发送数据，同时在切换用户时清理旧房间：

io.on('connection', socket => {
  socket.on('findAllChatsByUserId', (userId) => {
    // 离开之前的房间（避免同一个socket留在多个用户房间）
    if (socket.userId) {
      socket.leave(socket.userId);
    }
    socket.userId = userId;
    socket.join(socket.userId);
    
    ChatModel.aggregate([
      {$match: {$or: [{senderId: userId}, {receiver: userId}]}}, 
      {$group: {_id: '$chatId', 'data': {$last: '$$ROOT'}}}
    ]).exec(function(error, data) {
      if (error) {
        // 给当前请求的socket发送错误信息
        socket.emit('findAllChatsByUserIdError', error);
        return;
      } 
      data.sort((a, b) => b.data.date - a.data.date);
      // 直接发送给发起请求的socket，确保只有该客户端收到数据
      socket.emit('findAllChatsByUserId', data);
    })
  });

  // 断开连接时清理房间
  socket.on('disconnect', () => {
    if (socket.userId) {
      socket.leave(socket.userId);
    }
  });
});

2. 前端代码优化：管理socket生命周期 #

在用户切换账号（登出/登录）时，确保socket连接被正确销毁和重建，同时修正loading逻辑（避免异步请求未完成就结束loading）：

// 登录逻辑示例
login() {
  // 先断开旧的socket连接（如果存在）
  if (this.socket) {
    this.socket.disconnect();
    this.socket = null;
  }
  // 登录接口请求...
  // 登录成功后创建新的socket连接
  this.socket = io();
  // 监听聊天记录返回事件
  this.socket.on('findAllChatsByUserId', (data) => {
    this.chatList = data;
    this.loading = false;
  });
  this.socket.on('findAllChatsByUserIdError', (error) => {
    console.error('获取聊天记录失败:', error);
    this.loading = false;
  });
}

// 登出逻辑示例
logout() {
  if (this.socket) {
    this.socket.disconnect();
    this.socket = null;
  }
  // 其他登出操作（如清除token等）
}

// 组件mounted逻辑修正
mounted () {
  this.loading = true;
  this.socket.emit('findAllChatsByUserId', this.getUserId);
  // 用once确保只监听一次返回结果
  this.socket.once('findAllChatsByUserId', () => {
    this.loading = false;
  });
  this.socket.once('findAllChatsByUserIdError', () => {
    this.loading = false;
  });
}

关键说明 #

• 房间的正确用法：房间适合给同一个用户的多设备（如手机+电脑）同步消息，如果你有这个需求，再用io.to(socket.userId).emit；否则直接用socket.emit是最安全的方式。
• socket唯一性：每个客户端连接对应一个独立的socket，只要前端在切换用户时销毁旧连接、创建新连接，就能避免后端socket实例被复用导致的串号问题。

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