事件触发时解析Promise且避免重复事件监听器的实现方案

你的代码里确实存在一个典型的问题：每次调用processData时，都会给processSuccess和processError事件新增一对监听器。这些监听器不会自动移除，会导致两个严重问题：

1. 当事件触发时，所有之前添加的监听器都会被执行，造成同一个Promise被多次resolve/reject，或者多个Promise被错误地触发；
2. 未被清理的监听器会一直占用内存，引发内存泄漏。

下面给你两种实用的解决方案，根据你的业务场景选择：

方案1：使用once()替代on()（简单场景） #

Node.js的EventEmitter提供了once()方法，它会在事件触发一次后自动移除监听器，完美解决重复绑定的问题。修改后的代码如下：

public async processData(payload: Payload) {
  // 将数据推入栈中
  this._myStack.push(payload);
  return new Promise((resolve, reject) => {
    // 使用once，触发后自动销毁监听器
    myEventEmitter.once('processSuccess', data => {
      resolve(data);
    });
    myEventEmitter.once('processError', error => {
      reject(error);
    });
  });
}

适用场景： #

如果你的栈是串行处理的（每次只处理一个payload，处理完再取下一个），这个方案足够简单高效，不需要额外修改事件触发逻辑。

方案2：绑定唯一标识，精准匹配事件（复杂场景） #

如果你的栈是并行处理的（同时处理多个payload），once()可能会导致错误的Promise被resolve（比如第一个payload的成功事件触发时，会resolve最近创建的Promise）。这时候需要给每个payload添加唯一标识，让监听器只响应对应payload的事件：

步骤1：给Payload添加唯一ID #

// 定义带唯一标识的Payload类型
interface Payload {
  id: string; // 可以用uuid、时间戳+随机数生成
  // 你的原有字段...
}

步骤2：修改processData方法 #

// 可以用uuid库生成唯一ID，也可以自己实现简单的生成逻辑
import { v4 as uuidv4 } from 'uuid';

public async processData(payload: Omit<Payload, 'id'>) {
  // 给payload添加唯一标识
  const payloadWithId = { ...payload, id: uuidv4() };
  this._myStack.push(payloadWithId);

  return new Promise((resolve, reject) => {
    // 定义成功事件处理器
    const handleSuccess = (data: { id: string; result: any }) => {
      // 只处理当前payload对应的事件
      if (data.id === payloadWithId.id) {
        resolve(data.result);
        // 处理完立即移除监听器
        cleanup();
      }
    };

    // 定义错误事件处理器
    const handleError = (error: { id: string; message: string }) => {
      if (error.id === payloadWithId.id) {
        reject(new Error(error.message));
        cleanup();
      }
    };

    // 清理监听器的工具函数
    const cleanup = () => {
      myEventEmitter.off('processSuccess', handleSuccess);
      myEventEmitter.off('processError', handleError);
    };

    // 绑定监听器
    myEventEmitter.on('processSuccess', handleSuccess);
    myEventEmitter.on('processError', handleError);

    // 可选：添加超时处理，防止监听器永远留在内存中
    const timeoutId = setTimeout(() => {
      reject(new Error('Data processing timed out'));
      cleanup();
    }, 5000);
  });
}

步骤3：修改事件触发逻辑 #

在处理栈中payload的代码里，触发事件时要带上对应的id：

// 处理payload的逻辑示例
const processStackItem = async () => {
  const payload = this._myStack.pop();
  if (!payload) return;

  try {
    const result = await someProcessingLogic(payload);
    // 触发成功事件时携带id
    myEventEmitter.emit('processSuccess', { id: payload.id, result });
  } catch (error) {
    // 触发错误事件时携带id
    myEventEmitter.emit('processError', { id: payload.id, message: error.message });
  }
};

适用场景： #

并行处理多个payload、需要精准关联事件与请求的场景，同时还能避免超时导致的内存泄漏。

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