安装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说明。