**原理圖**  1. Create an epoll object——創建1個epoll對象 2. Tell the epoll object to monitor specific events on specific sockets——告訴epoll對象，在指定的socket上監聽指定的事件 3. Ask the epoll object which sockets may have had the specified event since the last query——詢問epoll對象，從上次查詢以來，哪些socket發生了哪些指定的事件 4. Perform some action on those sockets——在這些socket上執行一些操作 5. Tell the epoll object to modify the list of sockets and/or events to monitor——告訴epoll對象，修改socket列表和（或）事件，并監控 6. Repeat steps 3 through 5 until finished——重復步驟3-5，直到完成 7. Destroy the epoll object——銷毀epoll對象 **相關用法** ~~~ import select 導入select模塊 epoll = select.epoll() 創建一個epoll對象 epoll.register(文件句柄,事件類型) 注冊要監控的文件句柄和事件 事件類型: 　　select.EPOLLIN 可讀事件 　　select.EPOLLOUT 可寫事件 　　select.EPOLLERR 錯誤事件 　　select.EPOLLHUP 客戶端斷開事件 epoll.unregister(文件句柄) 銷毀文件句柄 epoll.poll(timeout) 當文件句柄發生變化，則會以列表的形式主動報告給用戶進程,timeout 為超時時間，默認為-1，即一直等待直到文件句柄發生變化，如果指定為1 那么epoll每1秒匯報一次當前文件句柄的變化情況，如果無變化則返回空 epoll.fileno() 返回epoll的控制文件描述符(Return the epoll control file descriptor) epoll.modfiy(fineno,event) fineno為文件描述符 event為事件類型 作用是修改文件描述符所對應的事件 epoll.fromfd(fileno) 從1個指定的文件描述符創建1個epoll對象 epoll.close() 關閉epoll對象的控制文件描述符 ~~~ 注：EPOLLIN(可讀)，EPOLLOUT(可寫) * EPOLLET: 邊緣觸發模式(只通知一次) * EPOLLLT：水平觸發模式(通知后沒有做處理的話還會繼續通知) ~~~ import socket import select tcp_server_tcp = socket.socket(socket.AF_INET, socket.SOCK_STREAM) tcp_server_tcp.bind(('0.0.0.0', 9292)) tcp_server_tcp.listen(128) # 設置套接字為非阻塞方式 tcp_server_tcp.setblocking(False) # 創建一個epoll對象 epl = select.epoll() # 將監聽套接字對應的fd注冊到epoll中 epl.register(tcp_server_tcp.fileno(), select.EPOLLIN) # fd為key,socket為value fd_event_dict = dict() while True: # 默認阻塞,直到os監測到數據到來,通過事件通知的方式,此時才會解開阻塞 # epl.poll(10) 里面可以寫超時時間 fd_event_list = epl.poll() # 結果是這樣,[(fd, event), (套接字對應的文件描述符,這個文件描述符到底是什么事件,例如,可以調用recv接收等)] if not fd_event_list: print("epoll超時無活動連接，重新輪詢......") continue print("有", len(fd_event_list), "個新事件，開始處理......") for fd, event in fd_event_list: # 如果活動socket為當前服務器socket，表示有新連接 if fd == tcp_server_tcp.fileno(): # 等待新客戶端的鏈接 new_socket, client_addr = tcp_server_tcp.accept() # 注冊新連接fd到待讀事件集合 epl.register(new_socket.fileno(), select.EPOLLIN) # 把新連接的文件句柄以及對象保存到字典 fd_event_dict[new_socket.fileno()] = new_socket elif event == select.EPOLLIN: # 判斷已經鏈接的客戶端是否有數據發送過來 recv__data = fd_event_dict[fd].recv(1024).decode('utf-8', 'ignore') if recv__data: print('收到的數據是: ', recv__data) # 發送數據回去 fd_event_dict[fd].send(recv__data.encode('utf-8')) else: fd_event_dict[fd].close() epl.unregister(fd) del fd_event_dict [fd] ~~~