什么是epoll

蔚落 2022-08-04 05:28 146阅读 0赞

核心：1.原理 2.函数使用 3.timeout 4.错误码 5.close,shudown 6. epoll操作线程安全问题 7.参数设置

## 什么是epoll ##

epoll是什么？按照man手册的说法：是为处理大批量句柄而作了改进的poll。当然，这不是2.6内核才有的，它是在2.5.44内核中被引进的(epoll(4) is a new API introduced in Linux kernel 2.5.44)，它几乎具备了之前所说的一切优点，被公认为Linux2.6下性能最好的多路I/O就绪通知方法。

## **epoll的相关系统调用** ##

epoll只有epoll\_create,epoll\_ctl,epoll\_wait 3个系统调用。

**1. int epoll\_create(int size);**

创建一个epoll的句柄。自从linux2.6.8之后，size参数是被忽略的。需要注意的是，当创建好epoll句柄后，它就是会占用一个fd值，在linux下如果查看/proc/进程id/fd/，是能够看到这个fd的，所以在使用完epoll后，必须调用close()关闭，否则可能导致fd被耗尽。

**2. int epoll\_ctl(int epfd, int op, int fd, struct epoll\_event \*event);**

epoll的**事件注册函数**，它不同于select()是在监听事件时告诉内核要监听什么类型的事件，而是在这里先注册要监听的事件类型。

第一个参数是epoll\_create()的返回值。

第二个参数表示动作，用三个宏来表示：

EPOLL\_CTL\_ADD：注册新的fd到epfd中；

EPOLL\_CTL\_MOD：修改已经注册的fd的监听事件；

EPOLL\_CTL\_DEL：从epfd中删除一个fd；

第三个参数是需要监听的fd。

第四个参数是告诉内核需要监听什么事，struct epoll\_event结构如下：

events可以是以下几个宏的集合：

EPOLLIN ：表示对应的文件描述符可以读（包括对端SOCKET正常关闭）；

EPOLLOUT：表示对应的文件描述符可以写；

EPOLLPRI：表示对应的文件描述符有紧急的数据可读（这里应该表示有带外数据到来）；

EPOLLERR：表示对应的文件描述符发生错误；

EPOLLHUP：表示对应的文件描述符被挂断；

EPOLLET： 将EPOLL设为边缘触发(Edge Triggered)模式，这是相对于水平触发(Level Triggered)来说的。

EPOLLONESHOT：只监听一次事件，当监听完这次事件之后，如果还需要继续监听这个socket的话，需要再次把这个socket加入到EPOLL队列里

EPOLLRDHUP： 2.6.17 版本内核中增加了 EPOLLRDHUP 事件，代表对端断开连接，对端调用close

**3. int epoll\_wait(int epfd, struct epoll\_event \* events, int maxevents, int timeout);**

收集在epoll监控的事件中已经发送的事件。参数events是分配好的epoll\_event结构体数组，epoll将会把发生的事件赋值到events数组中（events不可以是空指针，内核只负责把数据复制到这个events数组中，不会去帮助我们在用户态中分配内存）。maxevents告之内核这个events有多大，这个 maxevents的值不能大于创建epoll\_create()时的size，参数timeout是超时时间（毫秒，0会立即返回，-1将不确定，也有说法说是永久阻塞）。如果函数调用成功，返回对应I/O上已准备好的文件描述符数目，如返回0表示已超时。

## **epoll工作原理** ##

epoll同样只告知那些就绪的文件描述符，而且当我们调用epoll\_wait()获得就绪文件描述符时，返回的不是实际的描述符，而是一个代表就绪描述符数量的值，你只需要去epoll指定的一个数组中依次取得相应数量的文件描述符即可，这里也使用了内存映射（mmap）技术，这样便彻底省掉了这些文件描述符在系统调用时复制的开销。

另一个本质的改进在于epoll采用基于事件的就绪通知方式。在select/poll中，进程只有在调用一定的方法后，内核才对所有监视的文件描述符进行扫描，而epoll事先通过epoll\_ctl()来注册一个文件描述符，一旦基于某个文件描述符就绪时，内核会采用类似callback的回调机制，迅速激活这个文件描述符，当进程调用epoll\_wait()时便得到通知。

**Epoll的2种工作方式\-水平触发（LT）和边缘触发（ET）**

假如有这样一个例子：

1. 我们已经把一个用来从管道中读取数据的文件句柄(RFD)添加到epoll描述符

