• 开发环境
• CMake 工程构建
• mylib
  • 辅助类：
    • nocopyable
    • CheckError | Logger
    • Timestamp
    • CurrentThead
  • 顶层设计类：
    • TcpServer
    • EventLoop
  • Epoll类：
    • Poller
    • EpollPoller
    • Channel
  • 线程类
    • Thead
    • EventLoopThread
    • EventLoopThreadPool类
  • 网络类 && 连接类
    • InetAddress
    • Socket
    • Acceptor
    • Buffers
    • TcpConnection

开发环境

• 5.10.16.3-microsoft-standard-WSL2
• gcc version 9.3.0
• cmake version 3.16.3

CMake 工程构建

• src 源码文件
• mylib muduo网络文件
• 顶层CMakeLists.txt 构造项目

mylib

辅助类：

nocopyable

• 通过继承的方式来让接下来的类表示不可拷贝。

CheckError | Logger

• 检查错误信息
• 错误信息处理 写入日志类
• 行为写入日志类

Timestamp

• 返回事件戳，用于记录时间发生节点

CurrentThead

• 用于辅助EventLoop实现主从Reactor模式
• 获取线程的pid()

顶层设计类：

TcpServer

• 用户回调函数->TcpConnection->EventLoop

• 构造函数：

  • 初始化EventLoop

  • 创建新的accptor，指向主Loop，所以主loop处理链接请求

  • 创建线程池

  • 回调函数

• newConection()

  • 创建一个TcpConnection对象，并且设置相应的回调。
  • 构建线程 和 subLoop
  • 设置地址相关
  • 构建哈希表 名称->TcpConnection
  • 设置TcpConnection回调

EventLoop

• 链接Channel 和 Poller

• mian-Reactor 和 sub-Reactor

• loop() 由三部分组成：

  • 调用 Poller->poll()返回 有事件的channel
  • 处理channel里的回调函数
  • 处理上层注册的回调函数后陷入阻塞

• wakeupFd_ 和 wakeupChannel_ 专门用来唤醒loop，防止其不能及时处理上层分发的回调函数

• runInLoop() 向subloop塞入分发的回调函数

  queueInLoop() 分发回调函数 通过wakeupFd_写入一个数据唤醒loop

• doPendingFunctors()将需要处理的回调函数换出，减少锁的临界区开销

​ 同时避免死锁，保证加入的回调可以被迅速的执行

Epoll类：

Poller

纯虚基类

unordered_map<fd, Channel> 存储文件描述符和Channel的关系；

EpollPoller

• 在Poller的基础上实现工程化的Epoll相关功能
• 实现用户态Channel 和 内核态epoll的交互功能
• epoll_events.data.ptr == channel
• epoll_events.events = channel->events()
• epoll_events.data.fd = channnel->fd

Channel

• Channel 封装了 sockfd ，相关的 event 和回调函数

• Channel通过EventLoop调用Poller 进行update

• 通过 EventLoop 调用Channel 执行事件

• 二者通过EventLoop 沟通

​ Channel <-- EventLoop --> Epoll

线程类

Thead

• 基础的Thread类
• 创建一个线程，设置线程的名称，启动一个线程

EventLoopThread

• 将线程与eventloop绑定在一起

• 构造函数 -> threadFunc() : 构造EvnetLoop ，上层回调函数进行线程初始化需要进行的操作，绑定 eventLoop；条件变量唤醒

  ->startLoop()启动线程-> 启动loop

EventLoopThreadPool类

• 封装EventLoopThread成一个线程池类。
• 最上层的回调函数，向下注册。
• 自动的进行管理。
• 主Reactor 负责连接。

网络类 && 连接类

InetAddress

• 封装ip地址信息，端口信息。sockaddr 初始化
• 网络字节序和本地字节序进行转换，格式化的输出信息

Socket

• bind 绑定地址
• listen 监听端口
• accept 接收的同时保存客户端的socket信息

Acceptor

• 构造Socket
• 构造Channel 绑定 socketFd
• 指向主Reactor的EventLoop *

Buffers

• 用户和内核缓冲区的转折点

• 接收和发送数据的缓冲区

• 两个index 对buffer进行分区

TcpConnection

TcpServer-> Acceptor -> accept 得到连接的accept

->TcpConnection 设置回调函数 -> 设置Channel -> Poller -> Channel回调

• 主Reactor负责接收链接的请，会给已连接生成的一个TcpConnection对象，

​ 然后将这个connection分发给subLoop对象。

• 设置回调

  • EventLoop中的doPendingFuntors
  • Channel中的handle event

• 如果内核缓冲区满了，将会把要写的内容写入outbuffer中