Day15 - Python基础15 模块学习-selectors

本节内容

1：Python/selectors模块

2：selsect实例

1：Python/selectors模块及队列

 selectors模块是可以实现IO多路复用机制：

它具有根据平台选出最佳的IO多路机制，比如在win的系统上他默认的是select模式而在linux上它默认的epoll。

常用IO多路复用共分为三种：
 
select、poll、epoll

且windows上只支持select，而linux上都支持

select的缺点：

1、每次调用都要将所有的文件描述符（fd）拷贝的内核空间，导致效率下降

2、遍历所有的文件描述符（fd）查看是否有数据访问

3、最大链接数限额（1024）

poll：

它就是select和epoll的过渡阶段，它没有最大链接数的限额

epoll：

1、第一个函数是创建一个epoll句柄，将所有的描述符（fd）拷贝到内核空间，但只拷贝一次。

2、回调函数，某一个函数或某一个动作成功完成之后会触发的函数为所有的描述符（fd）绑定一个回调函数，一旦有数据访问就是触发该回调函数，回调函数将（fd）放到链表中

3、函数判断链表是否为空

4、最大启动项没有限额

2：selsect实例：

###服务端################

import selectors  #基于select模块实现的IO多路复用，建议大家使用
import socket
sock=socket.socket()
sock.bind(('127.0.0.1',8800))
sock.listen(5)
sock.setblocking(False)
sel=selectors.DefaultSelector() #根据平台选择最佳的IO多路机制，比如linux就会选择epoll

def read(conn,mask):
    try:
        data=conn.recv(1024)
        print(data.decode('utf8'))
        data2=input('>>>>')
        conn.send(data2.encode('utf8'))
    except Exception:
        sel.unregister(conn)

def accept(sock,mask):
    conn,addr=sock.accept()
    print('-------',conn)
    sel.register(conn,selectors.EVENT_READ,read)

sel.register(sock, selectors.EVENT_READ, accept)  #注册功能，一旦有反应继续往下执行

while True:
    print('wating....')
    events=sel.select()   #event和select的监听对象[(sock)，（），（）]一样，都是在监听

    for key,mask in events:
        # print(key.data)       #accept   找出有活动的绑定函数
        # print(key.fileobj)    #sock     找出有活动的文件描述符

        func=key.data
        obj=key.fileobj

        func(obj,mask)  #1 accept(sock,mask) 2read(conn,mask)

##客户端#################
import socket
tin=socket.socket()
tin.connect(('127.0.0.1',8800))
while True:
    inp=input('>>>>')
    tin.send(inp.encode('utf8'))
    data=tin.recv(1024)
    print(data.decode('utf8'))