C++ 仿 Muduo 库 #1：架构与 Reactor 模型解析

一、实现目标

本系列旨在通过 C++ 实现一个类似 Muduo 的高并发服务器组件。核心采用 One Thread One Loop 的主从 Reactor 模型，目标是提供一个简洁、高性能的基础设施。

通过这个组件，开发者可以快速搭建高性能的 TCP 或 HTTP 服务器。需要注意的是，当前项目定位为基础组件库，不包含具体业务逻辑，但预留了应用层协议（如 HTTP）的支持接口，方便后续扩展。

二、HTTP 服务器基础

HTTP 是运行在 TCP 之上的应用层协议，遵循简单的请求—响应模式。虽然 HTTP 服务器看起来只是处理文本数据，但其本质依然是 TCP 服务器。区别在于需要在应用层对数据进行格式化的组织与解析。

实现一个 HTTP 服务器的基本流程如下：

搭建 TCP 服务器接收客户端连接。
按照 HTTP 协议格式解析请求数据，明确客户端意图。
根据请求目的提供对应的服务处理。
将结果封装为 HTTP 响应格式发送回客户端。

当然，实现一个能跑通的 HTTP 服务器不难，难的是在高并发场景下保持高性能。这也是我们引入 Reactor 模式的初衷。

三、Reactor 模型详解

概念

Reactor 模式是一种事件驱动的处理模式。服务端程序利用 I/O 多路复用统一监听多个输入源，当有事件发生时，将其同步分派给对应的处理线程。它也被称为 Dispatcher 模式，是编写高性能网络服务器的核心技术之一。

简单来说，就是使用 I/O 多路复用统一监听事件，收到事件后分发给处理进程或线程。

四、功能模块划分

整个架构由以下核心模块协作完成，它们共同支撑起高并发网络服务。

1. Buffer 模块

用于管理用户态的接收和发送缓冲区，屏蔽底层 Socket 读写的复杂性，提供高效的内存操作接口。

2. Socket 模块

封装了底层的套接字操作，包括创建、绑定、监听、连接等系统调用。

3. Channel 模块

描述符的事件管理器。它封装了文件描述符及其对应的事件（可读、可写、错误等），并在 Poller 就绪时回调相应的处理函数。

4. Connection 模块

这是通信的核心单元，封装了 Buffer、Socket、Channel 以及连接状态。

内部结构：包含接收/发送缓冲区、Socket 对象、Channel 对象。
回调机制：提供连接建立、事件触发、新数据到达、关闭连接等回调接口。
工作流程：
1. 向 Channel 注册事件回调，并添加到 Poller 监控。
2. 描述符就绪（如可读），Channel 调用读事件处理，将数据读入接收缓冲区。
3. 触发新数据回调，由上层进行业务处理。
4. 业务处理后，通过发送接口写入发送缓冲区。
5. 启动写事件监控，就绪后将数据通过 Socket 发送出去。

5. Acceptor 模块

负责监听套接字的管理。它封装了 Socket 和 Channel，主要功能是获取新连接并构建 Connection 对象。

6. TimerQueue 模块

基于 Linux 的 timerfd 实现定时任务管理。主要用于非活跃连接的超时释放，管理连接的生命周期。

7. Poller 模块

对 epoll 的封装，负责 IO 事件的添加、修改、移除以及获取活跃连接列表。

8. EventLoop 模块

即 Reactor 的核心循环，保证'一个线程对应一个 EventLoop'。

线程安全：要求所有对 Connection 的操作必须在对应的 EventLoop 线程内完成。
内部组件：包含 Poller、TimerQueue、eventfd（用于唤醒阻塞）以及 PendingTask 队列。
工作流程：
1. Poller 监控描述符事件，触发 Channel 回调。
2. 处理完 IO 事件后，顺序执行任务队列中的操作。
3. 利用 eventfd 防止 epoll 因无事件而长时间阻塞，确保任务能及时调度。

9. TcpServer 模块

对外暴露的服务器接口，整合了 Acceptor 和 EventLoop 线程池。

初始化：设置 BaseLoop，实例化 Acceptor 和 EventLoop 线程池。
连接处理：Acceptor 获取新连接后，创建 Connection 对象，分配 EventLoop，设置回调及定时销毁任务，并加入 Hash 表管理。
启动：启动 BaseLoop 进入事件循环。

10. 模块关系图

整体架构中各模块的交互关系如下所示：

通信连接模块关系图

架构图