主Reactor仅负责accept，从Reactor独占epoll实例并管理Connection全生命周期；连接迁移需先关闭旧fd再添加新fd；线程间通信应使用无锁队列。
主Reactor线程只负责accept，别让它干别的
主Reactor必须严格限定在监听套接字的 accept() 事件上。一旦混入读写、定时器或连接池管理逻辑，就会成为性能瓶颈和竞态源头。Linux 下 epoll 的 EPOLLET 模式 + SO_REUSEPORT 是更轻量的替代方案，但若坚持 Reactor 分层，主Reactor 就该是“纯门卫”——收到新连接，用轮询或随机方式选一个从Reactor，把新 fd 通过线程安全队列（如 moodycamel::ConcurrentQueue 或封装了 std::mutex + std::queue 的简单队列）投递给它。
常见错误：主Reactor 在 accept() 后直接调用 setsockopt(fd, SOL_SOCKET, SO_RCVBUF, ...) 或做 SSL 握手预处理。这些操作阻塞时间不可控，会卡住整个监听循环。
- 主Reactor 线程不创建
Connection对象，只转发fd和对端地址 - 所有 socket 选项（
TCP_NODELAY、SO_KEEPALIVE）由从Reactor 在首次读事件时设置 - 避免在主Reactor 中调用
getpeername()—— 从Reactor 首次读取时再解析更稳妥
从Reactor线程绑定固定epoll实例，别共享
每个从Reactor 独占一个 epoll_create1(0) 实例，且生命周期与线程一致。多个从Reactor 共享同一个 epoll_fd 是典型误用，会导致 epoll_ctl(EPOLL_CTL_ADD) 竞态、事件丢失或 EBADF 错误。从Reactor 启动后立即调用 epoll_ctl(EPOLL_CTL_ADD) 注册该线程负责的所有连接 fd，并用 EPOLLIN | EPOLLET 监听可读事件。
注意：Linux 5.9+ 支持 epoll_pwait2()，但目前主流项目仍用 epoll_wait()；超时设为 -1（阻塞等待）比设为 1ms 更省 CPU，只要确保有机制能唤醒（如 timerfd 或 signalfd）即可。
立即学习“C++免费学习笔记（深入）”；
- 每个从Reactor 线程启动时初始化自己的
epoll_fd、事件数组struct epoll_event events[1024] - 连接迁移（如负载均衡重调度）必须走“优雅关闭旧fd → 新线程 add 新fd”流程，不能直接
epoll_ctl(MOD) -
epoll_wait()返回后，必须循环处理所有就绪事件，直到返回 0（ET 模式要求）
Connection对象必须归属单一从Reactor线程
Connection 实例的整个生命周期（创建、读写、析构）必须严格限定在一个从Reactor 线程内。跨线程访问其 fd、缓冲区或状态机将引发数据竞争。典型做法是：从Reactor 收到新 fd 后，在本线程栈/堆上构造 Connection，将其指针存入线程局部的 std::unordered_map<int std::unique_ptr>></int>，key 为 fd。
容易被忽略的点：当连接关闭时，close(fd) 必须在所属从Reactor 线程执行；如果业务逻辑触发异步关闭（比如 HTTP 请求处理完），需通过线程内消息队列把 “close fd=123” 任务投递回原线程，而不是在任意线程直接调用 close()。
- 禁止把
Connection*保存在全局容器中供多线程读写 - 缓冲区（
input_buffer_,output_buffer_）用std::string或自定义 ring buffer，避免锁，扩容在本线程完成 - 写操作若一次未发完（
writev()返回EAGAIN），需注册EPOLLOUT并等下次可写事件，而非轮询重试
线程间通信用无锁队列，别用条件变量模拟
主Reactor 向从Reactor 投递新连接、业务线程向网络线程推送响应数据，都依赖线程间消息通道。用 std::condition_variable + std::mutex 实现的队列在高并发下易成瓶颈，且难以保证 FIFO 和低延迟。推荐 moodycamel::ConcurrentQueue（C++11 兼容）或自己封装基于 std::atomic 的 SPSC 队列（单生产单消费场景足够）。
消息体应尽量小：例如只传 fd、sockaddr_storage 和长度，不要传整个 Connection 对象或大块数据。真实数据（如 HTTP body）应通过共享内存或零拷贝引用传递，或者由目标线程按需拉取。
- 主→从消息：结构体含
int fd、socklen_t addrlen、char addr[ sizeof(sockaddr_storage) ] - 从→主或业务→网络：用
std::shared_ptr包裹待发送数据，避免深拷贝 - 避免在消息处理中调用虚函数或复杂模板推导，防止 cache line 伪共享
真正难的不是模型拼装，而是边界情况：连接在 accept() 成功但尚未投递给从Reactor 时断开（此时 fd 已分配但无归属），或是 epoll_ctl(EPOLL_CTL_DEL) 后立刻 close() 导致内核释放 fd 号被复用。这些必须靠精细的状态标记（如 Connection::state_ 枚举）和原子操作来兜底。
