socketserver 模块
简化了网络服务器的编写,主要实现并发的处理.
主要有4个类:这4个类是同步进行处理的,另外通过ForkingMixIn和ThreadingMixIn类来支持异步。
socketserver.TCPServer
socketserver.UDPServer
socketserver.UnixStreamServer
socketserver.UnixDatagramServer
创建服务器的步骤4步:
1:你必须创建一个请求处理类,它是BaseRequestHandler的子类并重载其handle()方法。
2:你必须实例化一个服务器类,
3:传入服务器的地址和请求处理程序类。
4:调用handle_request()(一般是调用其他事件循环或者使用select())或serve_forever()。
举例服务器端:
![]()
1 import socketserver
2 class MySocketHandler(socketserver.BaseRequestHandler):
3 def handle(self):
4 while True:
5 try:
6 self.data = self.request.recv(1024).strip()
7 print(self.data)
8 print('{}'.format(self.client_address[0]))
9 self.request.send(self.data.upper())
10 except ConnectionResetError as e:
11 print('err',e)
12 break
13
14 if __name__ == '__main__':
15 host,port = 'localhost',9999
16 # server = socketserver.TCPServer((host,port),MySocketHandler) # 只实现简化服务器端,支持一个客户端
17 server = socketserver.ThreadingTCPServer((host,port),MySocketHandler) #多线程并发
18 server.serve_forever()
View Code