- server 端代码结构:
# socketserver 在处理用户请求时,同时使用了 “报警器(select)”和“腿毛(thread)”的功能import socketserverclass MyClass(socketserver.BaseRequestHandler):
def handler(self):
pass
obj = socketserver.ThreadingTCPServer(('127.0.0.1',9999), MyClass)obj.serve_forever()
- 执行流程:
- server = socketserver.ThreadingTCPServer(('127.0.0.1', 9997), MysocketServer)
-
- 1、实例化一个对象,并赋值给server,实则为执行类中构造方法:
- 从下到上查找__init__方法,ThreadingTCPServer、ThreadingMixIn,均没有__init__构造方法,从TCPServer中查找
- TCPServer中有__init__,且做了2件事情:
- 1、实例化一个对象,并赋值给server,实则为执行类中构造方法:
-
-
-
- 执行BaseServer父类中__init__方法(此时自定义类MySocketserver,已经赋值给了RequestHandlerClass)
- 创建一个socket、绑定并监听起来 # 可通过 server.socket访问
-
-
-
- 2、server.serve_forever()
-
- 从下到上,依次查找并执行如下方法:
- serve_forever(),
- 只有BaseServer类中有,执行该方法,发现其又执行了self._handler_request_noblock()
- _handler_request_noblock(),
- 只有BaseServer中有,执行该方法,发现其又执行了self.process_request()
- self.process_request(),
- ThreadingMixIn类和BaseServer中都有,执行ThreadingMixIn中 process_request方法:创建一个线程,target为process_request_thread()方法
- serve_forever(),
- 从下到上,依次查找并执行如下方法: