如何在Socket.io重连后保留服务器端的事件监听器？

本质原因是：客户端重连时，服务器会创建全新的socket实例，旧socket已被销毁，绑定在它上面的监听器自然无法转移到新socket。解决核心是在新socket建立连接时，重新为它绑定所需的事件监听器，以下是具体实现方案：

方案1：统一在连接回调中绑定监听器 #

确保每次新socket连接时，都执行监听器绑定逻辑，避免绑定逻辑仅执行一次的问题。如果原绑定函数有执行次数限制，需要重构它以支持为每个socket单独绑定：

io.on('connection', (socket) => {
   const CUSTOM_EVENT = 'CustomEvent';
   // 封装通用绑定函数，确保每次连接都能为当前socket绑定监听器
   function attachCustomListener(targetSocket, eventName) {
       // 先移除旧监听器（避免重复绑定导致多次触发）
       targetSocket.off(eventName);
       targetSocket.on(eventName, (data) => {
           // 此处编写你的事件处理逻辑
           console.log(`收到事件 ${eventName}:`, data);
       });
   }
   // 为当前新socket绑定监听器
   attachCustomListener(socket, CUSTOM_EVENT);

   console.log(`Client connected to socket id '${socket.id}'`);
   console.log(`事件 ${CUSTOM_EVENT} 的监听器数量: ${socket.listenerCount(CUSTOM_EVENT)}`);
   
   socket.on('disconnect', (reason) => {
     console.log('client disconnected');
   });
});

方案2：基于用户身份恢复专属监听器 #

如果不同用户需要绑定不同的事件，可以让客户端重连时发送身份标识，服务器根据身份为新socket绑定对应监听器：

客户端代码修改 #

socket.on('connect', () => {
  // 重连后发送用户身份信息（需提前存储用户ID）
  socket.emit('authenticate', { userId: 'your-user-id' });
});

服务器端代码 #

// 维护用户与订阅事件的映射（示例）
const userSubscribedEvents = new Map();

io.on('connection', (socket) => {
   // 监听客户端的身份认证请求
   socket.on('authenticate', (authData) => {
       const userId = authData.userId;
       const CUSTOM_EVENT = 'CustomEvent';
       // 绑定通用事件
       attachCustomListener(socket, CUSTOM_EVENT);
       // 绑定用户专属事件（如果有）
       const events = userSubscribedEvents.get(userId) || [];
       events.forEach(event => attachCustomListener(socket, event));
   });

   function attachCustomListener(targetSocket, eventName) {
       targetSocket.off(eventName);
       targetSocket.on(eventName, (data) => {
           console.log(`收到事件 ${eventName}:`, data);
       });
   }

   console.log(`Client connected to socket id '${socket.id}'`);
   
   socket.on('disconnect', (reason) => {
     console.log('client disconnected');
   });
});

方案3：利用房间（Rooms）简化事件推送 #

如果事件是面向一组用户的，可将用户加入指定房间，通过房间广播事件，无需为单个socket绑定监听器。重连后用户重新加入房间即可接收事件：

io.on('connection', (socket) => {
   const TARGET_ROOM = 'user-group-001';
   // 新socket加入房间
   socket.join(TARGET_ROOM);

   // 向房间内所有socket广播事件
   io.to(TARGET_ROOM).emit('CustomEvent', '房间内的消息');

   socket.on('disconnect', () => {
       // 用户断开后离开房间
       socket.leave(TARGET_ROOM);
   });
});

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