簡(jiǎn)介這是一份面向C#初學(xué)者的Socket網(wǎng)絡(luò)通訊完整源碼示例覆蓋服務(wù)端與客戶端兩端程序基于WinForm界面實(shí)現(xiàn)代碼風(fēng)格直接明了可幫助理解Socket連接、發(fā)送與接收消息的核心流程也適合作為課程設(shè)計(jì)或畢業(yè)設(shè)計(jì)的起點(diǎn)工程。壓縮包共61個(gè)文件以cs源碼文件為主體同時(shí)包含exe可執(zhí)行程序、sln/csproj工程文件、pdb調(diào)試符號(hào)、resx資源文件等整體僅1.17MB輕量且結(jié)構(gòu)完整。目前已有2914人學(xué)習(xí)下載說明其在入門場(chǎng)景中的實(shí)用性已被較多開發(fā)者驗(yàn)證。源碼將server與client分區(qū)整理打開即用無(wú)需復(fù)雜配置同時(shí)代碼中保留了清晰的邏輯層次讀者可以對(duì)照兩端程序逐步掌握通訊建立、數(shù)據(jù)交換與界面聯(lián)動(dòng)的方法。若想進(jìn)一步擴(kuò)展可在現(xiàn)有基礎(chǔ)上加入多客戶端管理、心跳機(jī)制或文件傳輸?shù)裙δ芊奖愣伍_發(fā)。1. C# Socket 網(wǎng)絡(luò)通訊一套完整源碼為什么值得從頭寫一遍很多剛接觸 C# Socket 網(wǎng)絡(luò)通訊的人第一反應(yīng)是去搜“完整源碼”結(jié)果拿回來(lái)的東西要么貼了半本 C# 高級(jí)編程的片段要么封了好幾層事件回調(diào)一改參數(shù)就翻車。Socket 編程的難點(diǎn)從來(lái)不在那幾行 API而在連接什么時(shí)候斷、消息什么時(shí)候拆、編碼按什么解這些看不見現(xiàn)場(chǎng)的問題才是通訊層真正要交付的東西。我按“簡(jiǎn)單、清楚”的標(biāo)準(zhǔn)整理了一套可以直接新建控制臺(tái)項(xiàng)目跑起來(lái)的 TCP 源碼服務(wù)端監(jiān)聽、客戶端連接、一次收發(fā)、斷線感知每一步都能在代碼里找到對(duì)應(yīng)位置。源碼不引第三方庫(kù)不堆設(shè)計(jì)模式適合剛上手 C# Socket 編程、以及要做上位機(jī)或設(shè)備數(shù)據(jù)采集的讀者。新手能照著跑通老手能直接對(duì)照邊界條件補(bǔ)自己的工程這就是這套源碼存在的價(jià)值。2. 先立通訊模型TCP 選型、阻塞式讀寫與 C# 里的 Socket 流程動(dòng)手寫代碼之前有三件事要先定下來(lái)鏈路用 TCP 還是 UDP收發(fā)用同步還是異步Socket 從 Bind 到 Close 到底經(jīng)歷了什么。這三個(gè)問題不解決后面的代碼再完整到排查問題時(shí)也是一只黑匣子只能靠猜。2.1 TCP 與 UDP 的選型為什么工控與上位機(jī)場(chǎng)景默認(rèn)選 TCPC# 做設(shè)備通訊面對(duì)的大多數(shù)協(xié)議最終都跑在 Socket 上。Modbus TCP 在外面裹了一層應(yīng)用協(xié)議底層還是 TCP西門子 S7 走的是加工過的 TCP自定義數(shù)據(jù)采集更是以 TCP 為主。原因不復(fù)雜TCP 有握手、確認(rèn)和重傳能保證字節(jié)按序到達(dá)。對(duì)“指令下發(fā) 數(shù)據(jù)回傳”這種需要一問一答的采集場(chǎng)景UDP 天然就不合適。兩種協(xié)議的業(yè)務(wù)側(cè)代價(jià)需要分清楚對(duì)比項(xiàng)TCPUDP連接狀態(tài)面向連接三次握手無(wú)連接直接發(fā)送可靠性確認(rèn)重傳、按序到達(dá)不保證不丟、不保證順序典型場(chǎng)景上位機(jī)指令、PLC 點(diǎn)位、采集上傳音視頻、廣播、告警遙測(cè)業(yè)務(wù)層難度要處理粘包和半包報(bào)文自帶邊界但丟包要業(yè)務(wù)自己兜底UDP 的代碼表面上看更短但“不丟包”這個(gè)承諾要業(yè)務(wù)層自己補(bǔ)序號(hào)、超時(shí)重發(fā)、去重、亂序排列做起來(lái)比 TCP 的拆包麻煩得多。所以我一般建議在沒有明確實(shí)時(shí)性要求時(shí)默認(rèn)選 TCP。真的要用 UDP就把收發(fā)和業(yè)務(wù)解耦不要在回調(diào)里做重活否則一處丟包會(huì)把整個(gè)狀態(tài)機(jī)帶偏。2.2 阻塞式、異步式與事件驅(qū)動(dòng)哪種寫法才配得上“簡(jiǎn)單清楚”“簡(jiǎn)單清楚”在 Socket 編程里有一個(gè)容易被忽略的含義代碼要能被第二個(gè)人快速看懂出問題時(shí)能順著調(diào)用鏈查下去。很多人把“代碼短”當(dāng)成簡(jiǎn)單于是滿屏 async/await實(shí)際上異步的異常棧和上下文切換在新人接手時(shí)明顯增加排查成本。我?？吹剿姆N寫法同步阻塞的 Read/Write、APM 風(fēng)格的 BeginXxx/EndXxx、async/await 異步、SocketAsyncEventArgs。APM 回調(diào)嵌套讀起來(lái)很累SocketAsyncEventArgs 適合幾千連接的網(wǎng)關(guān)性能好但理解成本高。C# 上位機(jī)通常是幾十臺(tái)設(shè)備的小規(guī)模通訊同步阻塞加每客戶端一個(gè)線程數(shù)據(jù)路徑最直日志最好加。TcpListener 本身就是為這種寫法設(shè)計(jì)的不是非要繞開它。在 .NET 6 之后的項(xiàng)目里為了不阻塞界面線程可以在 UI 層開 Task通訊內(nèi)核仍然保持同步循環(huán)。線程池會(huì)自動(dòng)在線程阻塞時(shí)補(bǔ)充線程幾十個(gè)客戶端看不出壓力。等業(yè)務(wù)規(guī)模真正超過這個(gè)模型的承受范圍再換異步不遲不要一開始就為了性能做架構(gòu)。2.3 從 Bind 到 ReceiveSocket 生命周期與關(guān)鍵參數(shù)Socket 生命周期可以用一張對(duì)應(yīng)表講清楚方法角色實(shí)際作用Bind服務(wù)端把 IP 和端口綁定到套接字Listen服務(wù)端進(jìn)入監(jiān)聽參數(shù)是 backlogAccept服務(wù)端取出一個(gè)已完成握手的 TCP 連接Connect客戶端發(fā)起三次握手Send / Write雙方發(fā)送字節(jié)流Receive / Read雙方讀取字節(jié)流這里最容易被忽略的是關(guān)閉行為。主動(dòng)關(guān)閉的一方會(huì)進(jìn)入 TIME_WAIT持續(xù)約幾十秒到兩分鐘的 2MSL期間同樣的端口不能被立刻重綁。服務(wù)端頻繁重啟遇到“地址已被占用”十有八九是這個(gè)原因。backlog 是內(nèi)核里“已完成握手但應(yīng)用還沒 Accept”的連接隊(duì)列上限給 10 以內(nèi)足夠給大不會(huì)提升并發(fā)能力。另一個(gè)必須建立的認(rèn)知是Socket 層面沒有“消息”只有“字節(jié)流”。Write 一次對(duì)端可能 Read 一次、兩次也可能一次把好幾條都讀走。這個(gè)特性決定了通訊層必須自己設(shè)計(jì)幀邊界也就是后面要展開的粘包問題。3. 完整源碼落地服務(wù)端、客戶端與最小可跑通實(shí)現(xiàn)模型立住了接下來(lái)給一套能直接復(fù)現(xiàn)的源碼。新建一個(gè) .NET 6 控制臺(tái)項(xiàng)目把下面三個(gè)類分別放到項(xiàng)目里或者全部放在同一個(gè) Program.cs 里也行。為了讀起來(lái)清爽我按服務(wù)端、客戶端、入口分開寫每段代碼后面跟著參數(shù)說明。3.1 TcpListener 服務(wù)端監(jiān)聽、Accept 與多客戶端處理服務(wù)端用 TcpListener 監(jiān)聽 9000 端口每連進(jìn)一個(gè)客戶端就交給線程池處理。這樣 Accept 循環(huán)不會(huì)被某個(gè)客戶端的收發(fā)卡住多客戶端同時(shí)在線也不互相干擾。using System; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; namespace SocketDemo { public class TcpServer { private readonly TcpListener _listener; private readonly int _bufferSize; public TcpServer(int port, int backlog 10, int bufferSize 4096) { // IPAddress.Any 表示監(jiān)聽本機(jī)所有網(wǎng)卡的 0.0.0.0:port _listener new TcpListener(IPAddress.Any, port); _listener.Start(backlog); _bufferSize bufferSize; Console.WriteLine($[Server] listening on 0.0.0.0:{port}, backlog{backlog}); } public void Run() { while (true) { // Accept 阻塞到有客戶端完成握手才返回一個(gè) TcpClient TcpClient client _listener.AcceptTcpClient(); Console.WriteLine($[Server] client connected: {client.Client.RemoteEndPoint}); // 每個(gè)客戶端一個(gè)線程池任務(wù)避免處理慢客戶端時(shí)阻塞后續(xù) Accept ThreadPool.QueueUserWorkItem(HandleClient, client); } } private void HandleClient(object state) { TcpClient client (TcpClient)state; byte[] buffer new byte[_bufferSize]; try { using (NetworkStream stream client.GetStream()) { while (true) { // Read 返回 0 表示對(duì)端完成了正常關(guān)閉 int readCount stream.Read(buffer, 0, buffer.Length); if (readCount 0) break; string text Encoding.UTF8.GetString(buffer, 0, readCount); Console.WriteLine($[Server] recv {readCount} bytes: {text}); // 原樣回給客戶端方便驗(yàn)證整條鏈路 byte[] ack Encoding.UTF8.GetBytes($ack[{readCount}]: {text}); stream.Write(ack, 0, ack.Length); } } } catch (Exception ex) { // 斷電、超時(shí)、對(duì)端強(qiáng)行斷開都會(huì)走到這里先記日志再關(guān)閉連接 Console.WriteLine($[Server] client error: {ex.Message}); } finally { client.Close(); Console.WriteLine([Server] client closed); } } } }這段代碼里的數(shù)據(jù)流是直線Accept 拿到連接ThreadPool 起一個(gè)任務(wù)任務(wù)里循環(huán) Read讀到 0 就退出異常就記日志最后必然 Close。IsConnected 這種屬性我故意不看因?yàn)樗谶B接異常后仍然可能為 true不能用來(lái)判斷鏈路真實(shí)狀態(tài)。TCP 連接拔線后不會(huì)主動(dòng)告知對(duì)方只有 Read 一直阻塞這個(gè)點(diǎn)留在第 4 章講。參數(shù)上IPAddress.Any 監(jiān)聽所有網(wǎng)卡。只想讓內(nèi)網(wǎng)機(jī)器連就把它換成具體內(nèi)網(wǎng) IP避免服務(wù)暴露到額外網(wǎng)卡上。backlog 給 10 即可這個(gè)數(shù)字只影響排隊(duì)未處理的連接數(shù)不提升收發(fā)性能。bufferSize 設(shè)為 4096 是單次 Read 的上限不是協(xié)議幀長(zhǎng)度。如果設(shè)備單幀超過 4096這段代碼會(huì)截?cái)嘈枰浜喜鸢壿嫴荒芎?jiǎn)單把 buffer 開大就算解決。3.2 TcpClient 客戶端連接超時(shí)、收發(fā)超時(shí)與一次標(biāo)準(zhǔn)回顯客戶端要解決的第一件事是連接超時(shí)。TcpClient.Connect 在目標(biāo) IP 不可達(dá)時(shí)等待時(shí)間由系統(tǒng)協(xié)議棧決定經(jīng)常十幾秒才拋錯(cuò)設(shè)備離線時(shí)體驗(yàn)很差。用 BeginConnect 加 WaitOne 可以自己控制這個(gè)時(shí)間。using System; using System.Net.Sockets; using System.Text; namespace SocketDemo { public class TcpClientHelper { private TcpClient _client; public void Connect(string ip, int port, int timeoutMs 3000, int receiveTimeoutMs 3000, int sendTimeoutMs 3000) { _client new TcpClient(); _client.ReceiveTimeout receiveTimeoutMs; _client.SendTimeout sendTimeoutMs; // BeginConnect WaitOne 是控制連接耗時(shí)的常用寫法 IAsyncResult handle _client.BeginConnect(ip, port, null, null); if (!handle.AsyncWaitHandle.WaitOne(timeoutMs)) { _client.Close(); throw new TimeoutException($connect to {ip}:{port} timeout after {timeoutMs}ms); } _client.EndConnect(handle); Console.WriteLine($[Client] connected to {ip}:{port}); } public void Send(string text) { if (_client null || !_client.Connected) throw new InvalidOperationException(client is not connected); byte[] data Encoding.UTF8.GetBytes(text); _client.GetStream().Write(data, 0, data.Length); Console.WriteLine($[Client] sent {data.Length} bytes); } public string ReceiveText() { byte[] buffer new byte[4096]; int n _client.GetStream().Read(buffer, 0, buffer.Length); if (n 0) return null; return Encoding.UTF8.GetString(buffer, 0, n); } public void Close() { _client?.Close(); } } }BeginConnect 之后必須調(diào)用 EndConnect否則異步句柄泄漏。WaitOne 超時(shí)后要立刻 Close 并拋異常這個(gè)動(dòng)作相當(dāng)于把半握手的連接直接放棄。ReceiveTimeout 和 SendTimeout 只對(duì)已建立的連接生效超時(shí)后下一次 Read 或 Write 會(huì)拋 IOException后續(xù)走異常分支執(zhí)行斷開。提示示例里 Send 和 ReceiveText 分別調(diào)用 GetStream()單線程一問一答時(shí)沒有問題。項(xiàng)目規(guī)范一點(diǎn)的話在 Connect 時(shí)保存一次 NetworkStream 并復(fù)用避免多個(gè)包裝實(shí)例同時(shí)讀寫同一個(gè) Socket。ReceiveText 是一次性 Read 的簡(jiǎn)化版它不保證“讀一次就是一條完整消息”。TCP 是字節(jié)流可能只讀到半條也可能一次性拿到好幾條。我這里先讓通路跑起來(lái)拆包統(tǒng)一放到第 4 章處理。3.3 入口與運(yùn)行驗(yàn)證兩個(gè)終端十分鐘跑通主程序用一個(gè)參數(shù)區(qū)分服務(wù)端和客戶端。帶 server 參數(shù)就啟動(dòng)監(jiān)聽不帶參數(shù)就走客戶端交互模式方便本機(jī)自測(cè)。using System; using System.Text; namespace SocketDemo { class Program { static void Main(string[] args) { // Windows 控制臺(tái)默認(rèn)編碼可能是 GBK先固定成 UTF8 再輸出日志 Console.OutputEncoding Encoding.UTF8; if (args.Length 0 args[0] server) { new TcpServer(port: 9000).Run(); return; } TcpClientHelper helper new TcpClientHelper(); helper.Connect(127.0.0.1, 9000, timeoutMs: 3000); while (true) { Console.Write( ); string line Console.ReadLine(); if (string.IsNullOrEmpty(line)) continue; if (line exit) break; helper.Send(line); string reply helper.ReceiveText(); Console.WriteLine($reply: {reply}); } helper.Close(); } } }運(yùn)行順序很簡(jiǎn)單打開終端 A 執(zhí)行dotnet run -- server再打開終端 B 執(zhí)行dotnet run。在 B 輸入任意字符串比如hello c# socket終端 A 會(huì)打印收到的字節(jié)數(shù)B 會(huì)收到ack回顯。輸入中文也能正常顯示因?yàn)榭刂婆_(tái)輸出編碼已經(jīng)固定為 UTF8。如果 reply 正常回來(lái)說明監(jiān)聽、握手、收發(fā)整條鏈路已經(jīng)通了。此時(shí)可以試一下輸入長(zhǎng)度超過 4000 的文本會(huì)看到服務(wù)端被截?cái)嗷蛘叻謨纱巫x這屬于預(yù)期行為不是代碼壞了是拆包還沒做。3.4 初始化參數(shù)表端口、backlog、緩沖區(qū)與超時(shí)參數(shù)推薦值說明端口9000避開常見系統(tǒng)服務(wù)客戶端與服務(wù)端必須一致backlog10已完成握手但未 Accept 的連接隊(duì)列上限bufferSize4096單次 Read 上限不等同業(yè)務(wù)幀長(zhǎng)度連接超時(shí)3000ms用 BeginConnect WaitOne 實(shí)現(xiàn)收發(fā)超時(shí)3000ms對(duì)已建立連接生效超時(shí)拋 IOException如果是本地學(xué)習(xí)端口隨意。要放到公司網(wǎng)絡(luò)長(zhǎng)期跑建議先和運(yùn)維確認(rèn)端口段避免跟其他系統(tǒng)撞上。連接超時(shí) 3 秒是一個(gè)比較穩(wěn)的起點(diǎn)太短會(huì)在設(shè)備啟動(dòng)慢時(shí)誤報(bào)離線太長(zhǎng)會(huì)讓重試機(jī)制失去意義。收發(fā)超時(shí)也一樣先給 3 秒跑通再按設(shè)備實(shí)際響應(yīng)時(shí)間調(diào)整。4. 踩坑排查C# Socket 最常見的 5 個(gè)“代碼沒錯(cuò)就是不工作”代碼能跑通只算第一步。下面幾類問題我在 Socket 項(xiàng)目里都遇到過現(xiàn)象看起來(lái)像玄學(xué)原因其實(shí)都在協(xié)議棧、編碼或者系統(tǒng)設(shè)置里。按“監(jiān)聽地址、端口占用、防火墻、編碼、粘包”這個(gè)順序排查基本能覆蓋多數(shù)場(chǎng)景。4.1 端口占用與 TIME_WAIT服務(wù)端第二次啟動(dòng)就報(bào) SocketException現(xiàn)象第一次運(yùn)行服務(wù)端正常改成代碼重新編譯后再次啟動(dòng)控制臺(tái)拋出“通常每個(gè)套接字地址(協(xié)議/網(wǎng)絡(luò)地址/端口)只允許使用一次”或者 SocketException 10048。原因上一次進(jìn)程沒有退干凈或者端口被別的服務(wù)占用了。還有一個(gè)常見來(lái)源是服務(wù)端主動(dòng) Close 后進(jìn)入 TIME_WAIT 狀態(tài)同一端口短期內(nèi)無(wú)法重新綁定。解決先查端口歸屬再動(dòng)手。在命令行執(zhí)行netstat -ano | findstr 9000拿到 PID 后用tasklist /fi pid eq PID確認(rèn)是什么進(jìn)程。測(cè)試環(huán)境可以換一個(gè)端口立刻恢復(fù)。有人會(huì)用 SetSocketOption(ReuseAddress) 讓重啟更快不建議生產(chǎn)環(huán)境這么做它會(huì)掩蓋“上一個(gè)進(jìn)程還沒退出”的真實(shí)故障。4.2 粘包拆包Read 一次收不到“一條消息”怎么辦現(xiàn)象客戶端連續(xù)發(fā)兩條指令服務(wù)端一次 Read 同時(shí)收到兩條或者一條大指令被拆成兩次到達(dá)。打印日志時(shí)看到的內(nèi)容和服務(wù)端發(fā)給客戶端的完全對(duì)不上。原因TCP 對(duì)上層只承諾字節(jié)流不保證一次 Write 對(duì)應(yīng)一次 Read。應(yīng)用層如果按 Read 次數(shù)切分消息必然出現(xiàn)粘連和半包。解決應(yīng)用層自己定義幀邊界。最常見做法是“4 字節(jié)長(zhǎng)度頭 負(fù)載”服務(wù)端維護(hù)一塊剩余緩沖區(qū)每次 Read 后按長(zhǎng)度頭切出完整幀using System; using System.Collections.Generic; using System.Linq; private byte[] _remain Array.Emptybyte(); public Listbyte[] TryDecodeFrames(byte[] chunk) { Listbyte[] frames new Listbyte[](); _remain _remain.Concat(chunk).ToArray(); while (_remain.Length 4) { // 先讀長(zhǎng)度頭判斷后續(xù)字節(jié)是否夠一個(gè)整幀 int len BitConverter.ToInt32(_remain, 0); if (_remain.Length 4 len) { break; } byte[] frame _remain.Skip(4).Take(len).ToArray(); frames.Add(frame); _remain _remain.Skip(4 len).ToArray(); } return frames; }每次收到網(wǎng)絡(luò)數(shù)據(jù)就把 chunk 交給 TryDecodeFrames返回值里的每個(gè)元素就是一條完整業(yè)務(wù)幀。長(zhǎng)度不足就留在 _remain 里等下一次。BitConverter.ToInt32 默認(rèn)解析小端序西門子 S7 和部分儀表用大端.NET 里要換成 BinaryPrimitives.ReadInt32BigEndian。這個(gè)寫法適合中小協(xié)議高吞吐場(chǎng)景要改成偏移量裁剪避免頻繁 Concat 產(chǎn)生新數(shù)組。4.3 斷電無(wú)感服務(wù)端一直卡在 Read怎么知道設(shè)備已經(jīng)離線現(xiàn)象設(shè)備斷電或者網(wǎng)線被拔掉服務(wù)端控制臺(tái)沒有任何異常日志停在最后一條接收記錄上程序還認(rèn)為設(shè)備在線。原因TCP 沒有物理鏈路檢測(cè)。對(duì)端斷電時(shí)不會(huì)發(fā)任何包服務(wù)端 Read 會(huì)一直阻塞既不會(huì)返回 0也不會(huì)拋異常。解決應(yīng)用層做心跳。客戶端每 3 秒發(fā)一個(gè)心跳幀服務(wù)端記錄每個(gè)連接的最近接收時(shí)間連續(xù) 9 秒以上沒收包就 Close。ReceiveTimeout 可以當(dāng)一個(gè)輔助兜底單次 Read 超時(shí)會(huì)拋 IOException但它只能告訴你“這一讀超時(shí)了”不能判斷對(duì)端是否活著而且 3 秒超時(shí)對(duì)慢速設(shè)備會(huì)誤殺。心跳字段要帶設(shè)備號(hào)或連接 ID否則多客戶端場(chǎng)景下不知道是哪個(gè)連接掉線。4.4 本機(jī)通、跨機(jī)不通防火墻、綁定地址與端口探測(cè)現(xiàn)象客戶端用 127.0.0.1 連接服務(wù)端一切正常換成局域網(wǎng) IP 后連接一直超時(shí)。原因最常見的是服務(wù)端監(jiān)聽地址綁在 127.0.0.1 上只接受回環(huán)連接其次是 Windows 防火墻默認(rèn)攔截入站端口還有可能服務(wù)器有多個(gè)網(wǎng)卡客戶端訪問的 IP 不對(duì)。解決服務(wù)端監(jiān)聽改成 IPAddress.Any 并重新編譯運(yùn)行?？蛻舳嗽诜?wù)器上用 ipconfig 確認(rèn)當(dāng)前有效 IP再用 PowerShell 執(zhí)行Test-NetConnection 192.168.x.x -Port 9000代替 telnet 做端口探測(cè)。若網(wǎng)絡(luò)層面通了但業(yè)務(wù)連不上去“高級(jí)安全 Windows Defender 防火墻”加一條 TCP 入站規(guī)則放行 9000。生產(chǎn)環(huán)境記得只對(duì)來(lái)源 IP 段開放別為了省事把整個(gè)入站關(guān)掉。4.5 編碼錯(cuò)位與二進(jìn)制協(xié)議UTF8 解 GBK 必然亂碼現(xiàn)象設(shè)備傳上來(lái)的中文字段變成亂碼常見的是“錕斤拷”這類 UTF8 解碼 GBK 的典型產(chǎn)物或者 ASCII 字符后跟了一串不認(rèn)識(shí)的符號(hào)。原因設(shè)備按 GBK 或 ASCII 編碼發(fā)送C# 端卻用 Encoding.UTF8 解碼字節(jié)和字符映射完全錯(cuò)位。很多工控設(shè)備固件是早期團(tuán)隊(duì)寫的默認(rèn)字符集停留在 GBK。解決協(xié)議文檔里寫清楚編碼啟動(dòng)時(shí)從配置文件讀 Encoding不要硬編碼 UTF8。對(duì)于 S7、Modbus TCP 這類純二進(jìn)制協(xié)議不要先轉(zhuǎn)字符串再解析用 MemoryStream 和 BitConverter 按偏移讀字段。如果異常同時(shí)出現(xiàn)“遠(yuǎn)程主機(jī)強(qiáng)迫關(guān)閉了一個(gè)現(xiàn)有的連接”多半是兩端協(xié)議字段理解不一致對(duì)端直接 RST 斷開了連接。5. 進(jìn)階驗(yàn)證把“能跑通”變成“可靠通訊”的三個(gè)小習(xí)慣通訊模塊能跑通之后下一步不是急著加業(yè)務(wù)而是做三輪驗(yàn)證。把這套驗(yàn)證固定成模板能省下大量后續(xù)聯(lián)調(diào)時(shí)間。5.1 回環(huán)自測(cè)、跨機(jī)驗(yàn)證與斷線測(cè)試一張表覆蓋四種場(chǎng)景自測(cè)項(xiàng)操作通過標(biāo)準(zhǔn)回環(huán)收發(fā)本機(jī)起服務(wù)端和客戶端發(fā)中文和長(zhǎng)文本服務(wù)端收到客戶端拿到 ack跨機(jī)連通客戶端換成服務(wù)器內(nèi)網(wǎng) IP連接建立無(wú)超時(shí)粘包拆包客戶端連續(xù)發(fā) 5 條短消息服務(wù)端按幀打印 5 條不串、不丟斷線感知客戶端運(yùn)行中拔掉網(wǎng)線心跳超時(shí)后服務(wù)端打印斷開日志本機(jī)回環(huán)只能證明代碼邏輯對(duì)跨機(jī)才能暴露防火墻和網(wǎng)卡綁定問題。斷線感知是最后一道關(guān)也是最容易被跳過的。5.2 把長(zhǎng)度頭固定成協(xié)議一部分發(fā)送和接收必須對(duì)稱把第 4 章的 TryDecodeFrames 集成進(jìn)客戶端的發(fā)送邏輯發(fā)送方先拼 4 字節(jié)長(zhǎng)度頭再加負(fù)載接收方用同一套規(guī)則拆幀。長(zhǎng)度頭里存放的是負(fù)載字節(jié)數(shù)不是整個(gè)緩沖區(qū)的長(zhǎng)度兩端對(duì)大端小端的約定必須一致。這樣以后設(shè)備協(xié)議變更只需要替換幀格式不碰 Socket 收發(fā)循環(huán)。5.3 心跳、超時(shí)、重連三件套通訊層交付前的最后一關(guān)客戶端要加一個(gè)定時(shí)器每 3 秒發(fā)心跳幀服務(wù)端維護(hù) LastReceiveTime超時(shí)即 Close?？蛻舳耸盏綌嗑€通知后按遞增退避重連比如 1 秒、2 秒、5 秒避免斷線風(fēng)暴打滿服務(wù)端。這套組合做下來(lái)設(shè)備半夜斷電服務(wù)端能在 30 秒內(nèi)感知并摘掉離線連接第二天現(xiàn)場(chǎng)不會(huì)出現(xiàn)數(shù)據(jù)缺了整晚卻無(wú)日志可查的局面。我有一年做過一個(gè)采集項(xiàng)目設(shè)備半夜掉電后服務(wù)端仍顯示在線第二天現(xiàn)場(chǎng)反饋數(shù)據(jù)缺了整晚日志里找不出任何報(bào)錯(cuò)。從那以后我養(yǎng)成了一個(gè)習(xí)慣凡是交付通訊層必須先過“拔線之后能否感知”這一關(guān)再談業(yè)務(wù)功能。這套驗(yàn)證模板幫我在后續(xù)好幾個(gè)項(xiàng)目里避了雷希望幫到你。本文還有配套的精品資源點(diǎn)擊獲取