epoll學習筆記

epoll有兩種模式,Edge Triggered(簡稱ET) 和 Level Triggered(簡稱LT).在采用這兩種模式時要注意的是,如果采用ET模式,那么僅當狀態發生變化時才會通知,而采用LT模式類似于原來的 select/poll操作,只要還有沒有處理的事件就會一直通知.

以代碼來說明問題:
首先給出server的代碼,需要說明的是每次accept的連接,加入可讀集的時候采用的都是ET模式,而且接收緩沖區是5字節的,也就是每次只接收5字節的數據:

下面給出測試所用的Perl寫的client端,在client中發送10字節的數據,同時讓client在發送完數據之后進入死循環, 也就是在發送完之后連接的狀態不發生改變--既不再發送數據, 也不關閉連接,這樣才能觀察出server的狀態:

#! / usr / bin / perl

use IO::Socket;

my $host  =   " 127.0.0.1 " ;
my $port  =   5000 ;

my $socket  =  IO::Socket::INET -> new ( " $host:$port " )  or  die  " create socket error $@ " ;
my $msg_out  =   " 1234567890 " ;
print $socket $msg_out;
print  " now send over, go to sleep \n " ;

while  ( 1 )
{
    sleep( 1 );
}

運行server和client發現,server僅僅讀取了5字節的數據,而client其實發送了10字節的數據,也就是說,server僅當第一次 監聽到了EPOLLIN事件,由于沒有讀取完數據,而且采用的是ET模式,狀態在此之后不發生變化,因此server再也接收不到EPOLLIN事件了.
(友情提示:上面的這個測試客戶端,當你關閉它的時候會再次出發IO可讀事件給server,此時server就會去讀取剩下的5字節數據了,但是這一事件與前面描述的ET性質并不矛盾.)

如果我們把client改為這樣:

#! / usr / bin / perl

use IO::Socket;

my $host  =   " 127.0.0.1 " ;
my $port  =   5000 ;

my $socket  =  IO::Socket::INET -> new ( " $host:$port " )  or  die  " create socket error $@ " ;
my $msg_out  =   " 1234567890 " ;
print $socket $msg_out;
print  " now send over, go to sleep \n " ;
sleep( 5 );
print  " 5 second gone send another line\n " ;
print $socket $msg_out;

while  ( 1 )
{
    sleep( 1 );
}

可以發現,在server接收完5字節的數據之后一直監聽不到client的事件,而當client休眠5秒之后重新發送數據,server再次監聽到了變化,只不過因為只是讀取了5個字節,仍然有10個字節的數據(client第二次發送的數據)沒有接收完.

如果上面的實驗中,對accept的socket都采用的是LT模式,那么只要還有數據留在buffer中,server就會繼續得到通知,讀者可以自行改動代碼進行實驗.

基 于這兩個實驗,可以得出這樣的結論:ET模式僅當狀態發生變化的時候才獲得通知,這里所謂的狀態的變化并不包括緩沖區中還有未處理的數據,也就是說,如果 要采用ET模式,需要一直read/write直到出錯為止,很多人反映為什么采用ET模式只接收了一部分數據就再也得不到通知了,大多因為這樣;而LT 模式是只要有數據沒有處理就會一直通知下去的.

另外,從這個例子中,也可以闡述一些基本的網絡編程概念.首先,連接的兩端中,一端發送成功并不代表著對方上層應用程序接收成功, 就拿上面的client測試程序來說,10字節的數據已經發送成功,但是上層的server并沒有調用read讀取數據,因此發送成功僅僅說明了數據被對 方的協議棧接收存放在了相應的buffer中,而上層的應用程序是否接收了這部分數據不得而知;同樣的,讀取數據時也只代表著本方協議棧的對應 buffer中有數據可讀,而此時時候在對端是否在發送數據也不得而知.