很难理解节点中的 async.parallel

Question

我在控制器中有这个功能

router.post('/', function(req, res, next) {
  if (req.user.isPremium == false) {
    // Free user - Single report
    let website = req.body.website0;
    let builtWithCall = `https://api.builtwith.com/free1/api.json?KEY=APIKEY&LOOKUP=${website}`;
    let pagespeedCall = `https://www.googleapis.com/pagespeedonline/v4/runPagespeed?url=https://${website}&strategy=mobile&key=APIKEY`;
    // curl 'https://www.googleapis.com/pagespeedonline/v4/runPagespeed?url=https://georgiancollege.ca&strategy=mobile&key=APIKEY'
    var calls = [];
    calls.push(function(callback) {
      // First call
      https.get(builtWithCall, function(resource) {
        resource.setEncoding('utf8');
        resource.on('data', function(data) {
          // console.log('BuiltWith received', data);
        });
      });
    });
    calls.push(function(callback) {
      // second call
      https.get(pagespeedCall, function(resource) {
        resource.setEncoding('utf8');
        resource.on('data', function(data) {
          // console.log(data);
        });
      });
    });
  } else {
    // Premium user - comparison report
    let websites = [];
  }
  async.parallel(calls, function(err, results) {
    if(err){
      console.log(err);
    }
    console.log('async callback ', results);
    res.render('/generated-report', {
      title: 'Report',
      data: {},
    });
  });
});

我正在尝试一次运行多个异步 API 调用。问题是，当我尝试像这样运行它们时

async.parallel(calls, function(err, results) {
  if(err){
    console.log(err);
  }
  console.log('async callback ', results);
  res.render('/generated-report', {
    title: 'Report',
    data: {},
  });
});

控制台不记录任何内容。

当我在这里做控制台日志时

function(callback) {
  // second call
  https.get(pagespeedCall, function(resource) {
    resource.setEncoding('utf8');
    resource.on('data', function(data) {
      // console.log(data);
    });
  });
}

它记录响应。 pageSpeed 进入一个奇怪的循环并重复多次，但至少它有效。

现在我在 async.parallel 部分做错了什么？还有function(callback) {中的这个回调是什么？

编辑：

这是新版本的匿名函数：

function(callback) {
  // second call
  var results;
  https.get(pagespeedCall, function(resource) {
    resource.setEncoding('utf8');
    resource.on('data', function(data) {
      results += data;
      // console.log(data);
    });
    resource.on('end', function(data) {
      callback(null, data);
    });
    resource.on('error', function(err) {
      callback(err);
    });
  });
}

Answer 1

你需要调用传入的callback。查看您的一个并行函数，您没有调用callback()。我假设你的 resource 对象有一个 end & error

function(callback) {
  // second call
  var results;
  https.get(pagespeedCall, function(resource) {
    resource.setEncoding('utf8');
    resource.on('data', function(data) {
       results += data;
      // console.log(data);
    });
    resource.on('end' function() {
      callback(null, results);
    });
    resource.on('error' function(err) {
      callback(err);
    });
  });
}

async.parallel 的工作原理是所有调用的函数都必须依次调用传入的回调函数；在你的情况下是callback。 一旦并行中的每个函数都调用了回调，那么只有这样才会调用最终的函数，即您定义为function(err, results) {...}的函数。

有一个警告，如果在 callback 调用中为第一个参数传递非空值，那么将立即调用最终函数，如果发生错误，您应该在其中处理该错误。