2. 这个时候从管道的另一端被写入了2KB的数据

3. 调用epoll\_wait(2)，并且它会返回RFD，说明它已经准备好读取操作

4. 然后我们读取了1KB的数据

5. 调用epoll\_wait(2)......

Edge Triggered 工作模式：

如果我们在第1步将RFD添加到epoll描述符的时候使用了EPOLLET标志，那么在第5步调用epoll\_wait(2)之后将有可能会挂起，因为剩余的数据还存在于文件的输入缓冲区内，而且数据发出端还在等待一个针对已经发出数据的反馈信息。只有在监视的文件句柄上发生了某个事件的时候 ET 工作模式才会汇报事件。因此在第5步的时候，调用者可能会放弃等待仍在存在于文件输入缓冲区内的剩余数据。在上面的例子中，会有一个事件产生在RFD句柄上，因为在第2步执行了一个写操作，然后，事件将会在第3步被销毁。因为第4步的读取操作没有读空文件输入缓冲区内的数据，因此我们在第5步调用 epoll\_wait(2)完成后，是否挂起是不确定的。epoll工作在ET模式的时候，必须使用非阻塞套接口，以避免由于一个文件句柄的阻塞读/阻塞写操作把处理多个文件描述符的任务饿死。最好以下面的方式调用ET模式的epoll接口，在后面会介绍避免可能的缺陷。

i    基于非阻塞文件句柄

ii   只有当read(2)或者write(2)返回EAGAIN时才需要挂起，等待。但这并不是说每次read()时都需要循环读，直到读到产生一个EAGAIN才认为此次事件处理完成，当read()返回的读到的数据长度小于请求的数据长度时，就可以确定此时缓冲中已没有数据了，也就可以认为此事读事件已处理完成。

Level Triggered 工作模式

相反的，以LT方式调用epoll接口的时候，它就相当于一个速度比较快的poll(2)，并且无论后面的数据是否被使用，因此他们具有同样的职能。因为即使使用ET模式的epoll，在收到多个chunk的数据的时候仍然会产生多个事件。调用者可以设定EPOLLONESHOT标志，在 epoll\_wait(2)收到事件后epoll会与事件关联的文件句柄从epoll描述符中禁止掉。因此当EPOLLONESHOT设定后，使用带有 EPOLL\_CTL\_MOD标志的epoll\_ctl(2)处理文件句柄就成为调用者必须作的事情。

LT(level triggered)是epoll**缺省的工作方式**，并且同时支持block和no-block socket.在这种做法中，内核告诉你一个文件描述符是否就绪了，然后你可以对这个就绪的fd进行IO操作。如果你不作任何操作，内核还是会继续通知你 的，所以，这种模式编程出错误可能性要小一点。传统的select/poll都是这种模型的代表．

ET (edge-triggered)是高速工作方式，只支持no-block socket，它效率要比LT更高。ET与LT的区别在于，当一个新的事件到来时，ET模式下当然可以从epoll\_wait调用中获取到这个事件，可是如果这次没有把这个事件对应的套接字缓冲区处理完，在这个套接字中没有新的事件再次到来时，在ET模式下是无法再次从epoll\_wait调用中获取这个事件的。而LT模式正好相反，只要一个事件对应的套接字缓冲区还有数据，就总能从epoll\_wait中获取这个事件。

因此，LT模式下开发基于epoll的应用要简单些，不太容易出错。而在ET模式下事件发生时，如果没有彻底地将缓冲区数据处理完，则会导致缓冲区中的用户请求得不到响应。

图示说明：

![Center][]

Nginx默认采用ET模式来使用epoll。

## **epoll的优点：** ##

**1.支持一个进程打开大数目的socket描述符(FD)**

select 最不能忍受的是一个进程所打开的FD是有一定限制的，由FD\_SETSIZE设置，默认值是2048。对于那些需要支持的上万连接数目的IM服务器来说显然太少了。这时候你一是可以选择修改这个宏然后重新编译内核，不过资料也同时指出这样会带来网络效率的下降，二是可以选择多进程的解决方案(传统的 Apache方案)，不过虽然linux上面创建进程的代价比较小，但仍旧是不可忽视的，加上进程间数据同步远比不上线程间同步的高效，所以也不是一种完美的方案。不过 epoll则没有这个限制，它所支持的FD上限是最大可以打开文件的数目，这个数字一般远大于2048,举个例子,在1GB内存的机器上大约是10万左右，具体数目可以cat /proc/sys/fs/file-max察看,一般来说这个数目和系统内存关系很大。

