简单的node.js代理通过将http服务器传递给http请求

Question

尝试通过创建一个简单的http代理服务器来了解有关node.js的更多信息.使用场景很简单:用户 - >代理 - >服务器 - >代理 - >用户

以下代码一直有效,直到最后一步.无法找到管道连接器输出回用户的方法.

#!/usr/bin/env node

var
    url = require('url'),
    http = require('http'),
    acceptor = http.createServer().listen(3128);

acceptor.on('request', function(request, response) {
    console.log('request ' + request.url);
    request.pause();
    var options = url.parse(request.url);
    options.headers = request.headers;
    options.method = request.method;
    options.agent = false;

    var connector = http.request(options);
    request.pipe(connector);
    request.resume();
//  connector.pipe(response); // doesn't work
//  connector.pipe(request); // doesn't work either
});

使用tcpflow我看到来自浏览器的传入请求,然后是传出代理请求,然后是服务器响应回代理.不知何故,我无法将响应重新传输回浏览器.

使用管道实现此逻辑的正确方法是什么？

Answer 1

你不必'暂停',只需'管'即可

var connector = http.request(options, function(res) {
  res.pipe(response, {end:true});//tell 'response' end=true
});
request.pipe(connector, {end:true});

http请求不会完成,直到你告诉它'结束';

Answer 2

好.得到它了.

更新:NB!正如评论中所报告的那样,此示例不再起作用.最有可能是由于Streams2 API更改(节点0.9+)

管道返回客户端必须在连接器的回调内发生,如下所示:

#!/usr/bin/env node

var
    url = require('url'),
    http = require('http'),
    acceptor = http.createServer().listen(3128);

acceptor.on('request', function(request, response) {
    console.log('request ' + request.url);
    request.pause();
    var options = url.parse(request.url);
    options.headers = request.headers;
    options.method = request.method;
    options.agent = false;

    var connector = http.request(options, function(serverResponse) {
            serverResponse.pause();
            response.writeHeader(serverResponse.statusCode, serverResponse.headers);
            serverResponse.pipe(response);
            serverResponse.resume();
    });
    request.pipe(connector);
    request.resume();
});

Answer 3

我使用这篇文章中的示例来代理 http/s 请求。面临cookie在某处丢失的问题。

因此，要解决此问题，您需要处理代理响应中的标头。

下面是工作示例：

const http = require('http');
const acceptor = http.createServer().listen(3128);

acceptor.on('request', function(request, response) {
  const req = service.request(options, function(res) {
      response.writeHead(res.statusCode, res.headers);
      return res.pipe(response, {end: true});
  });
  request.pipe(req, {end: true});
});