Python写的Socks5协议代理服务器

Python写的Socks5协议代理服务器

Python写的Socks5协议代理服务器

该代码仅供学习使用！
有兴趣的朋友可以参考学习。

# coding=utf-8
import socket
import select
import socketserver
import logging
import jsonlogging.basicConfig(filename='logger.log', level=logging.DEBUG, format='%(asctime)s %(levelname)-8s %(message)s',datefmt='%Y-%m-%d %H:%M:%S', filemode='a+')port = 8080class ThreadingTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):passclass Socks5Server(socketserver.StreamRequestHandler):def handle_tcp(self, client, remote):try:fds = [client, remote]while True:r, w, e = select.select(fds, [], [], 5)if client in r:cli_data = v(1024 * 100)if len(cli_data) <= 0:breakresult = send_all(remote, cli_data)if result < len(cli_data):logging.warn("Failed pipping all data to target!!!")breakif remote in r:remote_data = v(1024 * 100)if len(remote_data) <= 0:breakresult = send_all(client, remote_data)if result < len(remote_data):logging("Failed pipping all data to client!!!")breakexcept Exception as (e)finally:client.close()remote.close()def handle(self):client = questver, methods = v(1), v(1)methods = v(ord(methods))client.send(b'x05x00')ver, cmd, rsv, atype = v(1), v(1), v(1), v(1)if ord(cmd) is not 1:client.close()return# 判断是否支持atype，目前不支持IPv6# 比特流转化成整型 big表示编码为大端法，if ord(atype) == 1:# IPv4remote_addr = socket.inet_v(4))remote_port = int.from_v(2), 'big')elif ord(atype) == 3:# 域名addr_len = int.from_v(1), byteorder='big')remote_addr = v(addr_len)remote_port = int.from_v(2), byteorder='big')else:# 不支持则关闭连接client.close()returnremote = socket.socket(socket.AF_INET, socket.SOCK_STREAM)logging.info('[+] %s:%dConnect to --> %s:%d' % (self.client_address[0], self.client_address[1], remote_addr, remote_port))t((remote_addr, remote_port))reply = b"x05x00x00x01" + socket.inet_aton("0.0.0.0") + (2222).to_bytes(2, byteorder='big')client.send(reply)self.handle_tcp(client, remote)def send_all(sock, data):bytes_sent = 0while True:r = sock.send(data[bytes_sent:])if r < 0:return rbytes_sent += rif bytes_sent == len(data):return bytes_senttry:server = ThreadingTCPServer(('', port), Socks5Server)logging.info('[+] Lintening on port:%d' % port)server.serve_forever()
except Exception as (e)