25
  1. 我想以快递收听传入的 POST 请求。
  2. 我想将此请求传送到另一台服务器
  3. 我想在快速处理程序中接收响应（我不想将响应通过管道传输到快速 res 流）

现在我有以下代码：

app.post('server1',function(req,res,next){
    var request = require('request');
    req.pipe(request.post('server2')).pipe(res);

}

所以这不起作用 - 请求甚至没有通过管道传输到 server2 - 我检查了它并且没有传入请求。

我这样解决了第 1 点和第 2 点：

var bodyParser = express.bodyParser();

app.use(function(req,res,next){

    if(req.path == '/server1' && req.method == 'POST') {
        return next();
    }
    else {
        bodyParser(req,res,next);
    }
});

不是很好，但它可以工作 - 它只是为单个路由（POST /server1）禁用bodyparser。

但我仍然不知道如何从管道请求中获取 json 响应正文 - 我有以下代码：

app.post('/server1',function(req,res,next){

    var request = require('request');
    var pipe = req.pipe(request.post('/server2'));

    pipe.on('end',function(){

        var res2 = pipe.response;
        console.log(res2);

    });
});

res2对象具有正确的状态代码和标题等，但它不包含正文 - 我如何从res2对象中获取它？/server2在 json 中返回一些数据，但我不知道如何从响应中读取它...

4

2 回答 2

18

它不起作用，因为 bodyParser 用解析器拦截了所有主体

于 2013-09-20T06:50:45.863 回答
8

我想你快到了。您应该监听data管道上的事件以收集响应：

app.post('/server1',function(req,res,next) {
  var request   = require('request');
  var pipe      = req.pipe(request.post('/server2'));
  var response  = [];

  pipe.on('data',function(chunk) { 
    response.push(chunk);
  });

  pipe.on('end',function() { 
    var res2 = Buffer.concat(response);
    console.log(res2);
    // don't forget to end the 'res' response after this!
    ...
  });
});

但是，由于您解决了“bodyParser() 妨碍”问题，如果您只想返回 server2 生成的响应，也可以使用初始管道设置（另外，使用时请务必使用正确的 URL request）。

于 2013-09-20T08:08:46.957 回答