# 格式化
cargo fmt --all
# 静态检查，warning 当 error
cargo clippy --all-targets -- -D warnings
# 测试
cargo test --all-features
# CVE 扫描（独立安装）
cargo audit
# 许可证/重复依赖检查（独立安装）
cargo deny check
# 检测未使用依赖
cargo machete

edition：新项目默认 edition = "2024"，老项目保持 2021 不强迁。

版本基线（写死，避免重复决策）：

Tokio 1.x，Axum 0.8，tower-http 0.6
serde 1、tracing 0.1、tracing-subscriber 0.3
DB：sqlx 0.8（runtime-tokio-rustls）

命名约定

类型	规则	示例
模块/文件	snake_case	`user_service.rs`
函数/变量	snake_case	`fetch_user`, `db_pool`
类型/Trait/Enum	UpperCamelCase	`UserRepo`, `AppError`
常量/静态	SCREAMING_SNAKE_CASE	`MAX_RETRY`
泛型	单大写或 UpperCamelCase	`T`, `Req`, `Resp`
生命周期	短小写	`'a`, `'ctx`

禁止：common、util、helper、base 等无意义模块名。模块按职责命名（api、db、service）。

模块组织

参照 apple-store-price-rs / org-site-backend 的实证拆分，按职责切文件，不堆 lib.rs：

src/
├── main.rs          # 仅 bootstrap：日志初始化、读配置、建路由、启服务
├── config.rs        # 配置加载（env / toml）
├── error.rs         # AppError + IntoResponse impl
├── db.rs            # 数据库连接池/迁移
├── api.rs           # 路由聚合 + handler
├── service/         # 业务逻辑（无副作用层）
│   └── user.rs
└── models.rs        # 领域类型 + serde 派生

可见性：pub(crate) 优先于 pub。只在确实要对外暴露时才用 pub。

错误处理（核心）

分场景选边：

场景	选择	理由
库 crate	`thiserror`	调用方需要按变体匹配
二进制应用顶层	`anyhow`	只关心"成功/失败 + 上下文"
跨边界（handler / 公共 API）	自定义 `AppError` + `IntoResponse`	控制对外错误形态

禁止生产代码出现：

.unwrap() / .expect()（仅测试和 const 上下文可用）
panic!()（仅用于"逻辑上不可达"且带 SAFETY 注释）

clippy 配置（在 Cargo.toml 或 clippy.toml）：

[lints.clippy]
unwrap_used = "deny"
expect_used = "deny"
panic = "deny"

错误传播用 ?，跨类型用 From 实现自动转换：

