在一個(gè)非阻塞的socket上調(diào)用read/write函數(shù)，返回EAGAIN 或者 EWOULDBLOCK(注: EAGAIN就是EWOULDBLOCK)
從字面上看, 意思是:EAGAIN: 再試一次，EWOULDBLOCK: 如果這是一個(gè)阻塞socket, 操作將被block，perror輸出: Resource temporarily unavailable

總結(jié):
這個(gè)錯(cuò)誤表示資源暫時(shí)不夠，能read時(shí)，讀緩沖區(qū)沒有數(shù)據(jù)，或者write時(shí)，寫緩沖區(qū)滿了。

遇到這種情況，如果是阻塞socket，read/write就要阻塞掉。

　　　　　　　如果是非阻塞socket，read/write立即返回-1， 同時(shí)errno設(shè)置為EAGAIN。

所以，對于阻塞socket，read/write返回-1代表網(wǎng)絡(luò)出錯(cuò)了。

　　　　但對于非阻塞socket，read/write返回-1不一定網(wǎng)絡(luò)真的出錯(cuò)了?？赡苁荝esource temporarily unavailable。這時(shí)你應(yīng)該再試，直到Resource available。

綜上，對于non-blocking（非阻塞）的socket，正確的讀寫操作為:
　　讀：忽略掉errno = EAGAIN的錯(cuò)誤，下次繼續(xù)讀
　　寫：忽略掉errno = EAGAIN的錯(cuò)誤，下次繼續(xù)寫

對于select和epoll的LT模式，這種讀寫方式是沒有問題的。但對于epoll的ET模式，這種方式還有漏洞。

epoll的兩種模式LT（水平觸發(fā)）和ET（邊緣觸發(fā)）

　　二者的差異在于level-trigger模式下只要某個(gè)socket處于readable/writable狀態(tài)，無論什么時(shí)候進(jìn)行 epoll_wait都會(huì)返回該socket；

　　　而edge-trigger模式下只有某個(gè)socket從unreadable變?yōu)閞eadable或從 unwritable變?yōu)閣ritable時(shí)，epoll_wait才會(huì)返回該socket。

讀：只要可讀，就一直讀，直到返回0，或者 errno = EAGAIN
寫:只要可寫，就一直寫，直到數(shù)據(jù)發(fā)送完，或者 errno = EAGAIN

正確的讀：

1 n = 0; 2 while((nread = read(fd, buf+n, BUFSIZ-1)) > 0 ) 3 { 4 n += read; 5 } 6 7 if (nread == -1 && errno != EAGAIN ) 8 { 9 perror( " read error" ); 10 }

正確的寫：

int nwrite, data_size = strlen(buf);

n = data_size;

while(n >0){

? ? nwrite = write(fd, buf + data_size - n, n);

? ? if(nwrite < n){

? ? ? ? if(nwrite ==-1&& errno != EAGAIN){

? ? ? ? ? ? perror("write error");

? ? ? ? }

? ? ? ? break;

? ? }

? ? n -= nwrite;

}

正確的accept，accept 要考慮 2 個(gè)問題
(1) 阻塞模式 accept 存在的問題
考慮這種情況：TCP連接被客戶端夭折，即在服務(wù)器調(diào)用accept之前，客戶端主動(dòng)發(fā)送RST終止連接，導(dǎo)致剛剛建立的連接從就緒隊(duì)列中移出，如果套接 口被設(shè)置成阻塞模式，服務(wù)器就會(huì)一直阻塞在accept調(diào)用上，直到其他某個(gè)客戶建立一個(gè)新的連接為止。但是在此期間，服務(wù)器單純地阻塞在accept調(diào) 用上，就緒隊(duì)列中的其他描述符都得不到處理。

解決辦法是把監(jiān)聽套接口設(shè)置為非阻塞，當(dāng)客戶在服務(wù)器調(diào)用accept之前中止某個(gè)連接 時(shí)，accept調(diào)用可以立即返回-1，這時(shí)源自Berkeley的實(shí)現(xiàn)會(huì)在內(nèi)核中處理該事件，并不會(huì)將該事件通知給epool，而其他實(shí)現(xiàn)把errno 設(shè)置為ECONNABORTED或者EPROTO錯(cuò)誤，我們應(yīng)該忽略這兩個(gè)錯(cuò)誤。

(2)ET模式下accept存在的問題
考慮這種情況：多個(gè)連接同時(shí)到達(dá)，服務(wù)器的TCP就緒隊(duì)列瞬間積累多個(gè)就緒連接，由于是邊緣觸發(fā)模式，epoll只會(huì)通知一次，accept只處理一個(gè)連接，導(dǎo)致TCP就緒隊(duì)列中剩下的連接都得不到處理。

解決辦法是用while循環(huán)抱住accept調(diào)用，處理完TCP就緒隊(duì)列中的所有連接后再退出循環(huán)。如何知道是否處理完就緒隊(duì)列中的所有連接呢？accept返回-1并且errno設(shè)置為EAGAIN就表示所有連接都處理完。

綜合以上兩種情況，服務(wù)器應(yīng)該使用非阻塞地accept，accept在ET模式下的正確使用方式為：

while((conn_sock = accept(listenfd,(struct sockaddr *)&remote,(size_t *)&addrlen))>0){

? ? handle_client(conn_sock);

}

if(conn_sock ==-1){

? ? if(errno != EAGAIN && errno != ECONNABORTED && errno != EPROTO && errno != EINTR)

? ? perror("accept");

}

一道騰訊后臺開發(fā)的面試題
使用Linuxepoll模型，水平觸發(fā)模式；當(dāng)socket可寫時(shí)，會(huì)不停的觸發(fā)socket可寫的事件，如何處理？

第一種最普遍的方式：
需要向socket寫數(shù)據(jù)的時(shí)候才把socket加入epoll，等待可寫事件。
接受到可寫事件后，調(diào)用write或者send發(fā)送數(shù)據(jù)。
當(dāng)所有數(shù)據(jù)都寫完后，把socket移出epoll。

這種方式的缺點(diǎn)是，即使發(fā)送很少的數(shù)據(jù)，也要把socket加入epoll，寫完后在移出epoll，有一定操作代價(jià)。

一種改進(jìn)的方式：
開始不把socket加入epoll，需要向socket寫數(shù)據(jù)的時(shí)候，直接調(diào)用write或者send發(fā)送數(shù)據(jù)。如果返回EAGAIN，把socket加入epoll，在epoll的驅(qū)動(dòng)下寫數(shù)據(jù)，全部數(shù)據(jù)發(fā)送完畢后，再移出epoll。

這種方式的優(yōu)點(diǎn)是：數(shù)據(jù)不多的時(shí)候可以避免epoll的事件處理，提高效率。

總結(jié)

以上是生活随笔為你收集整理的Epoll在LT和ET模式下的读写方式的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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