1#coding=utf8 2from BaseHTTPServer import BaseHTTPRequestHandler 3from SocketServer import ThreadingTCPServer 4import gzip 5from StringIO import StringIO 6import logging 7 8logging.basicConfig(level=logging.DEBUG, 9 format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s', 10 datefmt='%a, %d %b %Y %H:%M:%S', 11 filename='proxy.log', 12 filemode='w') 13 14 15class proxyHandler(BaseHTTPRequestHandler): 16 17 def do_POST(self): 18 while True: 19 try: 20 path = self.path 21 if path.split("/")[-1] =="statistics": 22 #获取post提交的数据 23 datas =gzip.GzipFile(fileobj=StringIO(self.rfile.read())).read() 24 self.wfile.write(datas) 25 logging.debug(datas) 26 print datas 27 except Exception,e: 28 logging.error(e) 29 finally: 30 self.finish() 31 32 def do_CONNECT(self): 33 pass 34 35 def do_GET(self): 36 pass 37 38def test(): 39 host='127.0.0.1' 40 port=8888 41 try: 42 server = ThreadingTCPServer((host, port), proxyHandler) 43 print 'Welcome to the Server HTTP On %s Port %d...' %(host,port) 44 server.serve_forever() 45 46 47 except KeyboardInterrupt,e: 48 logging.error(e) 49 #print '^C received, shutting down server' 50 server.socket.close() 51 52if __name__ == '__main__': 53 test()
Python使用ThreadingTCPServer创建多线程代理
Wesley13
2021-10-11
974 0 0
点赞
收藏
评论区
加载中...