在 Node.js 中为 mongoDB 链接多个承诺函数

Question

有一个要求，只有在找到产品和用户时才能添加评论。所以我编写了代码来实现这个场景。User.findById(req.params.userId).exec()        .then(response => {            console.log("response", response);            if (response) {                return Product.findById(req.params.productId).exec();            }            else {                return res.status(404).json({                    message: 'User not found'                })            }        })        .then(response => {            console.log("response", response);            if (!response) {                return res.status(404).json({                    message: 'Product not found'                })            }            const review = new Review({                _id: mongoose.Types.ObjectId(),                rev: req.body.rev,                productId: req.params.productId,                userId: req.params.userId            });            return review.save();        })        .then(response => {            console.log("responseeeeeeee", response);            res.status(201).json({                response            })        })        .catch(error => {            console.log("error", error);            res.status(500).json({                error            })        })这工作正常，但一旦产品或用户丢失，它就会发出警告：(node:17276) UnhandledPromiseRejectionWarning: Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client    at ServerResponse.setHeader (_http_outgoing.js:470:11)    at ServerResponse.header (D:\backup-learning\project-shop-always\node_modules\express\lib\response.js:771:10)    at ServerResponse.send (D:\backup-learning\project-shop-always\node_modules\express\lib\response.js:170:12)    at ServerResponse.json (D:\backup-learning\project-shop-always\node_modules\express\lib\response.js:267:15)    at User.findById.exec.then.then.then.catch.error (D:\backup-learning\project-shop-always\api\controllers\review-controller.js:58:29)    at process._tickCallback (internal/process/next_tick.js:68:7)

Answer 1

问题在于，res.status当您return res.status(/*...*/)从then回调中执行操作时，该链会继续使用作为履行值的返回值。

您不能为此使用单个链。此外，由于您需要同时定位用户和产品，因此最好并行执行该操作。见评论：

// *** Start both the product and user search in parallel

Promise.all([

    User.findById(req.params.userId).exec(),

    Product.findById(req.params.productId).exec()

])

.then(([user, product]) => {

    // *** Handle it if either isn't found

    if (!user) {

        res.status(404).json({

            message: 'User not found'

        });

    } else if (!product) {

        res.status(404).json({

            message: 'Product not found'

        });

    } else {

        // *** Both found, do the review

        const review = new Review({

            _id: mongoose.Types.ObjectId(),

            rev: req.body.rev,

            productId: req.params.productId,

            userId: req.params.userId

        });

        // *** Return the result of the save operation

        return review.save()

        .then(response => {

            console.log("responseeeeeeee", response);

            res.status(201).json({

                response

            });

        }

    }

    // *** Implicit return of `undefined` here fulfills the promise with `undefined`, which is fine

})

.catch(error => {

    // *** An error occurred finding the user, the product, or saving the review

    console.log("error", error);

    res.status(500).json({

        error

    })

});

如果您在任何现代版本的 Node.js 中执行此操作，您可以使用async函数和await：

// *** In an `async` function

try {

    const [user, product] = await Promise.all([

        User.findById(req.params.userId).exec(),

        Product.findById(req.params.productId).exec()

    ]);

    if (!user) {

        res.status(404).json({

            message: 'User not found'

        });

    } else if (!product) {

        res.status(404).json({

            message: 'Product not found'

        });

    } else {

        // *** Both found, do the review

        const review = new Review({

            _id: mongoose.Types.ObjectId(),

            rev: req.body.rev,

            productId: req.params.productId,

            userId: req.params.userId

        });

        const response = await review.save();

        console.log("responseeeeeeee", response);

        res.status(201).json({

            response

        });

    }

} catch (error) {

    console.log("error", error);

    res.status(500).json({

        error

    })

}

请注意，整个代码包装在一个try/ catch，所以async功能这是永远都不会拒绝（除非console.log或res.send在catch块中引发错误），这样就不会导致未处理拒绝警告，如果你只是让你Express端点处理程序async（而通常将async函数传递给不希望收到承诺的东西是一种反模式）。（如果您想有点偏执，请将catch块的内容包装在另一个try/ 中catch。）