async/await下Array.reduce抛错致Node.js崩溃的解决方案问询

首先明确你的异步reduce代码导致Node.js崩溃的核心原因：

• 原生Array.reduce是同步方法，传入async reducer函数后，每一次迭代都会返回Promise。第一次抛出错误后，reduce不会停止迭代，后续async函数依然会执行并生成未被处理的Promise rejection，触发Node.js的未捕获异常最终导致崩溃。
• 普通同步reduce抛错会立即终止迭代；map+Promise.all通过Promise.all统一监控所有Promise状态，只要有一个reject就会立即返回结果，不会产生未处理的rejection。

解决方法一：自行实现异步reduce函数 #

手动封装一个支持错误立即终止的异步reduce，逻辑为串行迭代数组，每一步等待reducer执行结果，捕获到错误就立即抛出并终止循环：

async function asyncReduce(arr, reducer, initialValue) {
  let accumulator = initialValue;
  for (const item of arr) {
    try {
      accumulator = await reducer(accumulator, item);
    } catch (err) {
      throw err; // 抛出错误，终止后续迭代
    }
  }
  return accumulator;
}

使用示例：

try {
  const tests = await asyncReduce([1, 2, 3], async (acc, i) => {
    throw new Error("test error");
  }, []);
} catch (err) {
  console.error(err); // 正常捕获错误，不会崩溃
}

解决方法二：使用第三方异步工具库 #

如果不想自行实现，可以借助成熟的异步库，比如bluebird的Promise.reduce，它原生支持串行异步reduce，遇到错误会立即停止迭代并返回错误：

const Promise = require('bluebird');

try {
  const tests = await Promise.reduce([1, 2, 3], async (acc, i) => {
    throw new Error("test error");
  }, []);
} catch (err) {
  console.error(err);
}

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