{"id":243,"date":"2026-09-05T09:59:03","date_gmt":"2026-09-05T01:59:03","guid":{"rendered":"https:\/\/yykcj.com\/?p=243"},"modified":"2026-09-05T09:59:03","modified_gmt":"2026-09-05T01:59:03","slug":"rust-%e5%bc%82%e6%ad%a5%e7%bc%96%e7%a8%8b%e5%ae%9e%e6%88%98%ef%bc%9a%e7%94%a8-tokio-%e6%9e%84%e5%bb%ba%e9%ab%98%e6%80%a7%e8%83%bd%e7%bd%91%e7%bb%9c%e6%9c%8d%e5%8a%a1","status":"publish","type":"post","link":"https:\/\/yykcj.com\/?p=243","title":{"rendered":"Rust \u5f02\u6b65\u7f16\u7a0b\u5b9e\u6218\uff1a\u7528 Tokio \u6784\u5efa\u9ad8\u6027\u80fd\u7f51\u7edc\u670d\u52a1"},"content":{"rendered":"

\u4e3a\u4ec0\u4e48\u9009\u62e9 Rust \u548c Tokio\uff1f<\/h2>\n

\u5728\u7cfb\u7edf\u7f16\u7a0b\u9886\u57df\uff0cRust \u4ee5\u5176\u5185\u5b58\u5b89\u5168\u548c\u6027\u80fd\u4f18\u52bf\u8131\u9896\u800c\u51fa\u3002\u5f53\u6211\u4eec\u9700\u8981\u6784\u5efa\u9ad8\u5e76\u53d1\u7684\u7f51\u7edc\u670d\u52a1\u65f6\uff0c\u5f02\u6b65\u7f16\u7a0b\u6210\u4e3a\u4e0d\u4e8c\u4e4b\u9009\u3002Tokio \u662f Rust \u751f\u6001\u4e2d\u6700\u6210\u719f\u7684\u5f02\u6b65\u8fd0\u884c\u65f6\uff0c\u63d0\u4f9b\u4e86\u4e8b\u4ef6\u9a71\u52a8\u3001\u975e\u963b\u585e I\/O \u548c\u4efb\u52a1\u8c03\u5ea6\u7684\u6838\u5fc3\u529f\u80fd\u3002<\/p>\n

\u672c\u6587\u5c06\u901a\u8fc7\u4e00\u4e2a\u5b8c\u6574\u7684 TCP \u804a\u5929\u670d\u52a1\u5668\u793a\u4f8b\uff0c\u5e26\u4f60\u638c\u63e1 Tokio \u7684\u6838\u5fc3\u6982\u5ff5\u3002\u4f60\u5c06\u5b66\u4f1a\u5982\u4f55\u5904\u7406\u5e76\u53d1\u8fde\u63a5\u3001\u5728\u4e0d\u540c\u4efb\u52a1\u95f4\u901a\u4fe1\uff0c\u4ee5\u53ca\u5982\u4f55\u4f18\u96c5\u5730\u5173\u95ed\u670d\u52a1\u3002<\/p>\n

\u73af\u5883\u51c6\u5907<\/h2>\n

\u786e\u4fdd\u4f60\u5df2\u7ecf\u5b89\u88c5\u4e86 Rust\uff08\u63a8\u8350\u4f7f\u7528 rustup \u5b89\u88c5\uff09\u3002\u68c0\u67e5\u7248\u672c\uff1a<\/p>\n

\nrustc --version\ncargo --version\n<\/code><\/pre>\n
\u521b\u5efa\u65b0\u9879\u76ee\uff1a<\/p>\n
\ncargo new tokio-chat\ncd tokio-chat\n<\/code><\/pre>\n
\u5728 Cargo.toml<\/code> \u4e2d\u6dfb\u52a0\u4f9d\u8d56\uff1a<\/p>\n
\n[dependencies]\ntokio = { version = "1.37", features = ["full"] }\n<\/code><\/pre>\n
full<\/code> \u7279\u6027\u4f1a\u542f\u7528\u6240\u6709 Tokio \u7ec4\u4ef6\uff08\u4f8b\u5982 io\u3001time\u3001sync \u7b49\uff09\uff0c\u65b9\u4fbf\u5f00\u53d1\u3002<\/p>\n
\u5f02\u6b65\u57fa\u7840<\/h2>\n
Rust \u7684\u5f02\u6b65\u51fd\u6570\u4f7f\u7528 async fn<\/code> \u5b9a\u4e49\uff0c\u8c03\u7528\u65f6\u8fd4\u56de\u4e00\u4e2a Future<\/code>\uff0c\u9700\u8981\u6267\u884c\u5668\uff08Executor\uff09\u6765\u9a71\u52a8\u3002Tokio \u63d0\u4f9b\u4e86\u4e24\u79cd\u8fd0\u884c\u65f6\uff1a\u591a\u7ebf\u7a0b\u7684 currentthread<\/code> \u548c multi<\/em>thread<\/code>\uff0c\u9ed8\u8ba4\u662f\u540e\u8005\u3002<\/p>\n
\n#[tokio::main]\nasync fn main() {\n    println!("Hello from Tokio");\n}\n<\/code><\/pre>\n
#[tokio::main]<\/code> \u5b8f\u5c06\u5f02\u6b65 main \u51fd\u6570\u5305\u88c5\u6210\u8fd0\u884c\u65f6\u521d\u59cb\u5316\u548c\u6267\u884c\u3002<\/p>\n
\u5b9e\u6218\uff1a\u6784\u5efa TCP \u804a\u5929\u670d\u52a1\u5668<\/h2>\n
\u6211\u4eec\u5c06\u5b9e\u73b0\u4e00\u4e2a\u7b80\u5355\u7684\u804a\u5929\u5ba4\uff0c\u652f\u6301\u591a\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5\uff0c\u6bcf\u4e2a\u5ba2\u6237\u7aef\u53d1\u9001\u7684\u6d88\u606f\u4f1a\u5e7f\u64ad\u7ed9\u6240\u6709\u5176\u4ed6\u5ba2\u6237\u7aef\u3002<\/p>\n
\u7b2c\u4e00\u6b65\uff1a\u63a5\u53d7\u8fde\u63a5<\/h3>\n
\u9996\u5148\uff0c\u6211\u4eec\u76d1\u542c\u4e00\u4e2a TCP \u7aef\u53e3\uff0c\u5e76\u4e3a\u6bcf\u4e2a\u8fde\u63a5\u751f\u6210\u4e00\u4e2a\u4efb\u52a1\u3002<\/p>\n
\nuse tokio::net::{TcpListener, TcpStream};\nuse tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};\nuse std::sync::{Arc, Mutex};\nuse tokio::sync::broadcast;\n\n#[tokio::main]\nasync fn main() -> Result<(), Box<dyn std::error::Error>> {\n    let listener = TcpListener::bind("127.0.0.1:8080").await?;\n    println!("Server listening on port 8080");\n\n    \/\/ \u521b\u5efa\u5e7f\u64ad\u901a\u9053\uff0c\u7528\u4e8e\u5411\u6240\u6709\u5ba2\u6237\u7aef\u53d1\u9001\u6d88\u606f\n    let (tx, _rx) = broadcast::channel(10);\n\n    loop {\n        let (socket, addr) = listener.accept().await?;\n        println!("New connection from {}", addr);\n\n        \/\/ \u4e3a\u6bcf\u4e2a\u8fde\u63a5\u514b\u9686\u4e00\u4e2a\u53d1\u9001\u7aef\n        let tx = tx.clone();\n\n        \/\/ \u542f\u52a8\u4e00\u4e2a\u65b0\u4efb\u52a1\u5904\u7406\u8be5\u8fde\u63a5\n        tokio::spawn(async move {\n            if let Err(e) = handle_connection(socket, tx).await {\n                eprintln!("Error handling connection {}: {}", addr, e);\n            }\n        });\n    }\n}\n<\/code><\/pre>\n
\u7b2c\u4e8c\u6b65\uff1a\u5904\u7406\u5ba2\u6237\u7aef\u6d88\u606f<\/h3>\n
\u6bcf\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5\u6211\u4eec\u8bfb\u53d6\u5176\u53d1\u9001\u7684\u6bcf\u4e00\u884c\uff0c\u7136\u540e\u5e7f\u64ad\u7ed9\u6240\u6709\u5176\u4ed6\u5ba2\u6237\u7aef\u3002<\/p>\n
\nasync fn handle_connection(\n    mut socket: TcpStream,\n    tx: broadcast::Sender<String>,\n) -> Result<(), Box<dyn std::error::Error>> {\n    \/\/ \u5c06 socket \u5206\u6210\u8bfb\u548c\u5199\u90e8\u5206\n    let (reader, mut writer) = socket.split();\n    let mut reader = BufReader::new(reader);\n    let mut line = String::new();\n\n    loop {\n        \/\/ \u8bfb\u53d6\u4e00\u884c\n        match reader.read_line(&mut line).await {\n            Ok(0) => break, \/\/ \u8fde\u63a5\u5173\u95ed\n            Ok(_) => {\n                \/\/ \u53d1\u9001\u5230\u5e7f\u64ad\u901a\u9053\n                tx.send(line.trim().to_string()).unwrap();\n                line.clear();\n            }\n            Err(e) => {\n                eprintln!("Error reading: {}", e);\n                break;\n            }\n        }\n    }\n    Ok(())\n}\n<\/code><\/pre>\n
\u4f46\u662f\uff0c\u6211\u4eec\u8fd8\u9700\u8981\u4e00\u4e2a\u4efb\u52a1\u6765\u63a5\u6536\u5e7f\u64ad\u7684\u6d88\u606f\u5e76\u53d1\u9001\u7ed9\u5ba2\u6237\u7aef\u3002\u7531\u4e8e\u6211\u4eec\u53ea\u6709\u4e00\u4e2a writer<\/code>\uff0c\u4e0d\u80fd\u540c\u65f6\u8bfb\u548c\u5199\uff0c\u6240\u4ee5\u9700\u8981\u5c06\u5e7f\u64ad\u63a5\u6536\u7aef\u653e\u5165\u53e6\u4e00\u4e2a\u4efb\u52a1\u3002\u4f46\u6bcf\u4e2a\u8fde\u63a5\u53ea\u7528\u4e00\u4e2a\u4efb\u52a1\u4f1a\u5bfc\u81f4\u963b\u585e\u3002\u66f4\u597d\u7684\u65b9\u5f0f\u662f\uff1a\u6bcf\u4e2a\u8fde\u63a5\u6709\u4e24\u4e2a\u4efb\u52a1\uff0c\u4e00\u4e2a\u8d1f\u8d23\u8bfb\uff0c\u4e00\u4e2a\u8d1f\u8d23\u5199\u3002\u6216\u8005\u4f7f\u7528 tokio::select!<\/code> \u6765\u540c\u65f6\u7b49\u5f85\u3002<\/p>\n
\u6211\u4eec\u91c7\u7528 tokio::select!<\/code> \u6765\u5b9e\u73b0\u975e\u963b\u585e\u5904\u7406\uff1a<\/p>\n
\nuse tokio::sync::broadcast;\nuse tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};\nuse tokio::net::TcpStream;\n\nasync fn handle_connection(\n    socket: TcpStream,\n    tx: broadcast::Sender<String>,\n) -> Result<(), Box<dyn std::error::Error>> {\n    let (reader, mut writer) = socket.split();\n    let mut reader = BufReader::new(reader);\n    let mut rx = tx.subscribe();\n\n    let mut line = String::new();\n    loop {\n        tokio::select! {\n            \/\/ \u4ece\u5ba2\u6237\u7aef\u8bfb\u53d6\u4e00\u884c\n            result = reader.read_line(&mut line) => {\n                match result {\n                    Ok(0) => break, \/\/ EOF\n                    Ok(_) => {\n                        let msg = line.trim().to_string();\n                        \/\/ \u5e7f\u64ad\u6d88\u606f\uff08\u5305\u62ec\u81ea\u5df1\uff1f\u901a\u5e38\u4e0d\u5305\u62ec\uff0c\u4f46\u8fd9\u91cc\u4e3a\u4e86\u7b80\u5355\uff0c\u5e7f\u64ad\u7ed9\u6240\u6709\uff0c\u5305\u62ec\u81ea\u5df1\uff09\n                        tx.send(msg).unwrap();\n                        line.clear();\n                    }\n                    Err(e) => {\n                        eprintln!("read error: {}", e);\n                        break;\n                    }\n                }\n            }\n            \/\/ \u4ece\u5e7f\u64ad\u901a\u9053\u63a5\u6536\u6d88\u606f\n            result = rx.recv() => {\n                match result {\n                    Ok(msg) => {\n                        \/\/ \u53d1\u9001\u7ed9\u5ba2\u6237\u7aef\uff0c\u52a0\u4e0a\u6362\u884c\u7b26\n                        writer.write_all(format!("{}\\n", msg).as_bytes()).await?;\n                        writer.flush().await?;\n                    }\n                    Err(_) => break, \/\/ \u901a\u9053\u5173\u95ed\n                }\n            }\n        }\n    }\n    Ok(())\n}\n<\/code><\/pre>\n
\u7b2c\u4e09\u6b65\uff1a\u5e7f\u64ad\u6d88\u606f\u7ed9\u6240\u6709\u5ba2\u6237\u7aef<\/h3>\n
\u6211\u4eec\u5df2\u7ecf\u4f7f\u7528\u4e86 broadcast::channel<\/code>\uff0c\u5b83\u5141\u8bb8\u591a\u4e2a\u53d1\u9001\u8005\u548c\u63a5\u6536\u8005\u3002\u6bcf\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5\u6301\u6709\u4e00\u4e2a\u53d1\u9001\u8005\uff08tx\uff09\u548c\u4e00\u4e2a\u8ba2\u9605\u8005\uff08rx\uff09\u3002\u5f53\u67d0\u4e2a\u5ba2\u6237\u7aef\u53d1\u9001\u6d88\u606f\u65f6\uff0c\u6211\u4eec\u901a\u8fc7 tx.send(msg)<\/code> \u5e7f\u64ad\uff0c\u6240\u6709\u8ba2\u9605\u8005\u90fd\u4f1a\u6536\u5230\u3002<\/p>\n
\u6ce8\u610f\uff1abroadcast<\/code> \u7684\u63a5\u6536\u8005\u5982\u679c\u843d\u540e\u592a\u591a\u4f1a\u4e22\u5931\u6d88\u606f\uff0c\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7\u8bbe\u7f6e\u5408\u9002\u7684\u5bb9\u91cf\u6216\u4f7f\u7528\u5176\u4ed6\u6a21\u5f0f\u3002<\/p>\n
\u5b8c\u6574\u4ee3\u7801<\/h3>\n
\u5c06\u4e0a\u8ff0\u4ee3\u7801\u6574\u5408\u5230 main.rs<\/code>\uff0c\u5e76\u6dfb\u52a0\u5fc5\u8981\u7684\u9519\u8bef\u5904\u7406\uff1a<\/p>\n
\nuse tokio::net::{TcpListener, TcpStream};\nuse tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};\nuse tokio::sync::broadcast;\n\n#[tokio::main]\nasync fn main() -> Result<(), Box<dyn std::error::Error>> {\n    let listener = TcpListener::bind("127.0.0.1:8080").await?;\n    println!("Server running on 127.0.0.1:8080");\n\n    let (tx, _) = broadcast::channel(10);\n\n    loop {\n        let (socket, addr) = listener.accept().await?;\n        println!("New client: {}", addr);\n        let tx = tx.clone();\n        tokio::spawn(async move {\n            if let Err(e) = handle_connection(socket, tx).await {\n                eprintln!("Connection error: {}", e);\n            }\n        });\n    }\n}\n\nasync fn handle_connection(\n    socket: TcpStream,\n    tx: broadcast::Sender<String>,\n) -> Result<(), Box<dyn std::error::Error>> {\n    let (reader, mut writer) = socket.split();\n    let mut reader = BufReader::new(reader);\n    let mut rx = tx.subscribe();\n\n    let mut line = String::new();\n    loop {\n        tokio::select! {\n            result = reader.read_line(&mut line) => {\n                match result {\n                    Ok(0) => break,\n                    Ok(_) => {\n                        let msg = line.trim().to_string();\n                        tx.send(msg)?;\n                        line.clear();\n                    }\n                    Err(e) => {\n                        eprintln!("read error: {}", e);\n                        break;\n                    }\n                }\n            }\n            result = rx.recv() => {\n                match result {\n                    Ok(msg) => {\n                        writer.write_all(format!("{}\\n", msg).as_bytes()).await?;\n                        writer.flush().await?;\n                    }\n                    Err(_) => break,\n                }\n            }\n        }\n    }\n    Ok(())\n}\n<\/code><\/pre>\n
\u6d4b\u8bd5\u670d\u52a1\u5668<\/h3>\n
\u8fd0\u884c\u670d\u52a1\u5668\uff1a<\/p>\n
\ncargo run\n<\/code><\/pre>\n
\u5728\u53e6\u4e00\u4e2a\u7ec8\u7aef\uff0c\u4f7f\u7528 nc<\/code> \u6216 telnet<\/code> \u8fde\u63a5\uff1a<\/p>\n
\nnc 127.0.0.1 8080\n<\/code><\/pre>\n
\u6253\u5f00\u591a\u4e2a\u7ec8\u7aef\uff0c\u8f93\u5165\u6d88\u606f\uff0c\u89c2\u5bdf\u5e7f\u64ad\u6548\u679c\u3002<\/p>\n
\u6df1\u5165\u7406\u89e3\uff1aTokio \u4efb\u52a1\u4e0e\u8c03\u5ea6<\/h2>\n
Tokio \u7684\u4efb\u52a1\u662f\u8f7b\u91cf\u7ea7\u7684\uff0c\u6bcf\u4e2a tokio::spawn<\/code> \u90fd\u4f1a\u521b\u5efa\u4e00\u4e2a\u5e76\u53d1\u6267\u884c\u7684\u4efb\u52a1\u3002Tokio \u4f7f\u7528\u5de5\u4f5c\u7a83\u53d6\u8c03\u5ea6\u5668\uff0c\u5728\u591a\u7ebf\u7a0b\u8fd0\u884c\u65f6\u4e2d\uff0c\u4efb\u52a1\u4f1a\u88ab\u5206\u914d\u5230\u4e0d\u540c\u7684\u7ebf\u7a0b\uff0c\u5b9e\u73b0\u5e76\u884c\u3002<\/p>\n
\u91cd\u8981\u6982\u5ff5<\/strong>\uff1a<\/p>\n