epoll_ctl的概念和使用案例

epoll_ctl 是 Linux 系统中 I/O 多路复用机制 epoll 的核心函数之一,用于管理 epoll 实例监控的文件描述符(File Descriptor, FD)。它负责向 epoll 实例注册、修改或删除需要监控的 FD 及其事件类型,是实现高性能网络编程(如高并发服务器)的关键工具。


函数原型

#include <sys/epoll.h>int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
参数说明
参数说明
epfdepoll 实例的文件描述符(由 epoll_create 创建)
op操作类型:EPOLL_CTL_ADD(添加)、EPOLL_CTL_MOD(修改)、EPOLL_CTL_DEL(删除)
fd需要操作的目标文件描述符(如 socket)
event指向 epoll_event 结构体的指针,定义监控的事件类型和用户数据
返回值
  • 成功返回 0,失败返回 -1,错误信息通过 errno 获取。

epoll_event 结构体

struct epoll_event {uint32_t     events;   // 监控的事件类型(位掩码形式)epoll_data_t data;     // 用户数据(通常保存 FD 或关联的指针)
};typedef union epoll_data {void    *ptr;int      fd;uint32_t u32;uint64_t u64;
} epoll_data_t;
常用事件类型
事件类型说明
EPOLLIN文件描述符可读(例如 socket 接收缓冲区有数据)
EPOLLOUT文件描述符可写(例如 socket 发送缓冲区有空闲)
EPOLLERR发生错误(自动监控,无需显式设置)
EPOLLHUP对端关闭连接或挂起(自动监控)
EPOLLET边缘触发模式(Edge-Triggered),默认为水平触发(Level-Triggered)

使用场景案例:TCP 服务器监控 Socket

以下是一个简化的 TCP 服务器代码片段,展示 epoll_ctl 的典型用法:

1. 创建 epoll 实例
int epfd = epoll_create1(0);  // 创建 epoll 实例
if (epfd == -1) {perror("epoll_create1");exit(EXIT_FAILURE);
}
2. 注册监听 Socket 到 epoll
int listen_sock = socket(AF_INET, SOCK_STREAM, 0);  // 创建监听 socket
struct sockaddr_in addr = {/* 绑定 IP 和端口 */};
bind(listen_sock, (struct sockaddr*)&addr, sizeof(addr));
listen(listen_sock, SOMAXCONN);  // 开始监听// 定义 epoll_event 结构体
struct epoll_event ev;
ev.events = EPOLLIN | EPOLLET;  // 监控可读事件,边缘触发模式
ev.data.fd = listen_sock;       // 保存 socket FD 到用户数据// 将监听 socket 添加到 epoll
if (epoll_ctl(epfd, EPOLL_CTL_ADD, listen_sock, &ev) == -1) {perror("epoll_ctl: listen_sock");close(epfd);exit(EXIT_FAILURE);
}
3. 事件循环处理新连接
#define MAX_EVENTS 10
struct epoll_event events[MAX_EVENTS];while (1) {int n = epoll_wait(epfd, events, MAX_EVENTS, -1);  // 阻塞等待事件for (int i = 0; i < n; i++) {if (events[i].data.fd == listen_sock) {// 接受新连接int conn_sock = accept(listen_sock, NULL, NULL);if (conn_sock == -1) {perror("accept");continue;}// 将新连接的 socket 添加到 epollstruct epoll_event ev_conn;ev_conn.events = EPOLLIN | EPOLLET;  // 监控可读事件ev_conn.data.fd = conn_sock;if (epoll_ctl(epfd, EPOLL_CTL_ADD, conn_sock, &ev_conn) == -1) {perror("epoll_ctl: conn_sock");close(conn_sock);}} else {// 处理已连接的 socket 数据int conn_fd = events[i].data.fd;char buffer[1024];ssize_t n = read(conn_fd, buffer, sizeof(buffer));if (n > 0) {// 处理数据...} else if (n == 0 || errno == ECONNRESET) {// 对端关闭连接,从 epoll 中删除epoll_ctl(epfd, EPOLL_CTL_DEL, conn_fd, NULL);close(conn_fd);}}}
}

