在做C#上位機(jī)和設(shè)備通信時我估計你遲早會碰到這種場景設(shè)備下發(fā)一條數(shù)據(jù)幀程序收是收到了但解析出來卻是亂碼或者明明只發(fā)了一條指令接收方卻一下蹦出來兩幀內(nèi)容又或者一條完整的數(shù)據(jù)被拆成了兩次甚至三次才讀完。在調(diào)試溫控設(shè)備的時候我就被這個問題折騰了一整個下午PLC每100毫秒回傳一條長度固定的報文我用Socket接收后拼出來一看幀頭幀尾對不上數(shù)據(jù)東一塊西一塊。后來才弄清楚這不叫網(wǎng)絡(luò)爛了而是C#網(wǎng)絡(luò)編程中最典型的粘包和分包問題。這篇文章就專門來聊清楚TCP為什么會出現(xiàn)粘包和分包C#里一般怎么設(shè)計一個可靠的拆包機(jī)制以及實際代碼中哪些地方最容易被忽視。無論你是剛接觸C#網(wǎng)絡(luò)編程的新手還是在做上位機(jī)、工業(yè)設(shè)備、Modbus通信這類項目的開發(fā)者這篇文章的思路都可以直接抄到項目里。1. 粘包分包的本質(zhì)TCP是字節(jié)流不是消息流很多新手會把Socket通信想象成發(fā)一條、收一條給Socket發(fā)一個字節(jié)數(shù)組對面就應(yīng)該原封不動地一個字節(jié)數(shù)組收回來。這個直覺在UDP里是對的在TCP里是錯的。TCP是一個面向字節(jié)流的協(xié)議。它不關(guān)心你應(yīng)用層發(fā)了多少次寫入也不承諾每次寫入對應(yīng)一次讀取。操作系統(tǒng)內(nèi)核里有一塊發(fā)送緩沖區(qū)和一塊接收緩沖區(qū)發(fā)送端應(yīng)用調(diào)用一次Send數(shù)據(jù)可能被拆成多個TCP報文段接收端協(xié)議棧收到數(shù)據(jù)后會按照自己的節(jié)奏往接收緩沖區(qū)里放應(yīng)用層調(diào)用Receive時讀出來多少字節(jié)完全取決于緩沖區(qū)里當(dāng)時有多少數(shù)據(jù)。所以你無法通過TCP的讀寫次數(shù)來保證消息的邊界。1.1 為什么發(fā)送方調(diào)用一次Send接收方卻不按套路出牌這里面有多個層面的原因疊加我逐個說TCP分段發(fā)送數(shù)據(jù)量超過MSS最大報文段長度時一條應(yīng)用消息會被拆成多個TCP段發(fā)送于是接收方可能分多次讀到。Nagle算法默認(rèn)情況下TCP啟用Nagle算法它會把小包攢在一起直到收到前一個小包的ACK或者積累到一定程度才一起發(fā)出去。結(jié)果就是多次Send的數(shù)據(jù)可能被合并到一個TCP段里接收方一次性讀到的就是粘在一起的多條消息。接收方讀取時機(jī)真正決定一次Receive返回多少字節(jié)的是接收緩沖區(qū)的數(shù)據(jù)和程序調(diào)用Receive的時刻。哪怕發(fā)送方按固定的節(jié)奏發(fā)接收方如果攢了一會兒再讀就會攢出多包如果剛讀完緩沖區(qū)又立馬去讀可能一條消息還沒完整到達(dá)讀出來的就是半個包。所以粘包一次收到多條消息和分包一條消息被拆開多次本質(zhì)上就是同一個原因TCP把應(yīng)用消息切成了字節(jié)流而接收方?jīng)]有按消息邊界去取。解決的方向也就清晰了——必須自己定義消息邊界。1.2 四個典型的事故現(xiàn)場為了讓你排查時對號入座我把實際調(diào)試中常見的情況列成一張表遇到類似現(xiàn)象就可以直接判斷現(xiàn)象本質(zhì)常見原因一次Receive返回的數(shù)據(jù)里包含了兩條完整消息粘包多次Send的數(shù)據(jù)被TCP合并或接收端讀取間隔太長一條消息分兩次Receive返回分包半包消息長度超過MSS或TCP分片后到達(dá)時間不一致讀到的數(shù)據(jù)開頭是正確的但尾部少了一截不完整半包Receive返回的字節(jié)數(shù)小于應(yīng)用層消息長度緩沖區(qū)剩余數(shù)據(jù)還沒到達(dá)一次Receive返回的數(shù)據(jù)里有一條完整消息加另一條消息的開頭粘包分包同時發(fā)生最常見說明接收緩沖區(qū)里混合了多幀數(shù)據(jù)我自己最初踩的坑就是最后一種數(shù)據(jù)幀長度固定是32字節(jié)第一次收到48字節(jié)我以為是一條消息結(jié)果解析出來前32字節(jié)是上一幀后16字節(jié)是下一幀的開頭。如果不做邊界處理整個解析邏輯全亂。1.3 為什么UDP不粘包而TCP偏偏會這里簡單對比一下UDP是數(shù)據(jù)報協(xié)議它保留消息邊界。調(diào)用一次SendTo接收方調(diào)用一次ReceiveFrom拿到的基本就是那一個完整的數(shù)據(jù)報除非超過緩沖區(qū)被截斷所以UDP不需要處理粘包。但UDP不保證不丟包、不保證有序可靠性要自己在應(yīng)用層補(bǔ)所以很多強(qiáng)調(diào)可靠傳輸?shù)脑O(shè)備通信底層還是走TCP。用個生活化的類比UDP像是在郵局寄一個個獨(dú)立的快遞箱每個箱子就是一個包裹箱子和箱子之間不會粘在一起TCP則像一根水管里的水流你往水管里倒了幾杯水水管出口的水是連成一股的你想從這股水里撈出原來那幾杯水的分界就必須在水里放不同顏色的段或者加明顯的隔斷。在C#網(wǎng)絡(luò)編程里這個隔斷就是消息邊界的設(shè)計。2. 三種主流的消息邊界方案怎么選既然TCP字節(jié)流里沒有現(xiàn)成的邊界那我們就自己加上邊界。業(yè)界常見的方案有三種固定長度、特殊分隔符、長度前綴。這三種方案我都在實際項目里用過各自有非常明確的適用場景。2.1 方案一固定長度消息——最簡單但不夠靈活如果通信的雙方約定好每條消息固定為N個字節(jié)那么接收方只需要不斷讀取攢夠N個字節(jié)就解析一幀把剩下的數(shù)據(jù)留給下一輪。比如很多工業(yè)設(shè)備的狀態(tài)幀就是固定的8字節(jié)、16字節(jié)等。這種方案解析效率很高實現(xiàn)也最簡單缺點(diǎn)是消息長度不能變。如果一次要傳一個不定長的字符串比如設(shè)備名稱固定長度要么會浪費(fèi)帶寬按最大長度算要么會截斷內(nèi)容。只適合長度固定、或者能用固定結(jié)構(gòu)體表示的協(xié)議。如果協(xié)議里有一部分是固定的有一部分是變長的那就需要更靈活的方案。2.2 方案二特殊分隔符——適合文本命令用特殊的字符或者字符串作為一幀的結(jié)束標(biāo)志比如常見的\r\n幀內(nèi)容用ASCII文本編排。接收方一邊讀一邊掃描每當(dāng)遇到分隔符就把當(dāng)前緩沖區(qū)的數(shù)據(jù)當(dāng)作一幀返回。這種方法的好處是調(diào)試方便肉眼能看懂很多簡單硬件命令協(xié)議都這樣設(shè)計類似HTTP頭部的換行分割。缺點(diǎn)也明顯如果消息內(nèi)容本身可能包含分隔符就需要做轉(zhuǎn)義處理比如自定義類似\x0D\x0A的替代表示增加了復(fù)雜度而且掃描分隔符需要逐字節(jié)遍歷處理大量二進(jìn)制數(shù)據(jù)時效率不高。對于分隔符方案還有一個細(xì)節(jié)必須處理如果接收到的數(shù)據(jù)里只有半個分隔符比如\r到了\n還沒到你不能急著拼幀要等完整的分隔符出現(xiàn)。2.3 方案三長度前綴——二進(jìn)制協(xié)議的首選長度前綴是最通用、最穩(wěn)妥的做法在每條消息的最前面固定用幾個字節(jié)通常是2字節(jié)或4字節(jié)聲明本條消息或消息體的長度接收方先讀長度字段再根據(jù)長度讀取剩下的內(nèi)容完整湊夠一幀后再交給業(yè)務(wù)邏輯。一個典型的長度前綴幀結(jié)構(gòu)可能長這樣幀頭標(biāo)識可選2字節(jié)比如0xAA 0x55用于快速定位幀起始。長度字段4字節(jié)表示后面數(shù)據(jù)區(qū)包體的字節(jié)數(shù)。包體數(shù)據(jù)N字節(jié)承載具體業(yè)務(wù)命令和數(shù)據(jù)。校驗字段可選CRC32或CRC16用于保障數(shù)據(jù)完整性。接收方判斷一幀是否完整的邏輯是這樣的先看緩沖區(qū)里是否至少有幀頭長度字段這么多字節(jié)如果不夠就是半包等待如果夠了就讀取長度字段算出整幀長度 幀頭長度 長度字段長度 包體長度 校驗長度再看緩沖區(qū)里的數(shù)據(jù)有沒有這么多不夠就繼續(xù)等夠了就切一幀出來。2.4 為什么我推薦直接把長度前綴作為通用方案雖然我上面講了三種方案但如果你在設(shè)計一個全新的C#通信庫不用猶豫長度前綴是首選。它不限制消息長度用4字節(jié)可以表達(dá)最大2GB的消息天然支持二進(jìn)制數(shù)據(jù)流不需要轉(zhuǎn)義解析的時候也不需要逐字節(jié)掃描。很多工業(yè)協(xié)議比如Modbus TCP的應(yīng)用數(shù)據(jù)部分、自定義的RPC協(xié)議、消息隊列協(xié)議本質(zhì)都是一層長度前綴數(shù)據(jù)體的結(jié)構(gòu)。固定長度方案適合長度恒定的硬件協(xié)議字符分隔符適合簡單文本命令而當(dāng)你面對不固定、二進(jìn)制、高性能這組關(guān)鍵詞時長度前綴幾乎沒有短板。3. C#實戰(zhàn)一個完整的粘包分包接收器到代碼環(huán)節(jié)了。我會從零設(shè)計一個足夠簡單、但可以直接用在項目里的拆包器。協(xié)議格式就用上面說的長度前綴風(fēng)格2字節(jié)幀頭0xAA55 4字節(jié)包體長度小端序 N字節(jié)包體。校驗字段這一版先不加實際項目建議補(bǔ)上CRC32。3.1 定義協(xié)議幀結(jié)構(gòu)先寫一個表示已解析完整幀的結(jié)果類public class Packet { public byte[] Header { get; set; } // 幀頭數(shù)據(jù) public int BodyLength { get; set; } // 包體長度 public byte[] Body { get; set; } // 包體數(shù)據(jù) public int TotalLength 2 4 BodyLength; // 整幀長度 }實際開發(fā)中你可能會更直接地把整幀字節(jié)數(shù)組交給業(yè)務(wù)層由業(yè)務(wù)層再去挖字段這都沒關(guān)系。拆包器要解決的唯一問題是從不斷流入的原始字節(jié)流中找到一幀幀完整的消息并把它們切分出來。3.2 核心解析類的寫法我使用一個類似狀態(tài)機(jī)的思路先把收到的字節(jié)追加到一個緩沖區(qū)然后能拆就拆。public class PacketParser { private readonly byte[] _buffer; // 預(yù)先分配的內(nèi)存緩沖 private int _bufferLength; // 當(dāng)前緩沖中有效數(shù)據(jù)的長度 private readonly int _capacity; // 緩沖容量上限防止內(nèi)存無限制增長 private readonly int _maxBodyLength; // 允許的包體最大長度 public const byte Header0 0xAA; public const byte Header1 0x55; public const int HeaderLength 2; public const int LengthFieldLength 4; public const int MinimumFrameLength HeaderLength LengthFieldLength; // 最少的幀長度 public PacketParser(int capacity 1024 * 1024, int maxBodyLength 256 * 1024) { _capacity capacity; _maxBodyLength maxBodyLength; _buffer new byte[capacity]; _bufferLength 0; } // 每次從Socket收到新數(shù)據(jù)就調(diào)用這個入口 public void AppendData(byte[] data, int offset, int count) { if (count 0) return; // 如果緩沖空間不夠先做一次緊湊拷貝 EnsureCapacity(count); Buffer.BlockCopy(data, offset, _buffer, _bufferLength, count); _bufferLength count; // 不斷嘗試從緩沖區(qū)中拆出完整幀 while (TryExtractFrame()) { // 每拆出一幀就觸發(fā)一次回調(diào)把幀數(shù)據(jù)交給上層 // 這里直接調(diào)用事件或者用一個隊列收集 } } private bool TryExtractFrame() { // 1. 緩沖區(qū)數(shù)據(jù)連最小幀結(jié)構(gòu)都不夠等待更多數(shù)據(jù) if (_bufferLength MinimumFrameLength) return false; // 2. 掃描幀頭這里簡化為必須在彈緩沖區(qū)起始處有幀頭實際工程可能要滑動尋找 if (_buffer[0] ! Header0 || _buffer[1] ! Header1) { // 幀頭不對丟棄一個字節(jié)繼續(xù)向后找 // 實際項目建議做重新同步這里先把幀頭移至后面 Buffer.BlockCopy(_buffer, 1, _buffer, 0, _bufferLength - 1); _bufferLength--; return false; // 或者繼續(xù)循環(huán)找取決于具體設(shè)計 } // 3. 讀取長度字段 int bodyLength BitConverter.ToInt32(_buffer, HeaderLength); // 小端序 // 長度字段合法性檢查防止惡意數(shù)據(jù)或錯誤數(shù)據(jù)導(dǎo)致內(nèi)存問題 if (bodyLength 0 || bodyLength _maxBodyLength) { // 異常長度數(shù)據(jù)不可信清空緩沖重新同步 _bufferLength 0; return false; } int totalFrameLength HeaderLength LengthFieldLength bodyLength; // 4. 當(dāng)前緩沖區(qū)里的數(shù)據(jù)已經(jīng)達(dá)到一幀所需長度 if (_bufferLength totalFrameLength) { // 半包等待更多數(shù)據(jù) return false; } // 5. 完整幀消費(fèi)掉緩沖區(qū)前面 totalFrameLength 字節(jié) byte[] frame new byte[totalFrameLength]; Buffer.BlockCopy(_buffer, 0, frame, 0, totalFrameLength); // 將剩余數(shù)據(jù)移到緩沖區(qū)開頭供下一幀使用 int remaining _bufferLength - totalFrameLength; if (remaining 0) { Buffer.BlockCopy(_buffer, totalFrameLength, _buffer, 0, remaining); } _bufferLength remaining; // 把完整幀交給外部這里用事件也可以存到隊列 OnPacketReceived?.Invoke(frame); return true; } // 向上層提交完整幀 public event Actionbyte[] OnPacketReceived; private void EnsureCapacity(int extraSize) { // 如果緩沖區(qū)不夠用把有效數(shù)據(jù)往前面搬運(yùn)騰出空間 if (_bufferLength extraSize _capacity) return; int movementThreshold 0; // 如果前面已經(jīng)消費(fèi)了大量空間可以移動這里簡化處理若真的放不下就擴(kuò)容 throw new InvalidOperationException(接收緩沖區(qū)容量不足請增大capacity參數(shù)或排查協(xié)議長度); } }這個實現(xiàn)有一些取舍比如在幀頭不對時逐個字節(jié)滑動效率不是最高的但為了便于理解我把邏輯做成了線性。實際項目里你可以改成記錄一個_searchIndex先快速找到下一個0xAA55幀頭再解析長度。3.3 和Socket接收結(jié)合使用有了解析器接下來要做的事情就很簡單在接收數(shù)據(jù)的地方把字節(jié)喂給解析器。// 假設(shè)你已經(jīng)在監(jiān)聽TCP連接拿到NetworkStream或Socket private readonly PacketParser _parser new PacketParser(); void OnReceiveFromSocket(IAsyncResult ar) { var socket (Socket)ar.AsyncState; try { int bytesRead socket.EndReceive(ar); if (bytesRead 0) { int offset 0; // 把收到的數(shù)據(jù)全部交給解析器 // 這里使用了自定義的收包緩沖區(qū)極端情況可能本次讀到的數(shù)據(jù)包含多幀解析器會循環(huán)拆包 _parser.AppendData(_receiveBuffer, offset, bytesRead); // 繼續(xù)下一次異步接收 socket.BeginReceive(_receiveBuffer, 0, _receiveBuffer.Length, SocketFlags.None, OnReceiveFromSocket, socket); } else { // 對端關(guān)閉連接 } } catch (SocketException ex) { // 網(wǎng)絡(luò)異常處理 } }AppendData里會循環(huán)調(diào)TryExtractFrame直到緩沖區(qū)里的數(shù)據(jù)不足一幀。每拆出完整幀OnPacketReceived事件觸發(fā)業(yè)務(wù)層只要訂閱這個事件就能拿到一幀幀對齊好的數(shù)據(jù)再也不用關(guān)心這條數(shù)據(jù)是粘過來的還是拆過來的。3.4 為什么這個結(jié)構(gòu)不容易出亂子這套設(shè)計的核心是把接收網(wǎng)絡(luò)字節(jié)和解析業(yè)務(wù)協(xié)議完全解耦。Socket只管不停往解析器里灌字節(jié)解析器只負(fù)責(zé)攢數(shù)據(jù)和切幀業(yè)務(wù)層只處理完整幀。哪怕TCP把一個包拆成10次才傳過來解析器也能一次一次地把數(shù)據(jù)攢齊直到湊夠一幀才放行。這比在Receive回調(diào)里做一串復(fù)雜的邏輯要清晰得多。我在早期項目里就是直接在Receive函數(shù)里用Listbyte拼接數(shù)據(jù)結(jié)果把網(wǎng)絡(luò)收發(fā)和業(yè)務(wù)解析寫成了巨型面條函數(shù)一會兒判斷緩沖區(qū)長度一會兒要處理幀頭邏輯一多全是bug。后來改成這種獨(dú)立的解析器類接收線程永遠(yuǎn)只做數(shù)據(jù)搬運(yùn)業(yè)務(wù)層的邏輯簡單了不止一個量級。4. 實戰(zhàn)中的坑字節(jié)序、緩沖區(qū)大小、Nagle和并發(fā)拆包器寫好后你以為就完事了嗎還早。我在實際落地時踩過好幾個坑每一個都會讓你在聯(lián)調(diào)階段抓狂這里我按排查順序整理出來。4.1 大端小端別搞反和硬件協(xié)議對齊是第一優(yōu)先級C# 在Windows平臺上默認(rèn)使用小端序也就是BitConverter.ToInt32讀出來的4字節(jié)是把低位字節(jié)放在內(nèi)存前面。但很多網(wǎng)絡(luò)協(xié)議和設(shè)備廠商定義的幀格式長度字段用的是大端序網(wǎng)絡(luò)字節(jié)序也就是高位字節(jié)在前。我記得第一次聯(lián)調(diào)一臺基于Modbus TCP協(xié)議轉(zhuǎn)換的采集設(shè)備時對方協(xié)議文檔寫長度為2字節(jié)高字節(jié)在前我用BitConverter.ToUInt16去讀解析出來的長度值直接變成幾千然后整個拆包邏輯瞬間紊亂。后來才發(fā)現(xiàn)是把字節(jié)序搞反了。所以在設(shè)計解析器時建議不要直接依賴BitConverter默認(rèn)行為而是顯式用BinaryPrimitives// 明確使用小端序讀取長度 int bodyLength BinaryPrimitives.ReadInt32LittleEndian(_buffer.AsSpan(HeaderLength, 4)); // 如果設(shè)備使用大端序 // int bodyLength BinaryPrimitives.ReadInt32BigEndian(_buffer.AsSpan(HeaderLength, 4));這個選擇必須和設(shè)備協(xié)議手冊一致沒有商量余地。一個比較穩(wěn)妥的做法是把長度字段解析封裝成一個委托或者方法方便不同協(xié)議切換字節(jié)序而不是在拆包邏輯里寫死。4.2 接收緩沖區(qū)大小與數(shù)據(jù)合法性校驗拆包器里我預(yù)留了_maxBodyLength參數(shù)。這個參數(shù)必須好好利用。網(wǎng)絡(luò)數(shù)據(jù)是外界傳入的如果對端是惡意設(shè)備或者線路受到干擾長度字段可能變成異常巨大的值。如果沒用最大長度限制拆包器就會一直傻等那個永遠(yuǎn)湊不齊的超大幀導(dǎo)致大量內(nèi)存被占用這就是隱患。實際項目中我一般會根據(jù)設(shè)備協(xié)議的最大長度設(shè)置_maxBodyLength為合理值比如256KB。當(dāng)收到的長度字段超過這個值立即清空緩沖區(qū)重新等待下一個幀頭而不是繼續(xù)等下去。緩沖區(qū)capacity也不能拍腦袋設(shè)置。容量太小高頻接收時頻繁拷貝性能下降容量太大浪費(fèi)內(nèi)存。一個合理的建議是接收緩沖區(qū)容量應(yīng)該略大于網(wǎng)絡(luò)快速傳輸一幀的處理間隔內(nèi)可能到達(dá)的數(shù)據(jù)量而不是無限大。如果設(shè)備一幀最大128KB那么緩沖容量設(shè)成512KB基本夠用甚至可以復(fù)用底層的byte[]避免頻繁分配內(nèi)存降低GC壓力。4.3 要不要關(guān)閉Nagle算法Socket.NoDelayNagle算法會盡量把多個小的數(shù)據(jù)包合并后再發(fā)送這樣可以提高網(wǎng)絡(luò)利用率但會引入額外延遲也更容易讓接收端出現(xiàn)粘包錯覺。如果業(yè)務(wù)對實時性要求較高比如上位機(jī)每隔幾十毫秒就要發(fā)送一次控制指令建議把Socket設(shè)為NoDelay truesocket.NoDelay true;不過要強(qiáng)調(diào)NoDelay只影響發(fā)送端合并小包的策略它不能讓TCP變得不粘包。即使關(guān)閉了NagleTCP仍然可能因為分段、緩沖區(qū)讀取時機(jī)產(chǎn)生粘包和分包。所以NoDelay是為了降低延遲不是為了替代拆包邏輯。拆包邏輯必須一直在。4.4 多線程并發(fā)下如何安全傳遞完整幀在常見上位機(jī)架構(gòu)里接收數(shù)據(jù)使用獨(dú)立的網(wǎng)絡(luò)線程而業(yè)務(wù)處理可能在UI線程或者另一個工作線程。如果你在OnPacketReceived事件回調(diào)里直接做業(yè)務(wù)邏輯可能會導(dǎo)致網(wǎng)絡(luò)線程被阻塞——萬一業(yè)務(wù)處理很慢下一次Receive就來不及調(diào)用接收緩沖區(qū)被撐滿發(fā)送端就開始丟包重傳整個通信鏈路質(zhì)量下降。更好的做法是網(wǎng)絡(luò)線程只負(fù)責(zé)把完整幀放入一個線程安全的隊列業(yè)務(wù)處理線程從隊列里取幀private readonly ConcurrentQueuebyte[] _packetQueue new ConcurrentQueuebyte[](); public void OnPacketReceived(byte[] frame) { // 入隊快速返回不阻塞網(wǎng)絡(luò)線程 _packetQueue.Enqueue(frame); } // 業(yè)務(wù)線程或者定時器循環(huán)處理 void ProcessPackets() { while (_packetQueue.TryDequeue(out var frame)) { // 在這里解析幀執(zhí)行業(yè)務(wù)邏輯 } }使用ConcurrentQueue后網(wǎng)絡(luò)接收線程和業(yè)務(wù)線程解耦無論業(yè)務(wù)邏輯多慢都不會直接影響收包。如果處理不過來可以對隊列長度設(shè)置上限超出后做丟幀或重啟接收等策略。4.5 連接中斷時殘留數(shù)據(jù)的處理最后一個容易忽略的點(diǎn)每次TCP連接斷開后都要把解析器里的數(shù)據(jù)清空。因為TCP連接結(jié)束時接收緩沖區(qū)里可能還有半包數(shù)據(jù)如果不清理下一次建立連接時這些殘留字節(jié)會被當(dāng)成新連接的數(shù)據(jù)輕則解析錯誤重則影響新連接的所有幀。在連接斷開的事件處理里記得調(diào)用Reset()方法public void Reset() { _bufferLength 0; // 如果用了隊列也要清空 }清理時要小心如果清空操作和AppendData不在同一個線程要用鎖保護(hù)或者確保斷連事件也是在接收線程里觸發(fā)這樣才能避免競態(tài)。4.6 一個經(jīng)典誤判認(rèn)為多收的就是粘包少收的就是分包還有一個很容易被忽略的邏輯陷阱不少人收到多余數(shù)據(jù)時第一反應(yīng)是把多余的數(shù)據(jù)往后挪和下一次收到的數(shù)據(jù)拼在一起。這個思路沒錯但如果一次性收到三幀完整數(shù)據(jù)循環(huán)拆幀時一定要把處理完一幀剩余數(shù)據(jù)繼續(xù)處理下一幀這個邏輯寫對。我見過有人只拆了一幀就往回等待結(jié)果下一幀開頭數(shù)據(jù)被當(dāng)成幀頭的一部分吃掉整個協(xié)議永遠(yuǎn)對不齊。我的建議是把TryExtractFrame寫成循環(huán)每拆出一幀就丟給上層然后繼續(xù)檢查當(dāng)前緩沖區(qū)是否還有足夠的新幀直到不足一幀再退出。上面的代碼已經(jīng)這么做了你在自己實現(xiàn)時也要保證這個循環(huán)結(jié)構(gòu)而不是用if去判斷一幀就結(jié)束。5. 調(diào)試粘包分包問題的方法論看完代碼再多說幾句調(diào)試思路。因為軟件寫出來不是靠一次就能跑通的尤其網(wǎng)絡(luò)協(xié)議坑都在細(xì)節(jié)里。5.1 先用模擬器代替真實設(shè)備有時候設(shè)備不在手邊或者設(shè)備程序未部署可以先寫一個模擬服務(wù)端往TCP客戶端灌入特定的字節(jié)序列。比如你可以故意把兩幀合并成一個字節(jié)數(shù)組Send出去分兩次Send同一幀甚至先發(fā)一半等500毫秒再發(fā)另一半然后看解析器能不能穩(wěn)定拆出正確的幀。我用這個方法在半小時內(nèi)就驗證了拆包器的可靠性而不用拿著真機(jī)反復(fù)試。模擬器還能很方便地構(gòu)造異常數(shù)據(jù)比如錯誤的幀頭、超大的長度字段用來測試解析器的容錯能力。5.2 抓包工具比日志更靠譜如果聯(lián)調(diào)時出現(xiàn)幀丟失或者解析不對不要只盯著C#程序輸出的日志建議同時用Wireshark抓包。抓包能讓你看清網(wǎng)絡(luò)層實際傳輸?shù)臄?shù)據(jù)是不是真的多個小包被合并發(fā)送了接收確認(rèn)包是什么順序有沒有TCP重傳這些信息比應(yīng)用層日志透明得多。雖然我們做的是C#上層應(yīng)用不直接修改TCP內(nèi)核參數(shù)但抓包能快速定位問題是在網(wǎng)絡(luò)傳輸階段還是應(yīng)用解析階段節(jié)省大量排錯時間。5.3 日志里一定要打印十六進(jìn)制格式調(diào)試二進(jìn)制協(xié)議最忌諱只打印一串?dāng)?shù)字或者直接把字節(jié)轉(zhuǎn)成UTF-8字符串那樣會把二進(jìn)制數(shù)據(jù)弄成奇怪亂碼。我在代碼里一直留一個十六進(jìn)制輸出方法public static string ToHex(byte[] data) { return string.Join( , data.Select(b b.ToString(X2))); }調(diào)試時把收到的原始數(shù)據(jù)和拆出來的幀都用十六進(jìn)制打出來一眼就能看出幀頭、長度、數(shù)據(jù)是否對齊。尤其當(dāng)設(shè)備返回的數(shù)據(jù)里包含CRC校驗時十六進(jìn)制對比幾乎成了唯一高效的驗證方式。5.4 版本控制里為協(xié)議解析留好測試用例最后是我個人的習(xí)慣針對拆包器一定要留一組單元測試覆蓋粘包、半包、多包、異常幀頭、超長長度等等。網(wǎng)絡(luò)通信不像普通方法調(diào)用問題出現(xiàn)頻率低但一出現(xiàn)就很難查有自動化的測試用例相當(dāng)于給自己兜底。項目迭代后改過拆包邏輯跑一遍測試就知道有沒有破壞原有的兼容性。6. 從解決粘包到設(shè)計更健壯的通信層拆包器解決的是把字節(jié)流切成完整消息但它只是通信層的一部分。當(dāng)你的C#項目同時對接多種設(shè)備、多種協(xié)議你會發(fā)現(xiàn)網(wǎng)絡(luò)代碼很容易膨脹。這時候建議在拆包器之上再抽象一層把收包-拆包-命令分發(fā)-應(yīng)答處理拆成獨(dú)立模塊每塊只做一件事。比如可以定義統(tǒng)一的IMessageHandler接口每類設(shè)備命令實現(xiàn)各自的解析邏輯接收線程只負(fù)責(zé)把完整幀放到隊列命令分發(fā)線程根據(jù)協(xié)議命令字找到對應(yīng)處理器。這樣即使協(xié)議千變?nèi)f化主體通信框架不用改只需要新增協(xié)議解析類和命令處理器就可以。從最早的Socket收到什么就打印什么到后來一套完整的接收管道我最大的體會是粘包和分包并不是一個要消滅的問題而是一個要接納的協(xié)議設(shè)計問題。只要TCP還是字節(jié)流粘包分包就一定存在我們要做的不是幻想它消失而是設(shè)計一個清晰的消息邊界規(guī)則然后讓代碼嚴(yán)格遵守這個規(guī)則。這一步跨過去C#網(wǎng)絡(luò)編程中的很多其他問題都會變得透明起來。