Node-Express中Socket.io推送process.stdin KLV元数据流遇阻求助

问题背景 #

本地Node-Express服务器中，以下代码可正常获取解码后的KLV元数据流：

process.stdin.on('data', function (data) {
  const result = klv.decode(data, standards, null, { payload: true, debug: process.argv[2] === 'debug' })
  console.log(result);
})

但尝试通过Socket.io将数据流推送给客户端时出现异常：

尝试1：封装为异步函数调用 #

io.on('connection', (socket) =>{
  socket.emit('geolocation-data', process_data())
});

现象：无任何数据传递至客户端。

尝试2：Socket逻辑嵌入数据流处理 #

async function process_data () {
    process.stdin.on('data', function (data) {
        const result = klv.decode(data, standards, null, { payload: true, debug: process.argv[2] === 'debug' });
        io.on('connection', (socket) =>{
            socket.emit('geolocation-data', result );
        })
    })
};

现象：仅刷新页面（新连接）的客户端能收到部分数据；终端抛出内存泄漏警告：

(node:45139) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 connection listeners added to [Namespace]. Use emitter.setMaxListeners() to increase limit

错误原因 #

1. 尝试1失败原因：

   • process_data是异步逻辑，但调用时直接将其返回值（无有效数据）传给emit，仅在客户端连接时触发一次空推送，后续stdin数据流未关联Socket推送逻辑。

2. 尝试2失败原因：

   • 每次stdin有数据流入，就为io新增一个connection事件监听器，导致监听器数量持续累积，触发内存泄漏警告。
   • 只有新连接的客户端能收到当前result，已连接客户端无法获取后续数据流，因为新添加的监听器仅对新连接生效。

可行解决方案 #

核心思路：在客户端连接时绑定数据流推送逻辑，或维护在线客户端列表，有新数据时批量推送。

方案1：客户端连接后绑定推送（推荐） #

通过事件发射器解耦数据流处理与Socket推送，同时管理客户端连接生命周期：

const EventEmitter = require('events');
const klvEmitter = new EventEmitter();

// 处理stdin数据流，解码后触发自定义事件
process.stdin.on('data', function (data) {
  try {
    const result = klv.decode(data, standards, null, { payload: true, debug: process.argv[2] === 'debug' });
    klvEmitter.emit('klv-data', result);
  } catch (err) {
    console.error('KLV解码失败:', err);
  }
});

// Socket.io连接处理
io.on('connection', (socket) => {
  console.log('客户端已连接');

  // 绑定数据推送逻辑到当前客户端
  const sendKlvData = (result) => {
    socket.emit('geolocation-data', result);
  };
  klvEmitter.on('klv-data', sendKlvData);

  // 客户端断开时移除监听器，避免内存泄漏
  socket.on('disconnect', () => {
    console.log('客户端已断开');
    klvEmitter.off('klv-data', sendKlvData);
  });
});

方案2：批量推送给所有在线客户端 #

若无需针对单个客户端处理，直接在新数据产生时推送给所有已连接客户端：

// 处理stdin数据流，解码后推送给所有客户端
process.stdin.on('data', function (data) {
  try {
    const result = klv.decode(data, standards, null, { payload: true, debug: process.argv[2] === 'debug' });
    io.emit('geolocation-data', result);
  } catch (err) {
    console.error('KLV解码失败:', err);
  }
});

// 可选：监听客户端连接/断开事件
io.on('connection', (socket) => {
  console.log('客户端已连接');
  socket.on('disconnect', () => {
    console.log('客户端已断开');
  });
});

说明 #

• 方案1支持单个客户端的连接生命周期管理，避免无效推送，灵活性更高；
• 方案2代码简洁，适用于所有客户端需接收相同数据流的场景；
• 两种方案均避免了重复添加事件监听器，解决了内存泄漏问题，同时保证数据流实时推送给已连接客户端，无需刷新页面。

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