Express JS 在请求上使用异步函数

Question

app.use(async function(req, res, next) {
    try {
        var myres = await new Promise((resolve, reject) => {
            mysql_connection.query("select * from Users;", (err, rows) => {
                if (err) {
                    reject(err);
                } else {
                    resolve(rows);
                }
            });
        });
    } catch (error) {
        console.log(error);
    }
});

问题是。使用 async 函数可以将 await 用于 DB 查询可以吗？恐怕这会在expressjs方面引起一些问题。

Answer 1

async..await 是 promise 的语法糖，promise 只是一种依赖回调的模式。只要环境支持async 函数，就可以使用它们。从 Node.js 7.6.0 开始支持 async..await。

async 函数总是返回一个承诺。只要这个隐式返回值不会引起问题，它在任何地方都很好，包括 Express。不管是用于数据库查询还是其他用途。

除非 API 支持 Promise，否则错误应该完全在 async 函数中处理。函数体应该用try..catch 包裹起来，以排除未处理的拒绝，这可能会导致未来的 Node 版本出现异常。

原始代码不包含next 调用，只是抑制了一个错误。根据经验，async 中间件的结构应该是这样的：

app.use(async function(req, res, next) {
    try {
        ...
        next();
    } catch (error) {
        next(error);
    }
});

Answer 2

异步等待可以毫无问题地用于数据库查询。你可以使用 try catch 但是有一个更优雅的解决方案，它允许你使用 express 提供的错误处理中间件：

你用这个函数包装你的中间件：

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

那么你可以通过以下方式使用它：

const asyncMiddleware = require('./utils/asyncMiddleware');

router.get('/', asyncMiddleware(async (req, res, next) => {
    /* 
      if there is an error thrown in getUserFromDb, asyncMiddleware
      will pass it to next() and express will handle the error;
    */
    const user = await getUserFromDb({ id: req.params.id })
    res.json(user);
}));

如果抛出错误，控制权将移交给错误处理中间件，该中间件是具有如下四个参数的中间件：

app.use(function (err, req, res, next) {
   // your error code
})

Answer 3

您还可以在您的 server.ts 或 server.js 上导入 https://www.npmjs.com/package/express-async-errors 来处理 express 上的异步错误

yarn add express-async-errors

然后在你的主文件中导入import 'express-async-errors';。

Answer 4

使用异步函数来等待数据库查询是完全可以的。但是尝试将该代码嵌入到 try 和 catch 块中，以便捕获异常。