Node.js事件发射器模式递归文件搜索异步执行问题求助

问题原因 #

fs.readFile是Node.js的异步非阻塞API——调用它之后，JavaScript线程不会等待文件读取完成，而是直接继续执行后续代码。你用forEach循环同步发起了所有文件读取请求，但循环本身不会等待这些异步操作完成。所以当你在循环结束后立刻执行console.log时，所有fs.readFile的回调函数还没触发，用来存匹配文件名的数组自然是空的。

解决方案 #

结合题目要求的事件发射器模式，这里提供两种可行的修改方案：

方案1：用事件发射器追踪异步任务完成状态 #

通过计数追踪所有待完成的异步任务，当任务全部结束时触发自定义事件，在事件回调中处理最终的数组：

const fs = require('fs');
const path = require('path');
const EventEmitter = require('events');

class SearchEmitter extends EventEmitter {}
const searchEmitter = new SearchEmitter();

const matchedFiles = [];
let pendingTasks = 0; // 记录未完成的异步任务数

function searchDir(dir) {
  pendingTasks++;
  fs.readdir(dir, (err, files) => {
    if (err) throw err;
    files.forEach(file => {
      const fullPath = path.join(dir, file);
      pendingTasks++;
      fs.stat(fullPath, (err, stats) => {
        if (err) throw err;
        if (stats.isDirectory()) {
          searchDir(fullPath);
        } else {
          pendingTasks++;
          fs.readFile(fullPath, 'utf8', (err, content) => {
            if (err) throw err;
            if (content.includes('你的匹配关键词')) {
              matchedFiles.push(fullPath);
              searchEmitter.emit('file-matched', fullPath); // 实时触发匹配事件
            }
            pendingTasks--;
            checkCompletion();
          });
        }
        pendingTasks--;
        checkCompletion();
      });
    });
    pendingTasks--;
    checkCompletion();
  });
}

// 检查所有任务是否完成
function checkCompletion() {
  if (pendingTasks === 0) {
    searchEmitter.emit('search-complete'); // 触发搜索完成事件
  }
}

// 监听搜索完成事件，此时数组已填充完毕
searchEmitter.on('search-complete', () => {
  console.log('匹配的文件列表：', matchedFiles);
  // 写入输出文件
  fs.writeFile('output.txt', matchedFiles.join('\n'), err => {
    if (err) throw err;
    console.log('结果已写入output.txt');
  });
});

// 实时打印匹配到的文件名
searchEmitter.on('file-matched', filePath => {
  console.log('找到匹配文件：', filePath);
});

searchDir('./目标目录路径');

方案2：用Promise+async/await简化流程（兼容事件发射器） #

如果你的Node.js版本在10以上，可以用fs.promises将异步操作包装为Promise，结合async/await让代码更易读，同时保留事件发射器的功能：

const fs = require('fs').promises;
const path = require('path');
const EventEmitter = require('events');

class SearchEmitter extends EventEmitter {}
const searchEmitter = new SearchEmitter();

const matchedFiles = [];

async function searchDir(dir) {
  const files = await fs.readdir(dir);
  // 用for...of代替forEach，支持await等待异步操作完成
  for (const file of files) {
    const fullPath = path.join(dir, file);
    const stats = await fs.stat(fullPath);
    if (stats.isDirectory()) {
      await searchDir(fullPath);
    } else {
      const content = await fs.readFile(fullPath, 'utf8');
      if (content.includes('你的匹配关键词')) {
        matchedFiles.push(fullPath);
        searchEmitter.emit('file-matched', fullPath);
      }
    }
  }
}

// 自执行异步函数处理整个流程
(async () => {
  await searchDir('./目标目录路径');
  console.log('匹配的文件列表：', matchedFiles);
  await fs.writeFile('output.txt', matchedFiles.join('\n'));
  console.log('结果已写入output.txt');
})();

// 实时打印匹配文件名
searchEmitter.on('file-matched', filePath => {
  console.log('找到匹配文件：', filePath);
});

方案对比 #

• 方案1完全基于回调和事件发射器，贴合题目要求的模式，适合理解异步任务追踪的底层逻辑。
• 方案2用现代异步语法简化了代码，可读性更高，同时也满足事件发射器的使用要求。

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