当前位置：首页 > Rust > 正文

Rust网络编程入门（使用标准库net构建TCP服务器）

主机测评网
Rust
2025-12-27
490

在现代软件开发中，Rust网络编程因其内存安全性和高性能而备受青睐。Rust 标准库中的 std::net 模块为开发者提供了构建网络应用的基础工具。本教程将手把手教你如何使用 Rust 的 net 库创建一个简单的 TCP 服务器，即使你是编程新手也能轻松上手！

Rust网络编程入门（使用标准库net构建TCP服务器） Rust网络编程 Rust net库 TCP服务器 Rust异步网络第1张

什么是 std::net？

std::net 是 Rust 标准库中用于网络通信的模块。它提供了 TCP 和 UDP 协议的支持，包括 TcpListener、TcpStream、UdpSocket 等类型。通过这些类型，你可以轻松地监听端口、接受连接、发送和接收数据。

第一步：创建一个简单的 TCP 服务器

让我们从最基础的开始：创建一个能接收客户端连接并回显消息的 TCP 服务器。这个例子非常适合初学者理解 Rust net库 的基本用法。

use std::io::Read;use std::io::Write;use std::net::TcpListener;use std::net::TcpStream;fn handle_client(mut stream: TcpStream) {    let mut buffer = [0; 1024];    match stream.read(&mut buffer) {        Ok(n) => {            if n == 0 {                return;            }            // 回显接收到的数据            stream.write_all(&buffer[..n]).unwrap();        }        Err(e) => {            eprintln!("Failed to read from socket: {}", e);        }    }}fn main() {    let listener = TcpListener::bind("127.0.0.1:7878").unwrap();    println!("服务器正在监听 127.0.0.1:7878...");    for stream in listener.incoming() {        match stream {            Ok(stream) => {                println!("新客户端已连接！");                handle_client(stream);            }            Err(e) => {                eprintln!("连接失败: {}", e);            }        }    }}

代码解析

TcpListener::bind()：绑定到本地地址 127.0.0.1:7878，开始监听连接。
listener.incoming()：返回一个迭代器，每次有新连接时生成一个 TcpStream。
handle_client 函数：读取客户端发送的数据，并原样返回（回显）。

测试你的服务器

运行服务器后，你可以使用 telnet 或 nc（netcat）工具测试：

    # 在终端运行
    telnet 127.0.0.1 7878
    # 然后输入任意文字，服务器会回显给你  

进阶：并发处理多个客户端

上面的例子一次只能处理一个客户端。为了支持并发，我们可以为每个连接创建一个新线程：

use std::thread;use std::io::Read;use std::io::Write;use std::net::TcpListener;use std::net::TcpStream;fn handle_client(mut stream: TcpStream) {    let mut buffer = [0; 1024];    match stream.read(&mut buffer) {        Ok(n) => {            if n == 0 { return; }            stream.write_all(&buffer[..n]).unwrap();        }        Err(e) => eprintln!("读取错误: {}", e),    }}fn main() {    let listener = TcpListener::bind("127.0.0.1:7878").unwrap();    for stream in listener.incoming() {        match stream {            Ok(stream) => {                thread::spawn(|| {                    handle_client(stream);                });            }            Err(e) => eprintln!("连接错误: {}", e),        }    }}