用 Rust + Actix-Web 打造“Hello, WebSocket!”——從握手到回聲,只需 50 行代碼

用 Rust + Actix-Web 打造“Hello, WebSocket!”——從握手到回聲,只需 50 行代碼

一、為什么選擇 Rust 寫 WebSocket?

  • 零成本抽象:編譯期確定生命周期,無 GC 抖動,延遲低至微秒級
  • actix-web:Tokio 生態最成熟的 Web 框架,單機輕松扛 100k 并發
  • 類型安全:消息格式一旦定義,編譯器幫你杜絕“字段對不上”的運行時崩潰

二、核心代碼逐行拆解

下面這份 echo 處理器就是全部業務邏輯——沒有魔法,只有 Rust 標準流程:

pub async fn echo(req: HttpRequest,          // HTTP 升級握手請求stream: web::Payload,      // 原始 TCP 字節流
) -> Result<HttpResponse, Error> {// 1. 協議升級:返回 101 Switching Protocolslet (res, mut session, stream) = actix_ws::handle(&req, stream)?;// 2. 消息聚合:把可能分片的 WebSocket 幀拼成完整消息let mut stream = stream.aggregate_continuations().max_continuation_size(2_usize.pow(20)); // 1 MiB 上限// 3. 異步任務:在后臺持續讀寫,不阻塞主線程rt::spawn(async move {while let Some(msg) = stream.next().await {match msg {Ok(AggregatedMessage::Text(text)) => {println!("↑ {}", text);session.text(text).await.unwrap(); // 原樣回聲}Ok(AggregatedMessage::Binary(bin)) => {println!("↑ (bin) {:x?}", bin);session.binary(bin).await.unwrap();}Ok(AggregatedMessage::Ping(p)) => {println!("↑ ping");session.pong(&p).await.unwrap(); // 保活}_ => {} // Close/Pong 直接忽略}}});Ok(res) // 4. 立即返回 101,升級完成
}

三、把 WebSocket 掛到路由表

config_routes 里加一行即可:

web::scope("/ws").route("", web::get().to(echo))

前端連接示例:

const ws = new WebSocket('ws://localhost:8080/api/ws');
ws.onmessage = (ev) => console.log('↓', ev.data);
ws.send('Hello Rust!');

四、性能小貼士

  1. 零拷貝session.text(text) 直接借用 String,無需額外克隆
  2. 背壓保護max_continuation_size 限制單消息大小,防內存炸彈
  3. 任務隔離rt::spawn 讓每條連接獨立調度,互不影響

五、下一步?

  • broadcast 頻道實現聊天室
  • serde 把 JSON 消息強類型化
  • rustls 升級成 wss 安全連接

完整項目已上傳 GitHub,克隆即可跑:

git clone https://github.com/your-name/actix-ws-echo
cd actix-ws-echo && cargo run

打開瀏覽器,WebSocket 握手→回聲,只需一次 cargo run,你就擁有了毫秒級延遲的實時通信后端。Enjoy Rust!

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/bicheng/95877.shtml
繁體地址,請注明出處:http://hk.pswp.cn/bicheng/95877.shtml
英文地址,請注明出處:http://en.pswp.cn/bicheng/95877.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

基于Cursor的 STM32工程搭建 (編譯、下載、仿真)

嵌入式學習交流Q群 679912988 簡介 本工程使用GCC編譯器、MinGW、CMake構建工具和OpenOCD調試工具。實現了替代KEIL, IAR等在某些情況下不方便使用的情況。實現了編譯、調試、下載、燒錄一體。搭配Cursor的Tab補全功能&#xff0c;編碼效率大大提升。 工具下載及安裝 Cursor…

數據量太大處理不了?Hadoop+Spark輕松解決海洋氣象大數據分析難題

&#x1f34a;作者&#xff1a;計算機畢設匠心工作室 &#x1f34a;簡介&#xff1a;畢業后就一直專業從事計算機軟件程序開發&#xff0c;至今也有8年工作經驗。擅長Java、Python、微信小程序、安卓、大數據、PHP、.NET|C#、Golang等。 擅長&#xff1a;按照需求定制化開發項目…

