Node.js中无法获取forEach数据及导出所有forEach执行结果

我来帮你捋清楚这两个问题的根源和解决办法，本质都是异步操作和forEach的同步特性不兼容导致的～

问题根源 #

forEach是个同步迭代器，它会一口气跑完所有循环，但你在循环里调用的oxr.latest()是异步API——它的回调函数要等API返回数据后才会执行，这就造成了两个问题：

1. 你想在forEach里立即获取异步返回的数据？没戏，因为循环跑完的时候，API回调还没触发呢；
2. 等你想导出结果时，forEach早就执行完了，而异步操作还在后台跑，所以导出的要么是空数组，要么是不完整的结果。

解决方案：用异步友好的方式处理循环 #

下面给你两种常用的解决思路，都是基于Promise和async/await来处理异步流程：

方案1：并行处理（推荐，效率更高）

把每个异步操作包装成Promise，用Promise.all()等待所有操作完成，一次性拿到所有结果：

// 把依赖移到循环外！别每次循环都重新加载模块，既低效又容易出问题
const fx = require('../lib/money');
const oxr = require('open-exchange-rates');

// App ID只需要设置一次，不用放循环里
oxr.set({ app_id: 'd5e619a619bc40e4abdbbf2a1b5a971' });

// 封装单个数据的异步处理逻辑
async function handleSingleData(data) {
  return new Promise((resolve, reject) => {
    oxr.latest(function(error) {
      if (error) {
        console.log('ERROR loading exchange rates!');
        reject(error.toString());
        return;
      }
      // 这里写你的业务逻辑，比如汇率转换
      fx.rates = oxr.rates;
      fx.base = oxr.base;
      const convertedAmount = fx.convert(data.amount, { from: 'USD', to: 'CNY' });
      
      // 返回处理后的结果
      resolve({
        original: data,
        converted: convertedAmount
      });
    });
  });
}

// 处理所有数据的主函数
async function handleAllResults(results) {
  try {
    // 用map把每个数据转换成Promise，再用Promise.all等待全部完成
    const allProcessedResults = await Promise.all(results.map(handleSingleData));
    
    // 这里拿到的就是所有异步操作的结果数组，可以直接导出或者做其他处理
    console.log('所有处理结果：', allProcessedResults);
    return allProcessedResults;
  } catch (error) {
    console.error('处理流程出错：', error);
    throw error; // 按需决定是否抛出错误
  }
}

// 调用示例（假设你的results数组是yourResults）
// handleAllResults(yourResults).then(finalResults => {
//   module.exports = finalResults; // 在这里导出结果
// });

方案2：串行处理（适合需要按顺序执行的场景）

如果你的业务要求必须一个接一个处理数据（比如怕API限流），可以用for...of结合async/await：

const fx = require('../lib/money');
const oxr = require('open-exchange-rates');

oxr.set({ app_id: 'd5e619a619bc40e4abdbbf2a1b5a971' });

async function handleAllResults(results) {
  const allResults = [];
  
  // 用for...of代替forEach，支持await
  for (const data of results) {
    try {
      const processedData = await new Promise((resolve, reject) => {
        oxr.latest(function(error) {
          if (error) {
            reject(error.toString());
            return;
          }
          fx.rates = oxr.rates;
          fx.base = oxr.base;
          const converted = fx.convert(data.amount, { from: 'USD', to: 'EUR' });
          resolve({ original: data, converted });
        });
      });
      allResults.push(processedData);
    } catch (error) {
      console.error(`处理数据${data.id}失败：`, error);
      // 按需选择：跳过错误数据，或者抛出终止流程
    }
  }
  
  return allResults;
}

// 调用后导出结果
// handleAllResults(yourResults).then(results => {
//   module.exports = results;
// });

额外提醒 #

• 别在循环里重复require模块：模块加载是单例的，重复require只会浪费性能；
• API限流注意：如果你的results数组很大，频繁调用oxr.latest()可能触发API的限流机制，建议看看Open Exchange Rates的文档，能不能缓存汇率数据，不用每次循环都请求最新数据；
• 错误处理要到位：每个异步操作都要捕获错误，避免单个请求失败导致整个流程崩溃。

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