框架流程

框架详细流程分析

1. 框架总体架构

1.1 核心组件关系图

1.2 主要组件说明

提示

• Server: 主服务器结构，提供线程安全的服务器状态访问
• ServerInner: 包含服务器的所有核心组件，包括配置、路由、中间件和钩子
• Context: 请求-响应周期的应用上下文，提供线程安全的访问
• ArcRwLockStream: 线程安全的 TCP 流包装器，用于读写操作

2. 服务器启动流程

2.1 启动时序图

2.2 启动流程详细步骤

提示

• 服务器初始化: 创建 ServerInner 实例，初始化所有组件为默认值
• 配置设置: 设置主机地址、端口、缓冲区大小等参数
• 异常钩子初始化: 设置全局 panic 处理器
• TCP 监听器创建: 绑定到指定的地址和端口
• 连接接受循环: 持续接受新的 TCP 连接

3. 连接处理流程

3.1 连接处理时序图

3.2 Socket 配置流程

提示

服务器对每个新连接配置以下 Socket 选项：

• SO_LINGER: 控制连接关闭时的行为
• TCP_NODELAY: 禁用 Nagle 算法以减少延迟
• IP_TTL: 设置数据包生存时间

4. HTTP 请求处理流程

4.1 HTTP 处理时序图

4.2 HTTP 请求解析详细流程

5. WebSocket 处理流程

5.1 WebSocket 升级时序图

5.2 WebSocket 帧处理流程

6. Stream 处理流程

6.1 Stream 读写操作流程

6.2 Stream 并发安全机制

提示

Stream 使用 Arc<RwLock<TcpStream>> 实现线程安全：

• 读锁: 允许多个并发读操作
• 写锁: 确保写操作的独占访问
• 异步支持: 使用 tokio 的异步 RwLock

7. 中间件管道流程

7.1 中间件执行时序

7.2 钩子函数执行流程

提示

服务器支持多种类型的钩子函数：

• connected_hook: 新连接建立时执行
• pre_upgrade_hook: WebSocket 升级前执行
• request_middleware: 请求处理中间件
• response_middleware: 响应处理中间件

8. 路由匹配流程

8.1 路由匹配算法

8.2 路由类型说明

提示

路由匹配器将路由分为三类：

• 静态路由: 精确路径匹配
• 动态路由: 包含变量段的路径（如 /users/{id} ）
• 正则路由: 基于正则表达式的复杂匹配

9. 生命周期管理流程

9.1 生命周期状态转换

9.2 生命周期控制方法

提示

生命周期管理器提供以下控制方法：

• update_status(): 根据中止和保持连接标志更新状态
• is_abort(): 检查是否为中止状态
• keep_alive(): 返回连接保持状态

10. 广播系统集成

10.1 WebSocket 广播架构

10.2 广播消息流程

提示

WebSocket 插件支持两种广播模式：

• 点对点通信: 两个特定用户之间的私聊
• 群组通信: 多个用户在同一群组中的广播

11. 错误处理流程

11.1 异常处理时序图

11.2 全局异常钩子机制

提示

服务器在启动时设置全局异常处理器，能够：

• 捕获 panic 信息
• 关联到请求上下文
• 异步处理异常响应
• 自定义异常处理逻辑