**2.IO效率不随FD数目增加而线性下降**

传统的select/poll另一个致命弱点就是当你拥有一个很大的socket集合，不过由于网络延时，任一时间只有部分的socket是"活跃"的，但是select/poll每次调用都会线性扫描全部的集合，导致效率呈现线性下降。但是epoll不存在这个问题，它只会对"活跃"的socket进行操作\---这是因为在内核实现中epoll是根据每个fd上面的callback函数实现的。那么，只有"活跃"的socket才会主动的去调用 callback函数，其他idle状态socket则不会，在这点上，epoll实现了一个"伪"AIO，因为这时候推动力在os内核。在一些 benchmark中，如果所有的socket基本上都是活跃的---比如一个高速LAN环境，epoll并不比select/poll有什么效率，相反，如果过多使用epoll\_ctl,效率相比还有稍微的下降。但是一旦使用idle connections模拟WAN环境,epoll的效率就远在select/poll之上了。

**3.使用mmap加速内核与用户空间的消息传递**

这点实际上涉及到epoll的具体实现了。无论是select,poll还是epoll都需要内核把FD消息通知给用户空间，如何避免不必要的内存拷贝就很重要，在这点上，epoll是通过内核于用户空间mmap同一块内存实现的。而如果你想我一样从2.5内核就关注epoll的话，一定不会忘记手工 mmap这一步的。

**4.内核微调**

这一点其实不算epoll的优点了，而是整个linux平台的优点。也许你可以怀疑linux平台，但是你无法回避linux平台赋予你微调内核的能力。比如，内核TCP/IP协议栈使用内存池管理sk\_buff结构，那么可以在运行时期动态调整这个内存pool(skb\_head\_pool)的大小--- 通过echo XXXX>/proc/sys/net/core/hot\_list\_length完成。再比如listen函数的第2个参数(TCP完成3次握手的数据包队列长度)，也可以根据你平台内存大小动态调整。更甚至在一个数据包面数目巨大但同时每个数据包本身大小却很小的特殊系统上尝试最新的NAPI网卡驱动架构。

## **linux下epoll如何实现高效处理百万句柄的** ##

开发高性能网络程序时，windows开发者们言必称iocp，linux开发者们则言必称epoll。大家都明白epoll是一种IO多路复用技术，可以非常高效的处理数以百万计的socket句柄，比起以前的select和poll效率高大发了。我们用起epoll来都感觉挺爽，确实快，那么，它到底为什么可以高速处理这么多并发连接呢？

使用起来很清晰，首先要调用epoll\_create建立一个epoll对象。参数size是内核保证能够正确处理的最大句柄数，多于这个最大数时内核可不保证效果。

epoll\_ctl可以操作上面建立的epoll，例如，将刚建立的socket加入到epoll中让其监控，或者把 epoll正在监控的某个socket句柄移出epoll，不再监控它等等。

epoll\_wait在调用时，在给定的timeout时间内，当在监控的所有句柄中有事件发生时，就返回用户态的进程。

从上面的调用方式就可以看到epoll比select/poll的优越之处：因为后者每次调用时都要传递你所要监控的所有socket给select/poll系统调用，这意味着需要将用户态的socket列表copy到内核态，如果以万计的句柄会导致每次都要copy几十几百KB的内存到内核态，非常低效。而我们调用epoll\_wait时就相当于以往调用select/poll，但是这时却不用传递socket句柄给内核，因为内核已经在epoll\_ctl中拿到了要监控的句柄列表。

所以，实际上在你调用epoll\_create后，内核就已经在内核态开始准备帮你存储要监控的句柄了，每次调用epoll\_ctl只是在往内核的数据结构里塞入新的socket句柄。

当一个进程调用epoll\_creaqte方法时，Linux内核会创建一个eventpoll结构体，这个结构体中有两个成员与epoll的使用方式密切相关：

每一个epoll对象都有一个独立的eventpoll结构体，这个结构体会在内核空间中创造独立的内存，用于存储使用epoll\_ctl方法向epoll对象中添加进来的事件。这样，重复的事件就可以通过红黑树而高效的识别出来。

