文章目录
- 1、连接池
- 2、epoll两种工作模式
- 2.1、LT模式
- 2.2、ET模式
- 3、后端开发面试题
- 4、epoll验证
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 1024
void epollTest()
{
// 1、创建socket
int 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 listen
struct 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;
}