NodeJS：在for循环中调用回调函数

Question

基本上，我正在尝试调用一个函数，其中正在运行一个循环，其中存在许多回调函数（回调地狱）..如下：

for(var i=0;i<data.id.length;i++)
{
    DAO.getUserById(data.id[i],function(err,resp1)
    {
       /* some other work based on resp1 */
       DAO.getOtherData(resp1.username,resp1.userId,function(err,resp2)
       {
           /* similary some other work*/
       });
    });
}  

我在我的应用程序的多个位置有相同的模式，有时我遇到了回调问题，for 循环结束，但回调没有给出响应，这似乎是 DAO 方法已被调用但仍在等待回复。 有没有优化的方法来克服这个问题？

很高兴知道是否有一些 javascript 编码模式可以解决这个问题。（除了任何 3rd 方库）谢谢

Answer 1

您听说过延迟或承诺吗？我想这就是你要找的。在它的基本形式中，它基本上是一个有两个处理程序的对象。一个代表失败，一个代表成功。

但还有其他帮助函数，例如 then 或 when，它们可以让您以更易读的方式链接这些函数。查看 q 或 jQuery 实现。有关非常好的介绍，请阅读 Async JavaScript 一书。

编辑：/

我为你做了一个js fiddle 的工作示例。

    var data = { id : [] };

    for(var i = 0; i < 10; i++) {
        data.id.push(i);
    }

    // DAO definition
    var DAO = {
        getUserById : function(id) {
            var deferred = $.Deferred();

            setTimeout(function() { 
                var isError = Math.floor(Math.random()*11) > 5;

                if(isError) {
                    deferred.reject("WOW - Much Handler - So error");
                } else {
                    deferred.resolve({
                        username :  'Max',
                        userId : id
                    }); 
                }
            }, 50);

            return deferred.promise();
        },

        getOtherData : function(username, userId) {
            var deferred = $.Deferred();

            setTimeout(function() {
                deferred.resolve((username + ' id: ' + userId));
            }, 20);

            return deferred.promise();
        }
    };



    function printResult(res) {
        $('#result').html($('#result').html() + '<br />' + res);
    };

    // DAO usage

    for(var i=0;i<data.id.length;i++)
    {
        DAO.getUserById(data.id[i])
        .done(function(res) {
            DAO.getOtherData(res.username, res.userId).done(function(result) {
                printResult(result);
            });
        })
        .fail(function(res) {
            printResult(res);
        });
    }

这样做的巨大优势是双重的：

1. 您可以免费获得错误处理程序代码和结果处理程序代码的分离
2. 它可以防止你在地狱中筑巢。 （回调，回调，回调......）由于延迟，您可以将实际逻辑分解出来。
3. 回调同步变得非常容易，因为您只需要使用when。

我使用了 jQuerys Deferreds，因为 jsFiddle 在下拉框中有 jquery。你可以使用任何你想要的实现。

当您获得概念后，自己实施它应该不会太难。

Answer 2

您可以使用 async.waterfall function 来解决您的问题。所有函数都被串行调用，函数的结果作为参数发送给下一个函数。以下是文档中的示例用法：

async.waterfall([
    function(callback){
        callback(null, 'one', 'two');
    },
    function(arg1, arg2, callback){
        callback(null, 'three');
    },
    function(arg1, callback){
        // arg1 now equals 'three'
        callback(null, 'done');
    }
], function (err, result) {
   // result now equals 'done'    
});

Answer 3

看看这段代码。

var i=0;
var length = data.id.length;
var getData = function(index)
{
    DAO.getUserById(data.id[index],function(err,resp1)
    {
        /* some other work based on resp1 */
        DAO.getOtherData(resp1.username,resp1.userId,function(err,resp2)
        {
             /* similary some other work*/
             index++;
             if(index < length)
             {
                getData(index);
             }
        });
   });
}
getData(i);

这是你需要的吗？