Day34 UDP套接字編程 可靠文件傳輸與實時雙向聊天系統

day34 UDP套接字編程 可靠文件傳輸與實時雙向聊天系統 UDP文件傳輸 實現客戶端向服務器傳輸文件&#xff08;如圖片&#xff09;的功能&#xff0c;確保傳輸后文件內容完全一致且可正常打開。傳輸過程采用簡單的確認機制防止數據包丟失&#xff0c;傳輸完成后雙方程序自動退出。…

策略模式-不同的鴨子的案例

介紹了策略模式在C#中的應用&#xff0c;以一個鴨子的例子來說明。首先定義了鴨子類以及鴨子的行為&#xff08;方法&#xff09;&#xff0c;然后通過繼承和實現接口的方式來定義不同種類的鴨子的特性。介紹了策略模式的概念&#xff0c;將相同的算法封裝在不同的類中&#xf…

C++語言編程規范-初始化和類型轉換

01 C語言編程規范-常量 02 初始化和類型轉換 聲明、定義與初始化 03 禁止用 memcpy、memset 初始化非 POD 對象 說明&#xff1a;POD 全稱是“Plain Old Data”&#xff0c;是 C 98 標準(ISO/IEC 14882, first edition, 1998-09-01)中引入的一個概念&#xff0c; PO…

從零構建一款開源在線客服系統:我的Go語言實戰之旅

了解更多&#xff0c;搜索 "程序員老狼"用代碼連接世界&#xff0c;讓溝通無界限緣起&#xff1a;為什么選擇開發客服系統&#xff1f;在數字化浪潮席卷全球的今天&#xff0c;企業與客戶之間的溝通方式正在發生深刻變革。傳統的電話和郵件支持已無法滿足即時互動的需…

unsloth筆記:基本介紹

更快的速度、更省的內存訓練、運行、評估大模型 1 支持的模型 All Our Models | Unsloth Documentation 1.1 Dynamic GGUF/instruct 4-bit llama.cpp使用的新模型格式&#xff0c;專為高效、本地推理設計注&#xff1a;GGUF無法微調 只保留推理所需的內容&#xff0c;如量化…

博眾測控 | 一文看懂菊水電源產品在半導體測試中的應用

01 半導體在各行業上的應用半導體作為現代工業體系的“核心神經”&#xff0c;其性能參數與應用場景深度綁定&#xff0c;不同行業因核心設備的功能需求差異&#xff0c;對半導體的電流、電壓承載能力及類型選擇有著明確且嚴格的要求&#xff0c;具體應用細節如下&#xff1a;1…

【STM32】貪吃蛇 [階段 8] 嵌入式游戲引擎通用框架設計

這篇博客是 承接&#xff1a;【項目思維】貪吃蛇&#xff08;嵌入式進階方向&#xff09;中 嵌入式游戲引擎雛形&#xff08;終極進階&#xff09;&#xff0c; 是我們此前從 “寫一個小游戲”提升到“構建可復用游戲框架” 的飛躍階段。我們以“貪吃蛇游戲”為例&#xff0c;抽…

Vue圖標按鈕好用的樣式

圖標按鈕示例一 <template><div class"icon-button-group"><button class"icon-btn icon-btn--default"><i class"el-icon-moon"></i></button><button class"icon-btn icon-btn--primary"&g…

Nginx 實戰系列(一)—— Web 核心概念、HTTP/HTTPS協議 與 Nginx 安裝

文章目錄前言一、Web 概念1.1 Web 的基本概念1.1.1 Web的特點1.2 B/S 架構模型1.3 Web 請求與響應過程&#xff08;重點&#xff09;1.4 靜態資源與動態資源1.5 Web 的發展階段1.6 案例&#xff1a;搭建最小 Web 服務1.6.1 目標1.6.2 搭建步驟1.7 小結二、HTTP 與 HTTPS 協議2.…

