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.pswp.cn/news/895460.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/895460.shtml
英文地址,請注明出處:http://en.pswp.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;源碼報告數據…