http अनुरोध पर http सर्वर को पाइप करके सरल node.js प्रॉक्सी

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

ठीक है। समझ गया।

अद्यतन: एनबी! जैसा कि टिप्पणियों में बताया गया है, यह उदाहरण अब और काम नहीं करता है।

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

आप न 'रोकें' करने के लिए है, सिर्फ 'पाइप': अधिकांश शायद Streams2 API परिवर्तन (नोड 0.9+)

पाइपिंग वापस ग्राहक के लिए की वजह से इस प्रकार के अंदर कनेक्टर के कॉलबैक होना होता है ठीक है

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

http अनुरोध तब तक समाप्त नहीं होगा जब तक आप इसे 'अंत' नहीं बताते;

Answer 3

मैंने इस पोस्ट के उदाहरण प्रॉक्सी http/s अनुरोधों के लिए उपयोग किए। समस्या से सामना करना पड़ा कि कुकीज़ कहीं खो गई थी।

तो इसे ठीक करने के लिए आपको प्रॉक्सी प्रतिक्रिया से शीर्षलेखों को संभालने की आवश्यकता है।

काम कर उदाहरण नीचे:

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