day32socketserver

#socketserver 是在socket基础上进行了封装&＃xff0c;它让server可以实时跟多个client进行通信。
#thread线程&＃xff1a;一个程序有一个线程&＃xff0c;一个线程是调度cpu的最小单位。程序运行才产生线程&＃xff0c;不运行就不产生。
#如果启用多个线程去接收多个client的请求&＃xff0c;就能实现并发的效果。# server:
import socketserver
class MyServer(socketserver.BaseRequestHandler): #必须继承此父类def handle(self): #必须定义此函数,self.request相当于connwhile True:msg &＃61; self.request.recv(1024).decode(&＃39;utf-8&＃39;)print(msg)if msg &＃61;&＃61; &＃39;q&＃39;:breakinfo &＃61; input(&＃39;server:&＃39;)self.request.send(info.encode(&＃39;utf-8&＃39;))if __name__ &＃61;&＃61; &＃39;__main__&＃39;:server &＃61; socketserver.ThreadingTCPServer((&＃39;127.0.0.1&＃39;,8888),MyServer) #实例化对象 &＃61; 类()
server.serve_forever()#client1:
import socket
sk &＃61; socket.socket()
sk.connect((&＃39;127.0.0.1&＃39;,8888))while True:info &＃61; input(&＃39;client1:&＃39;)if info &＃61;&＃61; &＃39;q&＃39;:sk.send(info.encode(&＃39;utf-8&＃39;))breaksk.send(info.encode(&＃39;utf-8&＃39;))ret &＃61; sk.recv(1024).decode(&＃39;utf-8&＃39;)print(ret)sk.close()#client2:
import socket
sk &＃61; socket.socket()
sk.connect((&＃39;127.0.0.1&＃39;,8888))while True:info &＃61; input(&＃39;client2:&＃39;)if info &＃61;&＃61; &＃39;q&＃39;:sk.send(info.encode(&＃39;utf-8&＃39;))breaksk.send(info.encode(&＃39;utf-8&＃39;))ret &＃61; sk.recv(1024).decode(&＃39;utf-8&＃39;)print(ret)sk.close()