ZLMediaKit 源码分析（二）：EventPoller 事件循环机制深度分析

EventPoller 是 ZLMediaKit/ZLToolKit 网络层的核心引擎，本文从源码逐行分析其在 Linux 下的 epoll 实现，包括事件循环、异步任务、延时队列和退出机制。

1. EventPoller 在架构中的位置

┌─────────────────────────────────────────────┐ │ 业务层：RtspSession / RtmpSession / ... │ ├─────────────────────────────────────────────┤ │ 网络抽象层：Socket / TcpServer │ ├─────────────────────────────────────────────┤ ← 本篇重点 │ 事件引擎层：EventPoller / EventPollerPool │ ├─────────────────────────────────────────────┤ │ 系统调用层：epoll_create / epoll_ctl / ... │ └─────────────────────────────────────────────┘

2. 类结构

2.1 继承关系

TaskExecutor (线程任务执行器) └─ EventPoller (事件轮询器) └─ EventPollerPool (线程池管理多个 EventPoller)

• TaskExecutor：继承ThreadPool，提供async()投递任务能力
• EventPoller：在其基础上增加 epoll 事件循环
• EventPollerPool：单例，管理多个 EventPoller 实例

2.2 EventPoller 核心成员

// ZLToolKit/src/Poller/EventPoller.cppclassEventPoller:publicTaskExecutor{public:usingPtr=std::shared_ptr<EventPoller>;private:int_epoll_fd=-1;// epoll 实例 fdint_pipe_fd[2]={-1,-1};// pipe 用于唤醒 epoll_waitstd::mutex _mtx;// 保护 _event_mapstd::unordered_map<int,PollEventCB>_event_map;// fd → 事件回调std::deque<PollTaskCB>_list_task;// 异步任务队列DelayTaskMap _delay_task_map;// 延时任务（按执行时间排序）bool_exit_flag=false;// 退出标志};

3. 构造与初始化

EventPoller::EventPoller(ThreadPool::Priority priority){// 1. 创建 epoll 实例_epoll_fd=epoll_create1(EPOLL_CLOEXEC);if(_epoll_fd==-1){throwstd::runtime_error("epoll_create1 failed");}// 2. 创建 pipe 用于唤醒if(pipe(_pipe_fd)!=0){close(_epoll_fd);throwstd::runtime_error("pipe failed");}// 3. 将 pipe 读端注册到 epoll// 当有异步任务投递时，往 pipe 写端写 1 字节，唤醒 epoll_waitaddEvent(_pipe_fd[0],EPOLLIN,[this](intevent){onPipeEvent();});}

网络库级调用链：

• epoll_create1(EPOLL_CLOEXEC)→ 创建 epoll 实例
• pipe()→ 创建管道作为通知机制
• epoll_ctl(_epoll_fd, EPOLL_CTL_ADD, _pipe_fd[0], &ev)→ 注册管道读端

4. runLoop — 事件循环核心

voidEventPoller::runLoop(boolis_try){constintmax_events=1024;structepoll_eventevents