(文章目录)
前言
本篇文章我们讲解epoll函数的使用方法,epoll相比于poll来说性能方面有所提升和改进。
一、epoll概念特点讲解
epoll 是 Linux 上一种高性能的多路复用机制,用于监视大量文件描述符并在它们就绪时通知应用程序。它是在 select 和 poll 的基础上进一步优化和改进而来的。
epoll 的主要特点包括:
1.没有文件描述符数量限制:与 select 和 poll 不同,epoll 采用了基于事件的就绪通知机制,没有预定义的文件描述符数量限制,可以支持更大规模的并发连接。
2.高效的事件通知:epoll 使用了内核和用户空间共享的事件数据结构,将文件描述符的事件注册到内核空间,当事件就绪时,内核直接将就绪的事件通知给用户空间,避免了每次调用都需要遍历整个文件描述符数组的性能开销。
3.分离的就绪事件集合:epoll 将就绪的事件从内核空间复制到用户空间,形成一个分离的就绪事件集合,用户可以直接遍历这个集合来处理就绪的事件,而不需要遍历整个文件描述符数组。
4.支持边缘触发和水平触发:epoll 提供了两种模式来处理事件,一种是边缘触发模式(EPOLLET),只在状态发生变化时通知应用程序,另一种是水平触发模式(默认),在事件就绪期间一直通知应用程序。
5.更低的内存拷贝开销:epoll 使用内存映射技术,避免了每次调用都需要将事件数据从内核复制到用户空间的开销,从而减少了系统调用的次数和内存拷贝的开销。
6.支持较高精度的超时控制:与 poll 不同,epoll 的超时参数以毫秒和纳秒为单位,提供了较高精度的超时控制。
总体来说,epoll 在性能上相比于 select 和 poll 有较大的优势,特别适用于高并发场景下的网络编程。它的高效事件就绪通知、支持大规模并发连接、较低的内存拷贝开销以及较高的超时精度,使得它成为开发高性能服务器和网络应用的首选机制。
二、epoll实现机理
epoll是使用红黑树(Red-Black Tree)实现的。epoll是Linux操作系统提供的一种高效的事件通知机制,用于处理大量的并发连接。它能够监视多个文件描述符的状态变化,当文件描述符就绪时,通过回调函数进行相应的处理。
在Linux内核中,epoll使用红黑树作为其主要的数据结构,用于维护注册的文件描述符集合。红黑树是一种自平衡的二叉搜索树,具有较快的插入、删除和搜索操作的时间复杂度。通过使用红黑树,epoll能够高效地检索和管理大量的文件描述符。
当文件描述符发生事件时,epoll通过红黑树的查找操作快速定位到相应的结点,并触发注册的回调函数进行事件处理。使用红黑树的原因是它能够保持良好的平衡性,保证搜索、插入和删除操作的最坏情况时间复杂度为O(log n),从而保证了epoll的高性能和可伸缩性。
总结来说,epoll是利用红黑树作为其底层数据结构实现的,这使得它在处理大量并发连接时能够提供高效的事件通知机制。
三、epoll相关函数讲解
1.epoll_create函数
函数原型:
int epoll_create(int size);
epoll_create 函数创建一个 epoll 实例,并返回一个文件描述符,用于标识该 epoll 实例。参数 size 是一个提示,表示 epoll 实例可以监视的文件描述符的数量上限。但在大多数情况下,该参数会被忽略,可以传递任意的值。
返回的文件描述符可以用于之后对 epoll 实例进行操作,比如注册、修改和删除文件描述符的事件。
需要注意的是,epoll_create 函数在成功时返回一个非负整数,表示 epoll 实例的文件描述符,如果出现错误,返回值为 -1,并设置 errno 错误码来指示具体的错误类型。
2.epoll_ctl函数
函数原型:
int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
epoll_ctl 函数通过指定的 epfd 参数来操作特定的 epoll 实例,op 参数表示操作类型,可以是以下三种之一:
EPOLL_CTL_ADD:将指定的文件描述符 fd 添加到 epoll 实例中,并注册相应的事件。这样,当该文件描述符上的事件就绪时,就会通知应用程序。
EPOLL_CTL_MOD:修改已经注册在 epoll 实例中的文件描述符 fd 对应的事件。可以修改事件的类型、关注的事件、关联的用户数据等。
EPOLL_CTL_DEL:删除已经注册在 epoll 实例中的文件描述符 fd。
fd 参数是目标文件描述符,用于指定需要进行操作的文件描述符。
event 参数是一个指向 struct epoll_event 结构体的指针,用于指定事件相关的配置。该结构体包含两个成员:
uint32_t events:表示注册的事件类型,可以是 EPOLLIN(可读事件)、EPOLLOUT(可写事件)、EPOLLRDHUP(对端关闭连接)、EPOLLPRI(有紧急数据可读)、EPOLLERR(错误事件)等。可以使用位掩码进行组合。
epoll_data_t data:用于存储用户数据信息,可以是文件描述符本身的值,也可以是用户自定义的数据结构指针。
函数的返回值为 0 表示操作成功,-1 表示出现错误,具体的错误信息可以通过检查 errno 变量获得。
3.epoll_wait函数
函数原型:
int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout);
epfd 参数是 epoll 实例的描述符,通过它指定要进行事件等待的 epoll 实例。
events 参数是一个用于存放事件信息的数组,每个数组元素都是 struct epoll_event 类型的结构体,用于存储就绪的文件描述符以及对应的事件信息。
maxevents 参数表示 events 数组的大小,即最多可以等待多少个事件。
timeout 参数是超时时间,单位为毫秒。它决定了 epoll_wait 函数的阻塞行为:
如果 timeout 设置为 -1,表示无限期阻塞,直到有事件发生为止。
如果 timeout 设置为 0,表示非阻塞,立即返回当前就绪的事件,如果没有事件就绪,则返回 0。
如果 timeout 设置为一个正整数,表示阻塞等待指定的时间后返回,如果在超时时间内没有等到事件就绪,则返回 0。
epoll_wait 函数在成功时返回就绪事件的文件描述符数量,如果出现错误则返回 -1,并设置 errno 错误码来指示具体的错误类型。
四、epoll实现并发服务器
当使用epoll实现并发服务器时,通常的步骤包括以下几个主要环节:
1.创建socket:使用socket函数创建一个监听套接字,用于接受客户端的连接请求。
2.绑定socket:使用bind函数将监听套接字绑定到一个特定的IP地址和端口。
3.监听连接:使用listen函数开始监听连接请求,指定服务器可接受的最大连接数。
4.创建epoll实例:使用epoll_create函数创建一个epoll实例,返回一个文件描述符。
5.将监听套接字添加到epoll实例:使用epoll_ctl函数将监听套接字添加到epoll实例中,并注册对读事件的关注。
6.进入事件循环:循环调用epoll_wait函数来等待事件的发生,该函数会阻塞当前线程直至有事件发生。一旦有事件发生,它将返回一个就绪事件的列表。
7.处理就绪事件:遍历就绪事件列表,对每个事件进行处理。根据事件类型,可以进行接受连接、读取数据、发送数据或关闭连接等操作。
8.根据需要添加或删除文件描述符:在处理完一个事件后,可以根据需要使用epoll_ctl函数动态地添加或删除文件描述符,以便继续监听其他事件。
9.重复步骤6-8:继续循环执行步骤6-8,处理新的就绪事件,直到服务器主动关闭或出现错误条件为止。
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/epoll.h>
#define MAX_EVENTS 1024 //最多可以等待多少个事件
int main()
{
int server = 0;
struct sockaddr_in saddr = {0};
int client = 0;
struct sockaddr_in caddr = {0};
socklen_t asize = 0;
int len = 0;
char buf[32] = {0};
int maxfd;
int ret = 0;
int i = 0;
server = socket(PF_INET, SOCK_STREAM, 0);
if( server == -1 )
{
printf("server socket error\n");
return -1;
}
saddr.sin_family = AF_INET;
saddr.sin_addr.s_addr = htonl(INADDR_ANY);
saddr.sin_port = htons(8888);
if( bind(server, (struct sockaddr*)&saddr, sizeof(saddr)) == -1 )
{
printf("server bind error\n");
return -1;
}
if( listen(server, 128) == -1 )
{
printf("server listen error\n");
return -1;
}
printf("server start success\n");
struct epoll_event event, events[MAX_EVENTS];
/*创建epoll*/
int epollInstance = epoll_create1(0);
if (epollInstance == -1)
{
printf("Failed to create epoll instance\n");
}
/*将服务器添加进入event中*/
event.events = EPOLLIN;
event.data.fd = server;
if (epoll_ctl(epollInstance, EPOLL_CTL_ADD, server, &event) == -1)
{
printf("Failed to add server socket to epoll instance");
}
while( 1 )
{
int numEventsReady = epoll_wait(epollInstance, events, MAX_EVENTS, -1);
if (numEventsReady == -1)
{
printf("Failed to wait for events");
return -1;
}
for(i = 0; i < numEventsReady; i++)
{
if(events[i].data.fd == server)
{
/*有客户端连接上来了*/
asize = sizeof(caddr);
client = accept(server, (struct sockaddr*)&caddr, &asize);
printf("client is connect\n");
event.events = EPOLLIN | EPOLLET;
event.data.fd = client;
if (epoll_ctl(epollInstance, EPOLL_CTL_ADD, client, &event) == -1)
{
printf("Failed to add client socket to epoll instance");
return -1;
}
}
else
{
/*处理客户端的请求*/
len = read(events[i].data.fd, buf, 1024);
if(len == 0)
{
printf("client is disconnect\n");
close(events[i].data.fd);
}
else
{
/*对接收到的数据进行处理*/
printf("read buf : %s\n", buf);
write(events[i].data.fd, buf, len);
}
}
}
}
close(server);
return 0;
}
总结
本篇文章就讲解到这里,下篇文章继续讲解Linux网络编程的知识。
标签:epoll,int,编程,描述符,事件,Linux,就绪,event From: https://blog.51cto.com/u_16153875/7150279