"Rust Tokio 并发与异步 I/O 实战"

Rust Tokio 并发与异步 I/O 实战基本示例use tokio::{net::TcpListener, io::{AsyncReadExt, AsyncWriteExt}}; #[tokio::main] async fn main() -> anyhow::Result<()> { let listener = TcpListener::bind("127.0.0.1:8080").await?; loop { let (mut sock, _) = listener.accept().await?; tokio::spawn(async move { let mut buf = [0u8; 1024]; if let Ok(n) = sock.read(&mut buf).await { let _ = sock.write_all(&buf[..n]).await; } }); } } select! 与超时use tokio::{time::{timeout, Duration}, select}; async fn work() { // ... } async fn run() { let t = timeout(Duration::from_secs(2), work()); select! { _ = t => { /* 正常完成或超时 */ }, _ = tokio::signal::ctrl_c() => { /* 优雅退出 */ }, } } 连接与背压使用 `TcpStream::set_nodelay(false)` 保持 Nagle，视场景选择通过限流与队列控制避免写放大与背压失控监控与测试`cargo bench` 与 `tokio-console` 观察任务与资源总结Tokio 提供高效的任务调度与 I/O 原语，通过合理的超时与背压策略，可构建稳定的并发服务。