1. 简单一点首页
  2. 编程

epoll使用详解

WFXCJ • • 编程

一、epoll使用ET

在使用epoll的时候我们需要注意两种工作方式，一种是LT（Level Trigger）方式，一种是ET（Edge Trigger）方式。ET方式的精度比LT方式高，适用于需要高并发的场景。在使用ET方式时，我们需要使用非阻塞IO，因为只有在返回EAGAIN或EWOULDBLOCK错误后才能保证一定要读或写完所有的数据。如下是使用ET模式的示例代码：

int epoll_fd = epoll_create1(0);
if (epoll_fd < 0) {
    perror("epoll_create1 error");
    exit(EXIT_FAILURE);
}

struct epoll_event event;
event.events = EPOLLIN|EPOLLET;
event.data.fd = sockfd;
if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, sockfd, &event) < 0) {
    perror("epoll_ctl error");
    exit(EXIT_FAILURE);
}

while(1) {
    struct epoll_event events[MAX_EVENTS];
    int nfds = epoll_wait(epoll_fd, events, MAX_EVENTS, -1);
    if(nfds == -1) {
        perror("epoll_wait error");
        exit(EXIT_FAILURE);
    }

    for(int i = 0; i < nfds; i++) {
        if(events[i].events & EPOLLIN) {
            // 读取事件
        } else if (events[i].events & EPOLLOUT) {
            // 写入事件
        } else if (events[i].events & (EPOLLERR | EPOLLHUP)) {
            // 出错事件
            close(events[i].data.fd);
        }
    }
}

二、epoll使用et套接口

ET方式下我们还可以使用边沿触发的套接字（et套接口），与普通套接字相比可以更好地处理并发问题。下面是et套接字的示例代码：

int listenfd = socket(AF_INET, SOCK_STREAM, 0);
fcntl(listenfd, F_SETFL, fcntl(listenfd, F_GETFL, 0) | O_NONBLOCK);

struct epoll_event ev, events[MAX_EVENTS];
ev.events = EPOLLIN|EPOLLET;
ev.data.fd = listenfd;
int epollfd = epoll_create1(0);
epoll_ctl(epollfd, EPOLL_CTL_ADD, listenfd, &ev);

while (1) {
    int nfds = epoll_wait(epollfd, events, MAX_EVENTS, -1);
    for(int i = 0; i < nfds; i++) {
        if(events[i].data.fd == listenfd) {  // 边沿触发
            while(1) {
                int connfd = accept(listenfd, (struct sockaddr*)&clientaddr, &clientlen);
                if(connfd < 0) {
                    if(errno == EAGAIN || errno == EWOULDBLOCK) break;
                    else perror("accept error");
                } else {
                    fcntl(connfd, F_SETFL, fcntl(connfd, F_GETFL, 0) | O_NONBLOCK);
                    ev.events = EPOLLIN|EPOLLET;
                    ev.data.fd = connfd;
                    epoll_ctl(epollfd, EPOLL_CTL_ADD, connfd, &ev);
                }
            }
        } else {
            // 处理其它ET事件
        }
    }
}

三、epoll使用udp

在使用UDP时，我们需要使用epoll的EPOLLIN事件来监听读事件，和TCP的读取方式不同，UDP使用recvfrom函数来读取数据。

