Node.js中如何实现同步EventEmitter事件监听器并等待事件触发？

这个问题很常见——EventEmitter的异步特性确实会让习惯同步逻辑的开发者困惑。你的代码里有两个小问题：首先是拼写错误EventEmmitter（应该是EventEmitter），其次是回调里的return没办法传递给foo函数，因为foo在事件触发前就已经执行完了。不过我们可以用Promise + async/await来包装事件监听，实现让代码“等待”事件触发的效果，同时符合JavaScript的异步模型。

核心思路 #

EventEmitter本身是异步的，但我们可以用Promise来封装事件监听逻辑：当目标事件触发时，resolve这个Promise，这样就能用async/await让代码看起来像同步执行一样。

修正后的代码示例 #

我们可以直接利用Node.js events模块自带的once方法（它会返回一个Promise，监听事件触发一次后resolve）：

const EventEmitter = require('events');
const { once } = require('events'); // 引入官方封装的once方法
const emitter = new EventEmitter(); // 修正拼写错误

function bar(arg) {
  // 模拟业务计算（这里用setTimeout模拟异步操作）
  setTimeout(() => {
    const result = `${arg} processed`;
    emitter.emit('done', result);
  }, 1000);
}

async function foo(arg) {
  // 先执行bar逻辑
  bar(arg);
  // 等待'done'事件触发，once会返回Promise，触发后返回事件参数数组
  const [result] = await once(emitter, 'done');
  // 事件触发后才会执行这里的代码，返回结果
  return result;
}

// 使用async/await获取结果
async function run() {
  const result = await foo("something");
  console.log(result); // 输出: "something processed"
}

run();

// 或者用.then()链式调用（适合不能用async/await的场景）
// foo("something").then(result => console.log(result));

代码解释 #

1. once方法：相比on，once只会监听事件一次，避免后续多次触发导致Promise重复resolve的问题，同时它原生支持Promise，不用自己手动封装。
2. async/await：让异步代码的写法更接近同步逻辑，foo函数变成async函数后，调用它时需要用await或者.then()来获取结果——这是JavaScript里处理异步逻辑的标准方式，不会阻塞事件循环。
3. 避免同步阻塞：不要尝试用while循环等待标志位这种“伪同步”的方式，它会卡住Node.js的事件循环，导致其他任务无法执行，严重影响性能。

如果你需要手动封装Promise（不使用once） #

如果出于某些原因不想用官方的once方法，也可以手动用Promise封装事件监听：

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

function bar(arg) {
  setTimeout(() => {
    const result = `${arg} processed`;
    emitter.emit('done', result);
  }, 1000);
}

function foo(arg) {
  return new Promise((resolve) => {
    bar(arg);
    // 监听一次事件，触发后resolve
    emitter.once('done', (result) => {
      resolve(result);
    });
  });
}

// 调用方式和之前一致
async function run() {
  console.log(await foo("something"));
}

run();

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