axum中的各种响应
本章主要讨论 axum 的响应。axum 已经实现了多种响应,比如纯文本、HTML、JSON 及 自定义响应头(response header)。除了这些 axum 内置的响应之外,我们还将讨论如何将自己定义的结构体,作为响应返回给客户端。在axum中获取请求数据
在日常开发中,我们需要与用户进行交互,从各种渠道获取用户输入,包括但不限于:表单、URL 参数、URL Path 以及 JSON 等。axum 为我们提供了这些获取用户输入的支持。axum的状态共享
**状态共享**是指,在整个应用或不同路由之间,共享一份数据。axum 提供了方便的状态共享机制,但可能也会踩坑。本章将带你学习如何在 axum web 应用中共享状态。路由
axum 提供了常用的 HTTP 请求方式对应的路由,比如 `get`, `post`, `put`, `delete` 等。除此之外,axum 还提供了“嵌套路由”。路由,通常和 `handler(处理函数)` 结合在一起。中间件
中间件是一类提供系统软件和应用软件之间连接、便于软件各部件之间的沟通的软件,应用软件可以借助中间件在不同的技术架构之间共享信息与资源。本章将讨论如何在axum中使用中间件,以及如何自定义中间件。axum处理静态文件
和其它 Web 框架一样,axum 也会对所有请求进行处理。对于 CSS、JS 及图片等静态文件,并不需要 axum 的 handler 进行处理,而是只需要简单的把它们的内容进行返回即可。axum 提供了处理静态文件的中间件。axum处理cookie
Cookie 是通过 HTTP Header 进行传递的。由某个响应头进行设置,然后其它请求头就可以获取到了。本章将通过模拟用户中心来用 axum 操作 HTTP Header 演示 Cookie 的读写操作。axum 操作 redis
通过 redis-rs 这个 crate,可以很方便的操作 redis。它提供了同步和异步两种连接,由于我们要集成到 axum 中,所以这里使用异步连接。本章将展示如何获取 redis 异步连接、如何将字符串保存到 redis、如何获取到保存在 redis 里的字符串以及如何通过 redis 保存和读取自定义结构体。axum 操作 Postgres 数据库
PostgreSQL 是一款天然支持异步操作的高性能开源关系型数据库。本章将讨论如何在 axum 中使用 PostgreSQL。包括:数据的增加、修改、删除、查找以及开始事务保证业务的原子性。axum 实现 Session
由于 HTTP 是无状态的,所以我们可以通过Cookie来维护状态。但 cookie 是直接保存到客户端,所以对于敏感数据,不能直接保存到 cookie。我们可以把敏感数据保存到服务端,然后把对应的 ID 保存到 cookie,这就是 Session。本章我们将使用 Cookie 和 Redis 实现一个简单的 Session。axum 集成 JWT
Json web token(JWT)是为了网络应用环境间传递声明而执行的一种基于 JSON 的开发标准(RFC 7519),该 token 被设计为紧凑且安全的,特别适用于分布式站点的单点登陆(SSO)场景。JWT 的声明一般被用来在身份提供者和服务提供者间传递被认证的用户身份信息,以便于从资源服务器获取资源,也可以增加一些额外的其它业务逻辑所必须的声明信息,该 token 也可直接被用于认证,也可被加密。axum 中使用模板引擎
利用模板引擎,我们不需要再把 HTML 代码写在 Rust 代码中了,而是将其独立保存为`*.html`文件。既方便维护,也有利用开发。axum 上传文件
文件上传是 Web 开发中常见的功能,本章将演示如何在 axum 实现文件上传。axum 集成hcaptcha验证码进行人机验证
在机器人采集、恶意攻击的今天,人机验证筑起了一道保护网。从之前的图片验证码,到 Google 提供的 reCaptcha,人机验证经历了一段漫长的演进过程。配置文件:让axum app可配置
将数据库连接信息、redis 连接信息以及 Web 应用监听地址等信息通过配置文件进行单独管理是一个比较好的开发实践。这样就无须在更改配置的时候重新编译整个项目,同时也可以针对不同环境使用不同的配置文件。axum错误处理
本章主要讨论 axum 的错误处理
axum中的各种响应
本章主要讨论 axum 的响应。axum 已经实现了多种响应,比如纯文本、HTML、JSON 及 自定义响应头(response header)。除了这些 axum 内置的响应之外,我们还将讨论如何将自己定义的结构体,作为响应返回给客户端。
axum 的响应
axum 有句话说的是:
Anything that implements
IntoResponse
can be returned from a handler
Anything that implements IntoResponse
can be returned from a handler
大意就是:凡是实现了 IntoResponse trait 的,都可作为 handler 的返回值,也就是我们所说的响应
。
官方已经对若干常用数据类型实现了该 trait,亦是说,这些数据类型可以直接作为请求的响应进行返回。
对于我们自己的数据类型,比如自定义的 struct
,也只需要实现 IntoResponse
,就可以直接作为响应进行返回了。
官方提供了示例,我们将结合这个示例对官方提供的响应进行说明。
由于新版的 axum 文档删除了这部分内容,我们提供早些版本的文档。
由于新版的 axum 文档删除了这部分内容,我们提供早些版本的文档。
官方提供的响应
官方提供了以下响应:
类型 | 数据类型 |
---|---|
纯文本 | &str 和String |
字节序列 | Vec<u8> |
空响应 | () |
仅有状态码 | StatusCode |
带响应头的响应 | (HeaderMap, IntoResponse) |
带响应头和状态的响应 | (StatusCode, HeaderMap, IntoResponse) |
HTML 响应 | Html<IntoResponse> |
JSON 响应 | Json<IntoResponse> |
Result 响应 | Result<T:IntoResponse, E:IntoResponse> |
纯文本之 &str
async fn str_response() -> &'static str {
"Hello, axum.rs"
}
纯文本之 String
async fn string_response() -> String{
"Hello, axum.rs".to_string()
}
仅有状态码
async fn not_found() -> StatusCode {
StatusCode::NOT_FOUND
}
使用 curl 访问:
$ curl -I http://127.0.0.1:9527/404
HTTP/1.1 404 Not Found
content-length: 0
date: Mon, 15 Nov 2021 08:14:16 GMT
带响应头的响应
async fn with_headers() -> (HeaderMap, &'static str) {
let mut headers = HeaderMap::new();
headers.insert(
HeaderName::from_static("x-powered");
HeaderValue::from_static("axum.rs");
);
(headers, "axum.rs")
}
使用 curl 访问:
$ curl -I http://127.0.0.1:9527/with_headers
HTTP/1.1 200 OK
content-type: text/plain
x-powered: axum.rs
content-length: 0
date: Mon, 15 Nov 2021 08:18:00 GMT
带响应头和状态的响应
async fn with_headers_and_status() -> (StatusCode, HeaderMap, &'static str) {
let mut headers = HeaderMap::new();
headers.insert(
HeaderName::from_static("x-powered");
HeaderValue::from_static("axum.rs");
);
(StatusCode::OK, headers, "axum.rs")
}
使用 curl 访问:
$ curl -i http://127.0.0.1:9527/with_headers_and_status
HTTP/1.1 200 OK
content-type: text/plain
x-powered: axum.rs
content-length: 7
date: Mon, 15 Nov 2021 08:22:56 GMT
axum.rs
HTML 响应
async fn html() -> Html<&'static str> {
Html("Hello, <em>axum.rs</em>")
}
JSON 响应
async fn json() -> Json<serde_json::Value> {
Json(serde_json::json!({"hello":"axum.rs"}))
}
Result
响应
当 flag==false
时,使用 curl 访问:
$ curl -i http://127.0.0.1:9527/result
HTTP/1.1 500 Internal Server Error
content-length: 0
date: Mon, 15 Nov 2021 08:35:03 GMT
自定义结构体响应
#[derive(Serialize)]
struct Info {
web_site: String,
email: String,
level: i32,
}
async fn info_struct() -> Json<Info> {
let info = Info {
web_site: "https://axum.rs".to_string(),
email: "[email protected]".to_string(),
level: 123,
};
Json(info)
}
响应自定义错误
自定义一个错误类型
pub struct AppError {
pub message: String,
}
让这个自定义错误类型实现 IntoResponse
响应这个错误类型
async fn app_error() -> Result<&'static str, AppError> {
let flag = false;
if flag {
Ok("Hello, axum.rs")
} else {
Err(AppError {
message: "Opps!".to_string(),
})
}
}
思考题:
如果细心的话,你会发现在上面的例子中(axum 默认情况下),中文大概率会显示成乱码,利用本章所学知识,你能解决这个问题吗?请自行思考再看答案。
提示:HTTP 中的
content-type
header 可以指定响应的类型和编码。
async fn cn() -> (HeaderMap, &'static str) {
let mut headers = HeaderMap::new();
headers.insert(
HeaderName::from_static("content-type"),
HeaderValue::from_static("text/plain;charset=utf-8"),
);
(headers, "你好,axum.rs")
}