在这种情况下需要对 Node.js 中的函数进行阻塞调用吗？

我开始学习node.js。我在这里遇到了一个问题。我正在调用返回 JSON 的天气服务（网址如下）。

http://api.wunderground.com/api/Your_key/conditions/q/CA/San_Francisco.json

我想在 HTML 页面上显示 api 的结果。

我编写了以下代码（getInfo 模块）来检索并返回 JSON。

var fbResponse; 

module.exports = function (url) {

var http=require('http');


http.get(url, function(res) {
    var body = '';

    res.on('data', function(chunk) {
        body += chunk;
    });

    res.on('end', function() {
        fbResponse = JSON.parse(body);  
        console.log("Got response: ", fbResponse.response);


    });

}).on('error', function(e) {
      console.log("Got error: ", e);
});


return fbResponse;
};

因此，为了使用这个模块，我创建了一个 test.js 文件，如下所示：

var relay = require('./getInfo');
var url = 'http://api.wunderground.com/api/Your_key/conditions/q/CA/San_Francisco.json';
var response;
var x=relay(url);

console.log (x);

输出如下：

undefined                //  console.log(x) from test.js
Got response:  { version: '0.1',
  termsofService: 'http://www.wunderground.com/weather/api/d/terms.html',
  features: { conditions: 1 } }

测试代码中的控制台输出首先运行，其中没有数据。 HTTP get 稍后竞争并显示我需要的实际输出。

如何修改测试代码以进行阻塞调用，以便测试代码中的 var x 实际上具有 JSON 输出而不是未定义？

我可以在不阻塞调用 getInfo 模块的情况下获得所需的结果吗？

如您所知，节点是异步的，因此回调http.get and res.on('end', ..将在之后触发relay函数被执行并返回。所以通常你不能从中返回结果。

您有几个选择：

• 将回调传递给relay并使用它：

  module.exports = function (url, cb) {
      http.get(url, function(res) {
  
          var body = '';
          res.on('data', function(chunk) {
              body += chunk;
          });
  
          res.on('end', function() {
              cb(null, JSON.parse(body));
          });
  
      }).on('error', cb);
  };
  

  然后像这样使用它：

  var relay = require('./getInfo');
  relay(url, function (err, x) {
      if (err) {
          console.error('oohh i got a error: ', err)    
      }
      console.log('oohh i got a response: ', x)    
  });
  

• 使用承诺。这与传递回调几乎相同。稍微不那么轻量级，但是当组合不同的异步操作时，你就会明白它们有多么棒。对于一个异步调用来说可能没有任何区别。这里我使用q。您还可以使用bluebird它的性能更高，但缺乏 q 的一些糖分。你可以阅读本文理解为什么在某些情况下承诺比回调更干净。

  module.exports = function (url) {
      var deferred = Q.defer();
      http.get(url, function(res) {
          var body = '';
          res.on('data', function(chunk) {
              body += chunk;
          });
  
          res.on('end', function() {
              deferred.resolve(JSON.parse(body));
          });
  
      }).on('error', function(e) {
          deferred.reject(e);
      });
      return deferred.promise;
  };
  
  
  
  var relay = require('./getInfo');
  relay(url).then(function responseHandler(x) {
      console.log('my awesome response')
  }, function errorHandler(err) {
      console.error('got an error', err);
  });
  

• 使用发电机。它是 Ecmascript 6 规范的一部分，仅存在于节点 v0.11.x 及更高版本中。但这几乎就是你想要的。

  通过过去的承诺示例，我们可以这样做：

  Q.async(function *() {
      var relay = require('./getInfo');
      var x = yield relay(url);
      console.log('my awesome response', x)
  });
  

  这几乎就是你想要的。您还可以使用回调解决方案来实现它co library:

  co(function *() {
      var relay = require('./getInfo');
      var x = yield relay.bind(null, url);
      console.log('my awesome response', x);
  });
  

  您还可以使用节点纤维在上面的例子中，它几乎是一个类似于生成器的工具。

  如果你想使用前沿的 Javascript，你可以使用异步/等待而不是有承诺的发电机。