UnhandledPromiseRejectionWarning 尽管有多次错误检查

Question

我最近一直在用 NODEJS 开发一个网络应用程序。我有一个负责所有 crud 操作的数据库模型。示例数据库模型

    getDeviceList: function () {
        return new Promise(function (resolve, reject) {
            var sql = "SELECT * FROM `devices`";
            db.query(sql, function (err, result) {
                if (err) {
                    console.log(`FAILED: ${err}`);
                    reject(err);
                } else resolve(result);
            });
        });
    }

我在 DB 模块中访问此功能，如

router.get("/inventory/devices", checkAuth, function (req, res, next) {
    return new Promise(function (resolve, reject) {
        db.getDeviceList().then(function (result) {
            resolve(res.status(200).json(result));
        }).catch(function (err) {
            console.log(`FAILED: ${err}`);
            reject(res.status(200).json(err));
        });
    });
});

有时当我关闭数据库时；我得到 UnhandledPromiseRejectionWarning 但在我看来，我正在处理所有的承诺。处理承诺的最佳方式是什么？我的 rerun promise 方法是否正确？ 我的数据库连接块在app.js

var connection = db.connectDB().then(function (connect) {}).catch(function (err) {
    console.log(`FAILED: ${err}`);
});

而我的connectDB() 是

function () {
        return new Promise(function (resolve, reject) {
            db = mysql.createPool({
                host: "localhost",
                port: 3306,
                user: "migration",
                password: "iub5015",
                database: "migration"
            });
            db.getConnection(function (err) {
                if (err) {
                    console.log(`FAILED: ${err}`);
                    reject(err);
                } else {
                    console.log("Connected");
                    resolve(db);
                }
            });
        });
    }

Answer 1

你的 catch 块中的最后一条语句，

reject(res.status(200).json(err));

表示返回的 Promise 处于拒绝状态。即router.get("/inventory/devices", checkAuth, function (req, res, next) 返回的 Promise 处于拒绝状态，您错过了这一点。 （或者 express 没有像你的情况那样捕捉到）

这就是您收到此 UnhandledPromiseRejectionWarning 的原因。

处理承诺的最佳方式是什么，是我重新运行的方法 承诺正确吗？

嗯，根据我的经验，这取决于。在某些情况下，您可能希望通过拒绝 Promise 来传播错误，或者在某些情况下，您可能只想以某种方式处理它并将某些内容作为解析值返回。在您的情况下，您可能需要查看 express 文档以弄清楚您需要如何在中间件中实现承诺。

router.get("/inventory/devices", checkAuth, function (req, res, next) {
    return new Promise(function (resolve, reject) {
        db.getDeviceList().then(function (result) {
            resolve(res.status(200).json(result));
        }).catch(function (err) {
            console.log(`FAILED: ${err}`);
            // This will not give UnhandledPromiseRejectionWarning 
            resolve(res.status(500).json(err));
        });
    });
});

Answer 2

    router.get("/inventory/devices", checkAuth, function (req, res, next) {
    new Promise(function (resolve, reject) {
        db.getDeviceList().then(function (result) {
            resolve(result);
        }).catch(function (err) {
            console.log(`FAILED: ${err}`);
            reject(err);
        });
    }).then(r => {
        res.status(200).json(r)
     }).catch(er => {
       res.status(400).json(er)
     })
});