我是这个 node.js 的新手..我对这个回调有点困惑..在我的 for 循环内的应用程序中，我正在调用异步函数调用，我认为我的问题是在我得到响应之前异步调用我的 for 循环被循环。

我的代码:

async.forEach(Object.keys(config), function(key, next) {
        search(config[key].query, function(err, result) { // 
        console.log("fffffffffff="+ util.inspect(result))-------- >>>Getting undefined..
            if (err) return next(err) // 
            var json = JSON.stringify({
                "result": result
            });
            results[key] = {
                "result": result
            }
            console.log("rrrrrrrr="+util.inspect(results[key]))
            next() // <---- critical piece.  This is how the forEach knows to continue to the next loop.  Must be called inside search's callback so that it doesn't loop prematurely.                   
        })
    },
    function(err) {
        console.log('iterating done');

         res.writeHead(200, {
        'content-type': 'application/json'
    });
    res.end(JSON.stringify(results));  
    });


}

搜索功能代码:

var matches = [];
    var qrySubString = query.substring(0, 4);
    client.query("select * from xxxxxxxxx where level4 ILIKE '%" + query + "%'", function(err, row1, fields) {
        for (var id in row1.rows) {                
            var match, name;                
            if (query == row1.rows[id].level4) {
                match = true;
                name = row1.rows[id].level4;
            }
            else {
                match = false;
                name = query;
            }
            matches.push({
                "id": id,
                "name": row1.rows[id].level4,
                "score": 100,
                "match": match,
                "type": [{
                    "id": "/people/presidents",
                    "name": "US President"
                }]
            })
        }           
        callback(matches);
    })

我想在成功执行1个搜索功能后执行for循环，我想我必须使用异步for循环。请指导我解决这个问题..提前谢谢..

最佳答案

我已将您的代码示例简化为以下几行，以便更容易理解对概念的解释。

var results = [];
var config = JSON.parse(queries);
for (var key in config) {
    var query = config[key].query;
    search(query, function(result) {
        results.push(result);
    });
}
res.writeHead( ... );
res.end(results);

前面代码的问题是 search函数是异步的，因此当循环结束时，没有调用任何回调函数。因此，results 的列表是空的。

要解决此问题，您必须将代码放在回调函数中的循环之后。

    search(query, function(result) {
        results.push(result);
        // Put res.writeHead( ... ) and res.end(results) here
    });

但是，由于回调函数被多次调用(每次迭代一次)，您需要以某种方式知道所有回调都已被调用。为此，您需要统计回调的次数，并检查该次数是否等于异步函数调用的次数。

要获取所有键的列表，请使用 Object.keys .然后，为了遍历这个列表，我使用 .forEach (您也可以使用 for (var i = 0, key = keys[i]; i < keys.length; ++i) { .. } ，但这可能会产生问题，请参阅 JavaScript closure inside loops – simple practical example )。

这是一个完整的例子:

var results = [];
var config = JSON.parse(queries);
var onComplete = function() {
    res.writeHead( ... );
    res.end(results);
};
var keys = Object.keys(config);
var tasksToGo = keys.length;
if (tasksToGo === 0) {
   onComplete();
} else {
    // There is at least one element, so the callback will be called.
    keys.forEach(function(key) {
        var query = config[key].query;
        search(query, function(result) {
            results.push(result);
            if (--tasksToGo === 0) {
                // No tasks left, good to go
                onComplete();
            }
        });
    });
}

注意:上例中的异步代码是并行执行的。如果需要按特定顺序调用函数，则可以使用递归来获得所需的效果:

var results = [];
var config = JSON.parse(queries);
var keys = Object.keys(config);
(function next(index) {
    if (index === keys.length) { // No items left
        res.writeHead( ... );
        res.end(results);
        return;
    }
    var key = keys[index];
    var query = config[key].query;
    search(query, function(result) {
        results.push(result);
        next(index + 1);
    });
})(0);

我展示的是概念，您可以在您的实现中使用众多(第三方)NodeJS 模块之一，例如 async .

关于javascript - node.js中的异步for循环，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/21184340/