Python网络编程之socketserver模块实现并发

为何要讲socketserver？咱们以前写的tcp协议的socket是否是一次只能和一个客户端通讯，若是用socketserver能够实现和多个客户端通讯。它是在socket的基础上进行了一层封装，也就是说底层仍是调用的socket，在py2.7里面叫作SocketServer也就是大写了两个S，在py3里面就小写了。

　　那么咱们先看socketserver怎么用呢，而后在分析，先看下面的代码

import socketserver                              #一、引入模块
class MyServer(socketserver.BaseRequestHandler): #二、本身写一个类，类名本身随便定义，而后继承socketserver这个模块里面的BaseRequestHandler这个类
 
    def handle(self):                            #三、写一个handle方法，必须叫这个名字
        #self.request                            #六、self.request 至关于一个conn
 
        self.request.recv(1024)                  #七、收消息
        msg = '亲，学会了吗'
        self.request.send(bytes(msg,encoding='utf-8')) #八、发消息
 
        self.request.close()                     #九、关闭链接
 
        # 拿到了咱们对每一个客户端的管道，那么咱们本身在这个方法里面的就写咱们接收消息发送消息的逻辑就能够了
        pass
if __name__ == '__mian__':
    #thread 线程，如今只须要简单理解线程，别着急，后面很快就会讲到啦，看下面的图
    server = socketserver.ThreadingTCPServer(('127.0.0.1',8090),MyServer)#四、使用socketserver的ThreadingTCPServer这个类，将IP和端口的元祖传进去，还须要将上面我们本身定义的类传进去，获得一个对象，至关于咱们经过它进行了bind、listen
    server.serve_forever()                       #五、使用咱们上面这个类的对象来执行serve_forever()方法，他的做用就是说，个人服务一直开启着，就像京东同样，不能关闭网站，对吧，而且serve_forever()帮咱们进行了accept
 
 
#注意：
#有socketserver 那么有socketclient的吗？
#固然不会有，我要做为客户去访问京东的时候，京东帮我也客户端了吗，客户端是否是在咱们本身的电脑啊，而且socketserver对客户端没有过高的要求，只须要本身写一些socket就好了。

　　经过上面的代码，咱们来分析socket的源码：（你们还记得面向对象的继承吗，来，实战的时候来啦）

在整个socketserver这个模块中，其实就干了两件事情：一、一个是循环创建连接的部分，每一个客户连接均可以链接成功  2、一个通信循环的部分，就是每一个客户端连接成功以后，要循环的和客户端进行通讯。
看代码中的：server=socketserver.ThreadingTCPServer(('127.0.0.1',8090),MyServer)
 
还记得面向对象的继承吗？来，你们本身尝试着看看源码：
 
查找属性的顺序：ThreadingTCPServer->ThreadingMixIn->TCPServer->BaseServer
 
实例化获得server，先找ThreadMinxIn中的__init__方法，发现没有init方法，而后找类ThreadingTCPServer的__init__,在TCPServer中找到，在里面建立了socket对象，进而执行server_bind（至关于bind）,server_active（点进去看执行了listen）
找server下的serve_forever,在BaseServer中找到，进而执行self._handle_request_noblock()，该方法一样是在BaseServer中
执行self._handle_request_noblock()进而执行request, client_address = self.get_request()（就是TCPServer中的self.socket.accept()），而后执行self.process_request(request, client_address)
在ThreadingMixIn中找到process_request，开启多线程应对并发，进而执行process_request_thread，执行self.finish_request(request, client_address)
上述四部分完成了连接循环，本部分开始进入处理通信部分，在BaseServer中找到finish_request,触发咱们本身定义的类的实例化，去找__init__方法，而咱们本身定义的类没有该方法，则去它的父类也就是BaseRequestHandler中找....
源码分析总结：
 
基于tcp的socketserver咱们本身定义的类中的
 
　　self.server即套接字对象
　　self.request即一个连接
　　self.client_address即客户端地址
基于udp的socketserver咱们本身定义的类中的
 
　　self.request是一个元组（第一个元素是客户端发来的数据，第二部分是服务端的udp套接字对象），如(b'adsf', <socket.socket fd=200, family=AddressFamily.AF_INET, type=SocketKind.SOCK_DGRAM, proto=0, laddr=('127.0.0.1', 8080)>)
　　self.client_address即客户端地址

　一个完整的sockeserver代码示例：

　　　　服务端代码示例：

import socketserver
class Myserver(socketserver.BaseRequestHandler):
    def handle(self):
        self.data = self.request.recv(1024).strip()
        print("{} wrote:".format(self.client_address[0]))
        print(self.data)
        self.request.sendall(self.data.upper())
 
if __name__ == "__main__":
    HOST, PORT = "127.0.0.1", 9999
 
    # 设置allow_reuse_address容许服务器重用地址
    socketserver.TCPServer.allow_reuse_address = True
    # 建立一个server, 将服务地址绑定到127.0.0.1:9999
    #server = socketserver.TCPServer((HOST, PORT),Myserver)
    server = socketserver.ThreadingTCPServer((HOST, PORT),Myserver)
    # 让server永远运行下去，除非强制中止程序
    server.serve_forever()

　　客户端代码示例：

import socket
 
HOST, PORT = "127.0.0.1", 9999
data = "hello"
 
# 建立一个socket连接，SOCK_STREAM表明使用TCP协议
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
    sock.connect((HOST, PORT))          # 连接到客户端
    sock.sendall(bytes(data + "\n", "utf-8")) # 向服务端发送数据
    received = str(sock.recv(1024), "utf-8")# 从服务端接收数据
 
print("Sent:     {}".format(data))
print("Received: {}".format(received))