這里的代理服務(wù)器，是指二級代理服務(wù)器。比如：A可以訪問B，B可以訪問C，A不能直接訪問C。這時，如果在B開一個二級代理，就可實現(xiàn)A訪問C�，F(xiàn)有的工具有CCProxy。

這里就是使用Python簡單的實現(xiàn)一個二級代理。

#coding=utf-8   
import socket   
import select   
import sys   
import threading  
import time  
import logging  
import os  
logsDir = "logs"  
if not os.path.isdir(logsDir):  
    os.mkdir(logsDir)  
      
logging.basicConfig(level=logging.DEBUG,  
                format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',  
                datefmt='%a, %d %b %Y %H:%M:%S',  
                filename='logs/logs.log',  
                filemode='a')  
   
#C的IP和端口   
to_addr = ('0.0.0.0', 8087)  
  
class Proxy:   
    def __init__(self, addr):   
        self.proxy = socket.socket(socket.AF_INET, socket.SOCK_STREAM)   
        self.proxy.bind(addr)   
        self.proxy.listen(10)   
        self.inputs = [self.proxy]   
        self.route = {}   
     
    def serve_forever(self):   
        logging.info('proxy listen...')  
        while 1:   
            readable, _, _ = select.select(self.inputs, [], [])   
            for self.sock in readable:   
                if self.sock == self.proxy:   
                    self.on_join()   
                else:  
                    try:  
                        data = self.sock.recv(8192)  
                    except Exception, e:  
                        logging.error(str(e))  
                        self.on_quit()  
                        continue  
                      
                    if not data:   
                        self.on_quit()   
                    else:  
                        try:  
                            self.route[self.sock].send(data)  
                        except Exception, e:  
                            logging.error(str(e))  
                            self.on_quit()  
                            continue  
     
    def on_join(self):   
        client, addr = self.proxy.accept()   
        logging.info("proxy client " + str(addr) + 'connect')  
        forward = socket.socket(socket.AF_INET, socket.SOCK_STREAM)   
        forward.connect(to_addr)   
        self.inputs += [client, forward]   
        self.route[client] = forward   
        self.route[forward] = client   
      
    #刪除連接  
    def on_quit(self):  
        ls = [self.sock]  
        if self.sock in self.route:  
            ls.append(self.route[self.sock])  
        for s in ls:  
            if s in self.inputs:  
                self.inputs.remove(s)  
            if s in self.route:  
                del self.route[s]   
            s.close()   
              
if __name__ == "__main__":  
    try:   
        Proxy(('', 8192)).serve_forever()  
    except KeyboardInterrupt:   
        logging.error("KeyboardInterrupt")  
        return  
  

來自：http://blog.csdn.net/junfeng_feng/article/details/42966363

標(biāo)簽： 代理服務(wù)器 服務(wù)器

版權(quán)申明：本站文章部分自網(wǎng)絡(luò)，如有侵權(quán)，請聯(lián)系：west999com@outlook.com
特別注意：本站所有轉(zhuǎn)載文章言論不代表本站觀點！
本站所提供的圖片等素材，版權(quán)歸原作者所有，如需使用，請與原作者聯(lián)系。