Semplice proxy node.js mediante piping del server http alla richiesta http

Question

Cercando di saperne di più su node.js creando un semplice server proxy http. Lo scenario di utilizzo è semplice: utente -> proxy -> server -> proxy -> utente

Il codice seguente funziona fino all'ultimo passaggio. Impossibile trovare il modo di reindirizzare l'output del connettore all'utente.

#!/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 
}); 

Utilizzando tcpflow vedo la richiesta in ingresso dal browser, allora la richiesta proxy in uscita, quindi la risposta del server indietro al proxy. In qualche modo non sono riuscito a ritrasmettere la risposta al browser.

Qual è il modo corretto di implementare questa logica con i tubi?

Answer 1

OK. Fatto.

AGGIORNAMENTO: NB! Come riportato nei commenti, questo esempio non funziona più. Molto probabilmente a causa del cambiamento Streams2 API (nodo 0.9+)

Piping al client deve accadere callback di connettore all'interno come segue:

#!/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 2

non dovete 'pausa', solo 'pipe' è ok

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

la richiesta http non finirà fino a quando non lo dirai "fine";

Answer 3

Ho utilizzato gli esempi da questo post per le richieste http/s proxy. Di fronte al problema che i cookie sono stati persi da qualche parte.

Quindi per risolvere il problema è necessario gestire le intestazioni dalla risposta proxy.

Sotto l'esempio di lavoro:

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