IO复用之epoll

epoll是Linux内核为处理大批量文件描述符而作了改进的poll，是Linux下多路复用IO接口select/poll的增强版本，它能显著提高程序在大量并发连接中只有少量活跃的情况下的系统CPU利用率。另一点原因就是获取事件的时候，它无须遍历整个被侦听的描述符集，只要遍历那些被内核IO事件异步唤醒而加入Ready队列的描述符集合就行了。epoll除了提供select/poll那种IO事件的水平触发（Level Triggered）外，还提供了边缘触发（Edge Triggered），这就使得用户空间程序有可能缓存IO状态，减少epoll_wait/epoll_pwait的调用，提高应用程序效率.

epoll类似于事件机制,有客户端数据发送过来了,就激活了事件,所以极大的提高了效率,适用于高并发的服务端的开发.

epoll也有一般的形式:

  int epofd = 0;                                                      //epoll对象
    int fds = 0;                                                            //活跃连接对象
    int i = 0;
    int er = 0;
    int sock_fd = 0;
    int len = 0;

    struct epoll_event event;                                   //epoll事件
    struct epoll_event events[MAX_NUM];

    struct sockaddr_in client;

    len = sizeof(struct sockaddr_in);

    epofd =    epoll_create(MAX_NUM);                                //创建epoll对象
    if(epofd < 0){
        perror("epoll创建失败");
        return -1;
    }

    fcntl(listen_fd,F_SETFL,O_NONBLOCK);                        //将监听套接字转化为非堵塞的监听套接字

    event.data.fd = listen_fd;                                              //设置epoll事件
    event.events = EPOLLIN;

    er = epoll_ctl(epofd,EPOLL_CTL_ADD,listen_fd,&event);       //添加epoll事件
    if(er < 0){
        perror("epoll_ctl出错");
        return -1;
    }

    while(1){
        fds = epoll_wait(epofd,events,MAX_NUM,-1);              //等待数据连接
        if(fds < 0){
            perror("epoll_wait出错");
            continue;
        }

        for(i = 0;i < fds;i++){
            if(events[i].data.fd == listen_fd){                                                                 //判断是否是新联接
                sock_fd = accept(listen_fd,(struct sockaddr *)&client,&len);                //接受连接
                if(sock_fd < 0){
                    perror("有客户端连接失败");
                    continue;
                }

                //将连接添加到事件中
                event.data.fd = sock_fd;
                event.events = EPOLLIN | EPOLLET;
                epoll_ctl(epofd,EPOLL_CTL_ADD,sock_fd,&event);

                printf("有新连接%d
",sock_fd);

                continue;
            }else {
                er = rev_data(events[i].data.fd);//新的数据发送过来了
                if(er == 0){//客户端断开连接
                    epoll_ctl(epofd,EPOLL_CTL_DEL,events[i].data.fd,&event);//取消该客户端的时间监听
                    close(events[i].data.fd);//关闭套接字
                    continue;
                }
            }

        }

    }