核心内容摘要
FSMN-VAD真实案例：如何处理1小时长录音
你要的状态到底是哪一种Rocket 里最常用的两类状态Managed State全局托管状态应用级别、跨请求共享由 Rocket 统一管理生命周期按类型管理同一类型最多一个实例并发访问因此必须线程安全Send SyncRequest-Local State请求局部状态单次请求内有效请求结束即释放可缓存复用同一种类型在同一个请求里只生成一次特别适合“鉴权/解析/计算昂贵但可能被多次触发”的场景
Managed State全局状态的标准姿势
1 两步走manage State第一步启动时注入状态usestd::sync::atomic::AtomicUsize;structHitCount{count:AtomicUsize,}#[launch]fnrocket()-_{rocket::build().manage(HitCount{count:AtomicUsize::new(
})}第二步路由里用StateT取出来它是一个 request guarduserocket::State;usestd::sync::atomic::Ordering;#[get(/count)]fncount(hit_count:StateHitCount)-String{letnhit_count.count.load(Ordering::Relaxed);format!(Number of visits: {},n)}
2 一个类型只能 manage 一次这是优点不是限制Rocket “按类型唯一”意味着你不会在项目里出现两个同类型的全局对象互相打架依赖关系更清楚看到StateConfig就知道全局只有一个 Config如果你确实需要多个同类资源比如两个 Redis 客户端常见做法是用不同的“新类型”包装一层struct RedisA(Client)、struct RedisB(Client)或者用一个聚合结构struct AppState { redis_a: Client, redis_b: Client }
3 Rocket 会在启动期阻止“未托管状态”导致的运行时爆炸如果你在路由里写了StateT但启动时忘了.manage(T { .. })Rocket 会拒绝启动避免你上线后才发现某个路由一访问就 500。
这种检查背后是 Rocket
5 的 sentinel 机制把“启动前就能发现的错误”尽量前置到 launch 阶段。
在 Request Guard 里访问 Managed State更高级的复用方式因为State本身也是 request guard所以你可以在另一个 guard 的FromRequest实现里取全局状态常见于“读取配置、校验 token、加载缓存句柄”等场景。
两种方式都能用方式 Arequest.guard::StateT().awaituserocket::State;userocket::request::{self,FromRequest,Request};structMyConfig{user_val:String}structItemr(rstr);#[rocket::async_trait]implrFromRequestrforItemr{typeError();asyncfnfrom_request(req:rRequest_)-request::OutcomeSelf,(){req.guard::StateMyConfig().await.map(|cfg|Item(cfg.user_val))}}方式 Brequest.rocket().state::T()适合你想“直接查有没有”并在没有时自定义 forward / error。
这类模式的价值在于路由函数签名会变得非常干净很多业务约束被集中到了 guard路由只处理业务。
Request-Local State请求级缓存专治“同一请求里重复算多次”Rocket 的请求局部状态通过request.local_cache(|| ...)实现闭包在一个请求内最多执行一次之后同类型再取拿到的是缓存结果典型用途生成请求 ID、解析并缓存认证结果、记录请求耗时起点等。
下面是一个“每个请求生成唯一 ID并在请求内复用”的 guardusestd::sync::atomic::{AtomicUsize,Ordering};userocket::request::{self,FromRequest,Request};staticID_COUNTER:AtomicUsizeAtomicUsize::new(
;structRequestId(pubusize);#[rocket::async_trait]implrFromRequestrforrRequestId{typeError();asyncfnfrom_request(req:rRequest_)-request::OutcomeSelf,(){request::Outcome::Success(req.local_cache(||{RequestId(ID_COUNTER.fetch_add(1,Ordering::Relaxed))}))}}#[get(/)]fnid(id:RequestId)-String{format!(This is request #{}.,id.
}这个机制解决了三个痛点把数据绑定到请求本身而不是全局变量保证同一请求内只生成一次避免重复开销与不一致guard 可能在一次请求内被多次触发转发/多路由匹配/组合 guard缓存能直接省成本
数据库rocket_db_pools 的“三步接入法”Rocket
5 推荐用rocket_db_pools异步、ORM 无关接入数据库连接池流程非常固定
1 Cargo.toml 选择驱动 feature例如用 sqlx sqlite[dependencies.rocket_db_pools] version
0.
0 features [sqlx_sqlite]
2 Rocket.toml 配置数据库给数据库起个名字比如sqlite_logs[default.databases.sqlite_logs] url /path/to/database.sqlite
3 派生 Database attach 初始化 Connection 取连接#[macro_use]externcraterocket;userocket_db_pools::{Database,Connection};userocket_db_pools::sqlx::{self,Row};#[derive(Database)]#[database(sqlite_logs)]structLogs(sqlx::SqlitePool);#[get(/id)]asyncfnread(mutdb:ConnectionLogs,id:i
-OptionString{sqlx::query(SELECT content FROM logs WHERE id ?).bind(id).fetch_one(mut**db).await.and_then(|r|Ok(r.try_get(
?)).ok()}#[launch]fnrocket()-_{rocket::build().attach(Logs::init()).mount(/,routes![read])}你会注意到两点很舒服数据库连接就是一个 request guardConnectionLogs初始化连接池靠.attach(Logs::init())生命周期交给 Rocket
4 需要 sqlx 的额外能力自己把 sqlx feature 打开rocket_db_pools只开最小 feature。
你要用 sqlx 的宏、迁移等就显式依赖 sqlx[dependencies.sqlx] version
7 default-features false features [macros, migrate] [dependencies.rocket_db_pools] version
0.
0 features [sqlx_sqlite]
5 同步 ORM 怎么办如果你必须用 Diesel 这类同步 ORMRocket 也提供rocket_sync_db_pools。
但在 Rocket