I/O多路复用之epoll

2019独角兽企业重金招聘Python工程师标准>>>

在上一章，我们对select进行了大致的描述，知道了它相对传统的阻塞式服务提高了并发度，但是它也由于轮询而导致效率底下。本文对epoll进行讲解，相比select它的并发度更高，现代高负载服务器很多都采用这种模型。

在讲解epoll的具体用法之前，我们先看看采用 epoll模型主要用到的三个函数以及一个数据结构。

epoll中三个主要的函数：

（1）int epoll_create(int size);

功能：生成一个epoll专用的文件描述符。

参数：size:在该epoll fd上关注的最大socket fd数。

返回值：生成的文件描述符。

（2）int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);

功能：控制某个epoll文件描述符上的事件，可以注册事件，修改事件，删除事件。

参数：epfd ：由 epoll_create 生成的epoll专用的文件描述符；

op ：EPOLL_CTL_ADD 注册、EPOLL_CTL_MOD 修改、EPOLL_CTL_DEL 删除；

fd ：关联的文件描述符；

event：指向epoll_event的指针；

返回值：0：成功；

-1：失败；

（3）int epoll_wait(int epfd,struct epoll_event * events,int maxevents,int timeout);

功能：轮询I/O事件的发生。

参数：epfd ：由 epoll_create 生成的epoll专用的文件描述符；

events ：用于回传待处理事件的数组；

maxevents：每次能处理的事件数；

timeout ：等待I/O事件发生的超时值；-1相当于阻塞，0相当于非阻塞；

返回值：>=0 ：返回发生事件数；

-1 ：错误；

epoll中的主要数据结构：

 view source  
 print ? 
 01typedef union epoll_data { 
 02 void *ptr;
 03 int fd;
 04 __uint32_t u32;
 05 __uint64_t u64;
 06} epoll_data_t; 
 07 
 08struct epoll_event {
 09 __uint32_t events; /* Epoll events */
 10 epoll_data_t data; /* User data variable */
 11};

其中，events的类型有：

EPOLLIN ：文件描述符可以读；

EPOLLOUT：文件描述符可以写；

EPOLLPRI：文件描述符有紧急的数据可读；

EPOLLERR：文件描述符发生错误；

EPOLLHUP：文件描述符被挂断；

EPOLLET ：文件描述符有事件发生；

epoll的使用还是很简单的，请看下面一个简单的采用epoll提供并发服务的服务端程序（注：为了简洁，都没有进行错误处理，实际使用时，一定要记住进行错误处理。）：

 view source  
 print ? 
 01#include <errno.h>
 02#include <string.h>
 03#include <sys/types.h>
 04#include <netinet/in.h>
 05#include <sys/socket.h>
 06#include <sys/wait.h>
 07#include <unistd.h>
 08#include <arpa/inet.h>
 09#include <sys/epoll.h>
 10#include <sys/time.h>

 12#define MAXBUF 1024
 13#define MAX_EPOLL_SIZE 10000
 14#define SERVICE_PORT 8888


 17int main(int argc, char **argv)
 18{
int server_fd, new_fd;
struct sockaddr_in server_addr, client_addr;

struct epoll_event ev;
struct epoll_event events[MAX_EPOLL_SIZE];

socklen_t len = sizeof(struct sockaddr_in);
server_fd = socket(AF_INET, SOCK_STREAM, 0)；

bzero(&server_addr, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(SERVICE_PORT);
server_addr.sin_addr.s_addr = INADDR_ANY;

bind(server_fd, (struct sockaddr *) &server_addr, sizeof(struct sockaddr))；
listen(server_fd, 1000)；

//create epoll fd, and register the server listening fd
int epoll_fd = epoll_create(MAX_EPOLL_SIZE);
ev.events = EPOLLIN | EPOLLET;
ev.data.fd = server_fd;
epoll_ctl(epoll_fd, EPOLL_CTL_ADD, server_fd, &ev)；

int active_fd_count = 1;
while (1)
{
//wait for some events to happen
int event_active_fd_count = epoll_wait(epoll_fd, events, active_fd_count, -1);

// process all events
for (int i = 0; i < event_active_fd_count; ++i)
{
if (events[i].data.fd == server_fd)
{
new_fd = accept(server_fd, (struct sockaddr *) &client_addr,&len);

//register new fd to epoll
ev.events = EPOLLIN | EPOLLET;
ev.data.fd = new_fd;
epoll_ctl(epoll_fd, EPOLL_CTL_ADD, new_fd, &ev)；
active_fd_count++;
}
else
{
handle message on events[i].data.fd
if (client close the connection)
{
epoll_ctl(epoll_fd, EPOLL_CTL_DEL, events[i].data.fd,&ev);
active_fd_count--;
}
}
}
}
close(server_fd);
return 0;
 74}

讲完epoll的常规使用方法，这里需要注意的是epoll有两种工作方式：

（1）ET：Edge Triggered，边缘触发。仅当状态发生变化时才会通知，需要细致的处理每个请求，否则容易发生丢失事件的情况。只支持非阻塞的socket。

（2）LT：Level Triggered，水平触发（默认工作方式）。只要还有没有处理的事件就会一直通知，因此不用担心事件丢失的情况。效率会低于ET触发，尤其在大并发，大流量的情况下。支持阻塞和非阻塞的socket。

最后讲讲 为什么epoll会比select高效，主要从三方面来进行论述。

（1）elect对描述符状态的改变是通过轮询来进行查找的；而epoll是当描述符状态发生改变时主动进行通知内核，这就是所谓的Reactor事件处理机制。可以用“好莱坞原则”进行描述：不要打电话给我们，我们会打电话通知你。相比之下，select的机制就好比面试结束后不停给面试官打电话询问面试结果。效率孰高孰低，可见一斑。

（2）select的文件描述符是使用链表进行组织的；而epoll是使用红黑树这一高效数据结构组织的。

（3）select从内核到用户空间传递文件描述符上发送的信息是使用内存复制的方式进行的；而epoll是采用共享内存的方式。

转载于:https://my.oschina.net/u/581475/blog/73195

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/403753.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！