docs: 更新README并添加文件上传mock配置

- 移除文件上传相关文档（已从代码中移除） - 新增未来计划：动态参数、HTTPS、可视化管理界面 - 添加 upload.yaml mock 配置文件
docs: 重构项目文档结构
2026-03-25 17:40:34 +08:00 · 2026-03-25 17:11:10 +08:00 · 2026-03-25 17:10:36 +08:00 · 2026-03-25 16:59:09 +08:00 · 2026-01-04 11:44:18 +08:00
11 changed files with 511 additions and 49 deletions
--- a/.claude/CLAUDE.md
+++ b/.claude/CLAUDE.md
@@ -0,0 +1,76 @@
+# Mock Server 开发指南
+
+## 构建与测试命令
+
+```bash
+cargo build              # 构建项目
+cargo run                # 启动服务 http://127.0.0.1:8080
+cargo test               # 运行所有测试
+cargo test <pattern>     # 运行匹配的测试（如 `cargo test router`）
+cargo clippy             # 代码检查
+cargo fmt                # 格式化代码
+```
+
+## 架构
+
+```
+┌─────────────┐    ┌──────────────┐    ┌────────────────┐
+│  loader.rs  │───▶│   router.rs  │───▶│   handler.rs   │
+│ YAML → 索引 │    │ HashMap 索引  │    │  请求/响应处理  │
+└─────────────┘    └──────────────┘    └────────────────┘
+       ▲                                       │
+       │         ┌──────────────────┐          │
+       └─────────│   main.rs        │◀─────────┘
+         热重载   │ AppState(RwLock)│
+                 └──────────────────┘
+```
+
+**数据流：**
+
+1. `MockLoader` 扫描 `mocks/` 目录，解析 YAML 为 `MockRule` 结构体
+2. 规则按路径首段建立索引（如 `/api/users` → key: `api`）存储于 `MockRouter`
+3. 请求匹配顺序：method → path → query_params → headers → body
+4. `AppState` 使用 `RwLock` 包装 router，支持线程安全的热重载
+
+## 核心类型 (config.rs)
+
+- `MockRule`: 完整规则（id, request, response, settings）
+- `RequestMatcher`: 请求匹配条件（method, path, query_params, headers, body）
+- `MockResponse`: 响应配置（status, headers, body）
+- `MockSource`: 枚举类型，支持单接口/多接口 YAML 格式
+
+## 请求匹配 (router.rs)
+
+- 路径首段 HashMap 查找，O(1) 获取候选规则
+- 候选集内线性扫描进行精确匹配
+- Body 匹配：支持 JSON 对象和字符串两种比较方式
+
+## 响应处理 (handler.rs)
+
+- 内联 body：直接返回
+- `file://` 前缀：从磁盘流式读取文件（低内存占用）
+- `settings.delay_ms`：模拟网络延迟
+
+## 文件结构
+
+```
+src/
+├── main.rs      # 入口，热重载监听，Axum 路由配置
+├── config.rs    # 数据结构定义（MockRule, RequestMatcher 等）
+├── loader.rs    # YAML 解析，目录扫描
+├── router.rs    # 路径首段索引，匹配逻辑
+├── handler.rs   # 统一请求处理器，文件流式响应
+└── upload.rs    # Multipart 文件上传处理
+
+tests/           # 集成测试（每个模块一个测试文件）
+mocks/           # YAML Mock 配置文件
+storage/         # 上传文件存储（按 YYYY-MM-DD 分目录）
+```
+
+## 开发注意事项
+
+- **Rust Edition 2024**，Axum 0.8.8
+- 测试使用 `tempfile` crate 处理临时文件
+- 请求体大小限制：10MB (handler.rs:30)
+- 热重载防抖时间：200ms (main.rs:46)
+- Header 匹配大小写不敏感 (router.rs:75)
--- a/.claude/rules/commit-spec.md
+++ b/.claude/rules/commit-spec.md
@@ -0,0 +1,89 @@
+---
+paths:
+  - "**/*"
+---
+
+## Git 提交消息规范
+
+AI 在生成 commit 消息时必须遵循以下格式。
+
+### 格式
+
+```
+<类型>(<范围>): <描述>
+
+[可选的详细说明]
+
+[可选的脚注]
+```
+
+### 类型（Type）
+
+| 类型 | 说明 |
+|------|------|
+| feat | 新功能（feature） |
+| fix | 修复 bug |
+| docs | 文档更新 |
+| style | 代码格式（不影响功能的变动） |
+| refactor | 代码重构（既非新功能也非 bug 修复） |
+| test | 添加或修改测试 |
+| chore | 构建系统或辅助工具的变动 |
+| perf | 性能优化 |
+
+### 范围（Scope）
+
+描述提交影响的功能模块或组件（可选）。
+
+### 描述（Description）
+
+- 简明扼要描述变动内容
+- 首字母小写
+- 不超过 100 个字符
+- 使用祈使句（如 "add" 而非 "added"）
+
+### 详细说明（Body）
+
+- 提供更多上下文和详细说明（可选）
+- 每行不超过 72 个字符
+- 说明"做了什么"和"为什么"
+
+### 脚注（Footer）
+
+- 破坏性变动说明（如 `BREAKING CHANGE: ...`）
+- 关闭的 Issue（如 `Closes #123`）
+
+### 示例
+
+**新功能：**
+
+```
+feat(api): 添加用户登录端点
+
+- 实现 JWT 认证逻辑
+- 添加登录表单前端组件
+- 更新用户服务处理登录请求
+
+Closes #45
+```
+
+**Bug 修复：**
+
+```
+fix(router): 修复路径匹配大小写问题
+
+路径匹配在某些情况下区分大小写导致无法正确路由到处理器。
+```
+
+**文档更新：**
+
+```
+docs: 更新 README 中的安装说明
+```
+
+**重构：**
+
+```
+refactor(handler): 简化响应处理逻辑
+
+将文件响应和内联响应的处理逻辑分离到独立函数中。
+```
--- a/.claude/rules/mock-spec.md
+++ b/.claude/rules/mock-spec.md
@@ -0,0 +1,89 @@
+---
+paths:
+  - "mocks/**/*.{yml,yaml}"
+---
+
+## YAML 配置规范
+
+AI 在生成 Mock 规则时必须遵循以下格式。
+
+### 字段说明
+
+| 字段 | 类型 | 必填 | 说明 |
+|------|------|:----:|------|
+| id | string | 是 | 规则唯一标识 |
+| request.method | string | 是 | HTTP 方法 (GET/POST/PUT/DELETE...) |
+| request.path | string | 是 | 请求路径，精确匹配 |
+| request.query_params | object | 否 | 查询参数匹配 |
+| request.headers | object | 否 | 请求头匹配（大小写不敏感） |
+| request.body | any | 否 | 请求体匹配，支持 JSON 对象或字符串 |
+| response.status | number | 是 | HTTP 状态码 |
+| response.headers | object | 否 | 响应头 |
+| response.body | string | 是 | 响应体，支持 file:// 前缀 |
+| settings.delay_ms | number | 否 | 延迟响应（毫秒） |
+
+### 匹配规则
+
+1. **路径精确匹配**（非前缀匹配）
+2. **请求头匹配大小写不敏感**
+3. **Body 匹配**支持 JSON 对象或字符串比较
+
+### 配置示例
+
+**单接口模式：**
+
+```yaml
+id: "login"
+request:
+  method: "POST"
+  path: "/api/login"
+  body: { "username": "test" }
+response:
+  status: 200
+  body: '{"token": "xxx"}'
+settings:
+  delay_ms: 100
+```
+
+**多接口模式（数组）：**
+
+```yaml
+- id: "get-users"
+  request: { method: "GET", path: "/api/users" }
+  response: { status: 200, body: '{"users": []}' }
+
+- id: "create-user"
+  request: { method: "POST", path: "/api/users" }
+  response: { status: 201, body: '{"id": 1}' }
+```
+
+**带查询参数和请求头：**
+
+```yaml
+id: "search-users"
+request:
+  method: "GET"
+  path: "/api/users"
+  query_params: { "role": "admin" }
+  headers: { "Authorization": "Bearer token" }
+response:
+  status: 200
+  headers: { "X-Total-Count": "100" }
+  body: '{"users": []}'
+```
+
+**文件响应：**
+
+```yaml
+id: "download-pdf"
+request:
+  method: "GET"
+  path: "/api/download"
+response:
+  status: 200
+  body: "file://./data/large-file.pdf"
+```
+
+> `file://` 支持两种路径：
+> - 相对路径：`file://./data/file.pdf`（相对于项目根目录）
+> - 绝对路径：`file:///C:/path/to/file.pdf`
--- a/.claude/settings.local.json
+++ b/.claude/settings.local.json
@@ -0,0 +1,8 @@
+{
+  "permissions": {
+    "allow": [
+      "Bash(find:*)",
+      "Bash(cargo search:*)"
+    ]
+  }
+}
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -60,6 +60,12 @@ dependencies = [
 "tracing",
 ]