此外，epoll还维护了一个双链表，用户存储发生的事件。当epoll\_wait调用时，仅仅观察这个list链表里有没有数据即eptime项即可。有数据就返回，没有数据就sleep，等到timeout时间到后即使链表没数据也返回。所以，epoll\_wait非常高效。

而且，通常情况下即使我们要监控百万计的句柄，大多一次也只返回很少量的准备就绪句柄而已，所以，epoll\_wait仅需要从内核态copy少量的句柄到用户态而已，如何能不高效？！

那么，这个准备就绪list链表是怎么维护的呢？当我们执行epoll\_ctl时，除了把socket放到epoll文件系统里file对象对应的红黑树上之外，还会给内核中断处理程序注册一个回调函数，告诉内核，如果这个句柄的中断到了，就把它放到准备就绪list链表里。所以，当一个socket上有数据到了，内核在把网卡上的数据copy到内核中后就来把socket插入到准备就绪链表里了。

如此，一颗红黑树，一张准备就绪句柄链表，少量的内核cache，就帮我们解决了大并发下的socket处理问题。执行epoll\_create时，创建了红黑树和就绪链表，执行epoll\_ctl时，如果增加socket句柄，则检查在红黑树中是否存在，存在立即返回，不存在则添加到树干上，然后向内核注册回调函数，用于当中断事件来临时向准备就绪链表中插入数据。执行epoll\_wait时立刻返回准备就绪链表里的数据即可。

## **epoll的使用方法** ##

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

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

首先通过create\_epoll(int 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程序都使用下面的框架：

**\[cpp\]** [view plain][][copy][view plain][print][view plain][?][view plain]

1.  **for**( ; ; )  
2.     \{  
3.         nfds = epoll\_wait(epfd,events,20,500);  
4.         **for**(i=0;i<nfds;++i)  
5.         \{  
6.             **if**(events\[i\].data.fd==listenfd) //有新的连接  
7.             \{  
8.                 connfd = accept(listenfd,(sockaddr \*)&clientaddr, &clilen); //accept这个连接  
9.                 ev.data.fd=connfd;  
10.                ev.events=EPOLLIN|EPOLLET;  
11.                epoll\_ctl(epfd,EPOLL\_CTL\_ADD,connfd,&ev); //将新的fd添加到epoll的监听队列中  
12.            \}  
13.   
14.            **else** **if**( events\[i\].events&EPOLLIN ) //接收到数据，读socket  
15.            \{  
16.                n = read(sockfd, line, MAXLINE)) < 0    //读  
17.                ev.data.ptr = md;     //md为自定义类型，添加数据  
18.                ev.events=EPOLLOUT|EPOLLET;  
19.                epoll\_ctl(epfd,EPOLL\_CTL\_MOD,sockfd,&ev);//修改标识符，等待下一个循环时发送数据，异步处理的精髓  
20.            \}  
21.            **else** **if**(events\[i\].events&EPOLLOUT) //有数据待发送，写socket  
22.            \{  
23.                **struct** myepoll\_data\* md = (myepoll\_data\*)events\[i\].data.ptr;    //取数据  
24.                sockfd = md->fd;  
25.                send( sockfd, md->ptr, strlen((**char**\*)md->ptr), 0 );        //发送数据  
26.                ev.data.fd=sockfd;  
27.                ev.events=EPOLLIN|EPOLLET;  
28.                epoll\_ctl(epfd,EPOLL\_CTL\_MOD,sockfd,&ev); //修改标识符，等待下一个循环时接收数据  
29.            \}  
30.            **else**  
31.            \{  
32.                //其他的处理  
33.            \}  
34.        \}  
35.    \}

## epoll的程序实例 ##

