Python多线程socket服务器端

import threadingimport SocketServerimport jsonimport time

class 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_addressprint ' .... waiting for connection'server.serve_forever()</pre>