仿 muduo 实现的高并发服务器

1. 多 Reactor：main 只负责接，sub 负责干活#

Acceptor 挂在 main Reactor 上，只做一件事：accept 新连接并按轮询把它交给线程池里的某个 sub Reactor。连接一旦分配，之后所有的读写都在那个线程里完成 —— 所以写业务回调不需要加锁，天然是”单连接单线程”的。线程数可以在启动时配置，配成 0 就是纯单线程模式。

2. epoll 用水平触发，用 eventfd 换来”可以死等”#

事件底层是 Linux 的 epoll，采用**水平触发（LT）**模式，epoll_wait 的超时直接给 -1（一直阻塞到有事件）。既然线程真的睡着了，就必须能被别的线程叫醒 —— 这里用 eventfd 实现：任何线程往任务队列投递任务后，顺手往 eventfd 写一下，阻塞中的 loop 立即返回并处理任务。

LT 的特点是”只要可写就一直通知”，所以写事件的监控是按需开关的：发送缓冲区还有数据才打开可写监控，发完立刻关掉，避免事件循环空转。

3. 定时器：timerfd 驱动的时间轮#

超时管理没有用”遍历所有连接找超时”的笨办法，而是时间轮：一个 60 格的环形数组 + 一根秒针，由 timerfd 每秒触发一次。任务到期时不需要扫描，秒针走到哪一格就处理哪一格。

配合连接使用就变成了”每条连接一个可刷新的定时任务”：连接上任何事件都会给它续命（把任务挂到更靠后的刻度），一直没动静就会被时间轮踢掉。echo 示例里配的是 10 秒非活跃释放。

4. 连接的生命周期管理#

Connection 继承 enable_shared_from_this，所有回调都传 shared_ptr 而不是裸指针，保证”正在回调时对象不会被销毁”。关闭连接分三步：半关闭（不再接收新数据）→ 延后释放（即使用户在 loop 线程里调用，也要推到下一轮事件循环执行）→ 真正释放（摘除 epoll 监控、关闭 fd、撤销定时器、通知用户）。

“延后释放”这一步是刻意设计的：如果业务回调里触发了超时释放，而回调自己还在栈上使用这个对象，立刻析构就会出问题。把它推到下一轮循环，就天然避开了这类竞态。

5. HTTP 应用层：状态机解析 + 粘包/半包处理#

HTTP 解析写成了清晰的五态状态机：请求行 → 头部 → 空行 → 正文 → 完成。数据不够时原地等待、状态不推进，下次收到继续解析（解决半包）；一次收到多份请求时，在 onMessage 里循环解析直到缓冲区读空（解决粘包）。

应用层还实现了 URL 编解码、状态码文案、文件扩展名到 MIME 的映射、静态资源根目录限制，以及一套简单的路由注册接口。写一个 HTTP 服务只要这样：

1
int main() {
2
    HttpServer server(8085);
3
    server.SetThreadCount(3);       // 3 个工作线程
4
    server.SetBaseDir("./wwwroot/");
5
    server.Get("/hello",  Hello);   // 注册路由
6
    server.Post("/login", Login);
7
    server.Listen();
8
}