zoukankan      html  css  js  c++  java
  • socketserver 源码剖析:

    socketserver 源码剖析【有图有真相】:
    (一)、Socketserver 内部流程调用图:
      
     
      详解:
     1、self.RequestHandlerClass() = MyClass() 转换为 执行这个方法 class MyClass(socketserer.BaseRquestHandler)。

        


     2、 myclass 没有构造方法 __init__( ),从socketserer.BaseRquestHandler 父类 开始找,有构造函数 __init__( ),并且执行了一个 self.handle()方法 
        但是,还得从myclass() 类中开始找,即:class MyClass(socketserver.BaseRequestHandler):
                                                       def handle(self): # self = obj创建的实例化。 
        

       
        





    ################# 精简版的 socketserver 源码剖析 #################
    #!/usr/bin/env python
    # 详见老师分析:s13期。socketserver 源码分析剖析(一)和(二)。

    import socketserver

    class MyClass(socketserver.BaseRequestHandler):

    def handle(self): #self = obj创建的实例化。
    pass

    obj = socketserver.ThreadingTCPServer(('127.0.0.1', 9999), MyClass)
    obj.serve_forever()

    # 原理剖析:窥一斑见全豹
    # 创建socket对象
    # accept --
    # server_address = ('127.0.0.1', 9999)
    # RequestHandlerClass = MyClass == ()
    # self.RequestHandlerClass() = MyClass() == 执行自己的handle()
    # 1obj封装了 self.RequestHandlerClass = MyClass
    # 2、创建了socketbindlisten


    # 1
    、首先执行构造方法 __init__(),当所有的构造方法执行完了,意味着 实例化完成了,即 obj = socketserver.ThreadingTCPServer()
    # 2
    、遇到执行方法self.函数名(),然后在从头开始找执行。详见:s13 day10 socketserver() 源码分析二。







     2、ThreadingTCPServer源码剖析.

    学会看源码非常重要!不能仅仅光会用!大赞~ 知道他的过程和实现~ 怎么学会看源码呢?多看然后画类图,如上图!!!

    在理解的时候可以把他们想象为,把所有需要用的方法,都抓到ThreadingTCPServer

    内部调用流程为:

    • 启动服务端程序.
    • 执行 TCPServer.__init__ 方法,创建服务端Socket对象并绑定 IP 和 端口
    • 执行 BaseServer.__init__ 方法,将自定义的继承自SocketServer.BaseRequestHandler 的类 MyRequestHandle赋值给 self.RequestHandlerClass
    • 执行 BaseServer.server_forever 方法,While 循环一直监听是否有客户端请求到达 ...
    • 当客户端连接到达服务器
    • 执行 ThreadingMixIn.process_request 方法,创建一个 “线程” 用来处理请求
    • 执行 ThreadingMixIn.process_request_thread 方法
    • 执行 BaseServer.finish_request 方法,执行 self.RequestHandlerClass() 
    •  即:执行 自定义 MyRequestHandler 的构造方法(自动调用基类BaseRequestHandler的构造方法,在该构造方法中又会调用 MyRequestHandler的handle方法)

    精简源码:

    模拟Socekt Server的简化版本:




    import socket
    import threading
    import select


    def process(request, client_address): #模拟定义的handle()方法,这个方法内的代码是socket serverClient端交互代码
    print (request,client_address)
    conn
    = request
    conn.sendall('欢迎致电 10086,请输入1xxx,0转人工服务.')
    flag
    = True
    while flag:
    data = conn.recv(1024)
    if data == 'exit':
    flag = False
    elif data == '0':
    conn.sendall('通过可能会被录音.balabala一大推')
    else:
    conn.sendall('请重新输入.')

    sk
    = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sk.bind((
    '127.0.0.1',8002))
    sk.listen(
    5)

    while True: #这里一个while循环循环监控sk文件句柄
    r, w, e = select.select([sk,],[],[],1)
    print ('looping')
    if sk in r: #sk文件句柄发生变化的时候说明是新的客户端连接过来了
    print ('get request')
    request, client_address
    = sk.accept()
    t
    = threading.Thread(target=process, args=(request, client_address)) #创建一个线程,并调用自己定义的process方法执行~然后样客户端与之交互
    t.daemon = False
    t.start()

    sk.close()


       如精简代码可以看出,SocketServerThreadingTCPServer之所以可以同时处理请求得益于 select 和 Threading 两个东西,其实本质上就是在服务器端为每一个客户端创建一个线程,当前线程用来处理对应客户端的请求,所以,可以支持同时n个客户端链接(长连接)。


    • ForkingTCPServer 

           ForkingTCPServerThreadingTCPServer的使用和执行流程基本一致,只不过在内部分别为请求者建立 “线程”  和 “进程”。

    #!/usr/bin/env python
    # -*- coding:utf-8 -*-
    import socketserver

    class MyServer(socketserver.BaseRequestHandler):

    def handle(self):
    # print self.request,self.client_address,self.server
    conn = self.request
    conn.sendall(
    '欢迎致电 10086,请输入1xxx,0转人工服务.')
    Flag
    = True
    while Flag:
    data = conn.recv(1024)
    if data == 'exit':
    Flag = False
    elif data == '0':
    conn.sendall('通过可能会被录音.balabala一大推')
    else:
    conn.sendall('请重新输入.')


    if __name__ == '__main__':
    server = socketserver.ForkingTCPServer(('127.0.0.1',8009),MyServer)
    server.serve_forever()




    client 

    #!/usr/bin/env python
    # -*- coding:utf-8 -*-

    import socket

    ip_port = ('127.0.0.1',8009)
    sk = socket.socket()
    sk.connect(ip_port)
    sk.settimeout(5)

    while True:
    data = sk.recv(1024)
    print ('receive:',data)
    inp = input('please input:')
    sk.sendall(inp)
    if inp == 'exit':
    break

    sk.close()

    client


    以上ForkingTCPServer 只是将 ThreadingTCPServer 实例中的代码:

    server = SocketServer.ThreadingTCPServer(('127.0.0.1',8009),MyRequestHandler)
    变更为:
    server = SocketServer.ForkingTCPServer(('127.0.0.1',8009),MyRequestHandler)











    GitHub:https://github.com/ju-do-it
    个人博客:https://zhangju.lookdoc.cn
    博客园:https://www.cnblogs.com/zhangju
    Copyright ©2020 Ju-do-it
    【转载文章务必保留出处和署名,谢谢!】
  • 相关阅读:
    我的20130220日 在北京 do{ Web Develop } while(!die)
    关于NVelocity模板引擎初学总结
    C# 23种设计模式汇总
    基于模型的设备故障检测
    图像去噪之光斑去除
    虹膜识别
    封闭曲线拟合
    基于故障树的系统可靠性分析
    图像识别之棋子识别
    时间序列的模式距离
  • 原文地址:https://www.cnblogs.com/zhangju/p/5675247.html
Copyright © 2011-2022 走看看