> For the complete documentation index, see [llms.txt](https://xd96dx.gitbook.io/docs/llms.txt). Markdown versions of documentation pages are available by appending `.md` to page URLs; this page is available as [Markdown](https://xd96dx.gitbook.io/docs/c-c++/wang-luo-bian-cheng/reactor-shi-li-zhi-muduo-yuan-ma-fen-xi.md). # Reactor实例之 muduo 源码分析 Reactor 模型的实践库, 源码不难, 也很好分析, 和 beegfs 网络部分代码很像, 不过都大同小异 ### Reactor主要组件 #### EventLoop:

eventLoop 封装了Poller 和 Channel, 是muduo的事件循环, 负责事件处理, 任务分发, 定时器等功能 * **looping** 表示事件循环是否正在运行, 在loop 时会设置为true, 退出后设为false * **quit\_** : 事件循环是否退出 * **eventHandling**: 表示是否正在处理事件 * **callingPendingFunctors**: 表示是否正在执行线程安全的任务队列 * **iteration**: 事件循环次数 * **threadId\_**: eventLoop 的线程id * **pollReturnTime\_**: poller 返回的时间戳 * **poller**: 在linux下, 就是epoll, 用来监听channel 注册的事件 * **timerQueue**: 定时管理器, 触发定时任务 * **weakupChannel\_** 是用来监听 **weakupFd\_** 的, 他们和 **pendingFunctors** 是关联的, 在跨线程提交任务后, weakupChannel\_ 会被 weakUp() 唤醒, 将任务放入 pendingFunctors 里, 在loop 中执行, 并清除weakupFd\_ 的可读状态, 作用就是可以周期性的执行一部分其他线程提交的任务, 并恢复原状态 * **activeChannels**: Poller里活跃的事件列表 * **currentActiveChannel\_**: 当前正在处理的channel * **mutex\_**: 用来保护 pendingFunctors\_ (主要是push\_back, swap)

这是eventLoop 的 loop 方法, 监听poller 的事件, 然后执行, dopendingFunctors 里执行其他线程提交的任务, 不断循环 #### Channel

channel 主要用于封装fd 和事件处理的回调, 负责具体事件的监听和处理 * **loop\_** : 关联一个eventLoop 对象, 并将其注册到poller(epoll), 监听文件描述符事件 * **fd\_** : io 描述符 * **events\_**: channel 要监听的事件, 事件发生时, poller 通知eventLoop, 并执行回调 * **revents\_** : 实际发生的事件, 用来和监听的事件对比, 是否要执行相应注册的回调函数 * **index\_** : poller中的索引 * **logHup\_** : 是否记录挂起事件 * **tie\_** : channel 与其他对象共享生命周期时, 用来绑定channel, muduo里使用的有 tcpConnection 和 curl * **tied\_ :** 是否已经绑定对象 * **eventHandling:** eventLoop 是否正在处理channel 的事件 * **addedToLoop\_ :** channel 是否已经添加到eventLoop中 * **readCallback\_, writeCallback\_, closeCallback\_, errorCallback\_** : 对应事件注册的回调函数