+[[package]]
+name = "bitflags"
+version = "1.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
+
 [[package]]
 name = "bitflags"
 version = "2.10.0"
@@ -109,6 +115,15 @@ dependencies = [
 "percent-encoding",
 ]

+[[package]]
+name = "fsevent-sys"
+version = "4.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "76ee7a02da4d231650c7cea31349b889be2f45ddb3ef3032d2ec8185f6313fd2"
+dependencies = [
+ "libc",
+]
+
 [[package]]
 name = "futures-channel"
 version = "0.3.31"
@@ -271,12 +286,52 @@ dependencies = [
 "hashbrown",
 ]

+[[package]]
+name = "inotify"
+version = "0.11.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f37dccff2791ab604f9babef0ba14fbe0be30bd368dc541e2b08d07c8aa908f3"
+dependencies = [
+ "bitflags 2.10.0",
+ "inotify-sys",
+ "libc",
+]
+
+[[package]]
+name = "inotify-sys"
+version = "0.1.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e05c02b5e89bff3b946cedeca278abc628fe811e604f027c45a8aa3cf793d0eb"
+dependencies = [
+ "libc",
+]
+
 [[package]]
 name = "itoa"
 version = "1.0.16"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "7ee5b5339afb4c41626dde77b7a611bd4f2c202b897852b4bcf5d03eddc61010"

