IO多路復用就是我們說的select poll epoll

通過一種機制使一個進程能同時等待多個文件描述符，而這些文件描述符(套接字描述符)其中的任意一個進入讀就緒狀態(tài)，epoll()函數(shù)就可以返回。所以，IO多路復用，本質上不會有并發(fā)的功能，因為任何時候還是只有一個進程或線程進行工作，它之所以能提高效率是因為epoll把進來的socket放到他們的‘監(jiān)視’列表里面，當任何socket有可讀可寫數(shù)據(jù)立馬處理，那如果epoll手里同時檢測著很多socket，一有動靜馬上返回給進程處理，總比一個一個socket過來，阻塞等待，處理高效率。

為什么要選擇epoll而不使用select或者poll呢？

(1)epoll解決了前兩者將fd集合從用戶態(tài)拷貝到內核態(tài)時開銷大的問題

(2)epoll和poll一樣解決了select連接數(shù)受限的問題

(3)epoll不想前兩者那樣去邊離輪詢所有fd集合，而是將套接字添加到epoll的監(jiān)聽事件中

epoll常用事件

EPOLLIN? ?可讀事件

EPOLLOUT? ? 可寫事件

EPOLLHUP? ? 掛起事件

EPOLLET? ? ET模式

eopll對文件描述符的操作有兩種模式：LT和ET。LT模式是默認模式，LT模式與ET模式的區(qū)別如下：

LT模式：當epoll檢測到描述符事件發(fā)生并將此事件通知應用程序，應用程序可以不立即處理該事件。下次調用epoll時，會再次響應應用程序通知此事件

ET模式：當epoll檢測到描述符事件發(fā)生并將此事件通知應用程序，應用程序必須立即處理該事件。如果不處理，下次調用epoll時，不會再次響應應用程序并通知此事件

importsocketimportselect

server_socket=socket.socket(socket.AF_INET, socket.SOCK_STREAM)

server_socket.bind(("", 8000))

server_socket.listen(128)#創(chuàng)建一個epoll對象

epoll =select.epoll()#將套接字添加到epoll的事件監(jiān)聽中

epoll.register(server_socket.fileno(), select.EPOLLIN|select.EPOLLET)#創(chuàng)建字典用來存儲客戶端套接字信息

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的時間監(jiān)聽中

epoll.register(new_socket.fileno(), select.EPOLLIN)#如果客戶端套接字發(fā)送數(shù)據(jù)

elif events ==select.EPOLLIN:#接收數(shù)據(jù)

revcData = connections[fd].recv(1024).decode()ifrevcData:print("recv:%s"%revcData)#修改當前套接字的文件描述符

epoll.modify(fd, select.EPOLLOUT)#如果客戶端套接字為寫數(shù)據(jù)時

elif events ==select.EPOLLOUT:#發(fā)送數(shù)據(jù)

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)#禁止該套接字收發(fā)數(shù)據(jù)

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]

總結

以上是生活随笔為你收集整理的python epoll多路复用技术_python IO 多路复用 epoll简单模型的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內容還不錯，歡迎將生活随笔推薦給好友。