
本文介绍如何正确封装 express 异步中间件,解决 `try-catch` 无法捕获 promise 拒绝(如 mongodb 报错)导致应用崩溃的问题,并提供健壮、可复用的 `asynchandler` 工具函数。
你遇到的问题非常典型:直接在 tryCatch 包装器中调用 func(req, res, next),但该函数返回的是一个 Promise(因为是 async 函数),而你的包装器并未 await 它——这意味着 Promise 内部抛出的错误(例如 await User.create(…) 触发的 MongoServerError: E11000 duplicate key)不会被同步 try-catch 捕获,而是变成未处理的 Promise rejection,最终导致进程崩溃或静默失败。
✅ 正确做法是:显式 await 异步处理器,并将整个调用包裹在 try/catch 中。以下是推荐的、生产就绪的 asyncHandler 实现:
// utils/asyncHandler.ts import { RequestHandler } from 'express'; export const asyncHandler = (fn: RequestHandler): RequestHandler => { return (req, res, next) => { // 关键:必须 await,否则 Promise rejection 不会被 catch Promise.resolve(fn(req, res, next)).catch(next); }; };
✅ 为什么用 Promise.resolve(…).catch()? 它能同时兼容同步返回值、Promise 和 async 函数(自动转为 Promise),且语义清晰:任何异常(同步 throw 或 Promise rejection)都交由 next(err) 统一处理。
使用示例:
import { asyncHandler } from './utils/asyncHandler'; // ✅ 无需 try-catch,错误自动透传给全局错误处理器 export const login = asyncHandler(async (req, res) => { const user = await User.findOne({ email: req.body.email }); if (!user) throw new Error('User not found'); // 同步 throw → 被捕获 const token = await jwt.sign({ id: user._id }, process.env.JWT_SECRET!); res.json({ token }); });
⚠️ 注意事项:
// app.ts app.use('/api/auth', authRoutes); // ✅ 全局错误处理器(4 参数签名) app.use((err: Error, req: Request, res: Response, next: NextFunction) => { console.error('Unhandled error:', err); res.status(500).json({ success: false, message: 'Internal Server Error', ...(process.env.node_ENV === 'development' && { stack: err.stack }) }); });
? 进阶建议:
- 可扩展 asyncHandler 支持自定义错误分类(如 ValidationError → 400,MongoServerError → 409);
- 结合 Zod 或 Joi 做请求校验,提前拦截无效输入,减少运行时异常;
- 使用 express-async-errors 库(底层原理相同)作为轻量替代方案。
总结:Express 的异步错误处理核心在于 “await + next(err)” 的组合,而非裸调用。用 asyncHandler 封装后,所有路由逻辑回归简洁与专注,错误治理交由统一管道,大幅提升代码健壮性与可维护性。