[python]
#!/usr/bin/python
# Filename s5.py
# Python Dynamic Socks5 Proxy
# Usage: python s5.py 1080
# Background 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("x05x00");
# 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 = "x05x00x00x01"
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 = "x05x07x00x01" # Command not supported
local = remote.getsockname()
reply += socket.inet_aton(local[0]) + struct.pack(">H", local[1])
except socket.error:
# Connection refused
reply = ‘x05x05x00x01x00x00x00x00x00x00’
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()
[/python]
[python]
# encoding=utf-8
# Usage: python filename.py
# Background Run: nohup python filename.py 2079 &
# http://yaonie.org/
import socket, thread, select, sys
BUFLEN = 8192
HTTPVER = ‘HTTP/1.1′
class ConnectionHandler:
def __init__(self, connection, address, timeout):
self.client = connection
self.client_buffer = ”
self.timeout = timeout
self.method, self.path, self.protocol = self.get_base_header()
if self.method==’CONNECT’:
self.method_CONNECT()
elif self.method in (‘OPTIONS’, ‘GET’, ‘HEAD’, ‘POST’,):# ‘PUT’,’DELETE’, ‘TRACE’):
self.method_others()
self.client.close()
self.target.close()
def get_base_header(self):
while 1:
self.client_buffer += self.client.recv(BUFLEN)
end = self.client_buffer.find(‘n’)
if end!=-1:
break
print ‘%s’%self.client_buffer[:end]#debug
data = (self.client_buffer[:end+1]).split()
self.client_buffer = self.client_buffer[end+1:]
return data
def method_CONNECT(self):
self._connect_target(self.path)
self.client.send(HTTPVER+’ 200 Connection establishednProxy-agent: %snn’) %
r"Mozilla/5.0 (compatible; Konqueror/3.5; Linux) KHTML/3.5.5 (like Gecko) (Kubuntu)’)"
self.client_buffer = ”
self._read_write()
def method_others(self):
self.path = self.path[7:]
i = self.path.find(‘/’)
host = self.path[:i]
path = self.path[i:]
self._connect_target(host)
self.target.send(‘%s %s %sn’%(self.method, path, self.protocol)+self.client_buffer)
self.client_buffer = ”
self._read_write()
def _connect_target(self, host):
i = host.find(‘:’)
if i!=-1:
port = int(host[i+1:])
host = host[:i]
else:
port = 80
(soc_family, _, _, _, address) = socket.getaddrinfo(host, port)[0]
self.target = socket.socket(soc_family)
self.target.connect(address)
def _read_write(self):
time_out_max = self.timeout/3
socs = [self.client, self.target]
count = 0
while 1:
count += 1
(recv, _, error) = select.select(socs, [], socs, 3)
if error:
break
if recv:
for in_ in recv:
data = in_.recv(BUFLEN)
if in_ is self.client:
out = self.target
else:
out = self.client
if data:
out.send(data)
count = 0
if count == time_out_max:
break
def start_server(host, port, IPv6=False, timeout=60, handler=ConnectionHandler):
if IPv6==True:
soc_type=socket.AF_INET6
else:
soc_type=socket.AF_INET
soc = socket.socket(soc_type)
soc.bind((host, port))
print "Serving on %s:%d."%(host, port)#debug
soc.listen(0)
while 1:
thread.start_new_thread(handler, soc.accept()+(timeout,))
if __name__ == ‘__main__’:
if len(sys.argv) != 2:
print ‘usage: python %s port’ % sys.argv[0]
sys.exit()
try:
port = int(sys.argv[1])
except:
print ‘usage: python %s port’ % sys.argv[0]
sys.exit()
start_server(‘10.1.14.2’,port)
[/python]