一種用geoserver發布復雜樣式矢量服務的方法

最近因為系統需要在國產系統中部署&#xff0c;遇見了國產系統不支持ArcGIS的尷尬局面&#xff0c;好在geoserver還是可以支持的&#xff0c;遂用geoserver解決服務問題。 在發布過程中&#xff0c;遇到比較難受的點就是矢量數據的樣式配圖&#xff0c;在我用QGIS配好導出sld后…

為什么神經網絡網絡算法比機器學習模型算法更加強大?

神經網絡&#xff08;尤其是深度神經網絡&#xff09;相比傳統機器學習模型&#xff08;如線性回歸、決策樹、支持向量機等&#xff09;的“強大”主要體現在其更強的表達能力、自適應特征學習能力以及對復雜模式的建模能力。但這種“強大”并非絕對&#xff0c;而是有特定條件…

中國移動浪潮云電腦CD1000-系統全分區備份包-可瑞芯微工具刷機-可救磚

中國移動浪潮云電腦CD1000-系統全分區備份包-可瑞芯微工具刷機-可救磚 開啟ADB教程&#xff1a; 可查看&#xff1a;浪潮CD1000-移動云電腦-RK3528芯片-232G-安卓9-開啟ADB ROOT破解教程 可輕松打開了wifi adb和USB調試。 往期詳細內容-文章&#xff1a;浪潮CD1000-移動云電腦…

C++兩個字符串的結合

這段代碼實現字符串拼接功能。用戶輸入兩個字符串a和b后&#xff0c;使用append()方法將b追加到a后面&#xff0c;然后輸出拼接后的結果。代碼簡潔但存在改進空間&#xff1a;1. 缺少輸入驗證 2. 直接修改原字符串a可能不符合某些場景需求 3. 可考慮更高效的拼接方式。適合基礎…

UE4 Rider調試時添加自定義命令行參數

1、打開 Rider 右上角&#xff0c;針對你的項目&#xff08;例如叫做“Mini”&#xff09;打開 Edit 2、輸入自定義的參數&#xff0c;如下圖的例子是輸入 -dx12 -norhithread &#xff0c;然后Apply并OK。3、開始調試&#xff08;蟲子按鈕&#xff09;

混合架構大型語言模型(Jamba)

Jamba是由AI21 Labs開發的混合架構大型語言模型&#xff08;LLM&#xff09;&#xff0c;結合了Transformer的語義理解能力和Mamba結構化狀態空間模型&#xff08;SSM&#xff09;的高效性&#xff0c;旨在解決長文本處理中的計算瓶頸。 一、技術特點 1.混合架構設計 Jamba采用…

2025 年高教社杯全國大學生數學建模競賽C 題 NIPT 的時點選擇與胎兒的異常判定詳解(一)

基于胎兒Y染色體濃度的孕周與BMI建模分析摘要本文利用某競賽提供的胎兒Y染色體濃度數據&#xff0c;建立了以孕周和孕婦BMI為自變量的多項式回歸模型&#xff0c;探討了其對Y染色體濃度的影響。通過數據清洗與篩選&#xff0c;共獲得1082條有效男胎樣本。結果顯示&#xff1a;Y…

PyTorch DDP 隨機卡死復盤:最后一個 batch 掛起,NCCL 等待不返回

PyTorch DDP 隨機卡死復盤&#xff1a;最后一個 batch 掛起&#xff0c;NCCL 等待不返回&#xff0c;三步修復 Sampler & drop_last很多人在接觸深度學習的過程往往都是從自己的筆記本開始的&#xff0c;但是從接觸工作后&#xff0c;更多的是通過分布式的訓練來模型。由于…

計算機專業考研備考建議

對于全國碩士研究生招生考試&#xff08;考研&#xff09;&#xff0c;考試科目主要由兩大部分組成&#xff1a;全國統一命題的公共課 和 由招生單位自主命題的專業課。具體的考試科目取決于你報考的專業和學校。下面我為你詳細拆解&#xff1a;一、考試科目構成&#xff08;絕…