Node.js 处理快速异步中间件中的错误

发布于07月18日

我在express中有一个async中间件，因为我想在其中使用await来清理代码.

const express = require('express');
const app = express();

app.use(async(req, res, next) => {
    await authenticate(req);
    next();
});

app.get('/route', async(req, res) => {
    const result = await request('http://example.com');
    res.end(result);
});

app.use((err, req, res, next) => {

    console.error(err);

    res
        .status(500)
        .end('error');
})

app.listen(8080);

问题是，当它拒绝时，它不会转到我的错误中间件，但如果我删除中间件中的async关键字和throw，它就会转到.

app.get('/route', (req, res, next) => {
    throw new Error('Error');
    res.end(result);
});

所以我得到UnhandledPromiseRejectionWarning，而不是进入我的错误处理中间件，我如何让错误冒泡，并表示处理它？

推荐答案

问题是，当它拒绝时，它不会导致我的错误

express目前不支持promise ，支持可能会出现在express@5.x.x的future 版本中

所以当你传递一个中间件函数时，express将在try/catch块中调用它.

Layer.prototype.handle_request = function handle(req, res, next) {
  var fn = this.handle;

  if (fn.length > 3) {
    // not a standard request handler
    return next();
  }

  try {
    fn(req, res, next);
  } catch (err) {
    next(err);
  }
};

问题是，try/catch不会捕获async函数之外的Promise拒绝，而且由于express不会向中间件返回的Promise添加.catch处理程序，因此会得到UnhandledPromiseRejectionWarning.

简单的方法是在中间件中添加try/catch，然后调用next(err).

app.get('/route', async(req, res, next) => {
    try {
        const result = await request('http://example.com');
        res.end(result);
    } catch(err) {
        next(err);
    }
});

但是如果你有很多async个中间产品，它可能有点重复.

因为我喜欢我的中间件尽可能干净，而且我通常会让错误冒出来，所以我在async个中间件周围使用一个包装器，如果promise 被拒绝，它将调用next(err)，到达快速错误处理程序并避免UnhandledPromiseRejectionWarning

const asyncHandler = fn => (req, res, next) => {
    return Promise
        .resolve(fn(req, res, next))
        .catch(next);
};

module.exports = asyncHandler;

现在你可以这样称呼它:

app.use(asyncHandler(async(req, res, next) => {
    await authenticate(req);
    next();
}));

app.get('/async', asyncHandler(async(req, res) => {
    const result = await request('http://example.com');
    res.end(result);
}));

// Any rejection will go to the error handler

还有一些软件包可以使用