1

事情是这样的：我有一个将数据发送到服务器的客户端。该服务器必须联系外部 API 并将其响应发送回客户端。一旦服务器获得客户端数据，我就是不知道如何以及在何处联系外部 API。

我像这样路由客户端数据：

app.post('/getAutoComplete', routes.read);

routes.read 检索 req.body 中的数据。使用我的 nodejs 版本（没有 express 框架），然后我以这种方式请求 api：

var http = require('http'), options = {
        host : "192.168.1.38",
        port : 8080,
        path : "/myURL",
        method : 'POST'
};

var webservice_data = "";

var webservice_request = http.request(options, function(webservice_response)
{
    webservice_response.on('error', function(e){ console.log(e.message); });
    webservice_response.on('data', function(chunk){ webservice_data += chunk;});
    webservice_response.on('end', function(){res.send(webservice_data);});
});

webservice_request.write(req.body);
webservice_request.end();

问题是我想使用原生 expressJS 方法，如 app.post 但我不知道如何，因为：

  1. Express (app) 对象在此处不​​可用（在 app.js 中声明但不在路由文件中）
  2. 我不知道如何使用 app.post 发送 POST 数据

有什么建议吗？

4

2 回答 2

2 
app.post('/getAutoComplete', routes.read);
// assuming routes.read lookes something like this
routes.read = function read(req, res) {
  var http = require('http'), options = {
          host : "192.168.1.38",
          port : 8080,
          path : "/myURL",
          method : 'POST'
  };

  var webservice_data = "";

  var webservice_request = http.request(options, function(webservice_response)
  {
      webservice_response.on('error', function(e){ console.log(e.message); });
      webservice_response.on('data', function(chunk){ webservice_data += chunk;});
      webservice_response.on('end', function(){res.send(webservice_data);});
  });

  webservice_request.write(req.body);
  webservice_request.end();
};

另请查看https://github.com/mikeal/request 它是在节点中执行 Web 请求的事实上的模块。

于 2012-04-20T07:36:40.217 回答
0

routes.read是一个函数。您可以使用额外的参数调用它，例如

app.post('/getAutoComplete', function(req,res) {
    var q = req.query.q;  // or whatever data you need
    routes.read(q, function(err, response) {
        if (err) throw err;
        return res.json(response);
    });
});

现在让routes.read函数使用第一个参数作为查询，当它从远程 API 收集响应时，调用第二个参数，将任何错误作为第一个参数，将响应作为第二个参数。

更新这个答案已经被选为答案，但如果我也展示了一个 routes.read 的例子，它会更有帮助：

routes.read = function(q, cb) {
    // pretend we calculate the result
    var result = q * 10;
    if (result > 100) {
        // call the callback with error set
        return cb("q value too high");
    }
    // all is well, use setTimeout to demonstrate
    // an asynchronous return
    setTimeout(function() { cb(null, result) }, 2000);
};
于 2012-04-20T04:15:08.313 回答