ZeroBox Notes

分享一个Python 创建Socks5代理的代码:
==============================猥琐的分割线==============================

#!/usr/bin/python 
# Filename s5.py 
# Python Dynamic Socks5 Proxy 
# Usage: python s5.py 1080 
# Backgroup Run: nohup python s5.py 1080 & 
# Email: ringzero@557.im 

import socket, sys, select, SocketServer, struct, time 

class ThreadingTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer): pass
class Socks5Server(SocketServer.StreamRequestHandler): 
    def handle_tcp(self, sock, remote): 
        fdset = [sock, remote] 
        while True: 
            r, w, e = select.select(fdset, [], []) 
            if sock in r: 
                if remote.send(sock.recv(4096)) <= 0: break 
            if remote in r: 
                if sock.send(remote.recv(4096)) <= 0: break 
    def handle(self): 
        try: 
            pass # print 'from ', self.client_address nothing to do. 
            sock = self.connection 
            # 1. Version 
            sock.recv(262) 
            sock.send("\x05\x00"); 
            # 2. Request 
            data = self.rfile.read(4) 
            mode = ord(data[1]) 
            addrtype = ord(data[3]) 
            if addrtype == 1:       # IPv4 
                addr = socket.inet_ntoa(self.rfile.read(4)) 
            elif addrtype == 3:     # Domain name 
                addr = self.rfile.read(ord(sock.recv(1)[0])) 
            port = struct.unpack('>H', self.rfile.read(2)) 
            reply = "\x05\x00\x00\x01" 
            try: 
                if mode == 1:  # 1. Tcp connect 
                    remote = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
                    remote.connect((addr, port[0])) 
                    pass # print 'To', addr, port[0]  nothing do to. 
                else: 
                    reply = "\x05\x07\x00\x01" # Command not supported 
                local = remote.getsockname() 
                reply += socket.inet_aton(local[0]) + struct.pack(">H", local[1])
            except socket.error: 
                # Connection refused 
                reply = '\x05\x05\x00\x01\x00\x00\x00\x00\x00\x00' 
            sock.send(reply) 
            # 3. Transfering 
            if reply[1] == '\x00':  # Success 
                if mode == 1:    # 1. Tcp connect 
                    self.handle_tcp(sock, remote) 
        except socket.error: 
            pass #print 'error' nothing to do . 
        except IndexError: 
            pass 
def main(): 
    filename = sys.argv[0]; 
    if len(sys.argv)<2: 
        print 'usage: ' + filename + ' port' 
        sys.exit() 
    socks_port = int(sys.argv[1]);     
    server = ThreadingTCPServer(('', socks_port), Socks5Server) 
    print 'bind port: %d' % socks_port + ' ok!' 
    server.serve_forever() 
if __name__ == '__main__': 
    main()

==============================猥琐的分割线==============================

# 普通用户权限下，请使用1024之后的端口。

作者：ring04h 来源：http://hi.baidu.com/ring04h/blog/item/a192a026708b59378a82a1b0.html