600字范文,内容丰富有趣,生活中的好帮手!
600字范文 > python epoll多路复用技术_python IO 多路复用 epoll简单模型

python epoll多路复用技术_python IO 多路复用 epoll简单模型

时间:2020-09-29 08:45:13

相关推荐

python epoll多路复用技术_python IO 多路复用 epoll简单模型

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]

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。