异步多线程:
服务端
1 import socketserver 2 3 class MyServer(socketserver.BaseRequestHandler): 4 def setup(self): 5 pass 6 7 def handle(self): 8 #print(self.request) 9 #print(self.client_address) 10 #print(self.server) 11 conn = self.request 12 conn.sendall(bytes('hello','utf-8')) 13 flag = True 14 while flag: 15 data = str(conn.recv(1024),'utf-8') 16 print(data) 17 18 if data == 'exit': 19 flag =False 20 conn.sendall(bytes('sb','utf-8')) 21 conn.close() 22 23 24 def finish(self): 25 pass 26 27 28 29 if __name__=='__main__': 30 server = socketserver.ThreadingTCPServer(('127.0.0.1',9999),MyServer) 31 server.serve_forever()
客户端
1 import socket 2 3 client = socket.socket() 4 5 ip_port = ('127.0.0.1',9999) 6 client.connect(ip_port) 7 8 9 while True: 10 data = str(client.recv(1024),'utf-8') 11 print(data) 12 inp = input('clent:') 13 14 client.sendall(bytes(inp, 'utf-8')) 15 if inp=='exit': 16 break