SOCKET/串口通信粘包问题处理,附带详细代码
生活随笔
收集整理的這篇文章主要介紹了
SOCKET/串口通信粘包问题处理,附带详细代码
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
UDP TCP或者串口通信中有可能會出現粘包問題。具體解決辦法有以下幾種
1.自定義包體格式包含包頭+包體長度
2.加大讀取緩沖區buffer
本文介紹第一種方法的
socket通信中我們一般開啟一個線程然后死循環的讀取其中的信息
我們定好協議格式如下十六進制表示
A3A4+長度兩字節+json
其中A3A4為協議頭 json是我們需要的具體數據
我們就可以固定的先讀取4個字節獲取完整包長度再繼續讀取
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) {//計算命令長度 即2 3字節組合成Intint cmdSize = ConvertUtilsPlus.getIntFromBytes(temBuffer[2], temBuffer[3]);int bodyLength = 4+ cmdSize;//計算出中長度msg = new byte[bodyLength];//申明本次接收一個完整數據需要的容量int recLength = ret;//記錄當前已接收數據的長度int errorCount = 0;//記錄錯誤次數System.arraycopy(temBuffer, 0, msg, 0, recLength);//第一包無腦丟進數組中//如果本次讀取到的數據小于總長度那么繼續readwhile (recLength < bodyLength && errorCount < 10) {byte[] temp = new byte[bodyLength - recLength];int rec = mInputStream.read(temp);if (rec <= 0) {errorCount++;continue;}//復制讀取的數據到數組中System.arraycopy(temp, 0, msg, recLength, rec);recLength += rec;}}//沒有新消息繼續循環if (msg == null) continue;getIntFromBytes方法如下
public static int getIntFromBytes(byte low_h, byte low_l) {return (low_h & 0xff) << 8 | low_l & 0xff;}以上方法各位多看看注釋應該能理解透徹
總結
以上是生活随笔為你收集整理的SOCKET/串口通信粘包问题处理,附带详细代码的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: kotlin中Int Byte的相互转换
- 下一篇: 解决解码H264视频黑屏问题