2019獨(dú)角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

????先貼一段代碼，代碼很簡(jiǎn)單要看過epoll如何使用，都應(yīng)該能看懂。

????這是服務(wù)端程序：

#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",?"數(shù)據(jù)已經(jīng)讀完，沒有更多的數(shù)據(jù)可以讀了。");}else?if(n?==?0)?//errno?{printf("%s\n",?"客戶端斷開連接。");epoll_ctl(epfd,?EPOLL_CTL_DEL,?sockfd,?&ev);} else?if(n?<=?0) {printf("%s\n錯(cuò)誤代碼為%d",?"讀出錯(cuò)。",?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",?"系統(tǒng)緩沖區(qū)數(shù)據(jù)已寫滿。");}else?if(n?<=?0){printf("%s\n錯(cuò)誤代碼為%d",?"客戶端斷開連接或出錯(cuò)。",?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()

?

這段服務(wù)端的代碼展示的是用，epoll寫的一個(gè)簡(jiǎn)單的服務(wù)程序， ET非阻塞模式。

關(guān)于read的返回值：

????1、返回值n=-1, errno = EAGAIN;當(dāng)返回值等于你要讀取的數(shù)據(jù)時(shí)，說明你還有數(shù)據(jù)要讀。?當(dāng)數(shù)據(jù)量比較大，多次讀數(shù)據(jù)的時(shí)候非阻塞read的返回值為-1，errno值為11（EAGAIN）時(shí)，這個(gè) 并不是發(fā)生了錯(cuò)誤，而是數(shù)據(jù)已經(jīng)被讀完，這個(gè)時(shí)候停止讀數(shù)據(jù)就好了。阻塞模式不會(huì)這樣，因?yàn)楫?dāng)沒有數(shù)據(jù)的時(shí)候，read就阻塞了。

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

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

關(guān)于write的返回值：

????1、返回值n=-1,errno = EAGAIN時(shí); 說明系統(tǒng)緩沖區(qū)已經(jīng)滿了，不能再寫進(jìn)去了。當(dāng)write為阻塞時(shí)不會(huì)返回這個(gè)錯(cuò)誤，會(huì)阻塞掉。

????2、返回值n<=0時(shí);客戶端斷開連接或出錯(cuò)。

何時(shí)系統(tǒng)會(huì)通知一個(gè)寫事件：

????對(duì)于LT 模式，如果注冊(cè)了EPOLLOUT，只要該socket可寫(發(fā)送緩沖區(qū))未滿，那么就會(huì)觸發(fā)EPOLLOUT。

????對(duì)于ET模式，如果注冊(cè)了EPOLLOUT,只有當(dāng)socket從不可寫變?yōu)榭蓪懙臅r(shí)候，會(huì)觸發(fā)EPOLLOUT。

????上面server端的例子，當(dāng)你要寫入的數(shù)據(jù)比較大的時(shí)候，可能就會(huì)有困擾了，如何寫入的數(shù)據(jù)量較大，把系統(tǒng)緩沖區(qū)寫滿了，如果write設(shè)置是阻塞的，那就會(huì)阻塞了。這可能不是我們想要的。

????這個(gè)時(shí)候就需要注冊(cè)寫事件，自己在應(yīng)用層加個(gè)發(fā)送緩沖區(qū)，需要發(fā)送數(shù)據(jù)的時(shí)候，就寫到應(yīng)用層的發(fā)送緩沖區(qū)。觸發(fā)write事件的時(shí)候，從緩沖區(qū)寫入socket。

?

轉(zhuǎn)載于:https://my.oschina.net/u/2255341/blog/650661

總結(jié)

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

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