epoll是在linux系統中,一種高效率的i/o復用技術.
在linux的網路程式設計中,很長的時間都在使用select來做事件觸發。在linux新的核心中,有了一種替換它的機制,就是epoll。
相比於select,epoll最大的好處在於它不會隨著監聽fd數目的增長而降低效率。因為在核心中的select實現中,它是採用輪詢來處理的,輪詢的fd數目越多,自然耗時越多。並且,在linux/posix_types.h標頭檔案有這樣的宣告:
表示select最多同時監聽1024個fd,當然,可以通過修改標頭檔案再重編譯核心來擴大這個數目,但這似乎並不治本。
epoll的介面非常簡單,一共就三個函式:
1. int epoll_create(int size);
建立乙個epoll的控制代碼,size用來告訴核心這個監聽的數目一共有多大。這個引數不同於select()中的第乙個引數,給出最大監聽的fd+1的值。需要注意的是,當建立好epoll控制代碼後,它就是會占用乙個fd值,在linux下如果檢視/proc/程序id/fd/,是能夠看到這個fd的,所以在使用完epoll後,必須呼叫close()關閉,否則可能導致fd被耗盡。
int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
epoll的事件註冊函式,它不同與select()是在監聽事件時告訴核心要監聽什麼型別的事件,而是在這裡先註冊要監聽的事件型別。第乙個引數是epoll_create()的返回值,第二個引數表示動作,用三個巨集來表示:
epoll_ctl_add:註冊新的fd到epfd中;
epoll_ctl_mod:修改已經註冊的fd的監聽事件;
epoll_ctl_del:從epfd中刪除乙個fd;
第三個引數是需要監聽的fd,第四個引數是告訴核心需要監聽什麼事,struct epoll_event結構如下:
typedef union epoll_data epoll_data_t;
struct epoll_event ;
events可以是以下幾個巨集的集合:
epollin :表示對應的檔案描述符可以讀(包括對端socket正常關閉);
epollout:表示對應的檔案描述符可以寫;
epollpri:表示對應的檔案描述符有緊急的資料可讀(這裡應該表示有帶外資料到來);
epollerr:表示對應的檔案描述符發生錯誤;
epollhup:表示對應的檔案描述符被結束通話;
epollet: 將epoll設為邊緣觸發(edge triggered)模式,這是相對於水平觸發(level triggered)來說的。
epolloneshot:只監聽一次事件,當監聽完這次事件之後,如果還需要繼續監聽這個socket的話,需要再次把這個socket加入到epoll佇列裡
int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);
等待事件的產生,類似於select()呼叫。引數events用來從核心得到事件的集合,maxevents告之核心這個events有多大,這個 maxevents的值不能大於建立epoll_create()時的size,引數timeout是超時時間(毫秒,0會立即返回,-1將不確定,也有說法說是永久阻塞)。該函式返回需要處理的事件數目,如返回0表示已超時。
4、關於et、lt兩種工作模式:
可以得出這樣的結論:
et模式僅當狀態發生變化的時候才獲得通知,這裡所謂的狀態的變化並不包括緩衝區中還有未處理的資料,也就是說,如果要採用et模式,需要一直read/write直到出錯為止,很多人反映為什麼採用et模式只接收了一部分資料就再也得不到通知了,大多因為這樣;而lt模式是只要有資料沒有處理就會一直通知下去的.
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include 5
#define epoll_size 1000
#define buf_size 1024
using
namespace
std;
//vectorfd_num;
list
fd_num; //儲存客戶端的描述符(作業系統將描述符抽象成乙個int整數)
inline
void error_hande(char *str); //輸出錯誤資訊
inline
void setnonblockingmode(int fd); //將描述符fd設定成邊緣觸發 。 epoll中的概念
int main(int argc, char *argv)
puts("epoll_wait()!");
for(int i=0; iif(e_events[i].data.fd == serv_sock) //如果是本身的描述符響應了,就說明有新的客戶端連線了
else
//如果是已有的客戶端發資訊了
else
if(str_len<0 && errno==eagain)
break;
else}}
}}
}close(epfd);
close(serv_sock);
return0;}
void error_hande(char *str)
void setnonblockingmode(int fd)
Web伺服器 併發伺服器 Epoll(3 4 5)
epoll是一種解決方案,nginx就是用的這個 中心思想 不要再使用多程序,多執行緒了,使用單程序,單執行緒去實現併發 在上面部落格實現的 中使用過的輪詢去檢視套接字有沒有資料,而epoll是主動通知 當使用多程序的時候,是複製乙份資源去檢視,epoll不用複製,直接來 優勢 1.共享記憶體 2....
C 回聲伺服器 1 簡單版本
c 網路程式設計離不開socket程式設計。我們現在使用socket編寫簡單的回聲伺服器。這裡所說的流程包括兩部分 socket函式呼叫流程。伺服器與客戶端互動流程。回聲伺服器主要功能 伺服器將接收到來自客戶端的資料傳回客戶端。伺服器的功能 客戶端的功能 include include includ...
C 回聲伺服器 1 簡單版本
c 網路程式設計離不開socket程式設計。我們現在使用socket編寫簡單的回聲伺服器。這裡所說的流程包括兩部分 socket函式呼叫流程。伺服器與客戶端互動流程。回聲伺服器主要功能 伺服器將接收到來自客戶端的資料傳回客戶端。伺服器的功能 客戶端的功能 include include includ...