Select与Selectors

多路复用IO的select使用

select基础使用方法

########################################客户端
from socket import *client=socket(AF_INET,SOCK_STREAM)
client.connect(('10.11.190.147',8080))while True:msg=input('>>: ').strip()if not msg:continueclient.send(msg.encode('utf-8'))data=client.recv(1024)print(data.decode('utf-8'))client.close()
###########################################服务端
import select
import socket
sk=socket.socket()
sk.bind(('10.11.185.130',8080))
sk.listen(5)while True:r,w,e=select.select([sk,],[],[])#select时会发生阻塞，直到套接字的状态发生变化#如果不想阻塞，可以在最后再添加一个数字参数，如select。select.([sk,],[],[],5)表示非阻塞，每5秒监听一次#select会监听第一个列表里的套接字，如果套接字状态变成readable则会把对应的套接字放入r列表中  #当socket连接到新的链接，或者conn的收和发生消息时，他们的状态都会变成readable print(r) for obj in r: conn,addr=obj.accept() #如果socket不accept或者conn不recv，则他们会一直处于readable状态 data=conn.recv(1024) print(data) conn.send(data.upper())

完整客户端/服务端

###########################################服务端
import select
import socket
sk=socket.socket()
sk.bind(('10.11.190.147',8080))
sk.listen(5)
inputs=[sk,]#将需要监听的套接字放进inputs列表里
while True:r,w,e=select.select(inputs,[],[])for obj in r:if obj==sk:conn,addr=obj.accept()print('connect',conn,'from',addr)conn.setblocking(0)     #将套接字设为非阻塞inputs.append(conn)     #将套接字放入监听列表中else:try:data=obj.recv(1024)if data:print('message',data,'from',obj.getpeername())conn.send(data.upper())else: #如果接受为空则关闭链接print('close connect %s',obj.getpeername())obj.close()inputs.remove(obj)  #移除套接字except Exception as e:  #如果发生错误，则关闭链接print('Error',e)print('close connect',obj.getpeername())obj.close()inputs.remove(obj)  #移除套接字
########################################客户端
from socket import *client=socket(AF_INET,SOCK_STREAM)
client.connect(('10.11.190.147',8080))while True:msg=input('>>: ').strip()if not msg:continueclient.send(msg.encode('utf-8'))data=client.recv(1024)print(data.decode('utf-8'))client.close()

除了Select可以实现IO多路复用，还有poll和epoll模块可以实现，它们的不同点是：

Select最多可以监听1024个连接，且管理多个描述符也是进行轮询，根据描述符的状态进行处理，但select在linux,windows,mac上都有

poll解决select的监听个数限制，但是依旧是轮询方式。

epoll解决了轮询问题，可以直接拿到就绪的套接字，但是Windows不支持。

好在我们有selectors模块，帮我们默认选择当前平台下最合适的

Selectors

############################################################服务端
import selectors
import socket
sel=selectors.DefaultSelector()#设置不同平台默认的selectoer
sk=socket.socket()
sk.bind(('10.11.190.147',8080))
sk.setblocking(0)
sk.listen(5)def accpet(obj,mask):print('mask is',mask)conn,addr=obj.accept()print('connect',conn,'from',addr)conn.setblocking(0)sel.register(conn,selectors.EVENT_READ,read) #将套接字放入监听列表，并绑定read函数def read(obj,mask):print('mask is',mask)try:data=obj.recv(1024)if data:print('message:',data,'from',obj.getpeername())message=input('>>:').strip()obj.send(message.encode('utf8'))else:print('close connect:',obj.getpeername())sel.unregister(obj)  #将套接字从监听列表中移除，不再监听obj.close()except Exception as e:print(e)print('close connect:',obj.getpeername())sel.unregister(obj)obj.close()sel.register(sk,selectors.EVENT_READ,accpet)#监听套接字sk，并绑定函数accept
while True:events=sel.select() #开始监听for obj,mask in events:callable=obj.data #获得套接字绑定的函数，如果是sk，则callback=acceptcallable(obj.fileobj,mask)  #执行绑定的函数，obj.fileobj就是拿到的套接字，如果是sk，相当于accpet(sk，mask)
########################################客户端
from socket import *client=socket(AF_INET,SOCK_STREAM)
client.connect(('10.11.190.147',8080))while True:msg=input('>>: ').strip()if not msg:continueclient.send(msg.encode('utf-8'))data=client.recv(1024)print(data.decode('utf-8'))client.close()

Select与Selectors相关推荐

python中select用法_Python select及selectors模块概念用法详解
1. select模块针对select,要先理解其他几个概念: 文件描述符: 文件描述符在形式上是一个非负整数.实际上,它是一个索引值,指向内核为每一个进程所维护的该进程打开文件的记录表.当程序打开 ...
【经典】5种IO模型 | IO多路复用
上篇回顾:静态服务器+压测 3.2.概念篇 1.同步与异步同步是指一个任务的完成需要依赖另外一个任务时,只有等待被依赖的任务完成后,依赖的任务才能算完成. 异步是指不需要等待被依赖的任务完成,只是通 ...
CSS3表单设计–复古
CSS3 Form Design – Vintage Today I prepared great CSS3 styles for forms in vintage style. You can se ...
python123第五周作业答案_python第五十四天--第十周作业
SELECT版FTP: 使用SELECT或SELECTORS模块实现并发简单版FTP 允许多用户并发上传下载文件必须使用select or selectors模块支持多并发,禁止使用多线程或多进程 ...
python开发题库-进阶(持续更新2020-3-18)
文章目录 1.网络相关 01 IP地址的正则 03 三次握手四次挥手全过程为什么握手不是三次或者两次 04 使用python打开百度页面 05 进程线程协程 06 IO多路复用 07 TCP和U ...
python取整的几种方法,Python中取整的几种方法小结
Python中取整的几种方法小结前言对每位程序员来说,在编程过程中数据处理是不可避免的,很多时候都需要根据需求把获取到的数据进行处理,取整则是最基本的数据处理.取整的方式则包括向下取整.四舍五入. ...
python（40）- 进程、线程、协程及IO模型
一.操作系统概念操作系统位于底层硬件与应用软件之间的一层.工作方式:向下管理硬件,向上提供接口. 操作系统进行进程切换:1.出现IO操作:2.固定时间. 固定时间很短,人感受不到.每一个应用层运行起 ...
jeee的基础知识(转载)
Servlet: 1)servlet : servlet是一个特殊的java程序,需要在web服务器上运行,并接收和响应客户端的请求,遵循http协议. 2)Servlet;作用: 主要用于控制层. ...
ORACLE-SQL较全面笔记
-- 首先,以超级管理员的身份登录oracle sqlplus sys/bjsxt as sysdba --然后,解除对scott用户的锁 alter use ...

Select与Selectors

Selectors

Select与Selectors相关推荐

最新文章

热门文章