244-Linux epoll

1.epoll和poll相比有什么区别？

答案：epoll是Linux平台特有的，select和poll在Linux和Windows平台中都有，epoll的出现是为了解决客户端数量越来越多(描述符多)的场景

poll每次循环都需要把收集描述符的数组从用户空间拷贝到用户空间中，当数组大小非常大时，就会浪费资源，而epoll从头到尾只需要拷贝一次

select和poll只是知道n个描述符里面有m个描述符有请求，但是不知道具体是哪一个，它只能通过遍历的方式一个一个比对，当随着客户端数量急剧增长的时候，所需要的时间复杂度也会变的越来越高，久而久之，性能就不行了，epoll的出现就是为了解决这些问题

2.epoll有三个方法：epoll_create()、epoll_wait()、epoll_ctr()

epoll_create()的作用是：在内核中创建一个内核事件表
epoll_ctr()的作用是：往内核时间表中添加或者删除一个描述符
epoll_wait()的作用是：直接获取就绪描述符

epoll_wait()就不用像select或者poll那样还要遍历整个数组，找到就绪描述符

3.epoll_create(MAX);//其实这个参数没有任何意义，函数的作用是创建内核事件表，内核事件表本质上是一个红黑树，红黑树就像链表一样，没有大小，是在内核空间

4.服务器端代码

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/select.h>
#include <string.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <assert.h>
#include <sys/epoll.h>

#define MAX 10

int socket_init();

void epoll_add(int epfd,int fd)//添加描述符
{
    struct epoll_event ev;
    ev.events = EPOLLIN;
    ev.data.fd = fd;
    
    if(epoll_ctl(epfd,EPOLL_CTL_ADD,fd,&ev) == -1)
    {
        printf("epoll ctl error\n");
    }
}

void epoll_del(int epfd,int fd)//删除描述符
{
    if(epoll_ctl(epfd,EPOLL_CTL_DEL,fd,NULL) == -1)
    {
        printf("epoll ctr del error\n");
    }
}

int main()
{
    int sockfd = socket_init();
    assert(sockfd != -1);

    int epfd = epoll_create(MAX);//其实这个参数没有任何意义，他是一个红黑树，红黑树就像链表一样，没有大小，创建内核事件表，内核空间
    assert(epfd != -1);
    
    epoll_add(epfd,sockfd);//添加描述符到内核事件表

    struct epoll_event evs[MAX];//存放就绪描述符

    while(1)
    {
        int n = epoll_wait(epfd,evs,MAX,5000);//获取就绪描述符，前n个就是就绪描述符
        if(n == -1)//失败了
        {
            continue;
        }
        else if(n == 0)//超时了
        {
            printf("time out\n");
        }
        else//有n个描述符上有数据，而且就是evs的前n个元素,这一点和select和poll，这也是epoll的优点之处
        {
            for(int i = 0;i<n;++i)
            {
                int fd = evs[i].data.fd;
                if(evs[i].events & EPOLLIN)//说明读事件产生了
                {
                    if(fd == sockfd)//是监听套接字
                    {
                        //accept
                    }
                    else//连接套接字
                    {
                        //recv
                    }
                }
            }
        }
    }
    
}

int socket_init()
{
    int sockfd = socket(AF_INET,SOCK_STREAM,0);
    if(sockfd < 0)
    {
        return -1;
    }

    struct sockaddr_in saddr;
    memset(&saddr,0,sizeof(saddr));
    saddr.sin_family = AF_INET;
    saddr.sin_port = htons(6000);
    saddr.sin_addr.s_addr = inet_addr("127.0.0.1");

    int res = bind(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));
    if(res == -1)
    {
        return -1;
    }

    res = listen(sockfd,5);
    if(res == -1)
    {
        return -1;
    }

    return sockfd;
}