UDP TCP或者串口通信中有可能會出現(xiàn)粘包問題。具體解決辦法有以下幾種
1.自定義包體格式包含包頭+包體長度
2.加大讀取緩沖區(qū)buffer

本文介紹第一種方法的
socket通信中我們一般開啟一個(gè)線程然后死循環(huán)的讀取其中的信息

我們定好協(xié)議格式如下十六進(jìn)制表示
A3A4+長度兩字節(jié)+json
其中A3A4為協(xié)議頭 json是我們需要的具體數(shù)據(jù)

我們就可以固定的先讀取4個(gè)字節(jié)獲取完整包長度再繼續(xù)讀取

byte[] temBuffer = new byte[4];if (mInputStream == null) {continue;}int ret = mInputStream.read(temBuffer);if (ret > 0) {byte[] msg = null;//收到一條新命令為0XA3 0XA4開頭的if (temBuffer[0] == (byte) 0xA3 && temBuffer[1] == (byte) 0xA4) {//計(jì)算命令長度 即2 3字節(jié)組合成Intint cmdSize = ConvertUtilsPlus.getIntFromBytes(temBuffer[2], temBuffer[3]);int bodyLength = 4+ cmdSize;//計(jì)算出中長度msg = new byte[bodyLength];//申明本次接收一個(gè)完整數(shù)據(jù)需要的容量int recLength = ret;//記錄當(dāng)前已接收數(shù)據(jù)的長度int errorCount = 0;//記錄錯(cuò)誤次數(shù)System.arraycopy(temBuffer, 0, msg, 0, recLength);//第一包無腦丟進(jìn)數(shù)組中//如果本次讀取到的數(shù)據(jù)小于總長度那么繼續(xù)readwhile (recLength < bodyLength && errorCount < 10) {byte[] temp = new byte[bodyLength - recLength];int rec = mInputStream.read(temp);if (rec <= 0) {errorCount++;continue;}//復(fù)制讀取的數(shù)據(jù)到數(shù)組中System.arraycopy(temp, 0, msg, recLength, rec);recLength += rec;}}//沒有新消息繼續(xù)循環(huán)if (msg == null) continue;

getIntFromBytes方法如下

public static int getIntFromBytes(byte low_h, byte low_l) {return (low_h & 0xff) << 8 | low_l & 0xff;}

以上方法各位多看看注釋應(yīng)該能理解透徹

總結(jié)

以上是生活随笔為你收集整理的SOCKET/串口通信粘包问题处理，附带详细代码的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。