42

我正在使用 express 模块在 Node.js 中构建一个 RESTful API。在我的服务中，我正在向外部端点（服务器端）发出额外的 HTTP 请求。我需要将来自这些 HTTP 请求的数据返回到我的 Web 服务的请求正文。

在 Web 服务正在执行的所有操作中，通过使用console.log()我已经确认我得到了我需要的数据。但是，当我尝试将这些值返回给服务时，它们会返回 value null。我知道这是因为请求是异步的，并且回调没有等待 HTTP 请求完成。

有没有办法使这项工作？

4

3 回答 3

43

一种常见的做法是使用异步模块。

npm install async

该async模块具有处理各种形式的异步事件的原语。

在您的情况下，该async#parallel调用将允许您同时向所有外部 API 发出请求，然后组合结果以返回给请求者。

由于您正在发出外部 http 请求，因此您可能会发现request模块也很有帮助。

npm install request

使用request和async#parallel你的路由处理程序看起来像这样......

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

exports.handler = function(req, res) {
  async.parallel([
    /*
     * First external endpoint
     */
    function(callback) {
      var url = "http://external1.com/api/some_endpoint";
      request(url, function(err, response, body) {
        // JSON body
        if(err) { console.log(err); callback(true); return; }
        obj = JSON.parse(body);
        callback(false, obj);
      });
    },
    /*
     * Second external endpoint
     */
    function(callback) {
      var url = "http://external2.com/api/some_endpoint";
      request(url, function(err, response, body) {
        // JSON body
        if(err) { console.log(err); callback(true); return; }
        obj = JSON.parse(body);
        callback(false, obj);
      });
    },
  ],
  /*
   * Collate results
   */
  function(err, results) {
    if(err) { console.log(err); res.send(500,"Server Error"); return; }
    res.send({api1:results[0], api2:results[1]});
  }
  );
};

您还可以在此处阅读有关其他回调排序方法的信息。

于 2013-05-31T21:13:03.480 回答
17

Node.js 都是关于回调的。除非 API 调用是同步的（罕见且不应该这样做），否则您永远不会从这些调用中返回值，而是使用回调方法中的结果进行回调，或者调用 express 方法 res.send

request.js 是一个很好的调用 Web 请求的库

让我们以调用 google 的非常简单的示例为例。使用 res.send，您的 express.js 代码可能如下所示：

var request = require('request');
app.get('/callGoogle', function(req, res){
  request('http://www.google.com', function (error, response, body) {
    if (!error && response.statusCode == 200) {
      // from within the callback, write data to response, essentially returning it.
      res.send(body);
    }
  })
});

或者，您可以将回调传递给调用 Web 请求的方法，并从该方法中调用该回调：

app.get('/callGoogle', function(req, res){
  invokeAndProcessGoogleResponse(function(err, result){
    if(err){
      res.send(500, { error: 'something blew up' });
    } else {
      res.send(result);
    }
  });
});

var invokeAndProcessGoogleResponse = function(callback){
  request('http://www.google.com', function (error, response, body) {

    if (!error && response.statusCode == 200) {
      status = "succeeded";
      callback(null, {status : status});
    } else {
      callback(error);
    }
  })
}
于 2013-05-31T21:48:26.123 回答
3

等待 https://github.com/luciotato/waitfor

使用wait.for的其他答案示例：

Daniel's Answer (async) 中的示例，但使用的是 Wait.for

var request = require('request');
var wait = require('wait.for');

exports.handler = function(req, res) {
try {  
    //execute parallel, 2 endpoints, wait for results
    var result = wait.parallel.map(["http://external1.com/api/some_endpoint"
                 ,"http://external2.com/api/some_endpoint"]
                 , request.standardGetJSON); 
    //return result
    res.send(result);
}
catch(err){
    console.log(err); 
    res.end(500,"Server Error")
}
};

//wait.for requires standard callbacks(err,data)
//standardized request.get: 
request.standardGetJSON = function ( options, callback) {
    request.get(options,
            function (error, response, body) {
                //standardized callback
                var data;
                if (!error) data={ response: response, obj:JSON.parse(body)};
                callback(error,data);
            });
}
于 2013-09-06T14:24:13.377 回答