安装Rust
通过rustup安装Rust,自动配置环境变量:
curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh
source $HOME/.cargo/env # 激活环境
rustup update # 更新至最新版本
创建项目
使用cargo生成新项目:
cargo new rust_network_demo
cd rust_network_demo
| 场景 | 推荐库 | 特点 | 依赖配置(Cargo.toml) |
|---|---|---|---|
| 异步基础网络 | Tokio | 高性能异步运行时,支持TCP/UDP/HTTP等,社区成熟 | tokio = { version = "1", features = ["full"] } |
| HTTP客户端 | Reqwest | 简单易用的HTTP客户端,支持异步请求和响应 | reqwest = "0.11" |
| HTTP服务端 | Actix-Web/Warp | 高性能Web框架,支持路由、中间件、WebSocket等 | actix-web = "4" 或 warp = "0.3" |
| WebSocket | Tokio-Tungstenite | 基于Tokio的WebSocket库,支持异步消息收发 | tokio-tungstenite = "0.17" |
| 自定义协议 | Tokio + Serde | 基于Tokio的TCP/UDP,配合Serde实现消息序列化/反序列化 | tokio = "1", serde = { version = "1.0", features = ["derive"] } |
代码逻辑:监听端口并回显客户端消息
use tokio::net::{TcpListener, TcpStream};
use tokio::io::{AsyncReadExt, AsyncWriteExt};
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let listener = TcpListener::bind("127.0.0.1:8080").await?;
println!("Server running on 127.0.0.1:8080");
loop {
let (mut socket, _) = listener.accept().await?;
tokio::spawn(async move {
let mut buffer = [0; 1024];
while let Ok(n) = socket.read(&mut buffer).await {
if n == 0 { break; }
socket.write_all(&buffer[..n]).await.unwrap();
}
});
}
}
运行:cargo run,通过telnet 127.0.0.1 8080测试。
代码逻辑:发送GET请求并打印响应
use reqwest;
#[tokio::main]
async fn main() -> Result<(), reqwest::Error> {
let response = reqwest::get("https://httpbin.org/get").await?;
println!("Response: {}", response.text().await?);
Ok(())
}
依赖:需在Cargo.toml中添加reqwest和tokio。
代码逻辑:构建RESTful API
use actix_web::{get, App, HttpResponse, HttpServer, Responder};
#[get("/hello")]
async fn hello() -> impl Responder {
HttpResponse::Ok().body("Hello, CentOS!")
}
#[actix_web::main]
async fn main() -> std::io::Result<()> {
HttpServer::new(|| App::new().service(hello))
.bind("127.0.0.1:8080")?
.run()
.await
}
运行:cargo run,访问http://127.0.0.1:8080/hello。
cargo build自动下载库,复杂项目建议使用cargo.lock锁定版本。tokio的rt-multi-thread特性提升并行度。firewalld)限制端口访问。tokio-rustls)。README.md和docs.rs页面提供详细API说明。