博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
socketserver剖析.html
阅读量:4943 次
发布时间:2019-06-11

本文共 976 字,大约阅读时间需要 3 分钟。

 

  • server 端代码结构:
# socketserver 在处理用户请求时,同时使用了 “报警器(select)”和“腿毛(thread)”的功能
import socketserver
class 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. 执行BaseServer父类中__init__方法(此时自定义类MySocketserver,已经赋值给了RequestHandlerClass)
        2. 创建一个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()方法

 

转载于:https://www.cnblogs.com/qiaogy/p/5875439.html

你可能感兴趣的文章