axum::Router
结构体
pub struct Router<S = ()> { /* private fields */}
用于组合处理程序和服务的路由器类型。
实现
impl<S> Router<S>
where
S: Clone + Send + Sync + 'static,
新建路由器
pub fn new() -> Self
创建一个新的路由器,除非您添加额外的路由,否则将对所有请求响应404未找到。
添加另一个路由到路由器
pub fn route(self, path: &str, method_router: MethodRouter<S>) -> Self
path
: 是由/
分割的路径段字符串。每个段可能是静态的、捕获的或者是通配符。method_router
: 是一个MethodRouter
,它将请求方法映射到处理程序。method_router
通常会是类似于get
的方法路由器中的处理程序。
静态路径
例如:
/
/foo
/foo/bar
如果传入的请求路径完全匹配,则将调用相应的服务。
捕获
例如:
/:key
/foo/:key
/users/:id/tweets
路径可以包含类似于/:key
的段,它匹配任何单个段,并将存储在key
处捕获的值。
捕获的值可以是零长度,除了无效路径//
捕获可以使 用Path
进行提取。
MatchedPath
可以用于提取匹配路径,而不是实际路径。
通配符
路径可以以/*key
结尾,匹配所有段并捕获的段存储在key
中。
例如:
/*key
/users/*path
/:id/:repo/*tree
请注意,/*key
不匹配空段。因此:
/*key
不匹配/
,但匹配/a
,/a/
等。/x/*key
不匹配/x
或/x/
,但匹配/x/a
,/x/a/
等。
还可以使用 Path
来提取通配符捕获。
请注意,不包括前导斜杠,即对于路由 /foo/*rest
和路径 /foo/bar/baz
,
rest
的值将是 bar/baz
。
接受多种方法
要接受同一路由的多个方法,您可以同时添加所有处理程序。
use axum::{Router, routing::{get, delete}, extract::Path};
let app = Router::new().route(
"/",
get(get_root).post(post_root).delete(delete_root),
);
async fn get_root() {}
async fn post_root() {}
async fn delete_root() {}
或者你也可以一一添加:
let app = Router::new()
.route("/", get(get_root))
.route("/", post(post_root))
.route("/", delete(delete_root));
更多例子
use axum::{Router, routing::{get, delete}, extract::Path};
let app = Router::new()
.route("/", get(root))
.route("/users", get(list_users).post(create_user))
.route("/users/:id", get(show_user))
.route("/api/:version/users/:id/action", delete(do_users_action))
.route("/assets/*path", get(serve_asset));
async fn root() {}
async fn list_users() {}
async fn create_user() {}
async fn show_user(Path(id): Path<u64>) {}
async fn do_users_action(Path((version, id)): Path<(String, u64)>) {}
async fn serve_asset(Path(path): Path<String>) {}
Panics
如果路径与另一个路由重叠,则会发生panic
use axum::{routing::get, Router};
let app = Router::new()
.route("/", get(|| async {}))
.route("/", get(|| async {}));
静态路由 /foo
和动态路由 /:key
不被视为重叠,并且 /foo
将优先。
如果路径为空,也会引发 panic。
路由服务
添加另一个路由到路由器调用一个服务
pub fn route_service<T>(self, path: &str, service: T) -> Self
where
T: Service<Request, Error=Infallible> + Clone + Send + 'static,
T::Response: IntoResponse,
T::Future: Send + 'static,
示例:
use axum::{
Router,
body::Body,
routing::{any_service, get_service},
extract::Request,
http::StatusCode,
error_handling::HandleErrorLayer,
};
use tower_http::services::ServeFile;
use http::Response;
use std::{convert::Infallible, io};
use tower::service_fn;
let app = Router::new()
.route(
"/",
any_service(service_fn(|_: Request| async {
let res = Response::new(Body::from("Hi from `GET /`"));
}))
)
.route_service(
"/foo",
service_fn(|req: Request| async move {
let body = Body::from(format!("Hi from `{}` /foo", req.method()))
let res = Response::new(body);
Ok::<_, Infallible>(res)
})
)
.route_service(
"/static/Cargo.toml",
ServeFile::new("Cargo.toml"),
);
以这种方式路由到任意服务会对背压(Service::poll_ready
)产生复杂性。
有关更多详细信息,请参阅服务路由和背压模块。
由于相同的原因而出现panic,或者尝试将路由到Router时也会发生panic。
use axum::{routing::get, Router};
let app = Router::new().route_service(
"/",
Router::new().route("/foo", get(|| async {})),
);
使用Router::nest
替换
在某个路径上嵌套一个路由器。
这样可以将应用程序分解成更小的部分,并将它们组合在一起。
pub fn nest(self, path: &str, router: Router<S>) -> Self
示例:
use axum::{
routing::{get, post},
Router,
};
let user_routes = Router::new().route("/:id", get(|| async {}));
let team_routes = Router::new().route("/", post(|| async {}));
let api_routes = Router::new()
.nest("/users", user_routes)
.nest("/teams", team_routes);
let app = Router::new().nest("/api", api_routes);
// Our app now accepts
// - GET /api/users/:id
// - POST /api/teams
URI如何变化
请注意,嵌套路由将无法看到原始请求URI,而是会剥去匹配的前缀。
这对于像静态文件服务之类的服务工作是必要的。
如果需要原始请求URI,请使·OriginalUri
。
外部路由的捕获
在使用嵌套动态路由时要小心,因为嵌套还会从外部路由中捕获:
use axum::{
extract::Path,
routing::get,
Router,
};
use std::collections::HashMap;
async fn users_get(Path(params): Path<HashMap<String, String>>) {
// Both `version` and `id` were captured even though `users_api` only
// explicitly captures `id`.
let version = params.get("version");
let id = params.get("id");
}
let users_api = Router::new().route("/users/:id", get(users_get));
let app = Router::new().nest("/:version/api", users_api);
与通配符路由的区别
嵌套路由类似于通配符路由。 不同之处在于通配符路由仍然可以看到整个 URI,而嵌套路由将会去掉前缀:
use axum::{routing::get, http::Uri, Router};
let nested_router = Router::new()
.route("/", get(|uri: Uri| async {
// `uri` will _not_ contain `/bar`
}));
let app = Router::new()
.route("/foo/*rest", get(|uri: Uri| async {
// `uri` will contain `/foo`
}))
.nest("/bar", nested_router);
后备方案
如果嵌套路由器没有自己的回退,则将从外部路由器继承回退:
use axum::{routing::get, http::StatusCode, handler::Handler, Router};
async fn fallback() -> (StatusCode, &'static str) {
(StatusCode::NOT_FOUND, "Not Found")
}
let api_routes = Router::new().route("/users", get(|| async {}));
let app = Router::new()
.nest("/api", api_routes)
.fallback(fallback);
在这里,像 GET /api/not-found
这样的请求将进入 api_routes
,
但由于它没有匹配的路由,也没有自己的回退,它将调用外部路由器的回退,即回退功能。
如果嵌套路由器有自己的回退,则外部回退将不会被继承:
use axum::{
routing::get,
http::StatusCode,
handler::Handler,
Json,
Router,
};
async fn fallback() -> (StatusCode, &'static str) {
(StatusCode::NOT_FOUND, "Not Found")
}
async fn api_fallback() -> (StatusCode, Json<serde_json::Value>) {
(
StatusCode::NOT_FOUND,
Json(serde_json::json!({ "status": "Not Found" })),
)
}
let api_routes = Router::new()
.route("/users", get(|| async {}))
.fallback(api_fallback);
let app = Router::new()
.nest("/api", api_routes)
.fallback(fallback);
在这里,像 GET /api/not-found
这样的请求将转到 api_fallback
。
用状态嵌套路由器
当使用此方法将Router
组合时,每个Router
必须具有相同类型的状态。
如果您的路由器具有不同类型,您可以使用Router::with_state
来提供状态并使类型匹配:
use axum::{
Router,
routing::get,
extract::State,
};
#[derive(Clone)]
struct InnerState {}
#[derive(Clone)]
struct OuterState {}
async fn inner_handler(state: State<InnerState>) {}
let inner_router = Router::new()
.route("/bar", get(inner_handler))
.with_state(InnerState {});
async fn outer_handler(state: State<OuterState>) {}
let app = Router::new()
.route("/", get(outer_handler))
.nest("/foo", inner_router)
.with_state(OuterState {});
请注意,内部路由器仍将继承外部路由器的后备机制。
恐慌
- 如果路由与另一个路由重叠。有关详细信息,请参阅
Router::route
。 - 如果路由包含通配符(
*
)。 - 如果
path
为空。
与nest
类似,但接受任何服务
pub fn nest_service<T>(self, path: &str, service: T) -> Self
where
T: Service<Request, Error=Infallible> + Clone + Send + 'static,
T::Response: IntoResponse,
T::Future: Send + 'static,
将两个路由器的路径(path
)和回退(fallbacks
)合并到一个路由器
pub fn merge<R>(self, other: R) -> Self
where
R: Into<Router<S>>,
这对于将应用程序分成更小的部分并将它们组合成一个非常有用。
use axum::{
routing::get,
Router,
};
let user_routes = Router::new()
.route("/users", get(users_list))
.route("/users/:id", get(users_show));
let team_routes = Router::new()
.route("/teams", get(teams_list));
let app = Router::new()
.merge(user_routes)
.merge(team_routes);
// 也可以执行 `user_routes.merge(team_routes)`
// 我们的应用程序现在接受
// - GET /users
// - GET /users/:id
// - GET /teams
合并路由器的状态
使用此方法合并 Router
时,每个 Router
必须具有相同类型的状态。
如果您的 routers
具有不同类型,可以使用 Router::with_state
来提供状态并使类型匹配:
use axum::{
Router,
routing::get,
extract::State,
};
#[derive(Clone)]
struct InnerState {}
#[derive(Clone)]
struct OuterState {}
async fn inner_handler(state: State<InnerState>) {}
let inner_router = Router::new()
.route("/bar", get(inner_handler))
.with_state(InnerState {});
async fn outer_handler(state: State<OuterState>) {}
let app = Router::new()
.route("/", get(outer_handler))
.merge(inner_router)
.with_state(OuterState {});
合并具有回退的路由器
使用此方法合并 Router
时,后备(fallbacks
)也会合并。但是只能有一个路由器有后备。
将 tower::Layer
应用于路由器中的所有路由。
pub fn layer<L>(self, layer: L) -> Router<S>
where
L: Layer<Route> + Clone + Send + 'static,
L::Service: Service<Request> + Clone + Send + 'static,
<L::Service as Service<Request>>::Response: IntoResponse + 'static,
<L::Service as Service<Request>>::Error: Into<Infallible> + 'static,
<L::Service as Service<Request>>::Future: Send + 'static,
这可以用于为一组路由的请求添加额外的处理。
注意,中间件只应用于现有路由。
因此,您必须首先添加您的路由(和/
或回退(fallbacks
)),然后调用层(layer
)。
在调用层之后添加的额外路由将不会添加中间件。
如果要将中间件添加到单个处理程序,可以使用 MethodRouter::layer
或 Handler::layer
。
示例
添加tower_http::trace::TraceLayer
:
use axum::{
routing::get,
Router,
};
use tower_http::trace::TraceLayer;
let app = Router::new()
.route("/foo", get(|| async {}))
.route("/bar", get(|| async {}))
.layer(TraceLayer::new_for_http());
如果您需要编写自己的中间件,请参阅“编写中间件”以获取不同的选项。
如果您只想在某些路由上使用中间件,可以使用Router::merge
:
use axum::{
routing::get,
Router,
};
use tower_http::{trace::TraceLayer, compression::CompressionLayer};
let with_tracing = Router::new()
.route("/foo", get(|| async {}))
.layer(TraceLayer::new_for_http());
let with_compression = Router::new()
.route("/bar", get(|| async {}))
.layer(CompressionLayer::new());
let app = Router::new()
.merge(with_tracing)
.merge(with_compression);
多中间件
当应用多个中间件时,建议使用tower::ServiceBuilder
。有关更多详细信息,请参阅中间件。
路由之后运行
使用此方法添加的中间件将在路由之后运行,因此无法用于重写请求URI。 有关更多详细信息和解决方法,请参见“在中间件中重写请求URI”。
错误处理
请参阅有关错误处理影响中间件的详细信息。
向路由器应用一个 tower::Layer
,只有当请求匹配路由时才会运行
pub fn route_layer<L>(self, layer: L) -> Self
where
L: Layer<Route> + Clone + Send + 'static,
L::Service: Service<Request> + Clone + Send + 'static,
<L::Service as Service<Request>>::Response: IntoResponse + 'static,
<L::Service as Service<Request>>::Error: Into<Infallible> + 'static,
<L::Service as Service<Request>>::Future: Send + 'static,
请注意,中间件仅应用于现有路由。
因此,您必须首先添加您的路由(和/或回调),然后在之后调用 route_layer
。
调用 route_layer
后添加的额外路由将不会添加中间件。
这与 Router::layer
类似,不同之处在于只有当请求匹配路由时中间件才会运行。
这对于提前返回的中间件非常有用(例如授权),
否则可能会将 404 Not Found 转换为 401 Unauthorized。
示例
use axum::{
routing::get,
Router,
};
use tower_http::validate_request::ValidateRequestHeaderLayer;
let app = Router::new()
.route("/foo", get(|| async {}))
.route_layer(ValidateRequestHeaderLayer::bearer("password"));
// `GET /foo` 使用有效令牌将接收 `200 OK`
// `GET /foo` 使用无效令牌将接收 `401 未经授权`
// `GET /not-found` 使用无效令牌将接收 `404 未找到`