直接運行這個程序就給本機建立了一個socks5的代理服務器。

代碼如下：

importsocket,?sys,?select,?SocketServer,?struct,?time

classThreadingTCPServer(SocketServer.ThreadingMixIn,?SocketServer.TCPServer):pass

classSocks5Server(SocketServer.StreamRequestHandler):

defhandle_tcp(self,?sock,?remote):

fdset?=?[sock,?remote]

whileTrue:

r,?w,?e?=?select.select(fdset,?[],?[])

ifsockinr:

ifremote.send(sock.recv(4096))?<=0:break

ifremoteinr:

ifsock.send(remote.recv(4096))?<=0:break

defhandle(self):

try:

print'socks?connection?from?',self.client_address

sock?=?self.connection

#?1.?Version

sock.recv(262)

sock.send(b"\x05\x00");

#?2.?Request

data?=?self.rfile.read(4)

mode?=?ord(data[1])

addrtype?=?ord(data[3])

ifaddrtype?==1:#?IPv4

addr?=?socket.inet_ntoa(self.rfile.read(4))

elifaddrtype?==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:

ifmode?==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()

reply?+=?socket.inet_aton(local[0])?+?struct.pack(">H",?local[1])

exceptsocket.error:

#?Connection?refused

reply?=?'\x05\x05\x00\x01\x00\x00\x00\x00\x00\x00'

sock.send(reply)

#?3.?Transfering

ifreply[1]?=='\x00':#?Success

ifmode?==1:#?1.?Tcp?connect

self.handle_tcp(sock,?remote)

exceptsocket.error:

print'socket?error'

defmain():

server?=?ThreadingTCPServer(('',1080),?Socks5Server)

server.serve_forever()

if__name__?=='__main__':

main()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:

print 'socks connection from ', self.client_address

sock = self.connection

# 1. Version

sock.recv(262)

sock.send(b"\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 = 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()

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:

print 'socket error'

def main():

server = ThreadingTCPServer(('', 1080), Socks5Server)

server.serve_forever()

if __name__ == '__main__':

main()

已經修正Google SyntaxHighlighter無法正確顯示Python代碼的問題。問題出自shBrushPython.js中定義regexList數組的時候末尾多了一個","。刪去就行了。神奇的是，只有IEcore才報錯……

總結

以上是生活随笔為你收集整理的socks5 python_用Python写socks5服务器端的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。