#[derive(thiserror::Error, Debug)]
pub enum AppError {
    #[error("db error: {0}")]
    Db(#[from] sqlx::Error),
    #[error("not found")]
    NotFound,
    #[error("bad request: {0}")]
    BadRequest(String),
}

详见 references/async-axum.md 的 IntoResponse 实现。

异步编程红线

1. 阻塞调用必须丢到 spawn_blocking

// ❌ 在 async fn 里直接调用阻塞 API
let data = std::fs::read("big.bin")?;

// ✅
let data = tokio::task::spawn_blocking(|| std::fs::read("big.bin")).await??;

判定标准：CPU 密集 > 10ms、std::fs、std::thread::sleep、同步 DB driver、reqwest::blocking —— 都必须 spawn_blocking。

2. 不要跨 .await 持有 std::sync::Mutex

// ❌ 编译能过，运行时死锁/性能崩溃
let g = std_mutex.lock().unwrap();
do_async().await;

// ✅ 用 tokio::sync::Mutex
let g = tokio_mutex.lock().await;
do_async().await;

3. Rc / RefCell 不能跨 .await：违反 Send 边界，编译报错，改用 Arc / Mutex。

4. tokio::select! 分支必须取消安全

取消安全 ✅：tokio::time::sleep、channel.recv、tokio::io::AsyncRead 标记方法
取消不安全 ❌：自己实现的 async fn（取消时可能丢数据）

不确定时，把状态保存到 select! 外部变量，分支只读写本地变量。

5. 优雅停机：用 tokio::signal::ctrl_c() + axum::serve(...).with_graceful_shutdown()。

更多陷阱见 references/async-axum.md。

所有权与借用最小集

函数参数：

想要	用	不要用
只读字符串	`&str`	`&String`
只读切片	`&[T]`	`&Vec<T>`
路径	`&Path`	`&PathBuf` / `&str`
字符串入参可能多种来源	`impl AsRef<str>`	多个重载

共享决策树：

需要跨线程共享？
├── 否 → 用 Box<T> 或值传递
└── 是 → Arc<T>
        ├── 不可变共享 → Arc<T>
        ├── 读多写少 → Arc<RwLock<T>>
        └── 读写均衡 → Arc<Mutex<T>>

Clone 不是坏事，但循环内 Clone 大对象要警觉，考虑 Arc 或 Cow<'_, T>。

Axum 实战要点

type AppState = Arc<InnerState>;

let app = Router::new()
    .nest("/api/users", user::routes())     // 按模块拆 + nest
    .layer(TraceLayer::new_for_http())       // 日志中间件
    .layer(TimeoutLayer::new(Duration::from_secs(30)))
    .with_state(state);

State 一律 Arc 包装，不要克隆裸结构体
Handler 错误类型实现 IntoResponse，统一对外形态（status + json body）
路由按模块拆 fn routes() -> Router<AppState>，避免 main.rs 膨胀
中间件走 tower-http：CORS / 超时 / 限流 / 日志 / 静态文件

详见 references/async-axum.md。

依赖管理

版本指定：Cargo.toml 默认 caret（"1" 等价 ^1），不要锁死 =1.2.3 除非有兼容性问题。

features 显式声明，禁止盲依赖默认值：

# ✅ 显式开启需要的 feature
tokio = { version = "1", features = ["macros", "rt-multi-thread", "signal"] }
reqwest = { version = "0.12", default-features = false, features = ["json", "rustls-tls"] }

TLS 选 rustls，避免 openssl（跨平台编译麻烦）。

升级前先 dry-run：

cargo update --dry-run
# 独立安装
cargo outdated

Cargo.lock 二进制项目必须提交，库项目不提交。

测试规范

// 异步测试用 #[tokio::test]
#[tokio::test]
async fn fetches_user() {
    let svc = test_service().await;
    let user = svc.find(1).await.unwrap();   // 测试代码可以 .unwrap()
    assert_eq!(user.name, "alice");
}

// 表驱动：可选用 rstest crate
#[rstest::rstest]
#[case(1, 2, 3)]
#[case(-1, 1, 0)]
fn adds(#[case] a: i32, #[case] b: i32, #[case] expected: i32) {
    assert_eq!(a + b, expected);
}

单元测试：#[cfg(test)] mod tests { ... } 紧贴被测代码
集成测试：tests/ 顶层目录，每个文件独立 crate
测试中允许 .unwrap()（失败即测试失败，正是预期）

unsafe 红线

业务代码原则禁用 unsafe。

如必须使用（FFI / 极端性能场景）：

块前必须有 // SAFETY: ... 注释，说明保持的不变量
缩小 unsafe 块到最小范围
优先封装成 safe API 对外暴露
走 code review，单独标记审查

性能要点

陷阱	解决
循环内 `format!` / 字符串拼接	用 `String::with_capacity` + `write!`
Vec 频繁扩容	`Vec::with_capacity(n)`
循环内 `.clone()` 大对象	借用或 `Arc`
`Box<dyn Trait>` 滥用	优先泛型 `<T: Trait>`（静态分发）
`String` 当 key	优先 `&str` 或 `Cow<'static, str>`
阻塞 IO 在 async 里	`spawn_blocking`（见异步章节）

性能分析：

cargo build --release
# 火焰图（独立安装）
cargo flamegraph
# criterion 基准测试
cargo bench

详细参考

文件	内容
`references/rust-style.md`	命名细则、`From`/`TryFrom` 规范、newtype 模式、迭代器优先
`references/async-axum.md`	spawn_blocking 边界、select! 取消安全、tower 中间件组合、IntoResponse 模式、shutdown 信号

📋 本回复遵循：rust-dev - [具体章节]

rust-dev

Rust 开发规范

工具链