Node.js中如何让Object.keys循环每次迭代等待异步API获取结果？

核心问题原因 #

Array.prototype.forEach 本身不支持异步等待逻辑，遍历过程中会一次性触发所有迭代内的异步函数，不会等待上一轮迭代的Promise执行完成，因此会出现请求顺序、文件写入顺序混乱的问题。

你提到的手动设置布尔值等待的方案完全没有必要，JavaScript 已经提供了语言层面的async/await语法实现异步流程的串行控制，手写布尔量轮询不仅逻辑冗余，还容易出现卡死、内存泄漏等问题。

最优实现方案：替换forEach为for...of + async/await #

将遍历逻辑替换为for...of循环，并将整个异步处理流程包裹在async作用域内，每次迭代使用await等待当前轮的所有异步操作完成后再进入下一轮。

同时你原代码存在两个明显bug需要先修复：

• first_api_fetcher和second_api_fetcher中，先读取response.headers再执行await fetch的顺序错误，此时response还未初始化，会抛出引用错误，需要先await fetch拿到响应对象再读取headers
• 代码中调用的second_api_checker实际定义的函数名是second_api_fetcher，调用名需要修正

调整后的核心代码示例 #

// 引入Promise版本的fs API，适配async/await语法
const fs = require('fs/promises');

fs.readFile('./local.json', 'utf8', async (err, data) => {
  try {
    const processed_local_json = JSON.parse(data);

    // 原有的工具函数定义保持不变，修正两个fetcher的执行顺序
    const functions_to_check_and_process_local_data = (data) => { /* ... */ }
    const functions_to_check_and_process_api_data = (data) => { /* ... */ }

    const first_api_fetcher = async(urla, urlb) => {
      // 先请求拿到响应再读headers
      const response = await fetch(urla);
      const contentType = response.headers.get("content-type");

      if (contentType && contentType.indexOf("application/json") !== -1) {
        let results = await response.json();
        functions_to_check_and_process_api_data(results);
      }
      // 修正调用的函数名
      await second_api_fetcher(urlb);
    }

    const second_api_fetcher = async(url) => {
      const response = await fetch(url);
      const contentType = response.headers.get("content-type");
      if (contentType && contentType.indexOf("application/json") !== -1) {
        let results = await response.json();
        functions_to_check_and_process_api_data(results);
      }
    }

    // 替换forEach为for...of循环
    for (const item of Object.keys(processed_local_json)) {
      functions_to_check_and_process_local_data(item);
      
      const processData = async() => {
        await first_api_fetcher(url1, url2).then(() => {
          // 原有的数据处理、字符串拼接逻辑保持不变
        })
      }

      const printFile = async() => {
        const printData = await processData();
        // 用Promise版本的appendFile，支持await
        await fs.appendFile("file", printData);
        console.log('wrote strings template literals to file');
      }

      // 等待当前轮所有操作完成再进入下一轮循环
      await printFile();
    }
  } catch (e) {
    console.log('处理流程出错：', e);
  }
})

其他可选方案 #

如果不需要严格按遍历顺序执行请求和写入，想要提高执行效率，可以并行执行所有异步任务，最后统一等待所有任务完成：

// 把所有异步任务存入数组
const taskList = Object.keys(processed_local_json).map(async item => {
  // 原有的单轮处理逻辑保持不变
  functions_to_check_and_process_local_data(item);
  // ... 省略其余处理逻辑
  await printFile();
})

// 统一等待所有任务执行完成
await Promise.all(taskList);

注意该方案下文件写入的顺序和遍历顺序可能不一致，如果对写入顺序有要求不要使用该方案。

内容的提问来源于stack exchange，提问作者F. Certainly.