使用 connect-domain 捕获异步调用中出现的异常-白红宇

使用 connect-domain 捕获异步调用中出现的异常

阅读量：6911 次

发布时间：2019-06-27

本文共 2607 字，大约阅读时间需要 8 分钟。

之前经常有同学会问到怎么有些异常无法捕获到呢？

虽然已经在 handler 外层加了 try catch ，还是无法捕获异步调用中产生的异常。

现状

例如最简单的 helloworld.js 代码

var connect = require('connect');var app = connect().use(function (req, res, next) {  if (req.url === '/sync_error') {    throw new Error('sync error');  }  if (req.url === '/async_error') {    return process.nextTick(function () {      mk2.haha();    });  }  res.end('hello, ' + req.method + ' ' + req.url);});process.on('uncaughtException', function (err) {  console.error(err);});app.listen(1985);

使用 curl 来简单测试一下

$ curl localhost:1985/foohello, GET /foo$ curl localhost:1985/sync_errorError: sync error    at Object.handle ( .../app.js:33:11)    ....

好像还挺正常的，异常也被捕获了。继续测试

$ curl localhost:1985/async_error

没任何输出了吧？从服务器端控制台看到这样的输出: 证明触发了 uncaughtException 事件。

[ReferenceError: mk2 is not defined]

虽然我们能通过 uncaughtException 事件捕获到异步调用中产生的异常，但是我们没办法返回 HTTP 500 异常响应给调用者。调用者也只能一直hold住，直到请求超时。

这是非常不好的做法，因为请求量很大，服务进程内存会暴涨，会导致进程超出内存限制，非正常退出。

改进

任何时候，如果服务器端出现异常，我们就应该返回HTTP 500 告诉调用者服务器异常了。

异步调用产生的异常也应该如此处理。

开始，增加了模块来帮助我们更好地处理异常。

让我们使用来改进一下之前的 helloworld.js:

var connect = require('connect');var connectDomain = require('connect-domain');var app = connect().use(connectDomain()) // just using connect-domian middleware.use(function (req, res, next) {  if (req.url === '/sync_error') {    throw new Error('sync error');  }  if (req.url === '/async_error') {    return process.nextTick(function () {      mk2.haha();    });  }  res.end('hello, ' + req.method + ' ' + req.url);});process.on('uncaughtException', function (err) {  console.error(err);});app.listen(1984);

再看看的实现，非常简单:

var domain = require('domain');module.exports = function (handler) {  return function domainMiddleware(req, res, next) {    var reqDomain = domain.create();    res.on('close', function () {      reqDomain.dispose();    });    reqDomain.on('error', function (err) {      if (typeof handler === 'function') {        handler(err, req, res, next);      } else {        next(err);      }    });    reqDomain.run(next);  };};

重复刚才的 curl 测试:

$ curl localhost:1984/foohello, GET /foo$ curl localhost:1984/sync_errorError: sync error    at Object.handle ( .../app.js:33:11)    ....$ curl localhost:1984/async_errorReferenceError: mk2 is not defined    at .../app.js:24:7    at process.startup.processNextTick.process._tickCallback (node.js:244:9)

所有请求都有响应了。

服务器进程的输出:

{ [ReferenceError: mk2 is not defined]  domain_thrown: true,  domain:    { domain: null,     _events: { error: [Function] },     _maxListeners: 10,     members: [] } }

奇怪的连 uncaughtException 事件也触发了。这按我的思维来说，不应该触发才对的。

@isaacs 最新的提交已经修复此问题: