python监听网络请求-讲解Python中SocketServer模块处理网络请求

python监听⽹络请求_讲解Python中SocketServer模块处理⽹络请求SocketServer创建⼀个⽹络服务框架。它定义了类来处理TCP,UDP,UNIXstreams和UNIXdatagrams上的同步⽹络请求。⼀、ServerTypes有五个不同的服务器类在SocketServer中。1.BaseServer定义了API,⽽且他不是⽤来实例化和直接使⽤的。2.TCPServer⽤作TCP/IP的socket通讯。3.UDPServer使⽤datagramsockets。4.UnixStreamServer和UnixDatagramServer使⽤Unix-domainsockets⽽且智能在unix平台上使⽤。⼆、ServerObjects构建⼀个服务器,通过它来监听请求的地址和请求的处理类(notinstance)。1.classSocketServer.BaseServer这是模块中所有服务器对象的超类，它定义了接⼝,实现⼤多数都在⼦类中完成。2.BaseServer.fileno返回⼀个整数⽂件描述符来表⽰哪个服务器正在监听。这个函数最常见的传递给select.select()，允许监控多个相同处理过程的服务。3.BaseServer.handle_request处理单⼀的请求,这个函数会顺序调⽤接下来的⽅法。get_request(),verify_request和proccess_request。⽤户提供handle()⽅法抛出⼀个异常，那么handle_error()⽅法会被调⽤。self.timeout的时间内没有收到请求，handle_timeout()和handle_request()将返回。4.BaseServer.serve_foreverBaseServer.serve_forever(poll_interval=0.5)，处理请求⼀直到明确的shutdown()请求。轮训每隔poll_interval时间内关闭。忽略self.timeout,如果需要使⽤定时任务，需要使⽤其他线程。5.BaseServer.shutdown告诉serve_forever()循环停⽌。6.BaseServer.RequestHandlerClass⽤户请求处理程序类，为每个请求创建这个类的⼀个实例。三、ImplementingaServer如果你创建⼀个服务器，它通常可以重复使⽤现有的类和简单的提供⼀个⾃定义请求处理的类。如果不符合需求，有⼏种BaseServer⽅法覆盖⼀个⼦类。1.verify_request(reqeust,client_address):必须返回⼀个布尔值，如果返回True,请求将被处理，如果返回False，请求将被拒绝。这个函数可以覆盖来实现访问控制服务。2.process_request(request,client_address):调⽤finish_request来创建⼀个RequestHandlerClass()的实例，如果需要该函数可以创建⼀个新的进程或协程来处理请求。3.finish_request(request,client_address):创建⼀个请求处理实例。调⽤handle()来处理请求。四、RequestHandlers

请求处理程序做的⼤部分⼯作接收传⼊的请求,并决定采取何种⾏动。处理程序负责实现“协议”上的套接字层(例如,HTTP或xml-rpc)。从传⼊的请求处理程序读取请求数据通道,流程,和写⼀个响应。有三个⽅法可以重写。1.setup():准备请求的请求处理程序,就是初始化运⾏在handle之前。2.handle():做真正的请求⼯作。解析传⼊的请求，处理数据和返回响应。3.finish():清理任意时间创建的setup()。五、例⼦下⾯例⼦展⽰了tcp,udp和异步1.TCPServer例⼦importSocketServerclassMyHandler(SocketServer.BaseRequestHandler):defhandle(self):self.data=self.request.recv(1024).strip()print'{}wrote:'.format(self.client_address[0])printself.dataself.request.sendall(self.data.upper())if__name__=='__main__':HOST,PORT='localhost',9999server=SocketServer.TCPServer((HOST,PORT),MyHandler)server.serve_forever()2.UDPServr例⼦importSocketServerclassMyHandler(SocketServer.BaseRequestHandler):defhandle(self):data=self.request[0].strip()socket=self.request[1]print'{}wrote:'.format(self.client_address[0])printdatasocket.sendto(data.upper(),self.client_address)if__name__=='__main__':HOST,PORT='localhost',9999server=SocketServer.UDPServer((HOST,PORT),MyHandler)server.serve_forever()3.异步例⼦可以通过ThreadingMixIn和ForkingMixIn类来构造异步处理程序。

importsocketimportthreadingimportSocketServerclassMyHandler(SocketServer.BaseRequestHandler):defhandle(self):data=self.request.recv(1024)curr_thread=threading.current_thread()response='{}:{}'.format(curr_,data)self.request.sendall(response)classServer(SocketServer.ThreadingMixIn,SocketServer.TCPServer):passdefclient(ip,port,message):sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)sock.connect((ip,port))try:sock.sendall(message)response=sock.recv(1024)print'Received:{}'.format(response)finally:sock.close()if__name__=='__main__':HOST,PORT='localhost',0server=Server((HOST,PORT),MyHandler)ip,port=server.server_addressserer_thread=threading.Thread(target=server.serve_forever)server_thread.daemon=Trueserver_thread.start()print'Serverlooprunninginthread:',server_client(ip,port,'HelloWorld1')client(ip,port,'HelloWorld2')client(ip,port,'HelloWorld3')server.shutdown()server.server_close()4.SocketServer实现客户端与服务器间⾮阻塞通信(1)创建SocketServerTCP服务端

#创建SocketServerTCP服务器：importSocketServerfromSocketServerimportStreamRequestHandlerasSRHfromtimeimportctimehost='xxx.xxx.xxx.xxx'port=9999addr=(host,port)classServers(SRH):defhandle(self):print'gotconnectionfrom',self.client_addressself.wfile.write('connection%s:%sat%ssucceed!'%(host,port,ctime()))whileTrue:data=self.request.recv(1024)ifnotdata:breakprintdataprint"RECVfrom",self.client_address[0]self.request.send(data)print'serverisrunning....'server=SocketServer.ThreadingTCPServer(addr,Servers)server.serve_forever()(2)创建SocketServerTCP客户端fromsocketimport*host='xxx.xxx.xxx.xxx'port=9999bufsize=1024addr=(host,port)client=socket(AF_INET,SOCK_STREAM)client.connect(addr)whileTrue:data=raw_input()ifnot