Express路由中async/await控制器函数报错及正确用法咨询

我来帮你梳理清楚Express里如何正确使用async/await风格的控制器和路由——这个问题其实很多刚接触Express异步处理的开发者都会碰到，核心是要处理好异步错误的捕获和传递。下面我结合你的项目结构（路由、控制器、模型）一步步拆解正确的写法：

1. 模型层：编写Async风格的数据库操作函数 #

首先你的category.js模型文件里，所有数据库操作都应该封装成async函数，并且抛出错误让上层控制器处理，而不是在模型里直接返回错误：

// models/category.js
// 假设你用Mongoose，或者其他ORM/数据库驱动
const Category = require('./path-to-your-mongoose-model');

// 示例：获取所有分类
exports.getAllCategories = async () => {
  // 这里不需要try/catch（除非你要做特定的错误转换），直接让错误向上抛出
  const categories = await Category.find().lean();
  return categories;
};

// 示例：创建新分类
exports.createCategory = async (categoryData) => {
  const newCategory = new Category(categoryData);
  await newCategory.save();
  return newCategory;
};

2. 控制器层：Async函数 + 错误捕获 #

控制器是路由和模型之间的中间层，这里的函数必须是async的，并且要捕获异步操作的错误，然后传递给Express的错误处理中间件：

// controllers/categories.js
const categoryModel = require('../models/category');

// 获取分类列表的控制器
exports.getCategories = async (req, res, next) => {
  try {
    // 调用模型的async函数，用await等待结果
    const categories = await categoryModel.getAllCategories();
    // 返回成功响应
    res.status(200).json({
      success: true,
      data: categories
    });
  } catch (err) {
    // 把错误传递给Express的错误处理中间件（必须调用next(err)）
    next(err);
  }
};

// 创建分类的控制器
exports.createCategory = async (req, res, next) => {
  try {
    const newCategory = await categoryModel.createCategory(req.body);
    res.status(201).json({
      success: true,
      data: newCategory
    });
  } catch (err) {
    // 这里可以根据错误类型自定义statusCode，比如Mongoose的验证错误设为400
    err.statusCode = err.name === 'ValidationError' ? 400 : 500;
    next(err);
  }
};

3. 路由层：直接使用Async控制器（或用统一包裹函数） #

在categoryRoutes.js里，你可以直接把async控制器函数传给router.get/post——因为我们已经在控制器里用try/catch捕获了错误并调用next(err)：

// routes/categoryRoutes.js
const express = require('express');
const router = express.Router();
const categoryController = require('../controllers/categories');

// 直接挂载async控制器函数即可
router.get('/', categoryController.getCategories);
router.post('/', categoryController.createCategory);

// 如果你不想在每个控制器里写try/catch，可以用一个统一的异步处理包裹函数
// 这个函数会自动捕获async函数的错误并传递给next()
const asyncHandler = (fn) => (req, res, next) => {
  Promise.resolve(fn(req, res, next)).catch(next);
};

// 用法示例（如果控制器里没有try/catch，就用这个包裹）
// router.get('/', asyncHandler(categoryController.getCategories));

module.exports = router;

4. 关键：配置全局错误处理中间件 #

最后一定要在你的主入口文件（比如app.js）里添加Express的全局错误处理中间件，这样所有通过next(err)传递的错误都会被统一处理：

// app.js
const express = require('express');
const app = express();

// 挂载路由
const categoryRoutes = require('./routes/categoryRoutes');
app.use('/api/categories', categoryRoutes);

// 全局错误处理中间件（必须放在所有路由之后）
app.use((err, req, res, next) => {
  console.error('服务器错误:', err.stack);
  const statusCode = err.statusCode || 500;
  res.status(statusCode).json({
    success: false,
    error: err.message || '服务器内部错误'
  });
});

app.listen(3000, () => console.log('服务器启动在3000端口'));

常见报错原因及解决 #

你之前在路由里报错，大概率是以下两种情况：

• 没有捕获async函数的错误：async函数里的未处理Promise拒绝会导致Express无响应或者服务器崩溃，必须通过try/catch或asyncHandler捕获错误
• 控制器函数不是async却用了await：await只能在async函数内部使用，所以控制器函数必须标记为async

内容的提问来源于stack exchange，提问作者HelloWorld0815