如何在Promise.all()中当任一Promise拒绝时回滚已执行操作

问题场景 #

当前代码使用Promise.all()同时执行多个异步操作，其中包含数据库变更和短信发送等逻辑：

const promiseExecution = async ()=> {
    try{
        await Promise.all([
            promise1, // some db changes
            promise2, // send sms
            promise3, // other db changes
        ])
    }
    catch(er){
        //handle error
    }
}

存在的问题是：当其中一个Promise拒绝时，另外两个仍会继续执行并resolve，导致已完成的数据库变更无法回滚，引发数据不一致。

基于Promise.allSettled()的解决方案 #

你提到的Promise.allSettled()是可行的思路，核心是先执行所有操作，再根据每个操作的结果，对已成功的操作执行对应的回滚逻辑。

实现步骤 #

1. 为每个业务操作配对对应的回滚/补偿函数；
2. 使用Promise.allSettled()执行所有操作，获取每个操作的最终状态；
3. 检查是否有失败的操作，若有则对所有成功完成的操作触发回滚；
4. 处理回滚过程中的异常，确保补偿逻辑尽可能执行。

代码示例 #

const promiseExecution = async () => {
  // 定义每个操作及其对应的回滚/补偿逻辑
  const operations = [
    { 
      exec: () => promise1, 
      rollback: () => rollbackDbChanges1 // 数据库变更1的回滚函数
    },
    { 
      exec: () => promise2, 
      rollback: () => compensateSms // 短信发送后的补偿逻辑（如致歉短信）
    },
    { 
      exec: () => promise3, 
      rollback: () => rollbackDbChanges3 // 数据库变更2的回滚函数
    },
  ];

  try {
    // 执行所有操作，获取每个操作的状态（成功/失败）
    const results = await Promise.allSettled(operations.map(op => op.exec()));
    
    // 检查是否存在失败的操作
    const hasFailed = results.some(res => res.status === 'rejected');
    
    if (hasFailed) {
      // 对所有成功完成的操作执行回滚
      const rollbackTasks = results.map((res, idx) => {
        if (res.status === 'fulfilled') {
          return operations[idx].rollback();
        }
        return Promise.resolve(); // 失败的操作无需回滚
      });
      
      // 等待所有回滚操作完成
      await Promise.all(rollbackTasks);
      throw new Error('操作执行失败，已触发回滚');
    }

    console.log('所有操作执行成功');
  } catch (err) {
    console.error('处理异常:', err);
    // 可添加日志上报、告警等后续处理
  }
};

补充优化建议 #

• 数据库操作优先用事务：如果你的数据库支持事务，建议将所有数据库变更放在同一个事务中执行。这样一旦某个数据库操作失败，直接回滚整个事务，无需单独编写回滚函数，可靠性更高：

  const promiseExecution = async () => {
    let transaction;
    try {
      // 开启数据库事务
      transaction = await db.startTransaction();
      
      // 在事务内执行数据库操作
      await promise1(transaction);
      await promise3(transaction);
      
      // 执行非数据库操作（如发短信）
      await promise2();
      
      // 所有操作成功，提交事务
      await transaction.commit();
      console.log('操作执行成功');
    } catch (err) {
      // 回滚事务
      if (transaction) await transaction.rollback();
      // 处理非数据库操作的补偿（如短信已发送的情况）
      if (/* 判断短信已发送成功 */) {
        await sendApologySms();
      }
      console.error('处理失败:', err);
    }
  };
  

• 回滚异常处理：回滚过程中也可能出现失败，建议添加日志记录，便于后续人工介入处理，避免数据不一致问题扩大。

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