Python/selectors模块

Posted 2020-09-17

Python/selectors模块

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

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

常用共分为三种：

select、poll、epoll

select的缺点：

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

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

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

poll：

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

epoll：

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

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

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

4、最大启动项没有限额

selsect实例：

 1 服务端
 2 import selectors  #基于select模块实现的IO多路复用，建议大家使用
 3 import socket
 4 sock=socket.socket()
 5 sock.bind((‘127.0.0.1‘,8800))
 6 sock.listen(5)
 7 sock.setblocking(False)
 8 sel=selectors.DefaultSelector() #根据平台选择最佳的IO多路机制，比如linux就会选择epoll
 9 
10 def read(conn,mask):
11     try:
12         data=conn.recv(1024)
13         print(data.decode(‘utf8‘))
14         data2=input(‘>>>>‘)
15         conn.send(data2.encode(‘utf8‘))
16     except Exception:
17         sel.unregister(conn)
18 
19 def accept(sock,mask):
20     conn,addr=sock.accept()
21     print(‘-------‘,conn)
22     sel.register(conn,selectors.EVENT_READ,read)
23 sel.register(sock, selectors.EVENT_READ, accept)  #注册功能
24 while True:
25     print(‘wating....‘)
26     events=sel.select()   #[(sock)，（），（）]   监听
27 
28     for key,mask in events:
29         # print(key.data)       #accept   找出有活动的绑定函数
30         # print(key.fileobj)    #sock     找出有活动的文件描述符
31 
32         func=key.data
33         obj=key.fileobj
34 
35         func(obj,mask)  #1 accept(sock,mask) 2read(conn,mask)
36 ------------------------------------------------------------------------------
37 客户端
38 import socket
39 tin=socket.socket()
40 tin.connect((‘127.0.0.1‘,8800))
41 while True:
42     inp=input(‘>>>>‘)
43     tin.send(inp.encode(‘utf8‘))
44     data=tin.recv(1024)
45     print(data.decode(‘utf8‘))