Rust在CentOS上的网络编程指南

一环境准备与工具链

安装或更新 Rust：使用 rustup 安装与更新，确保工具链为最新稳定版。
- 安装：curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh
- 激活环境：source $HOME/.cargo/env
- 更新：rustup update
创建项目与依赖管理：使用 cargo 初始化项目，并在 Cargo.toml 中添加所需网络库依赖（如 tokio 等）。
常用测试工具：安装 telnet 或 nc(netcat) 用于连接与调试网络服务。

二同步与异步编程路径

同步编程：使用标准库 std::net 编写 TCP/UDP 客户端与服务器，适合逻辑简单或并发要求不高的场景。
异步编程：使用 tokio 运行时提供的异步 TCP/UDP 接口，适合高并发、I/O 密集型服务。

三快速上手示例

同步回显服务器（std::net）

代码示例：

use std::io::{Read, Write};
use std::net::{TcpListener, TcpStream};

fn handle_client(mut stream: TcpStream) {
    let mut buf = [0; 1024];
    while let Ok(n) = stream.read(&mut buf) {
        if n == 0 { return; }
        let _ = stream.write_all(&buf[..n]);
    }
}

fn main() -> std::io::Result<()> {
    let listener = TcpListener::bind("127.0.0.1:7878")?;
    for stream in listener.incoming() {
        if let Ok(s) = stream {
            std::thread::spawn(|| handle_client(s));
        }
    }
    Ok(())
}

运行与测试：
- 启动：cargo run
- 连接：telnet 127.0.0.1 7878 或 nc 127.0.0.1 7878，输入文本将回显。

异步回显服务器（tokio）

依赖（Cargo.toml）：

[dependencies]
tokio = { version = "1", features = ["full"] }

代码示例：

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:7878").await?;
    loop {
        let (mut socket, _) = listener.accept().await?;
        tokio::spawn(async move {
            let mut buf = [0; 1024];
            while let Ok(n) = socket.read(&mut buf).await {
                if n == 0 { break; }
                let _ = socket.write_all(&buf[..n]).await;
            }
        });
    }
}

运行与测试：
- 启动：cargo run
- 连接：telnet 127.0.0.1 7878 或 nc 127.0.0.1 7878。

四常见网络库与场景选择

异步基础网络：Tokio（TCP/UDP/Unix 域套接字，生态成熟，适合高并发服务）
HTTP 客户端：reqwest（简洁易用，支持同步/异步）
HTTP 服务端：Actix-Web、Warp（高性能 Web 框架，路由、中间件、WebSocket 等）
WebSocket：tokio-tungstenite（基于 Tokio 的异步 WebSocket）
自定义协议：Tokio + Serde（消息编解码与协议帧处理）

依赖示例（按需添加到 Cargo.toml）：

[dependencies]
tokio = { version = "1", features = ["full"] }
reqwest = "0.11"
actix-web = "4"
warp = "0.3"
tokio-tungstenite = "0.17"
serde = { version = "1.0", features = ["derive"] }

五部署与排错要点

监听地址与端口
- 仅本机访问：绑定 127.0.0.1:PORT
- 对外访问：绑定 0.0.0.0:PORT
- 云服务器需确保安全组/防火墙放行对应 TCP 端口
防火墙与 SELinux
- 放行端口（firewalld）：sudo firewall-cmd --add-port=7878/tcp --permanent && sudo firewall-cmd --reload
- SELinux：必要时调整策略或临时设为宽容模式进行排查
资源与并发
- 合理设置 线程/任务 数量与 缓冲区 大小
- 处理连接关闭与错误分支，避免资源泄漏
日志与可观测性
- 使用日志库（如 env_logger）输出连接、错误与关键路径信息
链路层与多网卡
- 若需跨网卡/二层通信，可使用 pnet 构造与发送以太网帧（示例见 pnet 在 CentOS 7 上的实践）

Rust在CentOS上的网络编程指南

发表回复