Promise.all 在失败时回滚成功的 Promise 的动作

Question

我正在使用以下 sn-p 执行多个承诺：

await Promise.all([promise1, promise2, promise3]);

我想要实现的是从Promise.all() 回滚成功的承诺对失败情况的影响。 更具体地说，这意味着上面会做一些文件加密，但如果一个失败，我想删除其他两个（或一个）加密成功的文件，以便拥有一致和干净的文件组。

根据我的阅读，这意味着我需要两个步骤： 1. 捕获每个promise 的错误，这样Promise.all() 就不会抛出错误。 2. 令人费解的部分：有另一个Promise.all() 之类的：

await Promise.all([rollbackPromise1, rollbackPromise2, rollbackPromise3]);

这似乎是棘手的部分：我是否应该独立于失败的承诺执行所有回滚？这意味着我应该对每个错误进行另一个捕获，以便 Promise.all() 等待每次回滚完成。

这是最好的方法吗？我发现它在代码方面效率低下且丑陋。

Answer 1

您可以按如下方式创建一个简单的解决方案：

const errorHandlers = []
function enc1 () {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      resolve('str')
    }, 1000)
    errorHandlers.push(() => {
      console.log('handler 1')
    })
  })
}
function enc2 () {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      resolve('str')
    }, 2000)
    errorHandlers.push(() => {
      console.log('handler 2')
    })
  })
}
function enc3 () {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      reject('str')
    }, 3000)
    errorHandlers.push(() => {
      console.log('handler 3')
    })
  })
}

Promise.all([enc1(), enc2(), enc3()]).then(() => {
  console.log('all resovled')
}).catch((e) => {
  errorHandlers.forEach(handler => handler(e))
})

它可以让您选择处理每个承诺中的“全局”错误。在创建promise all之前，可以重新设置errorHandlers，防止多个errorHandler执行

Answer 2

您可以创建自己的函数来实现函数的异步调用并在需要时执行回滚。

// Function that'll perform a promise.all and rollback if required
async function allWithRollback(promises) {
  // using the map we are going to wrap the promise inside of a new one
  return Promise.all(promises.map(([
    func,
    rollbackFunc,
  ], xi) => ((async() => {
    try {
      await func;

      console.log('One Function succeed', xi);
    } catch (err) {
      console.log('One Function failed, require rollback', xi);

      await rollbackFunc();
    }
  })())));
}

// Call the custom Promise.all
allWithRollback([
  [
    // First param is the promise
    okPromise(),

    // Second param is the rollback function to execute
    () => {},
  ],
  [okPromise(), () => {}],
  [errPromise(), rollback1],
  [errPromise(), rollback2],
  [okPromise(), () => {}],
]);

// ---------

async function okPromise() {
  return true;
}

async function errPromise() {
  throw new Error('no one read this');
}

async function rollback1() {
  console.log('Performed the rollback1');
}

async function rollback2() {
  console.log('Performed the rollback2');
}