前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >python socks5 proxy实

python socks5 proxy实

作者头像
py3study
发布2020-01-10 00:51:10
1.4K0
发布2020-01-10 00:51:10
举报
文章被收录于专栏:python3

zz http://www.ietf.org/rfc/rfc1928.txt

 http://www.ietf.org/rfc/rfc1929.txt

代码语言:javascript
复制
import socket, sys, select, SocketServer, struct, time
class ThreadingTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer): pass
class Socks5Server(SocketServer.StreamRequestHandler):
    passdct = {"123":"456"};
    iplist = ['127.0.0.1'];
    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 auth_user_pass(self, user, passwd):
        dic = self.__class__.passdct
        return dic.has_key(user) and passwd == self.__class__.passdct[user];

                
    def handle(self):
        try:
            print 'socks connection from ', self.client_address, self.__class__.iplist
            sock = self.connection
            # 1. Version
            data = sock.recv(262) # no auth, \x05\x01\x00
                                  # user/passwd auth, \x05\x03\x00\x03\x02


            if self.client_address[0] in self.__class__.iplist:
                reply = b"\x05\x00"   # no auth and ok
            else:
                reply = b"\x05\xff"
            
            if len(data) == 5:
                sock.send(b"\x05\x02");
                # 2. append user/passwd
                data = self.rfile.read(2)
                username = self.rfile.read(ord(data[1]))
                passwd = self.rfile.read(ord(sock.recv(1)[0]))
                # auth it
                if self.auth_user_pass(username, passwd):
                    reply = b"\x01\x00"
                else:
                    reply = b"\x01\x01"

            sock.send(reply);
            
            # 3. 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 = b"\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]))
                    print 'Tcp connect to', addr, port[0]
                else:
                    reply = b"\x05\x07\x00\x01" # Command not supported
                local = remote.getsockname()
                print "reply addr:", local
                reply += socket.inet_aton(local[0]) + struct.pack(">H", local[1])
                sys.stdout.flush()
                
            except socket.error:
                # Connection refused
                reply = '\x05\x05\x00\x01\x00\x00\x00\x00\x00\x00'
            sock.send(reply)
            # 4. Transfering
            if reply[1] == '\x00':  # Success
                if mode == 1:    # 1. Tcp connect
                    self.handle_tcp(sock, remote)
        except socket.error:
            print 'socket error'

def main():
    server = ThreadingTCPServer(('', 1080), Socks5Server)
    server.serve_forever()
if __name__ == '__main__':
    main()
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019/09/06 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档