2

我开始为工作开发我的 node.js 应用程序，但我不能“认为异步”。在我的函数中，我必须做一个查询，并且对于每一行我都必须做另一个查询来计算最终结果并创建我的 json。我尝试这样做：

async.series([
    function(callback) {
            db.myCannedResponseList(req.params.websiteid, function(err,questions) {
                if (err) return callback(err);
                ...
                callback();
            });
        },
    function(callback) {
            async.forEachSeries(temp,function(quest,callback) {
                    db.getCannedAnswer(quest.id, function(err,answers) {
                         console.log(answers);
                    });
            }, function(err) {
                if (err) return next(err);
            });
            callback();
        }
    ],
        function(err) { 
            if (err) return next(err);
            res.json(output);
    });

但是有一个问题：getCannedAnswer的结果显示在res.json(output)之后。我该如何解决？

4

2 回答 2

5

完成后您需要调用回调forEachSeries。您还需要调用传递给forEachSeries处理函数的回调：

async.forEachSeries(temp, function(quest, callback2) {
  db.getCannedAnswer(quest.id, function(err, answers) {
    console.log(answers);
    // call the callback for forEachSeries so it can proceed:
    callback2(); 
  });
}, callback); // forEachSeries is done here, call the callback for async.series
于 2013-10-20T08:26:26.900 回答
0

您的异步函数是嵌套的，因此需要成为您的回调。

这是一种方法：

    async.series([
        //async.apply(db.myCannedResponseList,req.params.websiteid), // This is equivalent to the first function below
        //db.myCannedResponseList(req.params.websiteid,callback), // This is equivalent too
        function(callback) {
            db.myCannedResponseList(req.params.websiteid, callback);
        },    
        function(callback) {
            // I'm not sure forEach is the best choice here
            // since it's callback isn't called with all the results so it won't be able to be forwarded...
            // Personally, I use async.times for something like this.
            async.times(temp.length,function(i,next) {
                db.getCannedAnswer(temp[i].id,next);
            },callback)
        }
     ],function(err) { 
          if (err) return next(err);
          res.json(output);
    });

我不确定这个函数应该做什么，但如果你遇到错误，async.series你应该调用res.json(500,error)或不调用res成功。

一个好的方法是完全分离这个函数并让它在完成时调用另一个回调。然后你会打电话给res那里。

此外，您可以传递一个对象，而不是将数组传递给async.series您，以便将结果命名为命名空间。

完整示例：

    function getCannedStuff(data,callback){
        async.series({
            list : async.apply(db.myCannedResponseList,data.websiteid),
            answer : function(cb) {
                async.times(data.temp.length,function(i,next) {
                db.getCannedAnswer(data.temp[i].id,next);
                },cb)
            }
        },callback);  
    }

然后从另一个模块调用该函数：

    getCannedStuff({
        websiteid: req.params.websiteid,
        temp:temp
    },function(error,results) {
        console.log(results.list);
        console.log(results.answer);
        if(err) return res.json(500,{error : error});
        res.json(results)
    });

您应该决定是否要控制内部或外部的错误，getCannedStuff但这是一个很好的方法来传递它们，而不是一直if(err)查看它们是否发生。

于 2013-10-20T09:53:25.320 回答