需要使用節點js異步調用兩個apis，並彙總來自apis的響應

Question

我到目前爲止編寫的代碼如下所示。 我不需要整個迴應，但只是其中的一部分。能夠同時做到以上

var request = require('request'); 
var async = require('async'); 

var asyncTasks = []; 
var install; 

async.series([ 

    function (callback) { 
     setTimeout(function() { 
     request('URL', function (error, response, body) { 
      if (!error && response.statusCode == 200) { 
      console.log(body); // Show the HTML for the Google homepage. 
      } 
     }); 
     }, 5000); 
    }, 

    function (callback) { 
     setTimeout(function() { 
     request('URL', function (error, response, body) { 
      if (!error && response.statusCode == 200) { 
      console.log(body); // Show the HTML for the Google homepage. 
      } 
     }); 
     }, 5000); 
    } 

    ], 
    function (error, results) { 
    console.log(results); 
    }); 

Answer 1

一種方法是使用async.parallel - 的形式：

async.parallel([ 
    function(){ ... }, 
    function(){ ... } 
], callback); 

另一種方法是使用一個承諾庫 - BlueBird或Q都是不錯的選擇。

Q.All是以下形式：

return Q.all([ 
    promise1, 
    promise2 
]).spread(function (resultFromPromise1, resultFromPromise2) { 
    // do something with the results... 

}）;

您可以使用這些方法之一來平行兩個調用。每個的輸出將給你一個數組，分別包含每個調用的結果。

下面是每個方法的一個簡單的例子：

使用Async.js

var async = require('async'); 

var task = function (cb, count) { 
    setTimeout(function() { 
    cb(null, "complete: " + count); 
    }, 1000); 
}; 

async.parallel([ 
    function (cb) { 
    task(cb, 'one'); 
    }, 
    function (cb) { 
    task(cb, 'two'); 
    } 
], function (err, results) { 
    console.log(results); 
    //[ 'complete: one', 'complete: two' ] 
}); 

使用Q：

var Q = require('q'); 

function task1(cb, count) { 
    var deferred = Q.defer(); 
    setTimeout(function() { 
    return deferred.resolve(cb(null, count)); 
    }, 1000); 
    return deferred.promise; 
} 

var myCb = function (err, count) { 
    return "complete: " + count; 
}; 

Q.all([task1(myCb, 'one'), task1(myCb, 'two')]) 
    .then(function (results) { 
    console.log(results); 
    //[ 'complete: one', 'complete: two' ] 
    }); 

讓我知道，如果你還不清楚。

Answer 2

承諾是在那裏幫助你在這種情況下。 我寧願使用'Q'庫。

我已經修改了你的代碼使用問答庫

var Q = require('q'); 
var request = require('request'); 


function makeCall() { 

Q.all([req1(), req2()]) 
    .spread(function (res1, res2) { 
     // This block is executed once all the functions(Provided in Q.all()) are finished its execution. 
     // Use responses from called functions 
    }, function (err) { 
     // Error, If any 
    }); 

} 

function req1() { 

var defer = Q.defer(); 
var url = ''; // Specify URL 
var options = { 
    method: 'get', // Method to use 
    url: url 
} 

request(options, function (err, res, body) { 
    if (err) { 
     return defer.reject(err); 
    } 
    return defer.resolve(body); 
}); 

return defer.promise; 
} 

function req2() { 

var defer = Q.defer(); 
var url = ''; // Specify URL 
var options = { 
    method: 'get', // Method to use 
    url: url 
} 
request(options, function (err, res, body) { 
    if (err) { 
     return defer.reject(err); 
    } 
    return defer.resolve(body); 
}); 
return defer.promise; 
} 

你可以找到對於Q庫這裏文檔：Q docs