身在天朝，難免會用到代理的時候。 比如在學校內網用代理免費上外網，在牆內用代理上404網站等。

    現在使用的代理大部分為HTTP和Socket代理。 Socket代理更底層，需要本地解析域名，而HTTP代理則是基於HTTP協議之上的，不需要本地解析域名。下面我講講HTTP(S)代理的設計思路以及NodeJS程式碼實現。

HTTP協議

    HTTP協議簡單說來就是瀏覽器把一串字串傳送到目標伺服器，然後把目標伺服器返回回來的一串字串顯示給使用者。

    瀏覽器傳送的這串字元主要分為兩個部分，一部分是頭，裡面包含目標伺服器域名，當前請求的檔案路徑等資訊。另一部分是正文，一般的GET請求沒有正文。

    伺服器返回來的字串也分為頭和正文。

HTTP代理原理

    HTTP代理需要做的事情就是接收瀏覽器發來的請求字串，再從請求字串的頭部分找出瀏覽器請求的目標主機，然後直接把這串請求字串發給目標主機，再把目標主機返回的資料發給瀏覽器。 “什麼？就這麼簡單？” “呃。。是啊，但這還沒完。。”

    現代瀏覽器一般都是預設採用HTTP/1.1版本，並且預設會發送Connection: keep-alive請求。 這些資訊是寫在請求的頭部的，意思是通知目標伺服器採用keep-alive技術繼續處理後續的請求。 但是我們做的代理程式要想支援keep-alive是比較麻煩的。所以乾脆就把這個篡改成Connection: close。 這樣就可以保證瀏覽器請求的每個檔案都會單獨傳送一個HTTP請求。

下面是NodeJS程式碼實現

var net = require('net');
var local_port = 8893;

//在本地建立一個server監聽本地local_port埠
net

.createServer(function (client)
{
   
    //首先監聽瀏覽器的資料傳送事件，直到收到的資料包含完整的http請求頭
    var buffer = new Buffer(0);
    client.on('data',function(data)
    {
        buffer = buffer_add(buffer,data);
        if (buffer_find_body(buffer) == -1) return;
        var req = parse_request(buffer);
        if (req === false) return;
        client.removeAllListeners('data');
        relay_connection(req);
    });

    //從http請求頭部取得請求資訊後，繼續監聽瀏覽器傳送資料，同時連線目標伺服器，並把目標伺服器的資料傳給瀏覽器
    function relay_connection(req)
    {
        console.log(req.method+' '+req.host+':'+req.port);
       
        //如果請求不是CONNECT方法（GET, POST），那麼替換掉頭部的一些東西
        if (req.method != 'CONNECT')
        {
            //先從buffer中取出頭部
            var _body_pos = buffer_find_body(buffer);
            if (_body_pos < 0) _body_pos = buffer.length;
            var header = buffer.slice(0,_body_pos).toString('utf8');
            //替換connection頭
            header = header.replace(/(proxy\-)?connection\:.+\r\n/ig,'')
                    .replace(/Keep\-Alive\:.+\r\n/i,'')
                    .replace("\r\n",'\r\nConnection: close\r\n');
            //替換網址格式(去掉域名部分)
            if (req.httpVersion == '1.1')
            {
                var url = req.path.replace(/http\:\/\/[^\/]+/,'');
                if (url.path != url) header = header.replace(req.path,url);
            }
            buffer = buffer_add(new Buffer(header,'utf8'),buffer.slice(_body_pos));
        }
       
        //建立到目標伺服器的連線
        var server = net.createConnection(req.port,req.host);
        //交換伺服器與瀏覽器的資料
        client.on("data", function(data){ server.write(data); });
        server.on("data", function(data){ client.write(data); });

        if (req.method == 'CONNECT')
            client.write(new Buffer("HTTP/1.1 200 Connection established\r\nConnection: close\r\n\r\n"));
        else
            server.write(buffer);
    }
}).listen(local_port);

console.log('Proxy server running at localhost:'+local_port);


//處理各種錯誤
process.on('uncaughtException', function(err)
{
    console.log("\nError!!!!");
    console.log(err);
});



/**
* 從請求頭部取得請求詳細資訊
* 如果是 CONNECT 方法，那麼會返回 { method,host,port,httpVersion}
* 如果是 GET/POST 方法，那麼返回 { metod,host,port,path,httpVersion}
*/
function parse_request(buffer)
{
    var s = buffer.toString('utf8');
    var method = s.split('\n')[0].match(/^([A-Z]+)\s/)[1];
    if (method == 'CONNECT')
    {
        var arr = s.match(/^([A-Z]+)\s([^\:\s]+)\:(\d+)\sHTTP\/(\d\.\d)/);
        if (arr && arr[1] && arr[2] && arr[3] && arr[4])
            return { method: arr[1], host:arr[2], port:arr[3],httpVersion:arr[4] };
    }
    else
    {
        var arr = s.match(/^([A-Z]+)\s([^\s]+)\sHTTP\/(\d\.\d)/);
        if (arr && arr[1] && arr[2] && arr[3])
        {
            var host = s.match(/Host\:\s+([^\n\s\r]+)/)[1];
            if (host)
            {
                var _p = host.split(':',2);
                return { method: arr[1], host:_p[0], port:_p[1]?_p[1]:80, path: arr[2],httpVersion:arr[3] };
            }
        }
    }
    return false;
}




/**
* 兩個buffer物件加起來
*/
function buffer_add(buf1,buf2)
{
    var re = new Buffer(buf1.length + buf2.length);
    buf1.copy(re);
    buf2.copy(re,buf1.length);
    return re;
}

/**
* 從快取中找到頭部結束標記("\r\n\r\n")的位置
*/
function buffer_find_body(b)
{
    for(var i=0,len=b.length-3;i<len;i++)
    {
        if (b[i] == 0x0d && b[i+1] == 0x0a && b[i+2] == 0x0d && b[i+3] == 0x0a)
        {
            return i+4;
        }
    }
    return -1;
}

另外，可以用 "nohup node some.js > /dev/null &" 命令讓nodejs程式在後臺執行。