+[[package]]
+name = "kqueue"
+version = "1.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "eac30106d7dce88daf4a3fcb4879ea939476d5074a9b7ddd0fb97fa4bed5596a"
+dependencies = [
+ "kqueue-sys",
+ "libc",
+]
+
+[[package]]
+name = "kqueue-sys"
+version = "1.0.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ed9625ffda8729b85e45cf04090035ac368927b8cebc34898e7c120f52e4838b"
+dependencies = [
+ "bitflags 1.3.2",
+ "libc",
+]
+
 [[package]]
 name = "lazy_static"
 version = "1.5.0"
@@ -335,6 +390,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "a69bcab0ad47271a0234d9422b131806bf3968021e5dc9328caf2d4cd58557fc"
 dependencies = [
 "libc",
+ "log",
 "wasi",
 "windows-sys 0.61.2",
 ]
@@ -345,6 +401,8 @@ version = "0.1.0"
 dependencies = [
 "axum",
 "futures-util",
+ "notify",
+ "notify-debouncer-mini",
 "serde",
 "serde_json",
 "serde_yaml",
@@ -356,6 +414,42 @@ dependencies = [
 "walkdir",
 ]

+[[package]]
+name = "notify"
+version = "8.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "4d3d07927151ff8575b7087f245456e549fea62edf0ec4e565a5ee50c8402bc3"
+dependencies = [
+ "bitflags 2.10.0",
+ "fsevent-sys",
+ "inotify",
+ "kqueue",
+ "libc",
+ "log",
+ "mio",
+ "notify-types",
+ "walkdir",
+ "windows-sys 0.60.2",
+]
+
+[[package]]
+name = "notify-debouncer-mini"
+version = "0.6.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a689eb4262184d9a1727f9087cd03883ea716682ab03ed24efec57d7716dccb8"
+dependencies = [
+ "log",
+ "notify",
+ "notify-types",
+ "tempfile",
+]
+
+[[package]]
+name = "notify-types"
+version = "2.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5e0826a989adedc2a244799e823aece04662b66609d96af8dff7ac6df9a8925d"
+
 [[package]]
 name = "nu-ansi-term"
 version = "0.50.3"
@@ -442,7 +536,7 @@ version = "0.5.18"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "ed2bf2547551a7053d6fdfafda3f938979645c44812fbfcda098faae3f1a362d"
 dependencies = [
- "bitflags",
+ "bitflags 2.10.0",
 ]

 [[package]]
@@ -451,7 +545,7 @@ version = "1.1.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "146c9e247ccc180c1f61615433868c99f3de3ae256a30a43b49f67c2d9171f34"
 dependencies = [
- "bitflags",
+ "bitflags 2.10.0",
 "errno",
 "libc",
 "linux-raw-sys",
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -26,7 +26,8 @@ tracing-subscriber = "0.3.22"
 # 性能优化：快速哈希（可选，用于路由匹配）
 #dashmap = "7.0.0-rc2"
 # 热加载支持（扩展功能）
-#notify = "8.2.0"
+notify = "8.2.0"
+notify-debouncer-mini = "0.6.0"
 # 路径处理
 #pathdiff = "0.2.3"

--- a/README.md
+++ b/README.md
@@ -1,11 +1,76 @@
 # mock-server
-基于Rust/Axum的配置驱动型Mock服务，支持YAML配置、请求匹配、延迟响应、大文件流式返回等特性。
+
+基于 Rust/Axum 的配置驱动型 Mock 服务，支持 YAML 配置、请求匹配、热重载、延迟响应、大文件流式返回等特性。

 ## 特性
- 配置驱动：YAML定义API行为，无需修改代码
- 高性能：基于Rust异步运行时，哈希索引匹配请求
- 低内存：大响应体支持磁盘文件流式读取，不占用常驻内存
- 易扩展：模块化设计，支持动态占位符、热加载（规划中）
+
+- **配置驱动**：YAML 定义 API 行为，无需修改代码
+- **热重载**：`mocks/*.yaml` 变更自动生效，无需重启服务
+- **高性能**：基于 Rust 异步运行时，路径首段哈希索引 O(1) 匹配
+- **低内存**：大响应体支持 `file://` 协议从磁盘流式读取
+- **请求匹配**：支持 method、path、headers、query_params、body 多维度匹配

 ## 快速开始
-### 1. 安装依赖
+
+### 1. 安装依赖
+
+确保已安装 Rust 工具链：
+
+```bash
+curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh
+```
+
+### 2. 构建与运行
+
+```bash
+cargo build              # 构建项目
+cargo run                # 启动服务 http://127.0.0.1:8080
+cargo test               # 运行所有测试
+cargo test <pattern>     # 运行匹配的测试（如 cargo test router）
+cargo clippy             # 代码检查
+cargo fmt                # 格式化代码
+```
+
+## 文件结构
+
+```
+src/
+├── main.rs      # 入口，热重载监听，Axum 路由配置
+├── config.rs    # 数据结构定义（MockRule, RequestMatcher 等）
+├── loader.rs    # YAML 解析，目录扫描
+├── router.rs    # 路径首段索引，匹配逻辑
+└── handler.rs   # 统一请求处理器，文件流式响应
+
+tests/           # 集成测试（每个模块一个测试文件）
+mocks/           # YAML Mock 配置文件
+```
+
+## Mock 配置
+
+详细配置规范请参考 [.claude/rules/mock-spec.md](.claude/rules/mock-spec.md)
+
+## 未来计划
+
+### 1. 动态参数与模板响应
+
+支持路径参数捕获（如 `/api/users/{id}`）和响应模板，可在响应中引用请求参数：
+
+```yaml
+# 请求: GET /api/users/123
+# 响应: { "id": "123", "name": "User 123" }
+```
+
+### 2. HTTPS 支持
+
+内置 TLS/SSL 支持，提供安全的 HTTPS 服务。
+
+### 3. 可视化管理界面
+
+- **TUI（终端界面）**：基于 Ratatui 的交互式终端管理
+- **GUI（图形界面）**：Web Dashboard 或桌面应用，可视化管理 Mock 规则
+
+> 此功能需要深入讨论，欢迎提出建议和需求
+
+## 许可证
+
+MIT
--- a/mocks/v1/auth/login.yaml
+++ b/mocks/v1/auth/login.yaml
@@ -25,4 +25,4 @@ response:
      "msg": "success"
    }
 settings:
-  delay_ms: 200 # 模拟真实网络延迟
+  delay_ms: 2000 # 模拟真实网络延迟
--- a/mocks/v1/upload.yaml
+++ b/mocks/v1/upload.yaml
@@ -0,0 +1,23 @@
+id: "upload_file"
+request:
+  method: "POST"
+  path: "/api/v1/upload"
+  headers:
+    Content-Type: "multipart/form-data"
+response:
+  status: 200
+  headers:
+    Content-Type: "application/json"
+  body: >
+    {
+      "code": 0,
+      "data": {
+        "filename": "example.txt",
+        "path": "storage/2024-01-15/example.txt",
+        "size": 1024,
+        "url": "/storage/2024-01-15/example.txt"
+      },
+      "msg": "upload success"
+    }
+settings:
+  delay_ms: 100
--- a/src/handler.rs
+++ b/src/handler.rs
@@ -5,31 +5,29 @@ use axum::{
    response::{IntoResponse, Response},
 };
 use std::collections::HashMap;
-use std::sync::Arc;
-use tokio_util::io::ReaderStream; // 需在 Cargo.toml 确认有 tokio-util
+use std::sync::{Arc, RwLock}; // 必须引入 RwLock
+use tokio_util::io::ReaderStream;

 use crate::router::MockRouter;

-/// 共享的应用状态
+/// 共享的应用状态，router 现在由 RwLock 保护以支持热重载
 pub struct AppState {
-    pub router: MockRouter,
+    pub router: RwLock<MockRouter>,
 }

 /// 全局统一请求处理函数
 pub async fn mock_handler(
-    State(state): State<Arc<AppState>>,
+    State(state): State<Arc<AppState>>, // State 必须是第一个或靠前的参数
    method: Method,
    headers: HeaderMap,
    Query(params): Query<HashMap<String, String>>,
-    req: Request<Body>,
+    req: Request<Body>, // Request<Body> 必须是最后一个参数
 ) -> impl IntoResponse {
-    // let path = req.uri().path();
-    // 1. 【关键】将需要的数据克隆出来，断开与 req 的借用关系
+    // 1. 提取 path 和 method
    let path = req.uri().path().to_string();
    let method_str = method.as_str().to_string();
-    // 1. 将 Axum HeaderMap 转换为简单的 HashMap 供 Router 使用

-    // 2. 现在可以安全地消耗 req 了，因为上面没有指向 req 内部的引用了
+    // 2. 读取请求 body（用于 body 字段匹配）
    let body_bytes = match axum::body::to_bytes(req.into_body(), 10 * 1024 * 1024).await {
        Ok(bytes) => bytes,
        Err(_) => {
@@ -39,43 +37,43 @@ pub async fn mock_handler(
                .unwrap();
        }
    };
-
    let incoming_json: Option<serde_json::Value> = serde_json::from_slice(&body_bytes).ok();

+    // 3. 将 Axum HeaderMap 转换为简单的 HashMap
    let mut req_headers = HashMap::new();
    for (name, value) in headers.iter() {
        if let Ok(v) = value.to_str() {
            req_headers.insert(name.as_str().to_string(), v.to_string());
        }
    }
-    // 2. 执行匹配逻辑
-    if let Some(rule) =
-        state
-            .router
-            .match_rule(&method_str, &path, &params, &req_headers, &incoming_json)
-    {
-        // 3. 处理模拟延迟
+
+    // 4. 执行匹配逻辑：先获取读锁 (Read Lock)
+    let maybe_rule = {
+        let router = state.router.read().expect("Failed to acquire read lock");
+        router.match_rule(&method_str, &path, &params, &req_headers, &incoming_json).cloned()
+        // 此处使用 .cloned() 以便尽早释放读锁，避免阻塞热重载写锁
+    };
+
+    if let Some(rule) = maybe_rule {
+        // 5. 处理模拟延迟
        if let Some(ref settings) = rule.settings {
            if let Some(delay) = settings.delay_ms {
                tokio::time::sleep(std::time::Duration::from_millis(delay)).await;
            }
        }

-        // 4. 构建响应基础信息
+        // 6. 构建响应
        let status = StatusCode::from_u16(rule.response.status).unwrap_or(StatusCode::OK);
        let mut response_builder = Response::builder().status(status);

-        // 注入 YAML 定义的 Header
        if let Some(ref h) = rule.response.headers {
            for (k, v) in h {
-                // println!("{}:{}",k.clone(), v.clone());
                response_builder = response_builder.header(k, v);
            }
        }

-        // 5. 执行 Smart Body 协议逻辑
+        // 7. Smart Body 逻辑
        if let Some(file_path) = rule.response.get_file_path() {
-            // A. 文件模式：异步打开文件并转换为流，实现低内存占用
            match tokio::fs::File::open(file_path).await {
                Ok(file) => {
                    let stream = ReaderStream::new(file);
@@ -91,13 +89,12 @@ pub async fn mock_handler(
                    .unwrap(),
            }
        } else {
-            // B. 内联模式：直接返回字符串内容
+            // 内联模式：直接返回字符串内容
            response_builder
                .body(Body::from(rule.response.body.clone()))
                .unwrap()
        }
    } else {
-        println!("请求头{:?}", req_headers.clone());
        // 匹配失败返回 404
        Response::builder()
            .status(StatusCode::NOT_FOUND)
--- a/src/main.rs
+++ b/src/main.rs
@@ -1,43 +1,63 @@
 use std::net::SocketAddr;
 use std::path::Path;
-use std::sync::Arc;
+use std::sync::{Arc, RwLock};
+use std::time::Duration;
 use axum::{routing::any, Router};
+use notify_debouncer_mini::{new_debouncer, notify::*};
+
 use mock_server::loader::MockLoader;
 use mock_server::router::MockRouter;
 use mock_server::handler::{mock_handler, AppState};

 #[tokio::main]
 async fn main() {
-    // 1. 初始化日志（建议添加，方便观察加载情况）
-    // 需要在 Cargo.toml 添加 tracing-subscriber = "0.3"
    tracing_subscriber::fmt::init();

-    // 2. 递归加载所有的 YAML 配置文件
    let mocks_dir = Path::new("./mocks");
    if !mocks_dir.exists() {
-        println!("Warning: 'mocks/' directory not found. Creating it...");
        std::fs::create_dir_all(mocks_dir).unwrap();
    }

+    // 1. 初始加载
    println!("Scanning mocks directory...");
    let index = MockLoader::load_all_from_dir(mocks_dir);
-
-    // 3. 构建路由引擎并包装为共享状态
-    let router_engine = MockRouter::new(index);
    let shared_state = Arc::new(AppState {
-        router: router_engine,
+        router: RwLock::new(MockRouter::new(index)),
    });

-    // 4. 配置 Axum 路由
-    // 使用 any(mock_handler) 意味着它会接管所有 HTTP 方法和所有路径的请求
+    // 2. 设置热加载监听器
+    let state_for_watcher = shared_state.clone();
+    let watch_path = mocks_dir.to_path_buf();
+    let (tx, rx) = std::sync::mpsc::channel();
+
+    // 200ms 防抖，防止编辑器保存文件时产生多次干扰
+    let mut debouncer = new_debouncer(Duration::from_millis(200), tx).unwrap();
+    debouncer.watcher().watch(&watch_path, RecursiveMode::Recursive).unwrap();
+
+    // 启动异步任务监听文件变动
+    tokio::spawn(async move {
+        while let Ok(res) = rx.recv() {
+            match res {
+                Ok(_) => {
+                    println!("🔄 Detecting changes in mocks/, reloading...");
+                    let new_index = MockLoader::load_all_from_dir(&watch_path);
+                    // 获取写锁 (Write Lock) 更新索引
+                    let mut writer = state_for_watcher.router.write().expect("Failed to acquire write lock");
+                    *writer = MockRouter::new(new_index);
+                    println!("✅ Mocks reloaded successfully.");
+                }
+                Err(e) => eprintln!("Watcher error: {:?}", e),
+            }
+        }
+    });
+
+    // 3. 配置 Axum 路由
    let app = Router::new()
        .fallback(any(mock_handler))
        .with_state(shared_state);

-    // 5. 启动服务
    let addr = SocketAddr::from(([127, 0, 0, 1], 8080));
-    println!("🚀 Rust Mock Server is running on http://{}", addr);
-    println!("Ready to handle requests based on your YAML definitions.");
+    println!("🚀 Server running at http://{}", addr);

    let listener = tokio::net::TcpListener::bind(addr).await.unwrap();
    axum::serve(listener, app).await.unwrap();
Author	SHA1	Message	Date
CNWei	9c1d0e16b4	docs: 更新README并添加文件上传mock配置 - 移除文件上传相关文档（已从代码中移除） - 新增未来计划：动态参数、HTTPS、可视化管理界面 - 添加 upload.yaml mock 配置文件	2026-03-25 17:40:34 +08:00
CNWei	b579a835de	docs: 重构项目文档结构 - 将 CLAUDE.md 移至 .claude/ 目录，精简为 AI 开发指南 - 扩充 README.md 为完整的用户文档 - 新增 rules/mock-spec.md: YAML 配置生成规范 - 新增 rules/commit-spec.md: Git 提交消息格式规范 - 从 .gitignore 移除 .claude/ 目录以便跟踪 Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>	2026-03-25 17:11:10 +08:00
CNWei	e218ab04fe	feat: 优化CLAUDE.md - 优化优化CLAUDE.md	2026-03-25 17:10:36 +08:00
CNWei	18e0ccad58	merge: 合并0321分支的热重载功能与body字段匹配支持	2026-03-25 16:59:09 +08:00
CNWei	3097a16465	feat: 实现配置热重载功能 - 引入热加载机制：集成 `notify-debouncer-mini` 监听 `./mocks` 目录，实现 YAML 变动自动重载。 - 优化并发控制：将 `MockRouter` 包装在 `RwLock` 中，确保 Web 线程（读）与监控线程（写）的数据安全。 - 增强系统健壮性：增加防抖处理防止频繁 IO 触发重载。	2026-01-04 11:44:18 +08:00