epoll 可以說是編寫高性能服務(wù)端程序必不可少的技術(shù)，在介紹 epoll 之前，我們先來了解一下 多路復(fù)用I/O 吧。

多路復(fù)用I/O多路復(fù)用I/O：是指內(nèi)核負(fù)責(zé)監(jiān)聽多個 I/O 流，當(dāng)任何一個 I/O 流處于就緒狀態(tài)（可讀或可寫）時都會通知進(jìn)程，以便可以處理該 I/O 流上的數(shù)據(jù)。如 圖1 所示：

如 圖1 所示，內(nèi)核負(fù)責(zé)監(jiān)聽多個 I/O 流，當(dāng)某些 I/O 流變?yōu)榫途w狀態(tài)，內(nèi)核會把這些 I/O 流添加到就緒隊列中，然后通知進(jìn)程處理就緒隊列中的 I/O 流。

與傳統(tǒng)的阻塞型 I/O 相比，多路復(fù)用 I/O 的優(yōu)點(diǎn)是可以同時監(jiān)聽多個 I/O 流，并且會把就緒的 I/O 流告知進(jìn)程。

epoll原理介紹完多路復(fù)用 I/O，接下來開始介紹我們的主角：epoll。

在 Linux 系統(tǒng)中，有多種多路復(fù)用 I/O 的實現(xiàn)，比如 select 和 poll 等。而 epoll 也是多路復(fù)用 I/O 一種實現(xiàn)，與 select 和 poll 相比，epoll 在性能上有較大的提升。

紅黑樹

epoll 內(nèi)部使用紅黑樹來保存所有監(jiān)聽的 socket，紅黑樹是一種平衡二叉樹，添加和查找元素的時間復(fù)雜度為 O（log n），其結(jié)構(gòu)如 圖2 所示：

epoll 通過 socket 句柄來作為 key，把 socket 保存在紅黑樹中。如 圖2 所示，每個節(jié)點(diǎn)中的數(shù)字代表著 socket 句柄。

把監(jiān)聽的 socket 保存在紅黑樹中的目的是，為了在修改監(jiān)聽 socket 的讀寫事件時，能夠通過 socket 句柄快速找到對應(yīng)的 socket 對象。

就緒隊列

另外，epoll 還維護(hù)著一個就緒隊列，當(dāng) epoll 監(jiān)聽的 socket 狀態(tài)發(fā)生改變（變?yōu)榭勺x或可寫）時，就會把就緒的 socket 添加到就緒隊列中。如 圖3 所示：

當(dāng) socket 從網(wǎng)絡(luò)中獲取到數(shù)據(jù)后，會發(fā)生通知給 epoll，epoll 會將當(dāng)前 socket 添加到就緒隊列中，并且喚醒等待中的進(jìn)程（也就是調(diào)用 epoll_wait 的進(jìn)程）。

當(dāng) socket 狀態(tài)發(fā)生變化時，會調(diào)用 ep_poll_callback 函數(shù)來通知 epoll，我們來看看這個函數(shù)的處理過程：

static int ep_poll_callback（wait_queue_t *wait， unsigned mode， int sync， void *key）{ 。。. struct epitem *epi = ep_item_from_wait（wait）; struct eventpoll *ep = epi-》ep; 。。. // 1） 把 socket 添加到就緒隊列中 list_add_tail（&epi-》rdllink， &ep-》rdllist）;

is_linked： // 2） 喚醒調(diào)用 epoll_wait（） 而被阻塞的進(jìn)程 if （waitqueue_active（&ep-》wq）） wake_up_locked（&ep-》wq）; 。。. return 1;}

ep_poll_callback 函數(shù)的意圖很清晰，主要完成兩個工作：

把就緒的 socket 添加到就緒隊列中。

喚醒調(diào)用 epoll_wait 函數(shù)而被阻塞的進(jìn)程。

當(dāng)進(jìn)程被喚醒后，就會從就緒隊列中，把就緒的 socket 復(fù)制到用戶提供的數(shù)組中。如 圖4 所示：

如 圖4 所示，在調(diào)用 epoll_wait 時需要提供一個 events 數(shù)組來存儲就緒的 socket。當(dāng) epoll_wait 返回后，用戶就可以從events 數(shù)組中獲取到就緒的 socket，并可對其進(jìn)行讀寫操作。

總結(jié)本文主要通過圖解的方式大概介紹了 epoll 的原理，但很多實現(xiàn)的細(xì)節(jié)只能通過閱讀源碼來了解。

編輯：jq