node.js 中的异步 for 循环

IT技术 javascript node.js
2021-02-06 01:57:49

我是这个 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 循环,我想我必须使用 async for 循环。请指导我解决这个问题..提前谢谢..

4个回答

我已将您的代码示例缩减为以下几行,以便更容易理解该概念的解释。

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 闭包 - 简单的实际示例)。

这是一个完整的例子:

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 module之一,例如async

@Subburaj 虽然我很欣赏 +1,但您应该根据其value而不是发布它的用户的努力来评价答案。如果答案根本没有帮助,请不要点赞。如果答案实际上是错误的,请拒绝它。如果答案解决了您的问题,请接受它。
2021-03-16 01:57:49
我遵循了你的第二个选项..它工作正常..你能帮我清除更多的疑问吗:正如你所说的在执行 for 循环后没有执行回调所以结果为空..现在 forEach 调用回调的循环..
2021-03-27 01:57:49
@Subburaj 在第一个示例中,当所有任务都处理完毕后,剩余任务数为零。然后,onComplete被调用。
2021-04-02 01:57:49
嘿伙计,很好的解释。1 个快速问题 - OnComplete 中的内容可以是回调函数调用吗?
2021-04-03 01:57:49
@mles 为什么你认为回调会过早地被调用?想象一下,只有一把钥匙。然后tasksToGo = keys.length = 1完成任务后,--tasksToGo == 0会为真,并被onComplete调用。如果有 2 个项目,则预增量运算符将给出 1,这不是 0,因此不会过早调用回调。
2021-04-11 01:57:49

你已经正确地诊断出你的问题,干得好。一旦您调用搜索代码,for 循环就会继续运行。

我是https://github.com/caolan/async 的忠实粉丝,它对我很有用。基本上有了它,你最终会得到类似的东西:

var async = require('async')
async.eachSeries(Object.keys(config), function (key, next){ 
  search(config[key].query, function(err, result) { // <----- I added an err here
    if (err) return next(err)  // <---- don't keep going if there was an error

    var json = JSON.stringify({
      "result": result
    });
    results[key] = {
      "result": result
    }
    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');
}); 

我希望这有帮助!

我没有在 async 中找到 forEach :S only each,它显然没有回调
2021-03-21 01:57:49
当我尝试实现您的代码时遇到一些问题..请参阅我编辑的问题..
2021-03-24 01:57:49
您遇到的问题是我更改了您传递给search. 我写的回调需要一个错误对象作为它的第一个参数而不是结果对象。如果您要采用这种方法来执行此操作,则需要将您的 `callback(matches);` 调用更改为类似 `callback(err,matches);` 的内容。然后调用者可以查看错误对象。
2021-04-03 01:57:49
尝试: async.eachSeries(arr, iterator, callback)
2021-04-07 01:57:49
你的样本最后错过了一个 )
2021-04-08 01:57:49

Node.js介绍了async await7.6所以这使得Javascript更美丽。

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

为此,search功能必须返回 apromise或必须是async函数

如果它没有返回一个Promise你可以帮助它返回一个Promise

function asyncSearch(query) {
  return new Promise((resolve, reject) => {
   search(query,(result)=>{
    resolve(result);
   })
  })
}

然后将这一行替换await search(query);await asyncSearch(query);

@PrashantTapase 你应该总是用 await 包裹try catch并Promisereject会去catch
2021-03-30 01:57:49

我喜欢在这种情况下使用递归模式。例如,这样的事情:

// If config is an array of queries
var config = JSON.parse(queries.queryArray);   

// Array of results
var results;

processQueries(config);

function processQueries(queries) {
    var searchQuery;

    if (queries.length == 0) {
        // All queries complete
        res.writeHead(200, {'content-type': 'application/json'});
        res.end(JSON.stringify({results: results}));
        return;
    }

    searchQuery = queries.pop();

    search(searchQuery, function(result) {
        results.push(JSON.stringify({result: result}); 
        processQueries();            
    });
}

processQueries是一个递归函数,它将从要处理的查询数组中提取一个查询元素。然后processQueries当查询完成时回调函数再次调用processQueries当没有查询时知道结束。

使用数组最容易做到这一点,但可以修改它以使用我想象的对象键/值。