1、连接池

将每一个套接字和一块内存进行绑定，连接池就是一个结构体数组，通过链表来维护一个空闲连接。
1、ngx_get_connection(int fd)从空闲链表取一个空闲连接，然后指向头的指针指向后面一个元素，然后将sock对应给到这个空闲连接中，然后返回这个结构体指针。
2、ngx_epoll_add_event将监听套接字，添加到红黑树上，

3、ngx_epoll_process_events内容：
事件驱动：通过获取到的事件，调用适当的函数，让整个程序干活

2、epoll两种工作模式

2.1、LT模式

LT也叫水平触发，这种工作模式是，低速模式（效率差）–默认缺省用次模式，来一个事件，不处理的话，就会一直触发（也就是循环调epoll_wait的时候每次都会有这个事件），能保证不会丢失事件，因为内核会反复通知。

2.2、ET模式

ET边沿触发，这种工作模式是，高速模式（效率高），只能对非阻塞套接字用，来一个事件，内核只通知一次（不管是否处理，内核都不在通知你）只需要增加EPOLLET(epl_ev.events)

事件驱动框架

就是由一些事件源（三次握手内核通知，事件发生源就是客户端），通过事件收集器和事件分发器（调用函数处理）【事件收集器：epoll_wait()】【accept() read()都属于事件处理函数】，

3、后端开发面试题

问题：使用epoll模型，水平触发模式，当socket可写时，会不停的触发可写事件，怎么处理？
1、需要向socket中写的时候才把socket加入红黑树中，等待可写事件，接受可写事件之后调用write()函数，写完之后，将socket移除红黑树。
2、开始不把socket加入epoll，需要写数据的时候，直接调用write函数，如果返回EAGAIN把socket加入epoll中，全部数据写完移除epoll。

4、epoll验证

将套接字设置为非阻塞，然后将epoll_wait设置为阻塞，会阻塞在那里等有事件来才会往下走，如果是水平触发，要是没有处理就有一直触发

#include <unistd.h>
#include <sys/wait.h>
#include <strings.h>
#include <stdio.h>
#include <stdlib.h>
#include <ctype.h>
#include <sys/time.h>
#include <errno.h>
#include <signal.h>
#include <stdio.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <sys/select.h>
#include <poll.h>
#include <sys/epoll.h>
#include <sys/ioctl.h>
#define OPEN_MAX 1024void epollTest()
{// 1、创建socketint fd = socket(AF_INET,SOCK_STREAM,0);if(fd<0){printf("socket err\n");return;}// 设置TIME_WAIT状态导致bind失败int reuseaddr = 1;if(setsockopt(fd,SOL_SOCKET,SO_REUSEADDR,(const void*)&reuseaddr,sizeof(reuseaddr)) == -1){printf("setsockopt err\n");return;}// 设置为非阻塞int nb=1; //0：清除，1：设置  if(ioctl(fd, FIONBIO, &nb) == -1){printf("ioctl err\n");return;}// bind listenstruct sockaddr_in serv_addr;bzero(&serv_addr,sizeof(serv_addr));serv_addr.sin_family = AF_INET;serv_addr.sin_port = htons(9999);serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);if(bind(fd,(struct sockaddr*)&serv_addr,sizeof(serv_addr))<0){printf("bind err\n");return;}listen(fd,128);// 创建红黑树int epoll_fd = epoll_create(OPEN_MAX);if(epoll_fd == -1){printf("epoll_create err");return;}// 添加到红黑树种struct epoll_event epl_ev;epl_ev.events = EPOLLIN;epl_ev.data.fd = fd;if(epoll_ctl(epoll_fd,EPOLL_CTL_ADD,fd,&epl_ev) == -1){printf("epoll_ctl err");return;}// 等待事件struct epoll_event ep[OPEN_MAX];while(true){int nready = epoll_wait(epoll_fd,ep,OPEN_MAX,5000);printf("nready:%d\n",nready);for(int i=0;i<nready;i++){if(!(ep[i].events & EPOLLIN))   // 不是读事件{continue;}else{if(ep[i].data.fd == fd){printf("连接事件\n");}}}}}int main()
{epollTest();return 0;
}