javascript - MongoDB 和 Node js 异步编程

Question

我正在尝试解决考试问题，所以我无法按原样发布我的考试代码。所以我进行了简化，以解决我不理解的核心概念。基本上，我不知道如何减慢 Node 的异步执行速度，以便我的 mongo 代码能够 catch 它。这是代码:

MongoClient.connect('mongodb://localhost:27017/somedb', function(err, db) {
  if (err) throw err;
  var orphans  = [];
  for (var i; i < 100000; i++) {
    var query = { 'images' : i };
    db.collection('albums').findOne(query, function(err, doc_album) {
        if(err) throw err;
        if (doc_album === null) {
          orphans.push(i);
        }
    });
  }
  console.dir(orphans.length);
  return db.close();
});

因此，我正在尝试创建一组不符合我的查询条件的图像。我最终得到 orphans.length 值为 0，因为 Node 不等待回调完成。如何修改代码，以便在计算数组中不符合查询条件的图像数量之前回调完成执行？

提前感谢您的宝贵时间。

印度

Answer 1

我假设您想进行 100000 次并行数据库调用。为了在每个调用回调中“等待”10000 个调用完成，我们增加了完成的调用计数器并在最后一个调用完成时调用主回调。请注意，这里非常常见的错误是使用 for 循环变量作为回调内部的闭包。这并不像预期的那样工作，因为所有 10000 个处理程序首先被安排，并且在第一次执行时循环变量具有相同的最大值。

function getOrphans(cb) {
  MongoClient.connect('mongodb://localhost:27017/somedb', function(err, db) {
    if (err) cb(err);
    var orphans  = [];

    var numResponses = 0;
    var maxIndex = 100000
    for (var i = 0; i < maxIndex; i++) {
       // problem: by the time you get reply "i" would be 100000.
       // closure variable changed to function argument:  
       (function(index) {
        var query = { 'images' : index };
        db.collection('albums').findOne(query, function(err, doc_album) {
          numResponses++;
          if(err) cb(err);
          if (doc_album === null) {
            orphans.push(index);
          }
          if (numResponses == maxIndex) {
            db.close();
            cb(null, orphans);
          }
        });
      })(i); // this is "immediately executed function
    }
  });
 }


 getOrphans(function(err, o) {
   if (err)
     return console.log('error:', err);
   console.log(o.length);
 });