Express自定义错误处理器未触发问题求助

问题原因 #

你遇到的核心问题是：异步回调函数中的错误无法被Express的同步错误处理机制捕获。

Express的错误处理器只能捕获两种错误：

1. 请求处理流程中同步抛出的错误
2. 通过next(err)主动传递的错误

而MySQL的db.query是异步操作，它的回调函数运行在Express的请求上下文之外。你在回调里直接抛出的错误会触发Node.js的全局未捕获异常，直接导致应用崩溃，根本无法传递到你的自定义错误处理器。

解决方案 #

方案1：用next()传递错误（快速修改）

直接在MySQL回调中调用next(err)，把错误手动传递给Express的错误处理中间件：

修改postController.js：

export const getPost = (req, res, next) => { // 必须添加next参数
    const q =
        "SELECT posts.id, `username`, `title`, `desc`, posts.img, users.img AS userImg, `category`, `date` FROM users JOIN posts on users.id = posts.uid WHERE posts.id = ?";

    db.query(q, [req.params.id], (err, data) => {
        if (err) {
            res.status(500);
            return next(new Error("Something went wrong, please try again.")); // 用next传递错误
        }
        
        if (data.length == 0) {
            res.status(404); // 无效ID返回404更符合HTTP规范
            return next(new Error("Invalid post id"));
        }
        return res.status(200).json(data[0]);
    });
};

同时调整errorHandler.js，移除末尾的next()调用（错误处理中间件是请求流程的终点，不需要继续传递）：

const errorHandler = (err, req, res, next) => {
    const statusCode = res.statusCode ? res.statusCode : 500;

    res.status(statusCode).json({
        message: err.message,
    });

    // 这里不要调用next()，避免重复响应
};

export default errorHandler;

方案2：改用Promise/async-await（更推荐）

把MySQL查询包装成Promise，用async-await语法编写，统一捕获异步错误：

1. 先给DB实例添加Promise化的查询方法（可放在DB配置文件中）：

// 包装db.query为Promise
db.queryPromise = (sql, params) => {
    return new Promise((resolve, reject) => {
        db.query(sql, params, (err, data) => {
            if (err) reject(err);
            else resolve(data);
        });
    });
};

2. 修改postController.js为async函数：

export const getPost = async (req, res, next) => {
    try {
        const q =
            "SELECT posts.id, `username`, `title`, `desc`, posts.img, users.img AS userImg, `category`, `date` FROM users JOIN posts on users.id = posts.uid WHERE posts.id = ?";

        const data = await db.queryPromise(q, [req.params.id]);
        
        if (data.length == 0) {
            res.status(404);
            throw new Error("Invalid post id");
        }
        return res.status(200).json(data[0]);
    } catch (err) {
        res.status(500);
        next(new Error("Something went wrong, please try again."));
    }
};

这种写法更简洁，错误逻辑更清晰，也符合现代Node.js异步编程的最佳实践。

注意事项 #

• 你的错误处理中间件放在所有路由之后的位置是正确的，无需调整。
• 对于资源不存在的场景，返回404状态码比默认的500更符合HTTP语义。

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