实现的代码&＃xff1a;
class RPCThreading(SocketServer.ThreadingMixIn, SimpleXMLRPCServer.SimpleXMLRPCServer):
pass
global mutex
mutex &＃61;thread.allocate_lock()
server_object &＃61; Server()
server &＃61; RPCThreading(("localhost", 8888))
server.register_instance(server_object)
#Go into the main listener loop
print "Listening"
server.serve_forever()
RPCThreading这个类也可以这样声明
class RPCThreading(ThreadingMixIn, SimpleXMLRPCServer):
pass
只要代码前端import的模块匹配就可以了。
看这个声明的格式&＃xff0c;应该是RPCThreading这个自定义的类&＃xff0c;继承了ThreadingMixIn和SimpleXMLRPCServer。
但是自定义方法部分直接pass&＃xff0c;什么也没做。
然后server.serve_forever()就可以做到多线程了&＃xff1f;
Forking and threading versions of each type of server can be created using the ForkingMixIn&＃xff08;多进程&＃xff09; and ThreadingMixIn&＃xff08;多线程&＃xff09; mix-in classes. For instance, a threading UDP server class is created as follows:
class ThreadingUDPServer(ThreadingMixIn, UDPServer): pass
The mix-in class must come first, since it overrides a method defined in UDPServer. Setting the various member variables also changes the behavior of the underlying server mechanism.
由上面例子可知&＃xff0c;能实现多线程(进程)版的server&＃xff08;UDP/TCP/XMLRPC都如此&＃xff09;&＃xff0c;是由于ThreadingMixIn(ForkingMixIn)类重写了server类中定义的方法。
找到定义ThreadingMixIn的py文件&＃xff1a;
这里看到process_requst函数中定义了多线程&＃xff0c;target指向process_request_thread
而process_request函数在BaseServer类中会被handler()调用&＃xff0c;具体如下&＃xff1a;
SimpleXMLRPCServer类继承自TCPServer类继承自BaseServer类&＃xff0c;
BaseServer类定义了server_forever方法&＃xff0c;其中调用了self._handle_request_noblock()方法&＃xff0c;这个方法中又调用了self.process_request(request, client_address)
应该就是这里的process_request方法被ThreadingMixIn重写之后&＃xff0c;变为多线程的方法&＃xff0c;所以简单的一句&＃xff1a; class RPCThreading(ThreadingMixIn, SimpleXMLRPCServer):
pass
就可以实现Server对象的多线程。
京公网安备 11010802041100号