使用Rust开发高性能WebSocket服务器 Tungstenite库使用教程【详细】-js教程-PHP中文网

不能直接用tungstenite::accept_hdr处理并发连接，因其为同步阻塞函数，一次仅处理一个连接，read/write时会卡住线程，无异步调度能力，无法支撑高并发；真实场景仅适用于单连接调试或轻量工具。

使用rust开发高性能websocket服务器 tungstenite库使用教程【详细】

直接用 tungstenite 写高性能 WebSocket 服务器容易卡在阻塞、连接泄漏、消息丢弃或 TLS 握手失败上——它本身是同步库，不带运行时，硬套 std::net::TcpListener 做循环 accept + read/write 就会掉进这些坑。

为什么不能直接用 `tungstenite::accept_hdr` 处理并发连接

这个函数是同步阻塞的，一次只能处理一个连接；调用 read() 或 write() 时若对方未就绪，线程就卡住。没有异步调度能力，根本撑不住几十个以上连接。

常见错误现象：thread 'main' panicked at 'called `Result::unwrap()` on an `Err` value: Os { code: 11, kind: WouldBlock, message: "Resource temporarily unavailable" }'
真实使用场景：仅适合单连接调试、CLI 工具内嵌轻量通信，或配合 epoll/kqueue 手写事件循环（极少见）
性能影响：每连接独占一个 OS 线程 → 连接数 > 100 就内存暴涨、上下文切换开销爆炸

`tokio-tungstenite` 是实际生产唯一可行起点

它把 tungstenite 包装成 Tokio 兼容的 WebSocketStream，所有 I/O 操作都变成 async fn，可被 tokio::spawn 轻松并发调度。

WebSocket 8.18.2

WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。

下载

必须搭配的依赖（Cargo.toml）：

[dependencies]
tokio = { version = "1", features = ["full"] }
tokio-tungstenite = "0.23"
futures-util = "0.3"

accept_async 返回的是 Result<websocketstream>, Error></websocketstream>，不是裸 socket；后续必须用 .split() 拆成 Sink 和 Stream 才能异步收发
别漏掉 futures-util 的 StreamExt 和 SinkExt —— 否则 .next() 和 .send() 都不可用

消息处理必须区分 `Text`/`Binary`，且要检查 `Close`

忽略 Message::Close 会导致连接不释放，客户端断开后服务端还维持着僵尸流；直接 msg.into_text().unwrap() 在二进制帧上会 panic。

安全写法示例：

while let Some(Ok(msg)) = receiver.next().await {
    match msg {
        Message::Text(text) => {
            sender.send(Message::Text(text)).await.ok();
        }
        Message::Binary(data) => {
            sender.send(Message::Binary(data)).await.ok();
        }
        Message::Close(_) => {
            // 主动关闭 sink，避免资源泄漏
            let _ = sender.close().await;
            break;
        }
        _ => continue,
    }
}

注意：sender.send() 可能失败（如对端已断开），必须用 .await.ok() 或显式 match，否则任务静默崩溃
不要用 msg.to_string() 解析文本 —— 它不校验 UTF-8，可能 panic；应走 msg.into_text() 并处理 Result

TLS 支持必须显式启用 `native-tls` feature

默认的 tungstenite 不含 TLS，tokio-tungstenite 也只提供接口，底层加密靠 native-tls 或 rustls。

启用方式（Cargo.toml）：

[dependencies]
tungstenite = { version = "0.23", features = ["native-tls"] }
tokio-tungstenite = { version = "0.23", features = ["native-tls"] }

服务端代码里不能直接传 TcpStream 给 accept_async，得先用 native_tls::TlsAcceptor 包一层再 upgrade
更推荐 rustls（零 unsafe、纯 Rust）：需额外加 rustls-tls feature，并手动构造 rustls::ServerConfig