万字总结IO多路复用技术

　　IO多路复用概述
　　IO多路复用技术是为了解决进程或线程阻塞到某个IO系统调用而出现的技术，使进程不阻塞于某个特定的IO系统调用。
　　在IO多路复用技术描述前，先讲解下同步，异步，阻塞，非阻塞的概念。网络IO模型
　　linux网络IO中涉及到的模型如下：
　　（1）阻塞式IO
　　（2）非阻塞式IO
　　（3）IO多路复用
　　（4）信号驱动IO
　　（5）异步IO
　　今天不谈信号驱动IO，略过。。同步异步
　　在学习IO模型的时候，我们必须明确一个概念，处理IO的时候，阻塞和非阻塞都是同步的的IO。
　　只有使用了特殊的API才是异步IO，例如Linux网络中的AIO。
　　再看下POSIX对同步和异步这两个术语的定义：同步IO操作：导致请求进程阻塞，直到IO操作完成；异步IO操作：不导致请求进程阻塞；
　　通俗的理解就是同步和异步同步：当执行系统调用read时，需要用户等待内核完成从内核缓冲区到用户缓冲区的数据拷贝。异步：当执行异步IO操作例如aioread时，用户不需要等待，只需要接收内核完成操作的通知，由内核来完成数据的读取。阻塞非阻塞
　　在知晓阻塞和非阻塞都是同步IO后，阻塞和非阻塞就很好理解了
　　阻塞IO：由系统调用read，导致线程一直等待数据返回。
　　非阻塞IO：系统调用read后立即返回一个状态，当数据达到内核缓冲区之前都是非阻塞的，即返回一个系统调用状态。
　　ps：闪客的动图做得非常的形象，上述gif动图来源低并发编程IO多路复用
　　IO多路复用是一种同步IO模型，实现一个线程可以监视多个文件句柄；select
　　select是操作系统提供的系统调用函数，select（）用来等待文件描述词（普通文件、终端、伪终端、管道、FIFO、套接字及其他类型的字符型）状态的改变。是一个轮循函数，循环询问文件节点，可设置超时时间，超时时间到了就跳过代码继续往下执行。
　　通过select，我们可以把一个文件描述符的数组发给操作系统，让操作系统去遍历，确定哪个文件描述符可以读写，然后告诉我们去处理：
　　头文件includesysselect。hincludesystime。hincludesystypes。hincludeunistd。hselect调用
　　拥塞函数，拥塞等待文件描述符事件的到来intselect（intmaxfdp，fdsetreadset，fdsetwriteset，fdsetexceptset，structtimevaltimeout）；
　　参数说明：
　　maxfdp：被监听的文件描述符的最大值，它比所有文件描述符集合中的文件描述符的最大值大1，因为文件描述符是从0开始计数的；
　　readfds、writefds、exceptset：分别指向可读、可写和异常等事件对应的描述符集合。
　　timeout：用于设置select函数的超时时间，即告诉内核select等待多长时间之后就放弃等待。timeoutNULL表示等待无限长的时间，timeout0，select立即返回timeval结构体structtimeval｛longtvsec；秒longtvusec；微秒｝；select置位intFDZERO（intfd，fdsetfdset）；一个fdset类型变量的所有位都设为0intFDCLR（intfd，fdsetfdset）；清除某个位时可以使用intFDSET（intfd，fdsetfdset）；设置变量的某个位置位intFDISSET（intfd，fdsetfdset）；测试某个位是否被置位
　　当声明了一个文件描述符集后，必须用FDZERO将所有位置零
　　调用select函数，拥塞等待文件描述符事件的到来；如果超过设定的时间，则不再等待，而是继续往下执行
　　select返回后，用FDISSET测试给定位是否置位：if（FDISSET（fd，rset）｛。。。dosomething｝fdset结构体
　　fdset其实这是一个数组的宏定义，实际上是一long类型的数组，每一个数组元素都能与一打开的文件句柄（socket、文件、管道、设备等）建立联系，建立联系的工作由程序员完成，当调用select（）时，由内核根据IO状态修改fdset的内容，由此来通知执行了select（）的进程哪个句柄可读。select使用
　　整个select流程图如下：
　　Demo1：select示例Serverincludestdio。hincludestdlib。hincludeerrno。hincludestring。hincludesystypes。hincludenetinetin。hincludesyssocket。hincludesyswait。hincludeunistd。hincludeincludesystime。hincludesystypes。hdefineMAXBUF1024defineLISTENNUM2intmain（intargc，charargv）｛intdefaultport8000；intoptch0；while（（optchgetopt（argc，argv，s：p：））！1）｛switch（optch）｛casep：defaultportatoi（optarg）；printf（port：s，optarg）；break；case？：printf（Unknownoption：c，（char）optopt）；break；default：break；｝｝intsockfd，newfd；socklentlen；structsockaddrinmyaddr，theiraddr；charbuf〔MAXBUF1〕；fdsetrfds；selectstructtimevaltv；超时时间intretval，maxfd1；select返回值select监听句柄的最大数量if（（sockfdsocket（PFINET，SOCKSTREAM，0））1）｛perror（socket）；exit（EXITFAILURE）；｝bzero（myaddr，sizeof（myaddr））；myaddr。sinfamilyPFINET；myaddr。sinporthtons（defaultport）；myaddr。sinaddr。saddrINADDRANY；if（bind（sockfd，（structsockaddr）myaddr，sizeof（structsockaddr））1）｛perror（bind）；exit（EXITFAILURE）；｝if（listen（sockfd，LISTENNUM）1）｛perror（listen）；exit（EXITFAILURE）；｝数据处理while（1）｛printf（waitfornewconnectport：d，defaultport）；lensizeof（structsockaddr）；if（（newfdaccept（sockfd，（structsockaddr）theiraddr，len））1）｛perror（accept）；exit（errno）；｝elseprintf（server：gotconnectionfroms，portd，socketd，inetntoa（theiraddr。sinaddr），ntohs（theiraddr。sinport），newfd）；while（1）｛FDZERO（rfds）；FDSET（0，rfds）；FDSET（newfd，rfds）；maxfdnewfd；tv。tvsec1；tv。tvusec0；retvalselect（maxfd1，rfds，NULL，NULL，tv）；if（retval1）｛perror（select）；exit（EXITFAILURE）；｝elseif（retval0）｛continue；｝else｛标准输入if（FDISSET（0，rfds））｛bzero（buf，MAXBUF1）；fgets（buf，MAXBUF，stdin）；if（！strncasecmp（buf，quit，4））｛printf（iwillquit！）；break；｝lensend（newfd，buf，strlen（buf）1，0）；if（len0）printf（sendsuccessful，dbytesend。。，len）；else｛printf（sendfailure！）；break；｝｝if（FDISSET（newfd，rfds））｛bzero（buf，MAXBUF1）；lenrecv（newfd，buf，MAXBUF，0）；if（len0）printf（recvsuccess：s，dbyterecv。。，buf，len）；else｛if（len0）printf（recvfailure）；else｛printf（theclientclose，quit）；break；｝｝｝｝｝close（newfd）；printf（needotheconnecdt（noquit））；fflush（stdout）；bzero（buf，MAXBUF1）；fgets（buf，MAXBUF，stdin）；if（！strncasecmp（buf，no，2））｛printf（quit！）；break；｝｝close（sockfd）；return0；｝
　　makefile：TARGETserverSRC（wildcard。cpp。c）OBJ（patsubst。cpp。c，。o，（SRC））DEFSCFLAGSgCCgLIBSlpthread（TARGET）：（OBJ）（CC）（CFLAGS）（DEFS）o（LIBS）。PHONY：clean：rmrf。o（TARGET）ubuntuVM165ubuntu：learnbaseIO复用selectmakeggoserverselect。clpthreadubuntuVM165ubuntu：learnbaseIO复用select。serverwaitfornewconnectport：8000clientincludestdio。hincludestring。hincludeerrno。hincludesyssocket。hincluderesolv。hincludestdlib。hincludenetinetin。hincludeincludeunistd。hincludesystime。hincludesystypes。hdefineMAXBUF1024intmain（intargc，charargv）｛intsockfd，len；structsockaddrindest；charbuffer〔MAXBUF1〕；fdsetrfds；structtimevaltv；intretval，maxfd1；intoptch，ret1；constcharserveraddr；intdefaultport8000；判断是否为合法输入必须传入一个参数：服务器Ipif（argc3）｛printf（usage：tcpcliIPaddress）；return0；｝while（（optchgetopt（argc，argv，s：p：））！1）｛switch（optch）｛cases：serveraddroptarg；break；casep：defaultportatoi（optarg）；printf（port：s，optarg）；break；case？：printf（Unknownoption：c，（char）optopt）；break；default：break；｝｝if（（sockfdsocket（AFINET，SOCKSTREAM，0））0）｛perror（Socket）；exit（EXITFAILURE）；｝bzero（dest，sizeof（dest））；dest。sinfamilyAFINET；dest。sinporthtons（defaultport）；if（inetaton（serveraddr，（structinaddr）dest。sinaddr。saddr）0）｛perror（serveraddr）；exit（EXITFAILURE）；｝if（connect（sockfd，（structsockaddr）dest，sizeof（dest））！0）｛perror（Connect）；exit（EXITFAILURE）；｝printf（getreadymessagechat：）；while（1）｛FDZERO（rfds）；FDSET（0，rfds）；FDSET（sockfd，rfds）；maxfdsockfd；tv。tvsec1；tv。tvusec0；retvalselect（maxfd1，rfds，NULL，NULL，tv）；if（retval1）｛printf（selects，strerror（errno））；break；｝elseif（retval0）continue；else｛if（FDISSET（sockfd，rfds））｛bzero（buffer，MAXBUF1）；lenrecv（sockfd，buffer，MAXBUF，0）；if（len0）printf（recvmessage：s，dbyterecv。。，buffer，len）；else｛if（len0）printf（messagerecvfailure）；else｛printf（serverclose，quit）；break；｝｝｝if（FDISSET（0，rfds））｛bzero（buffer，MAXBUF1）；fgets（buffer，MAXBUF，stdin）；if（！strncasecmp（buffer，quit，4））｛printf（iwillquit）；break；｝lensend（sockfd，buffer，strlen（buffer）1，0）；if（len0）｛printf（messagesendfailure）；break；｝elseprintf（sendsuccess，dbytesend。。，len）；｝｝｝close（sockfd）；return0；｝TARGETserverSRC（wildcard。cpp。c）OBJ（patsubst。cpp。c，。o，（SRC））DEFSCFLAGSgCCgLIBSlpthread（TARGET）：（OBJ）（CC）（CFLAGS）（DEFS）o（LIBS）。PHONY：clean：rmrf。o（TARGET）ubuntuVM165ubuntu：learnbaseIO复用selectclientmakeggoclientclient。clpthreadubuntuVM165ubuntu：learnbaseIO复用selectclient。clients0。0。0。0getreadymessagechat：简易聊天室select版本serverincludestdio。hincludesystypes。hincludestdlib。hincludesyssocket。hincludesysselect。hincludenetinetin。hincludeincludeunistd。hincludestring。hdefineBACKLOG5监听队列里允许等待的最大值defineMAXCONNECT20intfds〔MAXCONNECT〕；用来存放需要处理的IO事件intlistensock1；intcreatsock（intport）｛intsocksocket（AFINET，SOCKSTREAM，0）；if（sock0）｛perror（creatsockerror）；exit（1）；｝structsockaddrinlocal；local。sinfamilyAFINET；local。sinporthtons（port）；local。sinaddr。saddrINADDRANY；inetaddr（0。0。0。0）设置允许socket立即重用setsockopt（sock，SOLSOCKET，SOREUSEADDR，（constchar）sock，sizeof（sock））；if（bind（sock，（structsockaddr）local，sizeof（local））0）｛perror（bind）；exit（2）；｝if（listen（sock，BACKLOG）0）｛perror（listen）；exit（4）；｝returnsock；｝intacceptsock（）｛structsockaddrinclient；socklentlensizeof（client）；intacceptsockaccept（listensock，（structsockaddr）client，len）；if（acceptsock0）｛perror（accept）；exit（5）；｝printf（connectbyaclient，ip：sport：d，inetntoa（client。sinaddr），ntohs（client。sinport））；sizeti0；for（；iMAXCONNECT；i）将新接受的描述符存入集合中｛if（fds〔i〕1）｛fds〔i〕acceptsock；break；｝｝if（iMAXCONNECT）｛printf（acceptisupperlimit。。）；close（acceptsock）；｝｝intgroupChat（intsockFd，voidpBuf，intiSize）｛for（intindex0；indexMAXCONNECT；index）｛if（fds〔index〕sockFdfds〔index〕listensock）｛continue；｝if（fds〔index〕！1）｛printf（writefd：d。。socketFd：d，fds〔index〕，sockFd）；write（fds〔index〕，pBuf，iSize）；｝｝｝inthandleread（intsocketFd）｛intsocketsocketFd；charbuf〔1024〕；memset（buf，，sizeof（buf））；ssizetsizeread（socket，buf，sizeof（buf）1）；if（size0）｛perror（read）；exit（6）；｝elseif（size0）｛printf（clientclose。。）；close（socket）；socketFd1；｝else｛printf（clientsay：s，buf）；groupChat（socket，buf，size）；｝｝intmain（intargc，charargv〔〕）｛intdefaultport8000；intoptch0；while（（optchgetopt（argc，argv，s：p：））！1）｛switch（optch）｛casep：defaultportatoi（optarg）；printf（port：s，optarg）；break；case？：printf（Unknownoption：c，（char）optopt）；break；default：break；｝｝listensockcreatsock（defaultport）；sizetfdsnumsizeof（fds）sizeof（fds〔0〕）；sizeti0；for（；ifdsnum；i）｛fds〔i〕1；｝intmaxfdlistensock；fds〔0〕listensock；fdsetrset；while（1）｛FDZERO（rset）；FDSET（listensock，rset）；structtimevaltimeout｛10，0｝；sizeti0；for（；ifdsnum；i）｛if（fds〔i〕0）｛FDSET（fds〔i〕，rset）；if（maxfdfds〔i〕）｛maxfdfds〔i〕；｝｝｝switch（select（maxfd1，rset，NULL，NULL，timeout））｛case1：perror（select）；break；case0：printf（timeout。。）；break；default：｛sizeti0；for（；ifdsnum；i）｛连接请求当为listensocket事件就绪的时候，就表明有新的连接请求if（FDISSET（fds〔i〕，rset）fds〔i〕listensock）｛acceptsock（）；｝普通请求elseif（FDISSET（fds〔i〕，rset）（fds〔i〕0））｛handleread（fds〔i〕）；｝else｛｝｝｝break；｝｝return0；｝
　　makfeileTARGETserverSRC（wildcard。cpp。c）OBJ（patsubst。cpp。c，。o，（SRC））DEFSCFLAGSgCCgLIBSlpthread（TARGET）：（OBJ）（CC）（CFLAGS）（DEFS）o（LIBS）。PHONY：clean：rmrf。o（TARGET）ubuntuVM165ubuntu：learnbaseIO复用selectmakeggoserverselect。clpthreadubuntuVM165ubuntu：learnbaseIO复用select。serverconnectbyaclient，ip：127。0。0。1port：42964clientincludestdio。hincludestring。hincludeerrno。hincludesyssocket。hincluderesolv。hincludestdlib。hincludenetinetin。hincludeincludeunistd。hincludesystime。hincludesystypes。hdefineMAXBUF1024defineMAXNAME64intmain（intargc，charargv）｛intsockfd，len；structsockaddrindest；charbuffer〔MAXBUF1〕；fdsetrfds；structtimevaltv；intretval，maxfd1；intoptch，ret1；constcharserveraddr；intdefaultport8000；charclientName佚名；判断是否为合法输入必须传入一个参数：服务器Ipif（argc3）｛printf（usage：tcpcliIPaddress）；return0；｝while（（optchgetopt（argc，argv，s：p：n：））！1）｛switch（optch）｛cases：serveraddroptarg；break；casep：defaultportatoi（optarg）；printf（port：s，optarg）；break；casen：clientNameoptarg；printf（clientName：s，optarg）；break；case？：printf（Unknownoption：c，（char）optopt）；break；default：break；｝｝if（（sockfdsocket（AFINET，SOCKSTREAM，0））0）｛perror（Socket）；exit（EXITFAILURE）；｝bzero（dest，sizeof（dest））；dest。sinfamilyAFINET；dest。sinporthtons（defaultport）；if（inetaton（serveraddr，（structinaddr）dest。sinaddr。saddr）0）｛perror（serveraddr）；exit（EXITFAILURE）；｝if（connect（sockfd，（structsockaddr）dest，sizeof（dest））！0）｛perror（Connect）；exit（EXITFAILURE）；｝printf（getreadymessagechat：）；while（1）｛FDZERO（rfds）；FDSET（0，rfds）；FDSET（sockfd，rfds）；maxfdsockfd；tv。tvsec1；tv。tvusec0；retvalselect（maxfd1，rfds，NULL，NULL，tv）；if（retval1）｛printf（selects，strerror（errno））；break；｝elseif（retval0）continue；else｛if（FDISSET（sockfd，rfds））｛bzero（buffer，MAXBUF1）；lenrecv（sockfd，buffer，MAXBUF，0）；if（len0）printf（recvbyted，s，len，buffer）；else｛if（len0）printf（messagerecvfailure）；else｛printf（serverclose，quit）；break；｝｝｝if（FDISSET（0，rfds））｛charnamemsg〔MAXNAMEMAXBUF〕；bzero（buffer，MAXBUF1）；fgets（buffer，MAXBUF，stdin）；if（！strncasecmp（buffer，quit，4））｛printf（iwillquit）；break；｝sprintf（namemsg，〔s〕：s，clientName，buffer）；lensend（sockfd，namemsg，strlen（namemsg）1，0）；if（len0）｛printf（messagesendfailure）；break；｝elseprintf（sendsuccess，dbytesend。。，len）；｝｝｝close（sockfd）；return0；｝
　　makefileTARGETserverSRC（wildcard。cpp。c）OBJ（patsubst。cpp。c，。o，（SRC））DEFSCFLAGSgCCgLIBSlpthread（TARGET）：（OBJ）（CC）（CFLAGS）（DEFS）o（LIBS）。PHONY：clean：rmrf。o（TARGET）ubuntuVM165ubuntu：learnbaseIO复用selectclient。clients0。0。0。0n梦凡clientName：梦凡getreadymessagechat：poll调用
　　Poll就是监控文件是否可读的一种机制，作用与select一样。includepoll。hintpoll（structpollfdfds〔〕，nfdstnfds，inttimeout）；
　　参数说明structpollfd
　　fds：是一个structpollfd结构类型的数组，列出了我们需要poll（）检查的文件描述符typedefstructpollfd｛intfd；需要被检测或选择的文件描述符shortevents；对文件描述符fd上感兴趣的事件shortrevents；文件描述符fd上当前实际发生的事件｝pollfdt；
　　events：想要监听的事件
　　revents：实际上发生的事件POLLINPOLLOUTPOLLPRIPOLLRDHUBPOLLHUPPOLLERRnfds
　　指定了fds中元素的个数，nfdst为无符号整形timeout
　　决定阻塞行为，一般如下：1：一直阻塞到fds数组中有一个达到就绪态或者捕获到一个信号0：不会阻塞，立即返回0：阻塞时间返回值0：数组fds中准备好读、写或出错状态的那些socket描述符的总数量；0：数组fds中没有任何socket描述符准备好读、写，或出错；此时poll超时1：poll函数调用失败poll使用includestdio。hincludepoll。hincludestring。hintmain（）｛inttimeout0；charbuf〔1024〕；structpollfdfdpoll〔1〕；设置只有一个事件while（1）｛fdpoll〔0〕。fd0；fdpoll〔0〕。eventsPOLLIN；fdpoll〔0〕。revents0；memset（buf，，sizeof（buf））；switch（poll（fdpoll，1，1））｛case0：perror（timeout！）；break；case1：perror（poll）；break；default：｛if（fdpoll〔0〕。reventsPOLLIN）｛gets（buf）；printf（buf：s，buf）；｝｝break；｝｝return0；｝
　　makefiletcppoll：tcppoll。cgcco。PHONY：cleanclean：rmftcppollepoll调用
　　epoll没有对描述符数目的限制，它所支持的文件描述符上限是整个系统最大可以打开的文件数目，例如，在1GB内存的机器上，这个限制大概为10万左右。
　　epoll只有epollcreate、epollctl和epollwait这三个系统调用。
　　第一步，创建一个epoll句柄
　　第二步，向内核添加、修改或删除要监控的文件描述符。
　　第三步，发起了select（）调用
　　其定义如下：includesysepoll。hintepollcreate（intsize）；intepollctl（intepfd，intop，intfd，structepolleventevent）；intepollwait（intepfd，structepolleventevents，intmaxevents，inttimeout）；epollcreateincludesysepoll。hintepollcreate（intsize）；
　　调用epollcreate方法创建一个epoll的句柄，使用完epoll后使用close函数进行关闭epollctlincludesysepoll。hintepollctl（intepfd第一个参数epfd：epollcreate函数的返回值。，intop第二个参数events：表示动作类型。有三个宏来表示，intfd第三个参数fd：需要监听的fd。，structepolleventevent）；第四个参数event：告诉内核需要监听什么事件。
　　op：EPOLLCTLADD：注册新的fd到epfd中；EPOLLCTLMOD：修改已经注册的fd的监听事件；EPOLLCTLDEL：从epfd中删除一个fd。
　　fd：需要注册监视对象文件描述符structepollevent感兴趣的事件和被触发的事件structepollevent｛uint32tevents；Epolleventsepolldatatdata；Userdatavariable｝；保存触发事件的某个文件描述符相关的数据typedefunionepolldata｛voidptr；intfd；uint32tu32；uint64tu64；｝epolldatat；EpollEvents：
　　EPOLLIN：表示对应的文件描述符可读（包括对端Socket）；
　　EPOLLOUT：表示对应的文件描述符可写；
　　EPOLLPRI：表示对应的文件描述符有紧急数据可读（带外数据）；
　　EPOLLERR：表示对应的文件描述符发生错误；
　　EPOLLHUP：表示对应的文件描述符被挂断；
　　EPOLLET：将EPOLL设为边缘触发（EdgeTriggered），这是相对于水平触发（LevelTriggered）而言的。
　　EPOLLONESHOT：只监听一次事件，当监听完这次事件之后，如果还需要继续监听这个socket，需要再次添加
　　例如：structepolleventepev；intacceptsockaccept（listensock，（structsockaddr）remote，len）；epev。eventsEPOLLINEPOLLET；epev。data。fdacceptsock；epollctl（epollfd，EPOLLCTLADD，acceptsock，epev）epollwait
　　收集在epoll监控的事件中已经发生的事件includesysepoll。hintepollwait（intepfd第一个参数epfd：epollcreate函数的返回值。，structepolleventevents，intmaxevents，inttimeout）；超时时间（毫秒）
　　第一个参数epfd：epollcreate函数的返回值。
　　第二个参数events：是分配好的epollevent结构体数组，epoll将会把发生的事件赋值到events数组中（events不可以是空指针，内核只负责把数据赋值到这个event数组中，不会去帮助我们在用户态分配内存）
　　第三个参数maxevents：maxevents告诉内核这个events数组有多大，这个maxevents的值不能大于创建epollcreate时的size。
　　第四个参数：是超时时间（毫秒），如果函数调用成功，则返回对应IO上已准备好的文件描述符数目，如果返回0则表示已经超时。基于epoll的简易http服务器
　　基于epoll的简单回显服务器includestdio。hincludeunistd。hincludesystypes。hincludesyssocket。hincludenetinetin。hincludeincludesysepoll。hincludefcntl。hincludestdlib。hincludestring。hintlistensock1；intepollfd1；设置非阻塞intsetnoblock（intsock）｛intoptsfcntl（sock，FGETFL）；returnfcntl（sock，FSETFL，optsONONBLOCK）；｝intcreatsocket（intport）｛intsocksocket（AFINET，SOCKSTREAM，0）；if（sock0）｛perror（socket）；exit（2）；｝调用setsockopt使当server先断开时避免进入TIMEWAIT状态，将其属性设定为SOREUSEADDR，使其地址信息可被重用intopt1；if（setsockopt（sock，SOLSOCKET，SOREUSEADDR，opt，sizeof（opt））0）｛perror（setsockopt）；exit（3）；｝structsockaddrinlocal；local。sinfamilyAFINET；local。sinporthtons（port）；local。sinaddr。saddrINADDRANY；inetaddr（0。0。0。0）；if（bind（sock，（structsockaddr）local，sizeof（local））0）｛perror（bind）；exit（4）；｝if（listen（sock，5）0）｛perror（listen）；exit（5）；｝printf（listenportd。。，port）；returnsock；｝intacceptsocket（）｛structsockaddrinremote；socklentlensizeof（remote）；intacceptsockaccept（listensock，（structsockaddr）remote，len）；if（acceptsock0）｛perror（accept）；return1；｝printf（acceptaclient。。〔ip〕：s，〔port〕：d，inetntoa（remote。sinaddr），ntohs（remote。sinport））；将新的事件添加到epoll集合中structepolleventepev；epev。eventsEPOLLINEPOLLET；edge边沿触发，只触发一次epev。data。fdacceptsock；setnoblock（acceptsock）；if（epollctl（epollfd，EPOLLCTLADD，acceptsock，epev）0）｛perror（epollctl）；close（acceptsock）；return1；｝return0；｝inthandlerequest（intsocketFd）｛申请空间同时存文件描述符和缓冲区地址charbuf〔102400〕；memset（buf，，sizeof（buf））；ssizetsrecv（socketFd，buf，sizeof（buf）1，0）；if（s0）｛perror（recv）；return1；｝elseif（s0）｛printf（remoteclose。。）；远端关闭了，进行善后epollctl（epollfd，EPOLLCTLDEL，socketFd，NULL）；close（socketFd）；｝else｛读取成功，输出数据printf（clients，buf）；fflush（stdout）；将事件改写为关心事件，进行回写structepolleventepev；epev。data。fdsocketFd；epev。eventsEPOLLOUTEPOLLET；在epoll实例中更改同一个事件，触发socket可写事件epollctl（epollfd，EPOLLCTLMOD，socketFd，epev）；｝return0；｝inthandleresponse（intsocketFd）｛constcharmsgHTTP1。1200OKrrh1higirlh1r；send（socketFd，msg，strlen（msg），0）；epollctl（epollfd，EPOLLCTLDEL，socketFd，NULL）；close（socketFd）；｝intmain（intargc，charargv〔〕）｛intdefaultport8000；intoptch0；while（（optchgetopt（argc，argv，s：p：））！1）｛switch（optch）｛casep：defaultportatoi（optarg）；printf（port：s，optarg）；break；case？：printf（Unknownoption：c，（char）optopt）；break；default：break；｝｝listensockcreatsocket（defaultport）；epollfdepollcreate（256）；if（epollfd0）｛perror（epollcreat）；exit（6）；｝structepolleventepev；epev。eventsEPOLLIN；数据的读取epev。data。fdlistensock；添加关心的事件if（epollctl（epollfd，EPOLLCTLADD，listensock，epev）0）｛perror（epollctl）；exit（7）；｝structepolleventreadyev〔128〕；申请空间来放就绪的事件。intmaxnum128；inttimeout1；设置超时时间，若为1，则永久阻塞等待。intret0；intdone0；while（！done）｛switch（retepollwait（epollfd，readyev，maxnum，timeout））｛case1：perror（epollwait）；break；case0：printf（timeout。。。）；break；default：至少有一个事件就绪｛inti0；for（；iret；i）｛判断是否为监听套接字，是的话acceptintfdreadyev〔i〕。data。fd；if（（fdlistensock）（readyev〔i〕。eventsEPOLLIN））｛acceptsocket（）；｝else｛普通IOif（readyev〔i〕。eventsEPOLLIN）｛handlerequest（fd）；｝elseif（readyev〔i〕。eventsEPOLLOUT）｛handleresponse（fd）；｝｝｝｝break；｝｝close（listensock）；return0；｝
　　makefileTARGETserverSRC（wildcard。cpp。c）OBJ（patsubst。cpp。c，。o，（SRC））DEFSCFLAGSgCCgLIBSlpthread（TARGET）：（OBJ）（CC）（CFLAGS）（DEFS）o（LIBS）。PHONY：clean：rmrf。o（TARGET）复制BuildmakeUsageubuntuVM165ubuntu：learnbaseIO复用epoll。serverlistenport8000
　　浏览器输入：http：服务器ip：8000例如，http：49。234。35。128：8000
　　原文链接：https：www。cnblogs。comderoyp15700636。html