关键注意事项

  1. 边缘触发(ET) vs 水平触发(LT)

    • ET 模式:仅在 FD 状态变化时触发事件(需一次处理完所有数据,避免饥饿)。
    • LT 模式(默认):只要满足条件,持续触发事件(编程更简单,但效率可能略低)。
  2. 错误处理

    • 检查 epoll_ctl 返回值,避免遗漏错误(如重复添加 FD 或操作已关闭的 FD)。
  3. 资源管理

    • 关闭 FD 前需从 epoll 中删除(EPOLL_CTL_DEL),否则可能导致未定义行为。
  4. 高性能优化

    • 结合非阻塞 IO 和 ET 模式实现高并发(例如 Nginx、Redis 的做法)。

总结

epoll_ctlepoll 机制的核心函数,用于动态管理监控的 FD。通过合理使用 EPOLL_CTL_ADDEPOLL_CTL_MODEPOLL_CTL_DEL 操作,可以实现高效的事件驱动网络编程,支撑数万甚至百万级的并发连接。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/895460.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Java练习(20)

ps:练习来自力扣 给你一个 非空 整数数组 nums &#xff0c;除了某个元素只出现一次以外&#xff0c;其余每个元素均出现两次。找出那个只出现了一次的元素。 你必须设计并实现线性时间复杂度的算法来解决此问题&#xff0c;且该算法只使用常量额外空间。 class Solution {pu…

Tetragon:一款基于eBPF的运行时环境安全监控工具

关于Tetragon Tetragon是一款基于eBPF的运行时环境安全监控工具&#xff0c;该工具可以帮助广大研究人员检测并应对安全重大事件&#xff0c;例如流程执行事件、系统调用活动、I/O活动&#xff08;包括网络和文件访问等&#xff09;。 在 Kubernetes 环境中使用时&#xff0c;…

1046. 最后一块石头的重量

