使用 Promise.allSettled 和 try/catch 处理未处理的承诺拒绝

Question

我的想法如下： 我想同时发送多个请求，而不必等到之前的执行。

所以我的伪代码如下：

function sleep(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}

function failingRequest(){
    return new Promise((resolve, reject) => {
        reject('Request failed');
    });
}

function successRequest(){
    return new Promise((resolve, reject) => {
        resolve('Request success');
    });
}

async function main() {
    try {
        let executions = [];
        executions.push(failingRequest());
        await sleep(4000);
        executions.push(successRequest());
        let result = await Promise.allSettled(executions);
        console.log(result);
    } catch (err) {
        console.log('Outer error occured.');
        console.log(err.message);
    }

    console.log('done');
}
main();

在这里运行此代码可以在浏览器中按预期工作，但会给我以下与节点一起运行的输出：

node:761) UnhandledPromiseRejectionWarning: Request failed
api/cli.html#cli_unhandled_rejections_mode). (rejection id: 1)
(node:761) [DEP0018] DeprecationWarning: Unhandled promise rejections are deprecated. In the future, promise rejections that are not handled will terminate the Node.js process with a non-zero exi not handled will terminate the Node.js process with a non-zero exit code.
[
  { status: 'rejected', reason: 'Request failed' },
  { status: 'fulfilled', value: 'Request success' }
]
done
(node:761) PromiseRejectionHandledWarning: Promise rejection was handled asynchronously (rejection id: 1)

知道为什么会这样吗？

请注意，我只插入了sleep，因此我可以测试catch 块是否会在第一个请求失败的情况下被执行这不是所需的行为。我想同时发起这些请求，我不在乎是否失败。我想稍后通过let result = await Promise.allSettled(executions); 检查哪些请求有效，哪些请求失败。我希望这很清楚。

Answer 1

知道为什么会这样吗？

您创建 failingRequest()，然后等待 4 秒再处理它。

我只插入了睡眠，所以我可以测试

...因此您导致了未处理的拒绝。删除await sleep(4000);，它会按预期工作！

Answer 2

有趣的问题 - 问题是您实际上并没有模拟异步请求。实际上，您的两个请求方法只是创建同步/立即解决/拒绝的承诺。您需要将await 放在failingRequest() 之前，以便在try/catch 周围捕获被拒绝的承诺，但这可能不是您想要的。

您不应该立即“开始”承诺，而应该是这样的：

try {
        let executions = [];
        executions.push(failingRequest);
        await sleep(4000);
        executions.push(successRequest);
        let result = await Promise.allSettled(executions.map(promiseFn => promiseFn()));
        console.log(result);
    } catch (err) {
        console.log('Outer error occured.');
        console.log(err.message);
    }

这将记录

[
  { status: 'rejected', reason: 'Request failed' },
  { status: 'fulfilled', value: 'Request success' }
]
done

正如预期的那样。