如何在Node.js中高效管理多异步任务并实现错误处理？

针对你的需求——并发执行多个异步任务、单独处理每个任务的错误且等待所有任务完成，以下是两种可靠的解决方案，以及对应的最佳实践：

1. 使用Promise.allSettled()（推荐） #

ES2020引入的Promise.allSettled()完美匹配你的场景：它会等待所有传入的Promise完成（无论成功或失败），然后返回一个包含每个任务结果的数组，每个结果对象会标识任务是fulfilled（成功）还是rejected（失败），并携带对应的值或错误原因。

示例代码 #

async function performTask1() {
  // 模拟API调用/数据库查询
  return new Promise(resolve => setTimeout(() => resolve('Task 1 result'), 1000));
}

async function performTask2() {
  // 模拟失败的任务
  return new Promise((_, reject) => setTimeout(() => reject(new Error('Task 2 failed')), 500));
}

async function performTask3() {
  return new Promise(resolve => setTimeout(() => resolve('Task 3 result'), 800));
}

async function main() {
  const taskResults = await Promise.allSettled([
    performTask1(),
    performTask2(),
    performTask3()
  ]);

  // 逐个处理每个任务的结果
  taskResults.forEach((result, taskIndex) => {
    const taskName = `Task ${taskIndex + 1}`;
    if (result.status === 'fulfilled') {
      console.log(`${taskName} succeeded:`, result.value);
      // 这里可以添加成功后的业务逻辑，比如存储结果
    } else {
      console.error(`${taskName} failed:`, result.reason.message);
      // 错误处理：记录日志、重试任务、标记任务状态等
    }
  });

  // 所有任务完成后执行后续逻辑
  console.log('All tasks have finished executing');
}

main();

2. 手动包装Promise（兼容旧环境） #

如果你的运行环境不支持ES2020（比如旧版Node.js），可以手动为每个异步任务添加错误捕获包装，确保每个任务的错误不会终止整个并发流程。

示例代码 #

// 包装函数：统一处理任务的成功和错误，返回标准化结果
function wrapTask(task, taskName) {
  return task()
    .then(result => ({
      name: taskName,
      success: true,
      result
    }))
    .catch(error => ({
      name: taskName,
      success: false,
      error: error.message
    }));
}

async function main() {
  const taskResults = await Promise.all([
    wrapTask(performTask1, 'Task 1'),
    wrapTask(performTask2, 'Task 2'),
    wrapTask(performTask3, 'Task 3')
  ]);

  // 处理结果
  for (const res of taskResults) {
    if (res.success) {
      console.log(`${res.name} completed:`, res.result);
    } else {
      console.error(`${res.name} failed:`, res.error);
    }
  }

  console.log('All tasks completed');
}

main();

关键最佳实践 #

• 优先选用标准API：Promise.allSettled()是官方提供的标准解决方案，语义明确，代码简洁，无需手动维护包装逻辑。
• 避免错误吞噬：不要在错误处理中忽略错误，至少要将错误记录到日志系统，便于后续排查问题。
• 分类处理结果：可以通过filter快速筛选成功/失败的任务结果，比如：

  const successfulTasks = taskResults.filter(r => r.status === 'fulfilled');
  const failedTasks = taskResults.filter(r => r.status === 'rejected');
  

• 标识任务身份：在处理结果时，明确标记每个任务的名称或ID，方便定位问题。
• 并发效率保障：无论使用哪种方法，所有任务都是同时启动的，不会串行等待，最大化利用Node.js的异步IO特性，保证执行效率。

内容的提问来源于stack exchange，提问作者Ali Reza Riahi