1.       #include <stdio.h>  
        #include <stdlib.h>  
        #include <unistd.h>  
        #include <errno.h>  
        #include <sys/socket.h>  
        #include <netdb.h>  
        #include <fcntl.h>  
        #include <sys/epoll.h>  
        #include <string.h>  
          
        #define MAXEVENTS 64  
          
        //函数:  
        //功能:创建和绑定一个TCP socket  
        //参数:端口  
        //返回值:创建的socket  
        static int  
        create_and_bind (char *port)  
        {  
          struct addrinfo hints;  
          struct addrinfo *result, *rp;  
          int s, sfd;  
          
          memset (&hints, 0, sizeof (struct addrinfo));  
          hints.ai_family = AF_UNSPEC;     /* Return IPv4 and IPv6 choices */  
          hints.ai_socktype = SOCK_STREAM; /* We want a TCP socket */  
          hints.ai_flags = AI_PASSIVE;     /* All interfaces */  
          
          s = getaddrinfo (NULL, port, &hints, &result);  
          if (s != 0)  
            {  
              fprintf (stderr, "getaddrinfo: %s\n", gai_strerror (s));  
              return -1;  
            }  
          
          for (rp = result; rp != NULL; rp = rp->ai_next)  
            {  
              sfd = socket (rp->ai_family, rp->ai_socktype, rp->ai_protocol);  
              if (sfd == -1)  
                continue;  
          
              s = bind (sfd, rp->ai_addr, rp->ai_addrlen);  
              if (s == 0)  
                {  
                  /* We managed to bind successfully! */  
                  break;  
                }  
          
              close (sfd);  
            }  
          
          if (rp == NULL)  
            {  
              fprintf (stderr, "Could not bind\n");  
              return -1;  
            }  
          
          freeaddrinfo (result);  
          
          return sfd;  
        }  
          
          
        //函数  
        //功能:设置socket为非阻塞的  
        static int  
        make_socket_non_blocking (int sfd)  
        {  
          int flags, s;  
          
          //得到文件状态标志  
          flags = fcntl (sfd, F_GETFL, 0);  
          if (flags == -1)  
            {  
              perror ("fcntl");  
              return -1;  
            }  
          
          //设置文件状态标志  
          flags |= O_NONBLOCK;  
          s = fcntl (sfd, F_SETFL, flags);  
          if (s == -1)  
            {  
              perror ("fcntl");  
              return -1;  
            }  
          
          return 0;  
        }  
          
        //端口由参数argv[1]指定  
        int  
        main (int argc, char *argv[])  
        {  
          int sfd, s;  
          int efd;  
          struct epoll_event event;  
          struct epoll_event *events;  
          
          if (argc != 2)  
            {  
              fprintf (stderr, "Usage: %s [port]\n", argv[0]);  
              exit (EXIT_FAILURE);  
            }  
          
          sfd = create_and_bind (argv[1]);  
          if (sfd == -1)  
            abort ();  
          
          s = make_socket_non_blocking (sfd);  
          if (s == -1)  
            abort ();  
          
          s = listen (sfd, SOMAXCONN);  
          if (s == -1)  
            {  
              perror ("listen");  
              abort ();  
            }  
          
          //除了参数size被忽略外,此函数和epoll_create完全相同  
          efd = epoll_create1 (0);  
          if (efd == -1)  
            {  
              perror ("epoll_create");  
              abort ();  
            }  
          
          event.data.fd = sfd;  
          event.events = EPOLLIN | EPOLLET;//读入,边缘触发方式  
          s = epoll_ctl (efd, EPOLL_CTL_ADD, sfd, &event);  
          if (s == -1)  
            {  
              perror ("epoll_ctl");  
              abort ();  
            }  
          
          /* Buffer where events are returned */  
          events = calloc (MAXEVENTS, sizeof event);  
          
          /* The event loop */  
          while (1)  
            {  
              int n, i;  
          
              n = epoll_wait (efd, events, MAXEVENTS, -1);  
              for (i = 0; i < n; i++)  
                {  
                  if ((events[i].events & EPOLLERR) ||  
                      (events[i].events & EPOLLHUP) ||  
                      (!(events[i].events & EPOLLIN)))  
                    {  
                      /* An error has occured on this fd, or the socket is not 
                         ready for reading (why were we notified then?) */  
                      fprintf (stderr, "epoll error\n");  
                      close (events[i].data.fd);  
                      continue;  
                    }  
          
                  else if (sfd == events[i].data.fd)  
                    {  
                      /* We have a notification on the listening socket, which 
                         means one or more incoming connections. */  
                      while (1)  
                        {  
                          struct sockaddr in_addr;  
                          socklen_t in_len;  
                          int infd;  
                          char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV];  
          
                          in_len = sizeof in_addr;  
                          infd = accept (sfd, &in_addr, &in_len);  
                          if (infd == -1)  
                            {  
                              if ((errno == EAGAIN) ||  
                                  (errno == EWOULDBLOCK))  
                                {  
                                  /* We have processed all incoming 
                                     connections. */  
                                  break;  
                                }  
                              else  
                                {  
                                  perror ("accept");  
                                  break;  
                                }  
                            }  
          
                                          //将地址转化为主机名或者服务名  
                          s = getnameinfo (&in_addr, in_len,  
                                           hbuf, sizeof hbuf,  
                                           sbuf, sizeof sbuf,  
                                           NI_NUMERICHOST | NI_NUMERICSERV);//flag参数:以数字名返回  
                                          //主机地址和服务地址  
          
                          if (s == 0)  
                            {  
                              printf("Accepted connection on descriptor %d "  
                                     "(host=%s, port=%s)\n", infd, hbuf, sbuf);  
                            }  
          
                          /* Make the incoming socket non-blocking and add it to the 
                             list of fds to monitor. */  
                          s = make_socket_non_blocking (infd);  
                          if (s == -1)  
                            abort ();  
          
                          event.data.fd = infd;  
                          event.events = EPOLLIN | EPOLLET;  
                          s = epoll_ctl (efd, EPOLL_CTL_ADD, infd, &event);  
                          if (s == -1)  
                            {  
                              perror ("epoll_ctl");  
                              abort ();  
                            }  
                        }  
                      continue;  
                    }  
                  else  
                    {  
                      /* We have data on the fd waiting to be read. Read and 
                         display it. We must read whatever data is available 
                         completely, as we are running in edge-triggered mode 
                         and won't get a notification again for the same 
                         data. */  
                      int done = 0;  
          
                      while (1)  
                        {  
                          ssize_t count;  
                          char buf[512];  
          
                          count = read (events[i].data.fd, buf, sizeof(buf));  
                          if (count == -1)  
                            {  
                              /* If errno == EAGAIN, that means we have read all 
                                 data. So go back to the main loop. */  
                              if (errno != EAGAIN)  
                                {  
                                  perror ("read");  
                                  done = 1;  
                                }  
                              break;  
                            }  
                          else if (count == 0)  
                            {  
                              /* End of file. The remote has closed the 
                                 connection. */  
                              done = 1;  
                              break;  
                            }  
          
                          /* Write the buffer to standard output */  
                          s = write (1, buf, count);  
                          if (s == -1)  
                            {  
                              perror ("write");  
                              abort ();  
                            }  
                        }  
          
                      if (done)  
                        {  
                          printf ("Closed connection on descriptor %d\n",  
                                  events[i].data.fd);  
          
                          /* Closing the descriptor will make epoll remove it 
                             from the set of descriptors which are monitored. */  
                          close (events[i].data.fd);  
                        }  
                    }  
                }  
            }  
          
          free (events);  
          
          close (sfd);  
          
          return EXIT_SUCCESS;  
        }

