IO多路复用就是我们说的select poll epoll
通过一种机制使一个进程能同时等待多个文件描述符,而这些文件描述符(套接字描述符)其中的任意一个进入读就绪状态,epoll()函数就可以返回。所以,IO多路复用,本质上不会有并发的功能,因为任何时候还是只有一个进程或线程进行工作,它之所以能提高效率是因为epoll把进来的socket放到他们的‘监视’列表里面,当任何socket有可读可写数据立马处理,那如果epoll手里同时检测着很多socket,一有动静马上返回给进程处理,总比一个一个socket过来,阻塞等待,处理高效率。
为什么要选择epoll而不使用select或者poll呢?
(1)epoll解决了前两者将fd集合从用户态拷贝到内核态时开销大的问题
(2)epoll和poll一样解决了select连接数受限的问题
(3)epoll不想前两者那样去边离轮询所有fd集合,而是将套接字添加到epoll的监听事件中
epoll常用事件
EPOLLIN 可读事件
EPOLLOUT 可写事件
EPOLLHUP 挂起事件
EPOLLET ET模式
eopll对文件描述符的操作有两种模式:LT和ET。LT模式是默认模式,LT模式与ET模式的区别如下:
LT模式:当epoll检测到描述符事件发生并将此事件通知应用程序,应用程序可以不立即处理该事件。下次调用epoll时,会再次响应应用程序通知此事件
ET模式:当epoll检测到描述符事件发生并将此事件通知应用程序,应用程序必须立即处理该事件。如果不处理,下次调用epoll时,不会再次响应应用程序并通知此事件
importsocketimportselect
server_socket=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(("", 8000))
server_socket.listen(128)#创建一个epoll对象
epoll =select.epoll()#将套接字添加到epoll的事件监听中
epoll.register(server_socket.fileno(), select.EPOLLIN|select.EPOLLET)#创建字典用来存储客户端套接字信息
connections ={}
addresses={}whileTrue:#epoll进行fd扫描
epoll_list =epoll.poll()#对事件进行判断
for fd, events inepoll_list:#如果是server socket被激活
if fd ==server_socket.fileno():
new_socket, new_addr=server_socket.accept()print('有新的客户端到来%s' %str(new_addr))#将客户端套接字信息存放在字典中
connections[new_socket.fileno()] =new_socket
addresses[new_socket.fileno()]=new_addr#将客户端套接字添加到epoll的时间监听中
epoll.register(new_socket.fileno(), select.EPOLLIN)#如果客户端套接字发送数据
elif events ==select.EPOLLIN:#接收数据
revcData = connections[fd].recv(1024).decode()ifrevcData:print("recv:%s"%revcData)#修改当前套接字的文件描述符
epoll.modify(fd, select.EPOLLOUT)#如果客户端套接字为写数据时
elif events ==select.EPOLLOUT:#发送数据
content = "
hello world
"response= "HTTP/1.1 200 OK\r\nContent-Length:%d\r\n\r\n%s"%(len(content), content)connections[fd].send(response.encode())#修改当前套接字的文件描述符
epoll.modify(fd, 0)#禁止该套接字收发数据
connections[fd].shutdown(socket.SHUT_RDWR)#当客户端套接字处于挂起时
elif events ==select.EPOLLHUP:#注销文件描述符
epoll.unregister(fd)#关闭套接字
connections[fd].close()print("%s----offline----"%str(addresses[fd]))#删除字典中的信息
delconnections[fd]del addresses[fd]