时间轮为长连接绑定毫秒级活动倒计时,收包即重置位置,超时触发含SO_LINGER、epoll移除、异步资源清理的完整关闭流水线,并叠加TCP保活与心跳校验双重兜底。

核心思路是:用时间轮为每个长连接绑定一个“活动倒计时”,每次收到数据就刷新;倒计时归零时,自动触发资源释放逻辑(关闭 socket、回收内存、清理上下文),整个过程不依赖外部轮询,毫秒级响应、O(1)开销。
时间轮与连接生命周期强绑定
每个新建立的 socket 连接,在 accept 后立即注册进时间轮,初始超时值设为 30 秒(可根据业务调整)。关键不是“定时检查”,而是“连接一活跃就重置其在时间轮中的位置”——比如使用哈希槽+双向链表结构,刷新操作只需从旧槽摘下、插入新槽对应位置,耗时恒定。
- 注册时机:connection_established 事件中完成,非首次读写时才加,避免遗漏
- 刷新时机:每次成功 read 到有效协议包后调用 reset(),不是每 recv() 都刷,防止高频心跳打乱轮子分布
- 到期回调:时间轮线程检测到某槽位链表头节点超时,直接调用预设的 close_handler(conn_id)
自动关闭资源的具体动作
到期回调不是简单调用 close(),而是一套轻量但完整的清理流水线:
- 立即 setsockopt(sockfd, SOL_SOCKET, SO_LINGER, &linger_off, sizeof(linger_off)),确保四次挥手不阻塞
- 从 epoll/kqueue 中删除该 fd,并标记 conn 结构体状态为 CLOSING
- 异步释放关联资源:如解绑用户 session、清除 Redis 在线标识、更新数据库 last_active_time
- 若使用连接池,将该连接对象归还至 idle 队列,而非直接 free —— 复用比重建更省 CPU
应对异常场景的兜底设计
仅靠时间轮还不够,需叠加两层防护:
- TCP 层保活:启用 keepalive(tcp_keepalive_time=60s),内核主动探测死链,探测失败后触发 FIN,时间轮感知到 EPOLLIN/EPOLLRDHUP 后快速归档
- 应用层心跳校验:要求客户端每 15 秒发 PING,服务端在 reset() 前校验是否为合法心跳包;连续 2 次无心跳且无业务数据,强制提前触发超时
- 资源泄漏熔断:监控连接数突增但 time_wheel.pending_tasks 持续 >95%,自动降级为最小超时(如 5 秒),防雪崩
代码层面的关键控制点
以 Linux + timerfd + epoll 为例,避免常见坑:
- timerfd 必须用 CLOCK_MONOTONIC 创建,禁用 CLOCK_REALTIME(系统时间跳变会导致批量误杀)
- 时间轮 tick 精度设为 100ms 即可,太高无意义,反而增加 epoll_wait 唤醒频率
- close_handler 中禁止阻塞操作(如同步写日志、远程 HTTP 调用),全部投递到异步 worker 线程
- 每个连接对象必须带唯一 trace_id,超时关闭时打点日志:“conn[abc123] closed by time_wheel, idle_sec=32.7”