运行方式：

在一个终端运行此程序：epoll.out PORT

另一个终端：telnet  127.0.0.1 PORT

截图：

![Center 1][]

## select、poll、epoll之间的区别总结\[整理\] ##

1、select的几大缺点：

（1）每次调用select，都需要把fd集合从用户态拷贝到内核态，这个开销在fd很多时会很大

（2）同时每次调用select都需要在内核遍历传递进来的所有fd，这个开销在fd很多时也很大

（3）select支持的文件描述符数量太小了，默认是1024

2、poll实现

poll的实现和select非常相似，只是描述fd集合的方式不同，poll使用pollfd结构而不是select的fd\_set结构，其他的都差不多。

关于select和poll的实现分析，可以参考下面几篇博文：

[http://blog.csdn.net/lizhiguo0532/article/details/6568964\#comments][http_blog.csdn.net_lizhiguo0532_article_details_6568964_comments]

[http://blog.csdn.net/lizhiguo0532/article/details/6568968][http_blog.csdn.net_lizhiguo0532_article_details_6568968]

[http://blog.csdn.net/lizhiguo0532/article/details/6568969][http_blog.csdn.net_lizhiguo0532_article_details_6568969]

[http://www.ibm.com/developerworks/cn/linux/l-cn-edntwk/index.html?ca=drs-][http_www.ibm.com_developerworks_cn_linux_l-cn-edntwk_index.html_ca_drs-]

[http://linux.chinaunix.net/techdoc/net/2009/05/03/1109887.shtml][http_linux.chinaunix.net_techdoc_net_2009_05_03_1109887.shtml]

3、epoll

epoll既然是对select和poll的改进，就应该能避免上述的三个缺点。那epoll都是怎么解决的呢？在此之前，我们先看一下epoll和select和poll的调用接口上的不同，select和poll都只提供了一个函数——select或者poll函数。而epoll提供了三个函数，epoll\_create,epoll\_ctl和epoll\_wait，epoll\_create是创建一个epoll句柄；epoll\_ctl是注册要监听的事件类型；epoll\_wait则是等待事件的产生。

对于第一个缺点，epoll的解决方案在epoll\_ctl函数中。每次注册新的事件到epoll句柄中时（在epoll\_ctl中指定EPOLL\_CTL\_ADD），会把所有的fd拷贝进内核，而不是在epoll\_wait的时候重复拷贝。epoll保证了每个fd在整个过程中只会拷贝一次。

对于第二个缺点，epoll的解决方案不像select或poll一样每次都把current轮流加入fd对应的设备等待队列中，而只在epoll\_ctl时把current挂一遍（这一遍必不可少）并为每个fd指定一个回调函数，当设备就绪，唤醒等待队列上的等待者时，就会调用这个回调函数，而这个回调函数会把就绪的fd加入一个就绪链表）。epoll\_wait的工作实际上就是在这个就绪链表中查看有没有就绪的fd（利用schedule\_timeout()实现睡一会，判断一会的效果，和select实现中的第7步是类似的）。

对于第三个缺点，epoll没有这个限制，它所支持的FD上限是最大可以打开文件的数目，这个数字一般远大于2048,举个例子,在1GB内存的机器上大约是10万左右，具体数目可以cat /proc/sys/fs/file-max察看,一般来说这个数目和系统内存关系很大。

## **参考资料：** ##

[http://man7.org/linux/man-pages/man2/epoll\_create.2.html][http_man7.org_linux_man-pages_man2_epoll_create.2.html]

[https://banu.com/blog/2/how-to-use-epoll-a-complete-example-in-c/][https_banu.com_blog_2_how-to-use-epoll-a-complete-example-in-c]

[http://blog.csdn.net/sparkliang/article/details/4770655][http_blog.csdn.net_sparkliang_article_details_4770655]

《深入理解Nginx模块开发与架构解析》9.6小节

[http://blog.csdn.net/eroswang/article/details/4481521][http_blog.csdn.net_eroswang_article_details_4481521]

[http://www.ccvita.com/515.html][http_www.ccvita.com_515.html]

[http://blog.codingnow.com/2006/04/iocp\_kqueue\_epoll.html][http_blog.codingnow.com_2006_04_iocp_kqueue_epoll.html]

[Center]: /images/20220731/0b17c961bccf41e1b28842222e185450.png
[view plain]: http://blog.csdn.net/xiajun07061225/article/details/9250579#
[Center 1]: /images/20220731/7c74be1494644644a5afa249bfb672d6.png
[http_blog.csdn.net_lizhiguo0532_article_details_6568964_comments]: http://blog.csdn.net/lizhiguo0532/article/details/6568964#comments
[http_blog.csdn.net_lizhiguo0532_article_details_6568968]: http://blog.csdn.net/lizhiguo0532/article/details/6568968
[http_blog.csdn.net_lizhiguo0532_article_details_6568969]: http://blog.csdn.net/lizhiguo0532/article/details/6568969
[http_www.ibm.com_developerworks_cn_linux_l-cn-edntwk_index.html_ca_drs-]: http://www.ibm.com/developerworks/cn/linux/l-cn-edntwk/index.html?ca=drs-
[http_linux.chinaunix.net_techdoc_net_2009_05_03_1109887.shtml]: http://linux.chinaunix.net/techdoc/net/2009/05/03/1109887.shtml
[http_man7.org_linux_man-pages_man2_epoll_create.2.html]: http://man7.org/linux/man-pages/man2/epoll_create.2.html
[https_banu.com_blog_2_how-to-use-epoll-a-complete-example-in-c]: https://banu.com/blog/2/how-to-use-epoll-a-complete-example-in-c/
[http_blog.csdn.net_sparkliang_article_details_4770655]: http://blog.csdn.net/sparkliang/article/details/4770655
[http_blog.csdn.net_eroswang_article_details_4481521]: http://blog.csdn.net/eroswang/article/details/4481521
[http_www.ccvita.com_515.html]: http://www.ccvita.com/515.html
[http_blog.codingnow.com_2006_04_iocp_kqueue_epoll.html]: http://blog.codingnow.com/2006/04/iocp_kqueue_epoll.html