尝试进行嵌套查询时已调用节点异步回调

debugcn 发表于 Dev

宝87

尝试使用MEAN堆栈进行异步查询时，我收到了一个已被称为“回调”的错误。我需要第二个回调仅在嵌套查询完成后触发（根据代码中的注释）。为什么会出现此错误？

路线示例：

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()执行所有查询。我对这一切都很陌生，因此请原谅一些错误。

老人

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

相反，您应在完成所有草稿查询后而不是对每个草稿查询，都调用完完成的回调。由于您正在使用异步，因此可以嵌套另一个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)
            });
        });
    });

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。