NodeJS处理Express中异步错误

一、什么是异步错误？

Node.js中的异步操作会导致一些无法预料的错误，这些错误往往需要在代码逻辑中进行处理。在Express应用程序中，我们可以使用错误处理器来捕获和处理这些错误。

二、处理异步错误的方法

处理异步错误的方法有多种，其中一个常用的方法是使用异步错误处理器。异步错误处理程序允许我们通过catch方法处理异步错误。

1. 使用async/await模式：

app.get('/products', async (req, res, next) => {
  try {
    const products = await Product.find({});
    res.json(products);
  } catch (error) {
    next(error);
  }
});

这里我们使用了async/await模式，async函数返回一个Promise，await关键字会暂停async函数的执行，直到Promise成功或失败才会继续执行。在这种情况下，如果查询数据库时出现错误，catch块将会捕获该错误并将它传递给Express的错误处理程序。

1. 使用Promise：

app.get('/products', (req, res, next) => {
  Product.find({})
    .then((products) => {
      res.json(products);
    })
    .catch((error) => {
      next(error);
    });
});

在这种方法中，我们使用了Promise来处理异步错误。如果在数据库查询时出现错误，Promise就会被拒绝，catch块被调用并传递该错误给Express的错误处理程序。

三、自定义错误处理器

我们也可以自定义错误处理器来处理特定类型的错误。以下是一个例子：

class DatabaseError extends Error {
  constructor(message) {
    super(message);
    this.name = 'DatabaseError';
    this.statusCode = 500;
  }
}

app.get('/products', async (req, res, next) => {
  try {
    const products = await Product.find({});
    if (products.length === 0) {
      throw new DatabaseError('No products found.');
    }
    res.json(products);
  } catch (error) {
    if (error.name === 'DatabaseError') {
      res.status(error.statusCode).json({ message: error.message });
    } else {
      next(error);
    }
  }
});

在这个示例中，我们定义了一个名为DatabaseError的错误类。在查询数据库时，如果没有找到产品，我们会抛出一个DatabaseError错误。在错误处理程序中，我们检查错误的类型。如果错误类型是DatabaseError，我们将返回一个带有HTTP状态码和错误消息的JSON响应。否则，我们将该错误传递给Express的错误处理程序。