粘包解決方法

?方法1

getXOR——是校驗方法

?

/*** 最小數據包的長度(除開數據的N個字節）* 幀頭 保留字節 協議控制字 地址字段 命令長度 命令碼 命令數據 校驗和* 2字節 3字節 1字節 2或8字節 2字節 2字節 0-1100字節 2字節* SYN RES PTROL ADDR SLEN COMMAND APPDATA CRC16*/ int MIN_PACK_LEN = 2 + 3 + 1 + 2 + 2 + 2 + 2; /*** 數據：0-N字節，N小于等于250*/ int SLEN = 1100; int MAX_DATA_N = 255;

?

private final ByteBuffer mByteBuffer;public SerialReadThread(InputStream is) {mInputStream = new BufferedInputStream(is);mByteBuffer = ByteBuffer.allocate(1024);mByteBuffer.clear(); }

?

private boolean isValid(byte[] recvCheck, byte[] myCheck) {//LgqLogutil.d("rr=== "+ MyByteUtil.bytes2HexStr(recvCheck)+",,,m==="+MyByteUtil.bytes2HexStr(myCheck));for (int i = 0, n = recvCheck.length; i < n; ++i) {if (recvCheck[i] != myCheck[i]) {return false;}}return true; } /*** 處理獲取到的數據** @param received* @param size*/ private void onDataReceive(byte[] received, int size) {// TODO: 2018/3/22 解決粘包、分包等try {//LogPlus.e("Receiver", "接收數據=" + ByteUtil.bytes2HexStr(bytes, offset, length));byte b;int readable;mByteBuffer.put(received, 0, size);mByteBuffer.flip();out:while ((readable = mByteBuffer.remaining()) >= Protocol.MIN_PACK_LEN) { /*只處理數據幀, 不處理響應幀*/mByteBuffer.mark(); // 標記一下開始的位置int frameStart = mByteBuffer.position();byte[] frameHead = Protocol.FRAME_HEAD;for (byte h : frameHead) {b = mByteBuffer.get();if (b != h) { // 不滿足幀頭，就跳到第二位，重新開始mByteBuffer.position(frameStart + 1);continue out;}}byte[] dataLengthBytes = new byte[] { mByteBuffer.get(8), mByteBuffer.get(9) };//第9個字節 為 數據長度.兩個字節，所以是8,9int dataLen = (int) ByteUtil.bytes2long(dataLengthBytes, 0, 2); /*dataLen已經包含了*/if (dataLen > Protocol.MAX_DATA_N) {// 如果data n超過最大允許長度，表示數據錯亂了//則回到“第二位”，繼續找到下一個 幀頭mByteBuffer.position(frameStart + 2);continue;}int total = Protocol.MIN_PACK_LEN + dataLen - 2; /*-2 最小數據包長度中已經包含, dataLen中有最小數據包長度中的2個字節*/// 如果可讀數據小于總數據長度，表示不夠,還有數據沒接收if (readable < total) {// 重置一下要處理的位置,并跳出循環mByteBuffer.reset();break;}mByteBuffer.reset();// 拿到整個包byte[] allPack = new byte[total];mByteBuffer.get(allPack);byte[] recvCheck = new byte[2];recvCheck[0] = allPack[allPack.length - 2];recvCheck[1] = allPack[allPack.length - 1];byte[] myCheck = ByteUtil.getXOR(allPack, allPack.length - 2);if (isValid(recvCheck, myCheck)) {// 校驗通過/**/LgqLogutil.d("#####校驗通過,allPack:" + ByteUtil.bytes2HexStr(allPack));//validData.add(allPack);LogManager.instance().post(new RecvMessage(ByteUtil.bytes2HexStr(allPack)));} else {mByteBuffer.position(frameStart + 2);}}} catch (Exception e) {e.printStackTrace();} finally {// 最后清掉之前處理過的不合適的數據mByteBuffer.compact();}//String hexStr = ByteUtil.bytes2HexStr(received, 0, size);//String hexStr = ByteUtil.bytes2HexStr(allPack, 0, size);//LogManager.instance().post(new RecvMessage(hexStr)); }

?

?粘包解決方法2

?

?

try {//LogPlus.e("Receiver", "接收數據=" + ByteUtil.bytes2HexStr(bytes, offset, length));byte b;int readable;mByteBuffer.put(bytes, 0, length);mByteBuffer.flip();out:while ((readable = mByteBuffer.remaining()) >= Protocol.MIN_PACK_LEN) { /*只處理數據幀, 不處理響應幀*/mByteBuffer.mark(); // 標記一下開始的位置int frameStart = mByteBuffer.position();byte[] frameHead = Protocol.FRAME_HEAD;for (byte h : frameHead) {b = mByteBuffer.get();if (b != h) { // 不滿足幀頭，就跳到第二位，重新開始mByteBuffer.position(frameStart + 1);continue out;}}byte[] dataLengthBytes = new byte[]{mByteBuffer.get(4)};//第5個字節 為 數據長度int dataLen = (int) ByteUtil.bytes2long(dataLengthBytes, 0, 1); /*dataLen已經包含了*/if (dataLen > Protocol.MAX_DATA_N) {// 如果data n超過最大允許長度，表示數據錯亂了//則回到“第二位”，繼續找到下一個 幀頭mByteBuffer.position(frameStart + 2);continue;}int total = Protocol.MIN_PACK_LEN + dataLen - 2; /*-2 最小數據包長度中已經包含, dataLen中有最小數據包長度中的2個字節*/// 如果可讀數據小于總數據長度，表示不夠,還有數據沒接收if (readable < total) {// 重置一下要處理的位置,并跳出循環mByteBuffer.reset();break;}mByteBuffer.reset();// 拿到整個包byte[] allPack = new byte[total];mByteBuffer.get(allPack);byte recvCheck = allPack[allPack.length - 1];byte myCheck = ByteUtil.getXOR(allPack, 0, allPack.length - 1);if (myCheck == recvCheck) { // 校驗通過/**/LogPlus.d("#####校驗通過,allPack:" + ByteUtil.bytes2HexStr(allPack));validData.add(allPack);} else {mByteBuffer.position(frameStart + 2);}} } catch (Exception e) {e.printStackTrace(); } finally {// 最后清掉之前處理過的不合適的數據mByteBuffer.compact(); }

?

/*** 字節數組轉換成對應的16進制表示的字符串** @param src* @return*/ public static String bytes2HexStr(byte[] src) {StringBuilder builder = new StringBuilder();if (src == null || src.length <= 0) {return "";}char[] buffer = new char[2];for (int i = 0; i < src.length; i++) {buffer[0] = Character.forDigit((src[i] >>> 4) & 0x0F, 16);buffer[1] = Character.forDigit(src[i] & 0x0F, 16);builder.append(buffer);}return builder.toString().toUpperCase(); }

?1、心跳數據強轉為 byte[] 數據類型

@Override public RecvCommand adaptReceive(byte[] allPack, Object... other) {int cmd = (int) other[0];LogPlus.e( "收到的命令:" +cmd);byte[] data = (byte[]) other[1];

?

2、開始解析——必須根據解析協議才能解析數據

public class RecvA3Status extends BaseRecvCommand {private final int mResult;private final float mPowerFactorState;public List<AuxiliaryPlate> auxiliaryPlates;public RecvA3Status(byte[] allPack, byte[] data) {super(allPack, data);mResult = 0xff & data[0];mPowerFactorState = ByteUtil.getFloat(data, 25);auxiliaryPlates = new ArrayList<>();for (int i = 0; i < (data.length - 29) / 107; i++) {byte[] bytes = new byte[107];System.arraycopy(data, 29 + i * 107, bytes, 0, bytes.length);if (i==0){LogPlus.e("幾號門==="+i, "門狀態11接收數據2倉門=" + ByteUtil.bytes2HexStr(bytes));}else {LogPlus.i("幾號門==="+i, "門狀態11接收數據2倉門=" + ByteUtil.bytes2HexStr(bytes));}auxiliaryPlates.add(new AuxiliaryPlate(bytes));}}/*** 倉控板狀態表*/public static class AuxiliaryPlate {private int onlineState;private int doorState;private int batteryState;private int fireState;private int urgentState;private int temperature;private int batteryVoltage;private int chargerOnlineState;private ChargerState chargerState;private OnOffAmount onOffAmount;private AnalogQuantity analogQuantity;private int BMSOnlineState;private String BMSID;/**type 0 = 正常電池樣式 1 = 顯示屏樣式 */public int type = 0;public AuxiliaryPlate(byte[] bytes) {onlineState = 0xff & bytes[0];doorState = 0xff & bytes[1];batteryState = 0xff & bytes[2];fireState = 0xff & bytes[3];urgentState = 0xff & bytes[4];temperature = 0xff & bytes[5];batteryVoltage = ByteUtil.bytes2long(bytes, 6, 2) / 100;chargerOnlineState = 0xff & bytes[8];byte[] bytes1 = new byte[6];System.arraycopy(bytes, 9, bytes1, 0, bytes1.length);chargerState = new ChargerState(bytes1);BMSOnlineState = 0xff & bytes[15];byte[] bytes2 = new byte[26];System.arraycopy(bytes, 16, bytes2, 0, bytes2.length);BMSID = new String(bytes2, StandardCharsets.US_ASCII).trim();byte[] bytes3 = new byte[7];System.arraycopy(bytes, 42, bytes3, 0, bytes3.length);onOffAmount = new OnOffAmount(bytes3);byte[] bytes4 = new byte[58];System.arraycopy(bytes, 49, bytes4, 0, bytes4.length);analogQuantity = new AnalogQuantity(bytes4);}

?

付解析協議：

?

?

實現demo：https://download.csdn.net/download/meixi_android/12707609?

bug在線交流：?QQ1085220040

總結

以上是生活随笔為你收集整理的Android 串口开发——粘包解决方法，定时查询心跳数据，解析心跳数据。——持续更新中的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。