# Axum v0.8.x 开发指南 ## 处理程序使用 axum::{extract::{Path、Query、State、Json}、response::IntoResponse、http::StatusCode}；异步 fn get_user( 状态（池）：状态，路径（id）：路径， ) -> 结果, AppError> { 让 user = sqlx::query_as!(User, "SELECT * FROM users WHERE id = $1", id) .fetch_one(&pool).await?; 好的（Json（用户）） } 异步 fn create_user( 状态（池）：状态， Claims: Claims, // 自定义提取器 Json(有效负载): Json, ) -> 结果<(StatusCode, Json<用户>), AppError> { // ... 好的（（状态代码::已创建，Json（用户））） } ## 路由 fn app() -> Router { 路由器::new() .route("/", 获取(根)) .route("/users", get(list_users).post(create_user)) .route("/users/:id", get(get_user).put(update_user).delete(delete_user)) .nest("/api", api_routes()) .layer(middleware_stack()) .with_state(状态) } ## 错误处理 pub 结构应用程序错误 { 发布代码：StatusCode，发布消息：字符串， } 为 AppError 实现 IntoResponse { fn into_response(self) -> 响应 { (self.code, Json(json!({"error": self.message}))).into_response() } } impl From for AppError { fn from(err: sqlx::Error) -> Self { 匹配错误{ sqlx::Error::RowNotFound => AppError { 代码： StatusCode::NOT_FOUND， message: "资源未找到".into(), }, _ => 应用程序错误{ 代码：StatusCode::INTERNAL_SERVER_ERROR， message: "数据库错误".into(), }, } } } ## 中间件 async fnlogging_middleware(req: 请求，下一个: 下一个) -> 响应 { let method = req.method().clone(); 让 uri = req.uri().clone(); 让响应 = next.run(req).await; 跟踪::info!("{} {} -> {}", method, uri, response.status()); 反应 } 让应用程序 = Router::new() .route("/", get(处理程序)) .layer(中间件::from_fn(logging_middleware)); ## 自定义提取器 pub struct Claims { pub user_id: i32, pub role: String } #[异步特征] impl FromRequestParts for Claims { 类型拒绝=应用程序错误； async fn from_request_parts(parts: &mut Parts, _state: &S) -> Result { 让 token = parts.headers.get("cookie") .and_then(|v| v.to_str().ok()) .and_then(extract_token) .ok_or(AppError::unauthorized("没有令牌"))?; validate_jwt(&令牌) } } ## 身份验证中间件 async fn auth_middleware(claims: Claims, req: Request, next: Next) -> Response { next.run(req).await } 让 protected = Router::new() .route("/个人资料", 获取(个人资料)) .layer(中间件::from_fn(auth_middleware)); ## 跨域资源共享使用 tower_http::cors::{CorsLayer, Any}; 让 cors = CorsLayer::new() .allow_origin(任意) .allow_methods（任何） .allow_headers（任意） .allow_credentials(true); ## 响应标头和 Cookie async fn login() -> impl IntoResponse { 让 cookie = 格式！( “token={};HttpOnly;安全;SameSite=Strict;Path=/;Max-Age={}”, 令牌，最大年龄）； ([(标题::SET_COOKIE, cookie)], Json(响应)) } ## 文件上传异步 fn upload(mut multipart: Multipart) -> Result<(), AppError> { while let Some(field) = multipart.next_field().await？ { 让 name = field.name().unwrap_or_default().to_string(); 让数据 = field.bytes().await?; // 处理文件 } 好的(()) } ## 注释 1. **Extractor order** : 把`State`放在最后（其他可能会消耗body） 2. **一致的错误类型**：跨应用程序使用单个AppError 3. **中间件顺序** ：执行外层→内层（与层顺序相反） 4. **状态类型** ：必须实现`Clone`（通常包裹在`Arc`中）

Axum Guide

包含技能