使用 nodeJS 进行异步 http 调用

Question

我想在我的服务器节点上启动异步 http 调用，我看到了 async 节点模块，我猜 async.parallel 使我们能够做到这一点。

文档中的示例非常清楚，但我不知道如何管理多个 http 调用。

我尝试了下面的示例，但它甚至没有启动 http 调用：

var http = require('http');

var Calls = [];
Calls.push(function(callback) {
    // First call
    http.get('http://127.0.0.1:3002/first' callback);
});

Calls.push(function(callback) {
    // Second call
     http.get('http://127.0.0.1:3002/second' callback);
});

var async = require('async');
async.parallel(Calls, function(err, results) {
    console.log('async callback: '+JSON.stringify(results));
    res.render('view', results);
});

如果我单独启动 http 请求，我确实有结果，但调用异步回调我得到async callback: [null,null]

Answer 1

看看the documentation:

使用 http.request() 必须始终调用 req.end() 来表示 您已完成请求 - 即使没有写入数据 到请求正文。

您正在创建一个请求，但您没有完成它。在您的通话中，您应该这样做：

var req = http.request(options, function(page) {
    // some code
});
req.end();

这是假设您正在执行没有正文的普通 GET 请求。

您还应该考虑使用http.get，这是一个不错的快捷方式：

http.get("http://127.0.0.1:3002/first", function(res) {
    // do something with result
});

更新另一件事是异步回调必须是形式

function(err, res) { ... }

你现在的做法行不通，因为对 http.get 的回调只接受一个参数res。您需要做的是：

http.get('http://127.0.0.1:3002/second', function(res) {
    callback(null, res);
});

Answer 2

好的，事情是以这种方式调用回调callback(null, res); 而不是callback(res);，我认为第一个参数被解释为错误，第二个是真正的结果。

Answer 3

不要将大写名称用于类型/类以外的其他目的

下面是你的代码，纠正了明显的错误

var http = require('http');

var calls = [];
calls.push(function(callback) {
    // First call
    http.get('http://127.0.0.1:3002/first', function (resource) {
         resource.setEncoding('utf8');
         resource.on('data', function (data) {
             console.log('first received', data);
             callback();
         });
    });
});

calls.push(function(callback) {
    // Second call
    http.get('http://127.0.0.1:3002/second', function (resource) {
         resource.setEncoding('utf8');
         resource.on('data', function (data) {
             console.log('second received', data);
             callback();
         });
    });
});

var async = require('async');
async.parallel(calls, function(err, results) {
    console.log('async callback ', results);
    res.render('view', results);
});