当前位置:Gxlcms > Python > Python写的Socks5协议代理服务器

Python写的Socks5协议代理服务器

时间:2021-07-01 10:21:17 帮助过:252人阅读

直接上代码:

  1. #!/usr/bin/python
  2. # Filename s5.py
  3. # Python Dynamic Socks5 Proxy
  4. # Usage: python s5.py 1080
  5. # Background Run: nohup python s5.py 1080 &
  6. import socket, sys, select, SocketServer, struct, time
  7. class ThreadingTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer): pass
  8. class Socks5Server(SocketServer.StreamRequestHandler):
  9. def handle_tcp(self, sock, remote):
  10. fdset = [sock, remote]
  11. while True:
  12. r, w, e = select.select(fdset, [], [])
  13. if sock in r:
  14. if remote.send(sock.recv(4096)) <= 0: break
  15. if remote in r:
  16. if sock.send(remote.recv(4096)) <= 0: break
  17. def handle(self):
  18. try:
  19. pass # print 'from ', self.client_address nothing to do.
  20. sock = self.connection
  21. # 1. Version
  22. sock.recv(262)
  23. sock.send("\x05\x00");
  24. # 2. Request
  25. data = self.rfile.read(4)
  26. mode = ord(data[1])
  27. addrtype = ord(data[3])
  28. if addrtype == 1: # IPv4
  29. addr = socket.inet_ntoa(self.rfile.read(4))
  30. elif addrtype == 3: # Domain name
  31. addr = self.rfile.read(ord(sock.recv(1)[0]))
  32. port = struct.unpack('>H', self.rfile.read(2))
  33. reply = "\x05\x00\x00\x01"
  34. try:
  35. if mode == 1: # 1. Tcp connect
  36. remote = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  37. remote.connect((addr, port[0]))
  38. pass # print 'To', addr, port[0] nothing do to.
  39. else:
  40. reply = "\x05\x07\x00\x01" # Command not supported
  41. local = remote.getsockname()
  42. reply += socket.inet_aton(local[0]) + struct.pack(">H", local[1])
  43. except socket.error:
  44. # Connection refused
  45. reply = '\x05\x05\x00\x01\x00\x00\x00\x00\x00\x00'
  46. sock.send(reply)
  47. # 3. Transfering
  48. if reply[1] == '\x00': # Success
  49. if mode == 1: # 1. Tcp connect
  50. self.handle_tcp(sock, remote)
  51. except socket.error:
  52. pass #print 'error' nothing to do .
  53. except IndexError:
  54. pass
  55. def main():
  56. filename = sys.argv[0];
  57. if len(sys.argv)<2:
  58. print 'usage: ' + filename + ' port'
  59. sys.exit()
  60. socks_port = int(sys.argv[1]);
  61. server = ThreadingTCPServer(('', socks_port), Socks5Server)
  62. print 'bind port: %d' % socks_port + ' ok!'
  63. server.serve_forever()
  64. if __name__ == '__main__':
  65. main()

人气教程排行