如何使用nodejs强制执行async.each中的请求？

Question

我有一个 async.each 迭代一个数组，并且对于数组中的每个元素，它执行一个内部有请求的函数“检查”。这是代码，但是当我运行它时，我从调试器中看到节点没有执行检查功能并且它阻止了它的执行。

async.each(array,
  function(v_page, callback){
    if(v_page.url.length>=5){
      internals.check(v_page.url,array2, function (body) {
        callback();
      });
    }
  },
  function(err){
    internals.calls(var1,var2,var3);
});

我尝试了一个普通的 for 循环，但它跳转到了 internals.calls 函数，而没有执行 internals.check 函数来了解节点的异步性质。那么如何强制执行检查功能呢？

这是检查函数的代码：

internals.check = (url,array2,cb) => {
  request(url, function(err, recordset) {
    if(err){
      cb(array2);
    }else {
      //some stuffs
      cb(array2)
    }
  });
};

Answer 1

您仅在v_page.url.length >= 5 时调用callback，但您需要为每个元素都这样做：

async.each(array, function(v_page, callback) {
 if(v_page.url.length >= 5) {
   internals.check(v_page.url,array2, function(body) {
     callback();
   });
 } else {
   callback(); <== call callback here, when condition is not met
 }
 ...

另一个问题是，您在internals.check 中错误地调用了回调。根据 Node.js 的表示法，回调的第一个参数必须是错误或 null（异步使用这种表示法）。但在你的情况下，无论如何你都用array2 调用回调：

internals.check = (url, array2, cb) => {
  request(url, function(err, recordset) {
    if (err) {
      cb(err); // <== pass error here
    } else {
      cb(null, array2); // <== no error, so first parameter is null, the second is data
    }
  });
};