int sockfd = socket(AF_INET, SOCK_DGRAM, 0);
struct sockaddr_in servaddr;
memset(&servaddr, 0, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_port = htons(port);

if(bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1) {
    perror("bind error");
    exit(EXIT_FAILURE);
}

int epollfd = epoll_create1(0);
if (epollfd == -1) {
    perror("epoll_create1 error");
    exit(EXIT_FAILURE);
}

struct epoll_event event;
event.data.fd = sockfd;
event.events = EPOLLIN;
if (epoll_ctl(epollfd, EPOLL_CTL_ADD, sockfd, &event) == -1) {
    perror("epoll_ctl error");
    exit(EXIT_FAILURE);
}

while (1) {
    struct epoll_event events[MAX_EVENTS];
    int nfds = epoll_wait(epollfd, events, MAX_EVENTS, -1);
    for(int i = 0; i < nfds; i++) {
        if(events[i].data.fd == sockfd) {
            struct sockaddr_in clientaddr;
            socklen_t clientaddrlen = sizeof(clientaddr);
            char buffer[MAXLINE];
            int n = recvfrom(sockfd, buffer, MAXLINE, 0, (struct sockaddr *)&clientaddr, &clientaddrlen);
            buffer[n] = '\0';
            printf("recvfrom:%s\n", buffer);
        }
    }
}

四、epoll使用共享内存

在多进程的服务中，我们可以使用共享内存来实现进程间的通信。在监听socket上使用epoll事件，接受到新的连接后，把socket的信息写入共享内存，让其它进程读取。

#include 

int shmid = shmget(IPC_PRIVATE, sizeof(int), 0644|IPC_CREAT);
if(shmid == -1) {
    perror("shmget error");
    exit(EXIT_FAILURE);
}

int serverfd = socket(AF_INET, SOCK_STREAM, 0);
// 绑定等操作

if(fork() == 0) {
    // 子进程
    while(1) {
        int *p = (int*)shmat(shmid, 0, SHM_RDONLY);
        printf("listenfd=%d", *p);
        shmdt(p);
    }
} else {
    // 父进程
    listen(serverfd, SOMAXCONN);
    struct epoll_event ev, events[MAX_EVENTS];
    int epollfd = epoll_create1(0);
    ev.events = EPOLLIN|EPOLLET;
    ev.data.fd = serverfd;
    epoll_ctl(epollfd, EPOLL_CTL_ADD, serverfd, &ev);

    while (1) {
        int nfds = epoll_wait(epollfd, events, MAX_EVENTS, -1);
        for(int i = 0; i < nfds; i++) {
            if(events[i].data.fd == serverfd) {
                int connfd = accept(serverfd, (struct sockaddr*)&cliaddr, &addrlen);
                if(connfd < 0) {
                    if(errno == EAGAIN || errno == EWOULDBLOCK) break; // 内核缓冲区没有数据
                    else perror("accept error");
                } else {
                    fcntl(connfd, F_SETFL, fcntl(connfd, F_GETFL, 0) | O_NONBLOCK);
                    int *p = (int*)shmat(shmid, NULL, 0);
                    *p = connfd;
                    shmdt(p);
                }
            }
        }
    }
}

五、epoll使用举例

下面我们来看一个使用epoll的例子，代码实现了一个简单的HTTP服务器：

int listenfd = socket(AF_INET, SOCK_STREAM, 0);
fcntl(listenfd, F_SETFL, fcntl(listenfd, F_GETFL, 0) | O_NONBLOCK);

struct sockaddr_in serveraddr;
memset(&serveraddr, 0, sizeof(serveraddr));
serveraddr.sin_family = AF_INET;
serveraddr.sin_addr.s_addr = htonl(INADDR_ANY);
serveraddr.sin_port = htons(port);

bind(listenfd, (struct sockaddr *)&serveraddr, sizeof(serveraddr));
listen(listenfd, SOMAXCONN);

int epfd = epoll_create(EPOLLSIZE);
struct epoll_event event, events[MAXEPOLLSIZE];
event.events = EPOLLIN | EPOLLET;
event.data.fd = listenfd;
epoll_ctl(epfd, EPOLL_CTL_ADD, listenfd, &event);

while (1) {
    int n = epoll_wait(epfd, events, MAXEPOLLSIZE, -1);
    for (int i = 0; i < n; ++i) {
        if (events[i].data.fd == listenfd) {
            struct sockaddr_in clientaddr;
            socklen_t addrlen = sizeof(clientaddr);
            int connfd = accept(listenfd, (struct sockaddr *)&clientaddr, &addrlen);
            fcntl(connfd, F_SETFL, fcntl(connfd, F_GETFL, 0) | O_NONBLOCK);
            event.data.fd = connfd;
            event.events = EPOLLIN | EPOLLET;
            epoll_ctl(epfd, EPOLL_CTL_ADD, connfd, &event);
        } else if (events[i].events & EPOLLIN) {
            char buf[BUFSIZE];
            int connfd = events[i].data.fd;
            int n = read(connfd, buf, BUFSIZE);
            if (n <= 0) {
                close(connfd);
                epoll_ctl(epfd, EPOLL_CTL_DEL, connfd, &events[i]);
                continue;
            }
            // 处理HTTP请求

            char header[HEADERLEN];
            resp_header(header, 200, strlen(resp), "text/plain");
            write(connfd, header, strlen(header));
            write(connfd, resp, strlen(resp));
            close(connfd);
            epoll_ctl(epfd, EPOLL_CTL_DEL, connfd, &events[i]);
        }
    }
}

六、epoll使用回调通知吗

epoll基于事件驱动的方式，使用回调函数来处理事件。下面是一个简单的回调函数示例代码：

void handle_event(int epoll_fd, int fd, int event_type) {
    // 处理事件
} 

int epoll_fd = epoll_create1(0);
if(epoll_fd < 0) {
    perror("epoll create");
    exit(EXIT_FAILURE);
}

struct epoll_event event;
event.data.fd = sockfd;
event.events = EPOLLIN | EPOLLET;
event.data.ptr = &handle_event; // 使用回调函数
if(epoll_ctl(epoll_fd, EPOLL_CTL_ADD, sockfd, &event) < 0) {
    perror("epoll ctl");
    close(sockfd);
    exit(EXIT_FAILURE);
}

while(1) {
    struct epoll_event events[MAX_EVENTS];
    int nfds = epoll_wait(epoll_fd, events, MAX_EVENTS, -1);
    for(int i = 0; i < nfds; i++) {
        int fd = events[i].data.fd;
        int event_type = events[i].events;
        void (*cb)(int, int, int) = events[i].data.ptr;
        (*cb)(epoll_fd, fd, event_type);
    }
}

七、epoll原理

epoll利用了Linux内核提供的I/O事件通知机制，通过注册文件描述符将其与特定事件联系起来，当注册的事件发生时，内核会帮助我们进行触发，通知用户程序进行操作。其机制与信号机制类似，但比信号更加高效。下面是一个简单的epoll原理图：

八、epoll函数

epoll的函数包括epoll_create, epoll_ctl, epoll_wait。其中epoll_create函数用于创建一个epoll的文件描述符，epoll_ctl函数用于添加、删除或修改某个文件描述符的事件，epoll_wait函数用于等待事件的发生。

九、epoll实现原理

epoll的实现原理可以归纳为以下几个步骤：

1、创建一个epoll的文件描述符。

2、使用epoll_ctl函数注册文件描述符和对应的事件。

3、内核注册文件描述符上的事件，将其加入到一个红黑树中，根据需要创建等待队列。

4、使用epoll_wait函数等待事件的发生，如果有事件发生，内核会通知用户程序。

5、用户程序根据事件类型，进行相应的处理。

原创文章，作者：WFXCJ，如若转载，请注明出处：https://www.506064.com/n/316757.html

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
WFXCJWFXCJ
0
上一篇 2025-01-09 12:15
下一篇 2025-01-09 12:15

相关推荐

  • 神经网络代码详解

    神经网络作为一种人工智能技术，被广泛应用于语音识别、图像识别、自然语言处理等领域。而神经网络的模型编写，离不开代码。本文将从多个方面详细阐述神经网络模型编写的代码技术。 一、神经网…

    编程 2025-04-25

  • Linux sync详解

    一、sync概述 sync是Linux中一个非常重要的命令，它可以将文件系统缓存中的内容，强制写入磁盘中。在执行sync之前，所有的文件系统更新将不会立即写入磁盘，而是先缓存在内存…

    编程 2025-04-25

  • Linux修改文件名命令详解

    在Linux系统中，修改文件名是一个很常见的操作。Linux提供了多种方式来修改文件名，这篇文章将介绍Linux修改文件名的详细操作。 一、mv命令 mv命令是Linux下的常用命…

    编程 2025-04-25

  • Java BigDecimal 精度详解

    一、基础概念 Java BigDecimal 是一个用于高精度计算的类。普通的 double 或 float 类型只能精确表示有限的数字，而对于需要高精度计算的场景，BigDeci…

    编程 2025-04-25

  • Python安装OS库详解

    一、OS简介 OS库是Python标准库的一部分，它提供了跨平台的操作系统功能，使得Python可以进行文件操作、进程管理、环境变量读取等系统级操作。 OS库中包含了大量的文件和目…

    编程 2025-04-25

  • git config user.name的详解

    一、为什么要使用git config user.name? git是一个非常流行的分布式版本控制系统，很多程序员都会用到它。在使用git commit提交代码时，需要记录commi…

    编程 2025-04-25

  • Python输入输出详解

    一、文件读写 Python中文件的读写操作是必不可少的基本技能之一。读写文件分别使用open()函数中的’r’和’w’参数，读取文件…

    编程 2025-04-25

  • 详解eclipse设置

    一、安装与基础设置 1、下载eclipse并进行安装。 2、打开eclipse，选择对应的工作空间路径。 File -> Switch Workspace -> [选择…

    编程 2025-04-25

  • MPU6050工作原理详解

    一、什么是MPU6050 MPU6050是一种六轴惯性传感器，能够同时测量加速度和角速度。它由三个传感器组成：一个三轴加速度计和一个三轴陀螺仪。这个组合提供了非常精细的姿态解算，其…

    编程 2025-04-25

  • nginx与apache应用开发详解

    一、概述 nginx和apache都是常见的web服务器。nginx是一个高性能的反向代理web服务器，将负载均衡和缓存集成在了一起，可以动静分离。apache是一个可扩展的web…

    编程 2025-04-25

发表回复

登录后才能评论