使用 bluebird Promise的异步异常处理

IT技术 javascript node.js asynchronous promise bluebird
2021-02-04 02:39:41

处理这种情况的最佳方法是什么。我处于受控环境中,我不想崩溃。

var Promise = require('bluebird');

function getPromise(){
    return new Promise(function(done, reject){
        setTimeout(function(){
                throw new Error("AJAJAJA");
        }, 500);
    });
}

var p = getPromise();
    p.then(function(){
        console.log("Yay");
    }).error(function(e){
        console.log("Rejected",e);
    }).catch(Error, function(e){
        console.log("Error",e);
    }).catch(function(e){
        console.log("Unknown", e);
    });

从 setTimeout 中抛出时,我们将始终得到:

$ node bluebird.js

c:\blp\rplus\bbcode\scratchboard\bluebird.js:6
                throw new Error("AJAJAJA");
                      ^
Error: AJAJAJA
    at null._onTimeout (c:\blp\rplus\bbcode\scratchboard\bluebird.js:6:23)
    at Timer.listOnTimeout [as ontimeout] (timers.js:110:15)

如果抛出发生在 setTimeout 之前,则 bluebirds catch 将捡起它:

var Promise = require('bluebird');

function getPromise(){

    return new Promise(function(done, reject){
        throw new Error("Oh no!");
        setTimeout(function(){
            console.log("hihihihi")
        }, 500);
    });
}

var p = getPromise();
    p.then(function(){
        console.log("Yay");
    }).error(function(e){
        console.log("Rejected",e);
    }).catch(Error, function(e){
        console.log("Error",e);
    }).catch(function(e){
        console.log("Unknown", e);
    });

结果是:

$ node bluebird.js
Error [Error: Oh no!]

这很好 - 但是如何在节点或浏览器中处理这种性质的恶意异步回调。

3个回答

Promise 不是,它们不会从异步回调中捕获异常。你不能那样做。

然而诺言来捕捉从内抛出的异常then/ catch/Promise构造函数的回调。所以用

function getPromise(){
    return new Promise(function(done, reject){
        setTimeout(done, 500);
    }).then(function() {
        console.log("hihihihi");
        throw new Error("Oh no!");
    });
}

(或只是Promise.delay)以获得所需的行为。永远不要抛出自定义(非Promise)异步回调,始终拒绝周围的Promise。使用try-catch它是否真正需要。

在跑步者中: process.on('uncaughtException', uncaught);
2021-03-24 02:39:41
在浏览器中,它可能使用window.onerror,在节点中它可能使用域。
2021-03-26 02:39:41
如果我无法控制 setTimeout 调用的方法中发生的事情怎么办?根据@Kevin B 的建议再做一个Promise?
2021-03-28 02:39:41
不。当它失控时,你就无法捕捉到错误。针对您需要获得控制权的库提交错误。
2021-03-30 02:39:41
嗯,检查 mocha 在幕后做了什么,似乎处理类似的事情: it("should response with hello world", function(done) { setTimeout(function(){ throw new Error("ouch"); done( ); }, 500); }); 非常优雅。但可能不是Promise。
2021-04-05 02:39:41

在处理了您所描述的相同场景和需求之后,我发现了zone.js,这是一个了不起的 javascript 库,在多个框架中使用(Angular 就是其中之一),它使我们能够以非常优雅的方式处理这些场景。

区域是跨异步任务持续存在的执行上下文。您可以将其视为 JavaScript VM 的线程本地存储

使用您的示例代码:

import 'zone.js'

function getPromise(){
  return new Promise(function(done, reject){
    setTimeout(function(){
      throw new Error("AJAJAJA");
    }, 500);
  });
}

Zone.current
  .fork({
    name: 'your-zone-name',
    onHandleError: function(parent, current, target, error) {
      // handle the error 
      console.log(error.message) // --> 'AJAJAJA'
      // and return false to prevent it to be re-thrown
      return false
    }
  })
  .runGuarded(async () => {
    await getPromise()
  })

感谢@Bergi。现在我知道 promise 不会在异步回调中捕获错误。这是我测试过的 3 个示例。

注意:调用拒绝后,函数将继续运行。

示例 1:拒绝,然后在Promise构造函数回调中抛出错误

示例 2:拒绝,然后在 setTimeout 异步回调中抛出错误

示例 3:拒绝,然后在 setTimeout 异步回调中返回以避免崩溃

// Caught
// only error 1 is sent
// error 2 is reached but not send reject again
new Promise((resolve, reject) => {
  reject("error 1"); // Send reject
  console.log("Continue"); // Print 
  throw new Error("error 2"); // Nothing happen
})
  .then(() => {})
  .catch(err => {
    console.log("Error", err);
  });


// Uncaught
// error due to throw new Error() in setTimeout async callback
// solution: return after reject
new Promise((resolve, reject) => {
  setTimeout(() => {
    reject("error 1"); // Send reject
    console.log("Continue"); // Print

    throw new Error("error 2"); // Did run and cause Uncaught error
  }, 0);
})
  .then(data => {})
  .catch(err => {
    console.log("Error", err);
  });


// Caught
// Only error 1 is sent
// error 2 cannot be reached but can cause potential uncaught error if err = null
new Promise((resolve, reject) => {
  setTimeout(() => {
    const err = "error 1";
    if (err) {
      reject(err); // Send reject
      console.log("Continue"); // Did print
      return;
    }
    throw new Error("error 2"); // Potential Uncaught error if err = null
  }, 0);
})
  .then(data => {})
  .catch(err => {
    console.log("Error", err);
  });