Python Select 解析
在 Python 中,select 模块提供了一种高效的方式来监视多个文件描述符(好比网络套接字),查看是否可以进行读、写或有错误发生。这在网络编程中尤其有用,由于你可以同时处理多个毗连而不必要使用阻塞 I/O。select 模块提供了几个函数,其中最常用的是 select.select()。select.select() 函数
select.select() 函数的根本用法如下:
import select
# 定义三个列表:可读、可写、有异常的文件描述符
readable, writable, exceptional = select.select(read_list, write_list, except_list, timeout)
[*]read_list: 包罗你希望查抄是否可以进行读操作的文件描述符(如套接字)列表。
[*]write_list: 包罗你希望查抄是否可以进行写操作的文件描述符列表。
[*]except_list: 包罗你希望查抄是否有异常条件的文件描述符列表。
[*]timeout: 可选参数,指定在查抄文件描述符前等候的秒数。如果设置为 None,它将无穷期地等候。
返回值
select.select() 返回三个元组,每个元组包罗对应于发生事件的文件描述符:
[*]readable: 一个列表,包罗准备好读取的文件描述符。
[*]writable: 一个列表,包罗准备好写入的文件描述符。
[*]exceptional: 一个列表,包罗有异常条件待处理的文件描述符。
示例
下面是一个使用 select.select() 的简朴示例,来监听多个套接字的示例:
import socket
import select
# 创建两个示例套接字
sock1 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock2 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定或连接套接字等操作...
# 将套接字设置为非阻塞模式
sock1.setblocking(False)
sock2.setblocking(False)
# 定义要监视的文件描述符列表
read_list =
write_list = []
except_list = []
try:
while True:
# 使用 select 来监视套接字
readable, writable, exceptional = select.select(read_list, write_list, except_list, 5)
for s in readable:
if s is sock1:
data = sock1.recv(4096)
if data:
print(f"Received data from sock1: {data}")
else:
print("sock1 closed")
read_list.remove(sock1)
if s is sock2:
data = sock2.recv(4096)
if data:
print(f"Received data from sock2: {data}")
else:
print("sock2 closed")
read_list.remove(sock2)
except KeyboardInterrupt:
print("Interrupted by user")
finally:
sock1.close()
sock2.close()
应用场景
[*]多路复用 I/O: 处理多个客户端毗连,例如在一个服务器应用中同时处理多个客户端请求。
[*]高效资源使用: 通过非阻塞 I/O 和事件驱动模型低落 CPU 和内存使用率。
[*]实时应用: 开发必要实时数据处理的应用,例如谈天服务器、游戏服务器等。
使用 select 是一种经典的方法,不过在 Python 中处理高并发毗连时,你也可以考虑使用更高级的 asyncio 或 multiprocessing 模块来实现异步或并行处理。
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
页:
[1]