Actix-Web是Rust生态系统中非常强大的Web框架之一，凭借其高并发性和灵活性，成为了许多开发者首选的Web服务器框架。在这篇文章中，我们将详细探讨Actix-Web的HTTP服务器实现，以及如何通过不同的配置选项来优化服务器性能。
HTTP服务器的基础实现
在Actix-Web中，
HttpServer
类型负责处理HTTP请求。要启动一个Web服务器，首先需要将其绑定到网络套接字上。可以使用
HttpServer::bind()
方法绑定到一个套接字地址，例如
("127.0.0.1", 8080)
或者
"0.0.0.0:8080"
。
示例代码
以下是一个简单的示例，展示了如何启动一个Actix-Web服务器并在根路径上返回一个「OK」响应：
use actix_web::{web, App, HttpResponse, HttpServer};
#[actix_web::main]
asyncfnmain() -> std::io::Result<()> {
HttpServer::new(|| App::new().route("/", web::get().to(HttpResponse::Ok)))
.bind(("127.0.0.1", 8080))?
.run()
.await
}
这个例子中，我们通过
HttpServer::new()
方法创建了一个新的服务器实例，并绑定到
127.0.0.1:8080
。调用
HttpServer::run()
方法启动服务器，使其开始处理请求。
多线程处理
HttpServer
默认会启动多个HTTP工作线程，其数量等于单机的物理CPU核心数。然而，可以通过
HttpServer::workers()
方法来覆盖这个默认值。例如：
use actix_web::{web, App, HttpResponse, HttpServer};
#[actix_web::main]
asyncfnmain() -> std::io::Result<()> {
HttpServer::new(|| App::new().route("/", web::get().to(HttpResponse::Ok)))
.workers(4) // 启动4个工作线程
.bind(("127.0.0.1", 8080))?
.run()
.await
}
工作线程创建后，每个线程将接收一个独立的应用实例来处理请求。注意，应用状态在不同线程间并不共享，因此处理程序可以自由地操作其状态而无需考虑并发问题。
对于需要在不同工作线程间共享的状态，可以使用
Arc
/
Data
来实现。但是，在引入共享和同步机制时需要特别注意，以避免因锁定共享状态而导致的性能瓶颈。
异步处理
在Actix-Web中，任何长时间的非CPU绑定操作（例如I/O、数据库操作等）都应该以异步函数或
Future
的形式表达。这样可以避免工作线程因阻塞操作而停止处理新请求。
示例代码
同步处理器示例（不推荐）：
fnmy_handler() -> impl Responder {
std::thread::sleep(std::time::Duration::from_secs(5)); // 不推荐，会导致当前工作线程挂起
"response"
}
异步处理器示例（推荐）：
asyncfnmy_handler() -> impl Responder {
tokio::time::sleep(std::time::Duration::from_secs(5)).await; // 推荐，工作线程可以在此期间处理其他请求
"response"
}
同样的限制也适用于提取器。当处理函数接收到一个实现
FromRequest
的参数时，如果该实现阻塞了当前线程，那么工作线程也会在运行处理函数时被阻塞。因此，在需要的地方应实现异步提取器。
支持TLS/HTTPS
Actix-Web支持两种TLS实现：
rustls
和
openssl
。可以在
Cargo.toml
中指定相应的特性来启用这些实现。例如，使用
openssl
：
[dependencies]
actix-web = { version = "4", features = ["openssl"] }
openssl = { version = "0.10" }
示例代码
下面是一个启用HTTPS的示例：
use actix_web::{get, App, HttpRequest, HttpServer, Responder};
use openssl::ssl::{SslAcceptor, SslFiletype, SslMethod};
#[get("/")]
asyncfnindex(_req: HttpRequest) -> impl Responder {
"Welcome!"
}
#[actix_web::main]
asyncfnmain() -> std::io::Result<()> {
letmut builder = SslAcceptor::mozilla_intermediate(SslMethod::tls()).unwrap();
builder.set_private_key_file("key.pem", SslFiletype::PEM).unwrap();
builder.set_certificate_chain_file("cert.pem").unwrap();
HttpServer::new(|| App::new().service(index))
.bind_openssl("127.0.0.1:8080", builder)?
.run()
.await
}
要生成
key.pem
和
cert.pem
文件，可以使用如下命令：
openssl req -x509 -newkey rsa:4096 -nodes -keyout key.pem -out cert.pem -days 365 -subj '/CN=localhost'
Keep-Alive支持
Actix-Web会保持连接打开以等待后续请求。可以通过服务器设置来定义Keep-Alive连接行为。例如：
use actix_web::{http::KeepAlive, HttpServer};
use std::time::Duration;
#[actix_web::main]
asyncfnmain() -> std::io::Result<()> {
let server = HttpServer::new(app)
.keep_alive(Duration::from_secs(75)) // 设置Keep-Alive为75秒
.keep_alive(KeepAlive::Os) // 使用操作系统的Keep-Alive设置
.keep_alive(None); // 禁用Keep-Alive
server.run().await
}
使用
HttpResponseBuilder
上的
force_close()
方法可以强制关闭连接：
use actix_web::{http, HttpRequest, HttpResponse};
asyncfnindex(_req: HttpRequest) -> HttpResponse {
letmut resp = HttpResponse::Ok()
.force_close() // 强制关闭连接
.finish();
resp.head_mut().set_connection_type(http::ConnectionType::Close); // 关闭连接
resp
}
优雅的关机处理
Actix-Web支持优雅的关机处理，在接收到关机信号后，工作线程有一定的时间来完成正在处理的请求。超时后，仍然存活的工作线程将被强制关闭。可以使用
HttpServer::shutdown_timeout()
方法来修改默认的30秒关机超时设置。
HttpServer::new(...).shutdown_timeout(60); // 设置关机超时为60秒
默认情况下，
HttpServer
处理多个操作系统信号：
SIGINT
- 强制关闭工作线程
SIGTERM
- 优雅关闭工作线程
SIGQUIT
- 强制关闭工作线程
可以通过
HttpServer::disable_signals()
方法来禁用信号处理。
以上内容详细介绍了Actix-Web中的HTTP服务器实现与多线程、异步处理、TLS/HTTPS支持、Keep-Alive以及优雅的关机处理。在实际开发中，合理使用这些特性和配置，可以显著提高Web服务器的性能和可靠性。希望这篇文章能够帮助你更好地理解和使用Actix-Web来构建高性能的Web应用。
文章精选
点 击 关 注 并 扫 码 添 加 进 交 流 群
领
取
「Rust
语
言
」
学
习
资
料
