Python多線程socket服務器端
import threading import SocketServer import json import timeclass ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler): def handle(self): start_time=time.time() print start_time data = self.request.recv(1024) jdata = json.loads(data) try: print jdata#寫自己的處理過程 except Exception as e: msg=e.message else: msg='success'
# host=self.client_address # sub_thread = threading.current_thread() response = {'data':data,'message':msg} print response jresp = json.dumps(response) self.request.sendall(jresp) print 'count_time---',time.time()-start_time
if name == "main": server=SocketServer.ThreadingTCPServer(('192.168.15.32',5000),ThreadedTCPRequestHandler)
# ip, port = server.server_address print " .... waiting for connection" server.serve_forever()</pre>
本文由用戶 jopen 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!