Socket.IO 'connection'函数浏览器关闭后仍每次递增的异常问题

作为刚接触Socket.io的开发者，遇到这种连接后计数异常递增的情况太常见了——核心问题基本都是旧连接没被正确清理，或者计数逻辑没做断开时的反向处理。我来帮你一步步排查和解决：

可能的核心原因 #

• 全局计数变量没做反向递减：如果你的计数是定义在控制器函数外的全局变量，每次新连接只会累加，但断开时没减少，自然会越积越多；
• 断开事件没被正确监听：浏览器关闭时Socket.io本应触发disconnect事件，但如果服务器端没监听这个事件做清理，就会认为旧连接还活着，新连接又新增计数；
• 房间用户没及时移除：登录时把用户加入了房间，但断开时没从房间移除，下次登录重复加入，房间内的用户计数就会重复累加。

具体解决步骤 #

1. 给计数逻辑加上断开时的清理 #

把计数管理放在connection事件内部，同时监听disconnect事件做反向操作，确保连接断开时计数同步减少：

// 服务器端示例代码
io.on('connection', (socket) => {
  // 用对象跟踪每个房间的实时用户数
  const roomUserCounts = {};

  // 处理用户登录的逻辑（你的控制器核心代码）
  socket.on('user-login', (roomId) => {
    socket.join(roomId);
    // 递增对应房间的计数
    roomUserCounts[roomId] = (roomUserCounts[roomId] || 0) + 1;
    console.log(`房间${roomId}当前用户数：${roomUserCounts[roomId]}`);
  });

  // 监听断开事件，清理计数和房间关联
  socket.on('disconnect', () => {
    // 获取当前socket加入的所有房间
    const joinedRooms = Object.keys(socket.rooms);
    joinedRooms.forEach(roomId => {
      // 排除socket自身的默认房间（每个socket会有一个以自身ID命名的房间）
      if (roomId !== socket.id) {
        // 确保计数不会变成负数
        roomUserCounts[roomId] = Math.max((roomUserCounts[roomId] || 0) - 1, 0);
        console.log(`用户断开，房间${roomId}当前用户数：${roomUserCounts[roomId]}`);
        socket.leave(roomId);
      }
    });
  });
});

2. 优化扩展端的连接逻辑 #

在Chrome扩展里，确保每次登录时只建立一个socket连接，避免重复创建连接导致服务器端多次触发计数：

// 扩展端示例代码
let socketInstance = null;

function handleLogin() {
  // 如果已有连接，先主动断开
  if (socketInstance) {
    socketInstance.disconnect();
  }
  // 创建新的连接实例
  socketInstance = io('http://你的Express服务器地址');
  socketInstance.emit('user-login', '目标房间ID');
}

3. 依赖Socket.io内置的房间计数（更省心） #

如果你不需要自定义计数逻辑，完全可以用Socket.io内置的房间用户数查询，避免手动维护计数的错误：

socket.on('user-login', (roomId) => {
  socket.join(roomId);
  // 直接获取房间内的socket数量
  const currentUserCount = io.sockets.adapter.rooms.get(roomId)?.size || 0;
  console.log(`房间${roomId}当前用户数：${currentUserCount}`);
});

4. 配置心跳机制确保死连接被清理 #

Socket.io默认有心跳检测，但可以调整参数让服务器更快识别死连接：

const io = require('socket.io')(server, {
  pingTimeout: 60000, // 60秒没收到心跳就判定连接断开
  pingInterval: 25000 // 每25秒发送一次心跳包
});

验证方法 #

1. 打开浏览器登录扩展，查看服务器日志的计数是否正常；
2. 关闭浏览器，等待1分钟（心跳超时时间），再打开浏览器登录，确认计数回到预期值；
3. 如果还是有问题，在服务器端的disconnect事件里加日志，确认每次断开都触发了清理逻辑。

内容的提问来源于stack exchange，提问作者red house 87