node.js - 尝试进行嵌套查询时已调用 Node 异步回调

Question

我在尝试使用 MEAN 堆栈进行异步查询时遇到Callback was already called 错误。我需要第二个回调仅在嵌套查询完成后触发(根据代码中的注释)。为什么会出现此错误？

路线示例:

router.route('/teams/:user_id').get(function (req, res) {

TeamProfile.find({
    Members : {
        $in : [req.params.user_id]
    }
}).exec(function (err, teamProfiles) {

    var asyncTasks = [];

    teamProfiles.forEach(function (teamProfile) {
        asyncTasks.push(function (callback) {
            UserProfile.find({
                UserID : {
                    $in : teamProfile.Members.map(function (id) {
                        return id;
                    })
                }
            }, function (err, userProfiles) {
                teamProfile.Members = userProfiles;
                callback();
            })
        });
    });

    teamProfiles.forEach(function (teamProfile) {
        asyncTasks.push(function (callback) {
            Draft.find({
                _id : {
                    $in : teamProfile.Drafts.map(function (id) {
                        return id;
                    })
                }
            }, function (err, drafts) {
                teamProfile.Drafts = drafts;

                drafts.forEach(function (draft) {
                    Comment.find({
                        _id : {
                            $in : draft.Comments.map(function (id) {
                                return id;
                            })
                        }
                    }).exec(function (err, comments) {
                        draft.Comments = comments;
                        callback();
                        //This is where the callback should be called
                        //Throws Error: Callback was already called.
                    })                      
                })

            })
        });
    });

    async.parallel(asyncTasks, function () {
        res.json(teamProfiles)
    });
});
})

我正在使用 async.parallel() 来执行所有查询。我对所有这一切都很陌生，所以请原谅一些初学者的错误。

Answer 1

您正在同步迭代 drafts 并在第一项上调用 async 的 callback 函数。当您尝试使用第二项再次调用它时出现错误是预期的行为。

您应该在完成所有草稿查询后调用 done 回调，而不是针对每个查询。由于您使用的是异步，因此可以嵌套另一个 async.each 来处理此问题:

router.route('/teams/:user_id').get(function (req, res) {

        TeamProfile.find({
            Members : {
                $in : [req.params.user_id]
            }
        }).exec(function (err, teamProfiles) {

            var asyncTasks = [];

            teamProfiles.forEach(function (teamProfile) {

                asyncTasks.push(function (callback) {
                    UserProfile.find({
                        UserID : {
                            $in : teamProfile.Members.map(function (id) {
                                return id;
                            })
                        }
                    }, function (err, userProfiles) {
                        teamProfile.Members = userProfiles;
                        callback();
                    });
                });
            });

            teamProfiles.forEach(function (teamProfile) {
                asyncTasks.push(function (callback) {
                    Draft.find({
                        _id : {
                            $in : teamProfile.Drafts.map(function (id) {
                                return id;
                            })
                        }
                    }, function (err, drafts) {
                        teamProfile.Drafts = drafts;

                        async.each(drafts, function(draft, draftCallback){

                            Comment.find({
                                _id : {
                                    $in : draft.Comments.map(function (id) {
                                        return id;
                                    })
                                }
                            }).exec(function (err, comments) {
                                draft.Comments = comments;
                                draftCallback();
                            });

                        }, function(err){
                            callback();
                        });
                    });
                });
            });

            async.parallel(asyncTasks, function () {
                res.json(teamProfiles)
            });
        });
    });