UNIX环境高级编程：epoll函数使用详解

可以得出这样的结论:

ET模式仅当状态发生变化的时候才获得通知,这里所谓的状态的变化并不包括缓冲区中还有未处理的数据,也就是说,如果要采用ET模式,需要一直read/write直到出错为止,很多人反映为什么采用ET模式只接收了一部分数据就再也得不到通知了,大多因为这样;而LT模式是只要有数据没有处理就会一直通知下去的.

那么究竟如何来使用epoll呢？其实非常简单。

通过在包含一个头文件#include <sys/epoll.h> 以及几个简单的API将可以大大的提高你的网络服务器的支持人数。

首先通过create_epoll(int maxfds)来创建一个epoll的句柄，其中maxfds为你epoll所支持的最大句柄数。这个函数会返回一个新的epoll句柄，之后的所有操作将通过这个句柄来进行操作。在用完之后，记得用close()来关闭这个创建出来的epoll句柄。

之后在你的网络主循环里面，每一帧的调用epoll_wait(int epfd, epoll_event events, int max events, int timeout)来查询所有的网络接口，看哪一个可以读，哪一个可以写了。基本的语法为：

nfds = epoll_wait(kdpfd, events, maxevents, -1);

其中kdpfd为用epoll_create创建之后的句柄，events是一个epoll_event*的指针，当epoll_wait这个函数操作成功之后，epoll_events里面将储存所有的读写事件。max_events是当前需要监听的所有socket句柄数。最后一个timeout是 epoll_wait的超时，为0的时候表示马上返回，为-1的时候表示一直等下去，直到有事件范围，为任意正整数的时候表示等这么长的时间，如果一直没有事件，则范围。一般如果网络主循环是单独的线程的话，可以用-1来等，这样可以保证一些效率，如果是和主逻辑在同一个线程的话，则可以用0来保证主循环的效率。

epoll_wait范围之后应该是一个循环，遍利所有的事件。

几乎所有的epoll程序都使用下面的框架：

for( ; ; )  
 {  
     nfds = epoll_wait(epfd,events,20,500);  
     for(i=0;i<nfds;++i)  
     {  
         if(events[i].data.fd==listenfd) //有新的连接  
         {  
             connfd = accept(listenfd,(sockaddr *)&clientaddr, &clilen); //accept这个连接  
             ev.data.fd=connfd;  
             ev.events=EPOLLIN|EPOLLET;  
             epoll_ctl(epfd,EPOLL_CTL_ADD,connfd,&ev); //将新的fd添加到epoll的监听队列中  
         }  
         else if( events[i].events&EPOLLIN ) //接收到数据，读socket  
         {  
             n = read(sockfd, line, MAXLINE)) < 0    //读  
             ev.data.ptr = md;     //md为自定义类型，添加数据  
             ev.events=EPOLLOUT|EPOLLET;  
             epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev);//修改标识符，等待下一个循环时发送数据，异步处理的精髓  
         }  
         else if(events[i].events&EPOLLOUT) //有数据待发送，写socket  
         {  
             struct myepoll_data* md = (myepoll_data*)events[i].data.ptr;    //取数据  
             sockfd = md->fd;  
             send( sockfd, md->ptr, strlen((char*)md->ptr), 0 );        //发送数据  
             ev.data.fd=sockfd;  
             ev.events=EPOLLIN|EPOLLET;  
             epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev); //修改标识符，等待下一个循环时接收数据  
         }  
         else
         {  
             //其他的处理  
         }  
     }  
 }

查看本栏目更多精彩内容：http://www.bianceng.cn/OS/unix/

（编辑：济南站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!