文章目录 1.题目[1046. 最后一块石头的重量](https://leetcode.cn/problems/last-stone-weight/description/)2.思路3.代码 1.题目 1046. 最后一块石头的重量 有一堆石头&#xff0c;每块石头的重量都是正整数。 每一回合&#xff0c;从中选出两块** 最重的** 石头&#xff…

Qt多线程技术【线程池】:QRunnable 和 QThreadPool

在现代软件开发中&#xff0c;尤其是在处理大量并发任务时&#xff0c;线程池技术是一种高效的解决方案。线程池不仅能提高程序的性能&#xff0c;还能有效管理线程的生命周期&#xff0c;避免频繁的线程创建和销毁所带来的性能损失。本文将以Qt中的 QThreadPool 和 QRunnable …

DOM让JavaScript可以对文档中的标签、属性、内容等进行 访增删改 操作

示例 HTML 文档 首先&#xff0c;我们有一个简单的 HTML 文件 index.html&#xff0c;内容如下&#xff1a; <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta name"viewport" content"widt…

218.子结构判断

class Solution {/*** 判断树 B 是否是树 A 的子结构* param A 树 A 的根节点* param B 树 B 的根节点* return 如果 B 是 A 的子结构&#xff0c;返回 true&#xff1b;否则返回 false*/public boolean isSubStructure(TreeNode A, TreeNode B) {// 如果树 B 为空&#xff0c;…

【DuodooBMS】基于Odoo的开源制造执行系统——以开源之力,驱动智能制造

以用户为中心的开放式智造平台 DuodooMES的设计始终围绕“用户可编程、生态可生长”的核心思想&#xff0c;打破传统工业软件的封闭性&#xff0c;让制造企业真正成为系统的“主人”&#xff1a; 1. 用户可编程&#xff1a;生产流程由你定义 界面可配置&#xff1a;无需代码即…

Unity使用iTextSharp导出PDF-02基础结构及设置中文字体

基础结构 1.创建一个Document对象 2.使用PdfWriter创建PDF文档 3.打开文档 4.添加内容&#xff0c;调用文档Add方法添加内容时&#xff0c;内容写入到输出流中 5.关闭文档 using UnityEngine; using iTextSharp.text; using System.IO; using iTextSharp.text.pdf; using Sys…

Navicat导入海量Excel数据到数据库(简易介绍)

目录 前言正文 前言 此处主要作为科普帖进行记录 原先Java处理海量数据的导入时&#xff0c;由于接口超时&#xff0c;数据处理不过来&#xff0c;后续转为Navicat Navicat 是一款功能强大的数据库管理工具&#xff0c;支持多种数据库系统&#xff08;如 MySQL、PostgreSQL、…

文化财经t8优质短线期货交易量化模型源码

// 参数设置 BOLL_PERIOD : 20; // 布林带周期 RSI_PERIOD : 14; // RSI 周期 OVERSOLD : 30; // 超卖线 OVERBOUGHT : 70; // 超买线 // 计算布林带 MID : MA(CLOSE, BOLL_PERIOD); UPPER : MID 2 * STD(CLOSE, BOLL_PERIOD); LOWER : MID - 2 * STD(CLOSE,…

[AI]Mac本地部署Deepseek R1模型 — — 保姆级教程

[AI]Mac本地部署DeepSeek R1模型 — — 保姆级教程 DeepSeek R1是中国AI初创公司深度求索&#xff08;DeepSeek&#xff09;推出大模型DeepSeek-R1。 作为一款开源模型&#xff0c;R1在数学、代码、自然语言推理等任务上的性能能够比肩OpenAI o1模型正式版&#xff0c;并采用MI…

【UE5】PeerStream像素流部署

视频教程 https://www.bilibili.com/video/BV1GhiuecEpK?spm_id_from333.788.videopod.sections&vd_source02dd8acc3a83a728e375ff61f1ebe725步骤 下载PeerStream代码 代码结构和项目如图 github地址:https://github.com/inveta/PeerStreamEnterprise下载node node 对应…

老牌系统工具箱,现在还能打!

今天给大家分享一款超实用的电脑软硬件检测工具&#xff0c;虽然它是一款比较“资深”的软件&#xff0c;但依然非常好用&#xff0c;完全能满足我们的日常需求。 电脑软硬件维护检测工具 功能强大易用 这款软件非常贴心&#xff0c;完全不需要安装&#xff0c;直接打开就能用…

java商城解决方案

数字化时代&#xff0c;电子商务已成为企业拓展市场的重要渠道。对于想要建立在线商店的企业来说&#xff0c;选择正确的技术堆栈至关重要。 Java作为一种成熟且广泛使用的编程语言&#xff0c;为构建购物中心提供了强大的功能和灵活性。 商城Java源码&#xff1a;商城开发的核…

软件的生命周期和需求

什么是软件的生命周期? 定义(描述) --> 创建 --> 使用 --> 销毁 (这一整个过程就是事物的生命周期) 生命周期 那么软件的生命周期又分为哪些呢? 一共分为十步: 可行性研究: 通过分析软件开发要求,确定软件项目的性质、目标和规模,得出可行性研究报告,如果可行性研…

QGIS如何下载高程数据

一、准备工作 安装QGIS软件 访问QGIS官网下载最新版本,选择适合操作系统的安装包(如Windows 64位)完成安装。建议使用3.28及以上版本以获得完整功能支持。 注册数据平台账号 NASA EarthData账号:访问EarthData登录页面注册,用于SRTM数据下载。地理空间数据云账号:访问www…

【linux学习指南】线程同步与互斥

文章目录 &#x1f4dd;线程互斥&#x1f320; 库函数strncpy&#x1f309;进程线程间的互斥相关背景概念&#x1f309;互斥量mutex &#x1f320;线程同步&#x1f309;条件变量&#x1f309;同步概念与竞态条件&#x1f309; 条件变量函数 &#x1f6a9;总结 &#x1f4dd;线…

MySQL索引优化,性能飙升的秘密!

0.前言 假设你经营一家电商平台&#xff0c;某天用户突然投诉商品搜索加载时间超过10秒。技术团队紧急排查&#xff0c;发现一条原本执行0.1秒的查询语句&#xff0c;在百万级数据量下竟变成了全表扫描。这时&#xff0c;数据库索引犹如深夜急诊室里的救命仪器——它的存在与否…

基于STM32、HAL库、HS12864(ST7920,并行接口)C语言程序设计

1、hs12864.h头文件: #ifndef __HS12864_H #define __HS12864_H #ifdef __cplusplus extern "C" {#endif #include "stm32l4xx_hal.h" // 控制线定义 - 根据实际硬件修改 #define HS12864_RS_GPIO_PORT GPIOC #define HS12864_RS_PIN GPIO_PI…

【C语言】C语言 实践课题选题系统(源码+报告+数据文件)【独一无二】

&#x1f449;博__主&#x1f448;&#xff1a;米码收割机 &#x1f449;技__能&#x1f448;&#xff1a;C/Python语言 &#x1f449;专__注&#x1f448;&#xff1a;专注主流机器人、人工智能等相关领域的开发、测试技术。 系C语言 实践课题选题系统&#xff08;源码报告数据…