Socket.io客户端频繁断开重连及内存泄漏问题咨询

首先咱们先揪出核心问题：你的代码里每次新Socket连接都会给EMG传感器绑定一个新的change事件监听器，旧连接断开后这些监听器并没有被移除，时间一长就会触发MaxListenersExceededWarning，服务器负担越来越重，间接导致Socket连接不稳定，形成"断连→重连→新增监听器→性能下降→再断连"的恶性循环。

下面分两步解决：

一、立即修复内存泄漏问题 #

把传感器的事件监听器从io.on("connection")回调里移出来，只绑定一次，然后向所有连接的客户端广播数据，或者按需发送。

优化后的服务器代码（广播版）： #

board.on("ready", () => { 
  const mySensor = new five.Sensor("A0"); 

  // 只给传感器绑定一次change事件，避免重复添加监听器
  mySensor.on("change", function(event) { 
    // 向所有在线的客户端广播传感器数据
    io.emit("emg", event); 
  }); 

  io.on("connection", socket => { 
    console.log("New client connected"); 

    socket.on("disconnect", () => console.log("Client disconnected")); 
  }); 
});

如果是多客户端场景，需要给单个连接的客户端单独发送数据，可以用"连接时绑定、断开时移除"的方式：

board.on("ready", () => { 
  const mySensor = new five.Sensor("A0"); 

  io.on("connection", socket => { 
    console.log("New client connected"); 

    // 定义传感器数据发送函数
    const sendEmgData = (event) => {
      socket.emit("emg", event);
    };

    // 绑定监听器
    mySensor.on("change", sendEmgData);

    // 断开连接时移除监听器，彻底避免内存泄漏
    socket.on("disconnect", () => {
      console.log("Client disconnected");
      mySensor.removeListener("change", sendEmgData);
    });
  }); 
});

二、解决Socket频繁断连问题 #

内存泄漏修复后服务器性能会恢复，还可以通过以下配置进一步稳定连接：

1. 优化前端Socket.IO配置 #

在React前端代码里，优先使用WebSocket传输（默认可能用轮询，容易导致频繁连接），并设置合理的重连参数：

import { io } from "socket.io-client";

const socket = io('/', {
  transports: ['websocket', 'polling'], // 优先用WebSocket，轮询作为 fallback
  reconnection: true,
  reconnectionDelay: 1000, // 首次重连延迟1秒
  reconnectionDelayMax: 5000, // 最大重连延迟5秒，避免短时间内频繁重试
  reconnectionAttempts: 10 // 最多重连10次，防止无限重试
});

2. 限制传感器数据发送频率 #

EMG传感器的数据更新可能非常频繁，每秒几十上百次，会给Socket带来不必要的压力。可以用节流函数限制发送频率，比如每100ms发送一次（10帧/秒，足够前端展示）：

const _ = require('lodash');

board.on("ready", () => { 
  const mySensor = new five.Sensor("A0"); 

  // 节流函数，每100ms最多执行一次
  const throttledSend = _.throttle((event) => {
    io.emit("emg", event);
  }, 100);

  mySensor.on("change", function(event) { 
    throttledSend(event);
  }); 

  // ... 连接逻辑不变
});

3. 配置Socket.IO心跳参数 #

在服务器端设置心跳间隔和超时，确保及时检测无效连接，避免无效重连：

const io = require('socket.io')(server, {
  pingInterval: 10000, // 每10秒发送一次心跳包
  pingTimeout: 5000, // 5秒没收到响应则判定连接断开
});

为什么原来的代码会出问题？ #

你之前的写法，每来一个新客户端，就给mySensor加一个新的change监听器。当客户端断开时，这个监听器并没有被销毁，所以每次重连都会新增一个。比如客户端重连10次，传感器就有10个change监听器，每个监听器都会向对应的Socket发送数据——服务器既要处理大量重复的回调，还要维护过多的Socket连接，最终导致内存泄漏和连接不稳定。

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