本文详解 node.js 异步编程中常见的“提前执行”问题，通过手动状态机替代 foreach 实现串行文件读取，并基于 eventemitter 构建可监听的递归搜索流程，确保匹配文件名与内容能正确收集并写入目标文件。

本文详解 node.js 异步编程中常见的“提前执行”问题，通过手动状态机替代 foreach 实现串行文件读取，并基于 eventemitter 构建可监听的递归搜索流程，确保匹配文件名与内容能正确收集并写入目标文件。

在 Node.js 中，fs.readFile() 是典型的异步非阻塞 I/O 操作：调用后立即返回，不等待文件读取完成，而是通过回调函数通知结果。原代码中使用 fileList.forEach() 并发启动多个 fs.readFile()，但后续的 console.log("All matching files: ", matchingFiles) 会在所有回调执行前就运行——此时 matchingFiles 仍为空数组。这是初学者常遇的经典异步时序陷阱。

要正确收集结果，必须确保：
✅ 所有文件读取完成后再汇总输出；
✅ 错误（如权限拒绝）能中断流程或优雅跳过；
✅ 文件内容匹配逻辑与写入操作可组合、可监听。

以下是一个融合 EventEmitter 模式 与 手动串行控制流 的完整实现方案：

Json Schema Toolkit

使用 JSON Schema 验证 JSON 数据，从示例 JSON 生成 schema，并将其转换为 TypeScript 接口、Python 数据类或 Markdown 文档。

下载

const fs = require('fs').promises; // 使用 Promise 版本更简洁（也可用 callback + util.promisify）
const path = require('path');
const EventEmitter = require('events');

class FileSearcher extends EventEmitter {
  constructor() {
    super();
  }

  async search(srcDir, keyword, dstDir, destFile) {
    const outputFile = path.join(dstDir, destFile);
    const matchingFiles = [];

    try {
      // 1. 递归读取所有文件路径（示例：简化为同步获取，实际可用 readdir + 递归）
      const allFiles = await this._collectFiles(srcDir);
      this.emit('scanStart', { total: allFiles.length });

      // 2. 串行处理每个文件（避免并发竞争与时序错乱）
      for (const file of allFiles) {
        const fullPath = path.join(srcDir, file);
        try {
          const content = await fs.readFile(fullPath, 'utf8');
          if (content.includes(keyword)) {
            matchingFiles.push(file);
            this.emit('match', { file, content });
            await this._saveContent(content, outputFile);
          }
        } catch (err) {
          if (err.code === 'ENOENT') {
            this.emit('warn', `File not found: ${fullPath}`);
            continue;
          }
          throw err; // 其他错误中止
        }
      }

      this.emit('complete', { matchingFiles, outputFile });
      return matchingFiles;

    } catch (err) {
      this.emit('error', err);
      throw err;
    }
  }

  _collectFiles(dir) {
    return new Promise((resolve, reject) => {
      const files = [];
      function walk(currentDir) {
        try {
          const entries = fs.readdirSync(currentDir, { withFileTypes: true });
          for (const entry of entries) {
            const fullPath = path.join(currentDir, entry.name);
            if (entry.isDirectory()) {
              walk(fullPath);
            } else if (entry.isFile() && path.extname(entry.name).toLowerCase() === '.txt') {
              files.push(path.relative(dir, fullPath));
            }
          }
        } catch (err) {
          reject(err);
        }
      }
      walk(dir);
      resolve(files);
    });
  }

  _saveContent(content, outputFile) {
    return fs.appendFile(outputFile, `\n--- ${new Date().toISOString()} ---\n${content}\n`);
  }
}

// 使用示例
const searcher = new FileSearcher();

searcher.on('scanStart', ({ total }) => console.log(`? 开始扫描 ${total} 个文件...`));
searcher.on('match', ({ file }) => console.log(`✅ 匹配文件: ${file}`));
searcher.on('warn', msg => console.warn(`⚠️  ${msg}`));
searcher.on('complete', ({ matchingFiles, outputFile }) => {
  console.log(`? 搜索完成！共找到 ${matchingFiles.length} 个匹配文件`);
  console.log(`? 结果已追加至: ${outputFile}`);
});
searcher.on('error', err => console.error('❌ 搜索失败:', err.message));

// 启动搜索
searcher.search('./src', 'TODO', './dist', 'matches.txt')
  .catch(console.error);

关键设计说明：

• ✅ 串行而非并发：使用 for...of 配合 await 确保逐个处理，自然解决时序问题；
• ✅ 事件驱动解耦：emit('match')、emit('error') 等让调用方自由订阅行为，符合 EventEmitter 设计模式要求；
• ✅ 错误分类处理：ENOENT 视为警告并跳过，其他错误（如 EACCES）抛出中断流程；
• ✅ 内容写入安全：使用 appendFile 而非覆盖，避免多文件写入冲突；
• ⚠️ 注意递归深度：生产环境建议改用 fs.promises.readdir(..., { recursive: true })（Node.js 16.13+）或流式处理防止栈溢出。

该方案既修复了原始异步时序缺陷，又严格遵循事件发射器范式，同时具备可扩展性（如后续接入日志系统、WebSockets 实时推送进度等）。