Node.js - 將端口A的所有流量轉發到端口B

Question

我試圖將端口6999的所有流量轉發到端口7000（我知道我可以使用iptables，但想法是使用Node.js來做一些包檢查）。

這裏是我SOFAR代碼：

var net=require('net'); 
var compress=require('./node-compress/compress'); 

var ip='172.16.1.224'; 
var ipPort=6999; 
var opPort=7000; 

var output=net.createServer(function(connOut){ 
     var input=net.createServer(function(connIn){ 
       connIn.pipe(connOut); 
     }); 
     input.listen(ipPort,ip); 
}); 
output.listen(opPort,ip); 

它只是似乎沒有工作。當我在7000端口上執行tcpdump時，什麼也沒有顯示出來。任何人有任何建議？

提前許多感謝，

Answer 1

這是我走在它的腳本：

支持給予「從」和「到」的命令行，並支持遠程機器。

var net = require('net'); 

// parse "80" and "localhost:80" or even "42mEANINg-life.com:80" 
var addrRegex = /^(([a-zA-Z\-\.0-9]+):)?(\d+)$/; 

var addr = { 
    from: addrRegex.exec(process.argv[2]), 
    to: addrRegex.exec(process.argv[3]) 
}; 

if (!addr.from || !addr.to) { 
    console.log('Usage: <from> <to>'); 
    return; 
} 

net.createServer(function(from) { 
    var to = net.createConnection({ 
     host: addr.to[2], 
     port: addr.to[3] 
    }); 
    from.pipe(to); 
    to.pipe(from); 
}).listen(addr.from[3], addr.from[2]); 

（保存爲的proxy.js）

爲了從本地主機轉發：9001 =>本地主機：80

$ node proxy.js 9001 80 

或本地主機：9001 => OTHERHOST：80

$ node proxy.js 9001 otherhost:80 

（這是基於安德烈的回答，謝謝！）

Answer 2

你有沒有看Node.js的模塊Hoxy？從開發者的自述

http://www.youtube.com/watch?v=2YLfBTrVgZU

簡單描述：

Hoxy是node.js的，旨在用於web開發者網絡黑客的代理服務器。使用hoxy，您可以充當「中間人」，並根據一組有條件的規則在HTTP請求和響應流經時改變它們。作爲一個正在運行的進程，hoxy會像獨立的代理服務器一樣運行。 Hoxy靈感來源於一種補充像Firebug這樣的調試器的方式，它可以讓你操縱客戶端運行時而不是底層的HTTP對話。

這應該工作得很好，除非您正在尋找更低級別的數據包到數據包檢查。

Answer 3

您需要在一側創建連接。下面是我用轉發流量

var net = require('net'); 

var sourceport = 1234; 
var destport = 1235; 

net.createServer(function(s) 
{ 
    var buff = ""; 
    var connected = false; 
    var cli = net.createConnection(destport); 
    s.on('data', function(d) { 
     if (connected) 
     { 
      cli.write(d); 
     } else { 
      buff += d.toString(); 
     } 
    }); 
    cli.on('connect', function() { 
     connected = true; 
     cli.write(buff); 
    }); 
    cli.pipe(s); 
}).listen(sourceport);