2019獨角獸企業重金招聘Python工程師標準>>>

????先貼一段代碼，代碼很簡單要看過epoll如何使用，都應該能看懂。

????這是服務端程序：

#include?<sys/socket.h> #include?<sys/epoll.h> #include?<netinet/in.h> #include?<arpa/inet.h> #include?<fcntl.h> #include?<unistd.h> #include?<stdio.h> #include?<errno.h> #include?<stdlib.h> #include?<string.h>#define?MAXLINE 10 #define?OPEN_MAX 100 #define?LISTENQ 20 #define?SERV_PORT 5555 #define?INFTIM 1000void?setnonblocking(int?sock) {int?opts;opts?=?fcntl(sock,?F_GETFL);if(opts?<?0)?{perror("fcntl(sock,?GETFL)");exit(1);}opts?=?opts?|?O_NONBLOCK;if(fcntl(sock,?F_SETFL,?opts)?<?0)?{perror("fcntl(sock,?SETFL,?opts)");exit(1);} }int?main(int?argc,?char?*argv[]) {printf("epoll?socket?begins.\n");int?i,?maxi,?listenfd,?connfd,?sockfd,?epfd,?nfds,?on?=?1;ssize_t?n;char?line[MAXLINE];socklen_t?clilen;struct?epoll_event?ev,?events[20];epfd?=?epoll_create(256);struct?sockaddr_in?clientaddr;struct?sockaddr_in?serveraddr;listenfd?=?socket(AF_INET,?SOCK_STREAM,?0);setnonblocking(listenfd);ev.data.fd?=?listenfd;ev.events?=?EPOLLIN?|?EPOLLET;epoll_ctl(epfd,?EPOLL_CTL_ADD,?listenfd,?&ev);setsockopt(listenfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(int));bzero(&serveraddr,?sizeof(serveraddr));serveraddr.sin_family?=?AF_INET;char?*local_addr?=?"0.0.0.0";inet_aton(local_addr,?&(serveraddr.sin_addr));serveraddr.sin_port?=?htons(SERV_PORT);int?ret?=?bind(listenfd,?(struct?sockaddr?*)&serveraddr,?sizeof(serveraddr));if(ret?<?0){printf("%s\n",?"bind?error!");exit(-1);}listen(listenfd,?LISTENQ);maxi?=?0;for(;?;)?{nfds?=?epoll_wait(epfd,?events,?20,?500);for(i?=?0;?i?<?nfds;?++i)?{if(events[i].data.fd?==?listenfd)?{printf("accept?connection,?fd?is?%d\n",?listenfd);connfd?=?accept(listenfd,?(struct?sockaddr?*)&clientaddr,?&clilen);if(connfd?<?0)?{perror("connfd?<?0");exit(1);}setnonblocking(connfd);char?*str?=?inet_ntoa(clientaddr.sin_addr);printf("connect?from?%s\n",?str);ev.data.fd?=?connfd;ev.events?=?EPOLLIN?|?EPOLLET;epoll_ctl(epfd,?EPOLL_CTL_ADD,?connfd,?&ev);}else?if(events[i].events?&?EPOLLIN)?{sockfd?=?events[i].data.fd;n?=?read(sockfd,?line,?MAXLINE);if(n?<?0?&&?errno?==?EAGAIN){printf("%s\n",?"數據已經讀完，沒有更多的數據可以讀了。");}else?if(n?==?0)?//errno?{printf("%s\n",?"客戶端斷開連接。");epoll_ctl(epfd,?EPOLL_CTL_DEL,?sockfd,?&ev);} else?if(n?<=?0) {printf("%s\n錯誤代碼為%d",?"讀出錯。",?errno);epoll_ctl(epfd,?EPOLL_CTL_DEL,?sockfd,?&ev);}else{ ?printf("%s\n",?line);memset(line,?0,?MAXLINE);n?=?write(sockfd,?"hello?client!",?strlen("hello?client!"));if(n?<?0?&&?errno?==?EAGAIN){printf("%s\n",?"系統緩沖區數據已寫滿。");}else?if(n?<=?0){printf("%s\n錯誤代碼為%d",?"客戶端斷開連接或出錯。",?errno); } else{ ev.data.fd?=?sockfd;ev.events?=?EPOLLIN?|?EPOLLET; epoll_ctl(epfd,?EPOLL_CTL_MOD,?sockfd,?&ev);}} }else?if(events[i].events?&?EPOLLOUT)?{}}} }

?

????客戶端程序：

????可以不用代碼寫客戶端，用telnet連接就行。

telnet?localhost?5555

?

#!/usr/bin/pythonfrom?socket?import?* from?time?import?sleephost?=?gethostname() addr?=?(host,?5555)sockCli?=?socket()sockCli.connect(addr)while?True:sockCli.sendall("sadf")data?=?sockCli.recv(1024)print?datasleep(1)sockCli.close()

?

這段服務端的代碼展示的是用，epoll寫的一個簡單的服務程序， ET非阻塞模式。

關于read的返回值：

????1、返回值n=-1, errno = EAGAIN;當返回值等于你要讀取的數據時，說明你還有數據要讀。?當數據量比較大，多次讀數據的時候非阻塞read的返回值為-1，errno值為11（EAGAIN）時，這個 并不是發生了錯誤，而是數據已經被讀完，這個時候停止讀數據就好了。阻塞模式不會這樣，因為當沒有數據的時候，read就阻塞了。

????2、返回值n=0， errno = 0。說明客戶端已經關閉了。經過測試即使沒有數據的時候，阻塞的read就阻塞，非阻塞的read時為第一種情況。只有客戶端關閉時返回0（socket fd是這樣其他io流為測試）?。這個時候就就不要再注冊事件了，從隊列中刪除這個fd吧。而且當客戶端斷開時，epoll會主動通知一個EPOLLIN事件。

????3、返回值n=-1,errno != EAGAIN;時是錯了，看一下錯誤碼是多吧。

關于write的返回值：

????1、返回值n=-1,errno = EAGAIN時; 說明系統緩沖區已經滿了，不能再寫進去了。當write為阻塞時不會返回這個錯誤，會阻塞掉。

????2、返回值n<=0時;客戶端斷開連接或出錯。

何時系統會通知一個寫事件：

????對于LT 模式，如果注冊了EPOLLOUT，只要該socket可寫(發送緩沖區)未滿，那么就會觸發EPOLLOUT。

????對于ET模式，如果注冊了EPOLLOUT,只有當socket從不可寫變為可寫的時候，會觸發EPOLLOUT。

????上面server端的例子，當你要寫入的數據比較大的時候，可能就會有困擾了，如何寫入的數據量較大，把系統緩沖區寫滿了，如果write設置是阻塞的，那就會阻塞了。這可能不是我們想要的。

????這個時候就需要注冊寫事件，自己在應用層加個發送緩沖區，需要發送數據的時候，就寫到應用層的發送緩沖區。觸發write事件的時候，從緩沖區寫入socket。

?

轉載于:https://my.oschina.net/u/2255341/blog/650661

總結

以上是生活随笔為你收集整理的epoll socket 服务端中read和write的返回值讨论的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。