Socket.io搭配Redis Adapter调用emit内存持续增长如何解决

问题根因 #

• 隐式全局变量泄漏：代码中io、data_out、data_ref未使用const/let声明，直接赋值会被挂载到全局对象上，永远不会被垃圾回收（GC）释放，循环运行过程中生成的大量数据对象会持续占用内存。
• 逻辑错误导致无效消息堆积：原代码中data_ref = data_out[id]属于逻辑错误，实际预期是取data_out的id属性，应为data_ref = data_out.id，错误写法会导致data_ref为undefined，所有emit的事件名均为undefined，大量无效消息持续堆积。
• Socket.io默认消息缓冲机制：没有客户端连接时，Socket.io会默认将emit的消息暂存到本地缓冲区，等待后续客户端连接后推送，循环持续运行时缓冲区会无限扩容，导致内存持续上涨。
• 高频同步循环阻塞GC：如果for循环是高频同步无限循环，会完全占满Node.js事件循环，GC没有运行机会，大量临时对象无法被回收，进一步加剧内存增长。

修复方案 #

1. 修复变量声明与逻辑错误 #

补全所有变量的显式声明，修正事件名取值逻辑，避免全局变量泄漏与无效消息生成：

....node modules require statements here....

const server = http.createServer(app);
// 显式声明io变量，避免挂载到全局
const io = socketIo(server);
io.adapter(socketIoRedis({ host: redis_host, port: redis_port }));

for(....) {
    // 循环内变量用const声明，迭代结束后作用域销毁，可被GC回收
    const data_out = {A:10, B:20, id:'1234'} 
    // 修正事件名取值逻辑
    const data_ref = data_out.id
    io.emit(data_ref, JSON.stringify(data_out));
}

2. 关闭不必要的消息缓冲 #

如果推送消息不需要保证离线必达，优先使用volatile标识调用emit，没有客户端连接时直接丢弃消息，不会写入缓冲区：

// volatile标识表示消息为非必达，无接收端时直接丢弃，不占用缓冲内存
io.volatile.emit(data_ref, data_out);

也可以在Socket.io初始化时全局关闭缓冲（按需选择）：

const io = socketIo(server, {
  // 关闭消息压缩，减少内存占用
  perMessageDeflate: false
});

3. 优化循环逻辑，给GC留出运行空间 #

避免使用同步无限循环，改用setInterval、setTimeout或process.nextTick拆分迭代，避免持续阻塞事件循环，保证GC有足够的运行时间回收临时对象。

4. 移除冗余序列化操作 #

Socket.io的emit方法会自动序列化传入的对象，不需要手动调用JSON.stringify，冗余操作会额外生成字符串临时对象，增加GC压力。

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