工作调动。暂时停更了一段时间。续上一篇我们学习了如何去自定义一组报文，今天我们接着解析和组装报文。 前面我们讲过在物联网通信中实际上不论我们使用什么方式作为通信介质，其本质就是字节。所以我再一次对本章节的内容进行了调整，我们不讲Socket和ServerSocket这两个阻塞式IO Socket如何写。那个意义不大。

也正式因为在上一节中有读者提出说需要知道报文该如何拆解就有了这一篇。

章节

  • Android与物联网设备通信-概念入门
  • Android与物联网设备通信-数据传递的本质
  • Android与物联网设备通信-网络模型分层
  • Android与物联网设备通信-UDP协议原理
  • Android与物联网设备通信-TCP协议原理
  • Android与物联网设备通信-基于TCP/IP自定义报文
  • Android与物联网设备通信-什么是字节序
  • Android与物联网设备通信- 字节报文组装与解析
  • Android与物联网设备通信-利用UDP广播来做设备查找
  • Android与物联网设备通信-实现远程控制Android客户端
  • Android与物联网设备通信-Android做小型服务器
  • Android与物联网设备通信-调试技巧
  • Android与物联网设备通信-并行串行与队列
  • Android与物联网设备通信-数据安全
  • Android与物联网设备通信-心跳
  • Android与物联网设备通信-网络IO模型

目录

  • 组装报文
  • 解析报文
  • 总结

组装报文

接上一节的功能拿来，我们到底是怎么做到把下面的结构体转换成字节的呢？

协议：

转换后的字节：

0x00 0x00 0x00 0x11 | 0x31 0x32 0x33 0x34 0x35 0x36 0x37 0x38 0x39 0x30 0x31 0x32 0x33 | 0x21 | 0x01 |0x57 0x9D

首先我们需要定义一个对象，当做结构体。(不明白为什么要这样定义的同学请看上一节文章)

public class AirCondBaseStructure {int len; //长度byte sn[]; //序列号byte code; //功能码byte data[]; //透传数据byte crc[]; //校验
}复制代码

针对这个结构体，我们再写一个枚举：

    public enum CodeEnum {POWER((byte) 0x21),//开关MODE((byte) 0x22),//模式TEMPERATURE((byte) 0x23);//温度byte code;CodeEnum(byte i) {code = i;}}复制代码

该枚举器正好对应功能对照表里的功能。

写一下构造方法。

  public AirCondBaseStructure(String sn, AirCondBaseStructure.CodeEnum code, byte[] data){this.sn = sn.getBytes(); // 序列号this.code = code.code;this.data = data;this.len=computeLen();//获取长度this.crc =computeCrc();//校验}复制代码

这里构造方法只传入三个参数:

  • 序列号
  • 功能
  • 透传内容

可以看到实际里面还有长度和crc校验。是根据computeLen();和computeCrc();来自动完成计算的。

computeLen方法：

    /*** 计算长度* @return*/private int computeLen() {return sn.length + 1/*功能码长度*/ + data.length + 2/*校验和*/;}复制代码

这里的长度是固定字段+可变长。

computeCrc方法：

    /*** 计算crc* @return*/private byte[] computeCrc() {byte[] crc=new byte[2];byte[] datas=null;try {ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();DataOutputStream dataOutputStream = new DataOutputStream(byteArrayOutputStream);dataOutputStream.writeInt(len);dataOutputStream.write(sn);dataOutputStream.writeByte(code);dataOutputStream.write(data);dataOutputStream.flush();datas = byteArrayOutputStream.toByteArray();dataOutputStream.close();} catch (IOException e) {e.printStackTrace();}CRC16M crc16 = new CRC16M();crc16.update(datas, datas.length);int ri = crc16.getValue();crc[0] = (byte) ((0xff00 & ri) >> 8);crc[1] = (byte) (0xff & ri);return crc;}复制代码

crc校验是使用是crc16/modbus标准。完整代码后面贴出来。

最后是把报文组合起来变成字节。

    /*** 序列化* @return*/public byte[] toBytes(){byte[] datas=null;try {ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();DataOutputStream dataOutputStream = new DataOutputStream(byteArrayOutputStream);dataOutputStream.writeInt(len);dataOutputStream.write(sn);dataOutputStream.writeByte(code);dataOutputStream.write(data);dataOutputStream.write(crc);dataOutputStream.flush();datas = byteArrayOutputStream.toByteArray();dataOutputStream.close();} catch (IOException e) {e.printStackTrace();}return datas;}
复制代码

这里我们使用的就是ByteArrayOutputStream+DataOutputStream把对应的字段按照顺序写入，以保证和协议一致。

最后我们看看一下使用结果：

  public static void main(String[] args) {String sn="1234567890123";AirCondBaseStructure powerOpen =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.POWER, new byte[]{0x01});System.out.println("空调打开报文："+hex2Str(powerOpen.toBytes()));AirCondBaseStructure powerCloce =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.POWER, new byte[]{(byte)0x00});System.out.println("空调关闭报文："+hex2Str(powerCloce.toBytes()));AirCondBaseStructure modeAuto =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.MODE, new byte[]{(byte)0x03});System.out.println("空调自动报文："+hex2Str(modeAuto.toBytes()));AirCondBaseStructure modeDeh =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.MODE, new byte[]{(byte)0x05});System.out.println("空调除湿报文："+hex2Str(modeDeh.toBytes()));AirCondBaseStructure temperature =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.TEMPERATURE,  new byte[]{(byte)0x00, (byte) 0x19});System.out.println("空调25度报文："+hex2Str(temperature.toBytes()));}复制代码

对上层而言组装的方式比较简单，只需要把对应的枚举功能设置进去，带上该有的数据，剩下的序列化和校验均在内部实现。

这里我们模拟了五组报文，输出结果如下。

控制台输出：

空调打开报文：0x00 0x00 0x00 0x11 0x31 0x32 0x33 0x34 0x35 0x36 0x37 0x38 0x39 0x30 0x31 0x32 0x33 0x21 0x01 0x57 0x9D
空调关闭报文：0x00 0x00 0x00 0x11 0x31 0x32 0x33 0x34 0x35 0x36 0x37 0x38 0x39 0x30 0x31 0x32 0x33 0x21 0x00 0x96 0x5D
空调自动报文：0x00 0x00 0x00 0x11 0x31 0x32 0x33 0x34 0x35 0x36 0x37 0x38 0x39 0x30 0x31 0x32 0x33 0x22 0x03 0xD6 0xAC
空调除湿报文：0x00 0x00 0x00 0x11 0x31 0x32 0x33 0x34 0x35 0x36 0x37 0x38 0x39 0x30 0x31 0x32 0x33 0x22 0x05 0x56 0xAE
空调25度报文：0x00 0x00 0x00 0x12 0x31 0x32 0x33 0x34 0x35 0x36 0x37 0x38 0x39 0x30 0x31 0x32 0x33 0x23 0x00 0x19 0x4D 0x94 复制代码

我们来细看一下他们的变化。

到这里我们就已经将报文组装好并转换成了字节数组。

也许我们此时会想，那怎么发出去呢？我们前面第一节就讲过其实并不管中间用什么在传输。他们最后都是字节或二进制的形式。所以我们都已经转换好了，剩下的都是很简单的事情了。就是把数据喂进去，喂给TCP/IP、UDP、蓝牙、红外、无线电、声波、电磁波....看实际情况来了。

完整代码：

import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.IOException;/*** Created by Bolex on 2018/6/17.*/
public class AirCondBaseStructure {int len; //长度byte sn[]; //序列号byte code; //功能码byte data[]; //透传数据byte crc[]; //校验public AirCondBaseStructure(String sn, AirCondBaseStructure.CodeEnum code, byte[] data){this.sn = sn.getBytes(); // 序列号this.code = code.code;this.data = data;this.len=computeLen();//获取长度this.crc =computeCrc();//校验}public enum CodeEnum {POWER((byte) 0x21),//开关MODE((byte) 0x22),//模式TEMPERATURE((byte) 0x23);//温度byte code;CodeEnum(byte i) {code = i;}}/*** 计算长度* @return*/private int computeLen() {return sn.length + 1/*功能码长度*/ + data.length + 2/*校验和*/;}/*** 计算crc* @return*/private byte[] computeCrc() {byte[] crc=new byte[2];byte[] datas=null;try {ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();DataOutputStream dataOutputStream = new DataOutputStream(byteArrayOutputStream);dataOutputStream.writeInt(len);dataOutputStream.write(sn);dataOutputStream.writeByte(code);dataOutputStream.write(data);dataOutputStream.flush();datas = byteArrayOutputStream.toByteArray();dataOutputStream.close();} catch (IOException e) {e.printStackTrace();}CRC16M crc16 = new CRC16M();crc16.update(datas, datas.length);int ri = crc16.getValue();crc[0] = (byte) ((0xff00 & ri) >> 8);crc[1] = (byte) (0xff & ri);return crc;}/*** 序列化* @return*/public byte[] toBytes(){byte[] datas=null;try {ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();DataOutputStream dataOutputStream = new DataOutputStream(byteArrayOutputStream);dataOutputStream.writeInt(len);dataOutputStream.write(sn);dataOutputStream.writeByte(code);dataOutputStream.write(data);dataOutputStream.write(crc);dataOutputStream.flush();datas = byteArrayOutputStream.toByteArray();dataOutputStream.close();} catch (IOException e) {e.printStackTrace();}return datas;}}
复制代码

public class CRC16M {byte uchCRCHi = (byte) 0xFF;byte uchCRCLo = (byte) 0xFF;private static byte[] auchCRCHi = { 0x00, (byte) 0xC1, (byte) 0x81,(byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,(byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,(byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,(byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,(byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40,(byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01,(byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1,(byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81,(byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,(byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01,(byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0,(byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,(byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,(byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00,(byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,(byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,(byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,(byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,(byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1,(byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80,(byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,(byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01,(byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1,(byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81,(byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,(byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,(byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1,(byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80,(byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40,(byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x01,(byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1,(byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81,(byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,(byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,(byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,(byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,(byte) 0x40, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40,(byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,(byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,(byte) 0x80, (byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80,(byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40,(byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,(byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00, (byte) 0xC1,(byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80,(byte) 0x41, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,(byte) 0x00, (byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x00,(byte) 0xC1, (byte) 0x81, (byte) 0x40, (byte) 0x01, (byte) 0xC0,(byte) 0x80, (byte) 0x41, (byte) 0x00, (byte) 0xC1, (byte) 0x81,(byte) 0x40, (byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41,(byte) 0x01, (byte) 0xC0, (byte) 0x80, (byte) 0x41, (byte) 0x00,(byte) 0xC1, (byte) 0x81, (byte) 0x40 };private static byte[] auchCRCLo = { (byte) 0x00, (byte) 0xC0, (byte) 0xC1,(byte) 0x01, (byte) 0xC3, (byte) 0x03, (byte) 0x02, (byte) 0xC2,(byte) 0xC6, (byte) 0x06, (byte) 0x07, (byte) 0xC7, (byte) 0x05,(byte) 0xC5, (byte) 0xC4, (byte) 0x04, (byte) 0xCC, (byte) 0x0C,(byte) 0x0D, (byte) 0xCD, (byte) 0x0F, (byte) 0xCF, (byte) 0xCE,(byte) 0x0E, (byte) 0x0A, (byte) 0xCA, (byte) 0xCB, (byte) 0x0B,(byte) 0xC9, (byte) 0x09, (byte) 0x08, (byte) 0xC8, (byte) 0xD8,(byte) 0x18, (byte) 0x19, (byte) 0xD9, (byte) 0x1B, (byte) 0xDB,(byte) 0xDA, (byte) 0x1A, (byte) 0x1E, (byte) 0xDE, (byte) 0xDF,(byte) 0x1F, (byte) 0xDD, (byte) 0x1D, (byte) 0x1C, (byte) 0xDC,(byte) 0x14, (byte) 0xD4, (byte) 0xD5, (byte) 0x15, (byte) 0xD7,(byte) 0x17, (byte) 0x16, (byte) 0xD6, (byte) 0xD2, (byte) 0x12,(byte) 0x13, (byte) 0xD3, (byte) 0x11, (byte) 0xD1, (byte) 0xD0,(byte) 0x10, (byte) 0xF0, (byte) 0x30, (byte) 0x31, (byte) 0xF1,(byte) 0x33, (byte) 0xF3, (byte) 0xF2, (byte) 0x32, (byte) 0x36,(byte) 0xF6, (byte) 0xF7, (byte) 0x37, (byte) 0xF5, (byte) 0x35,(byte) 0x34, (byte) 0xF4, (byte) 0x3C, (byte) 0xFC, (byte) 0xFD,(byte) 0x3D, (byte) 0xFF, (byte) 0x3F, (byte) 0x3E, (byte) 0xFE,(byte) 0xFA, (byte) 0x3A, (byte) 0x3B, (byte) 0xFB, (byte) 0x39,(byte) 0xF9, (byte) 0xF8, (byte) 0x38, (byte) 0x28, (byte) 0xE8,(byte) 0xE9, (byte) 0x29, (byte) 0xEB, (byte) 0x2B, (byte) 0x2A,(byte) 0xEA, (byte) 0xEE, (byte) 0x2E, (byte) 0x2F, (byte) 0xEF,(byte) 0x2D, (byte) 0xED, (byte) 0xEC, (byte) 0x2C, (byte) 0xE4,(byte) 0x24, (byte) 0x25, (byte) 0xE5, (byte) 0x27, (byte) 0xE7,(byte) 0xE6, (byte) 0x26, (byte) 0x22, (byte) 0xE2, (byte) 0xE3,(byte) 0x23, (byte) 0xE1, (byte) 0x21, (byte) 0x20, (byte) 0xE0,(byte) 0xA0, (byte) 0x60, (byte) 0x61, (byte) 0xA1, (byte) 0x63,(byte) 0xA3, (byte) 0xA2, (byte) 0x62, (byte) 0x66, (byte) 0xA6,(byte) 0xA7, (byte) 0x67, (byte) 0xA5, (byte) 0x65, (byte) 0x64,(byte) 0xA4, (byte) 0x6C, (byte) 0xAC, (byte) 0xAD, (byte) 0x6D,(byte) 0xAF, (byte) 0x6F, (byte) 0x6E, (byte) 0xAE, (byte) 0xAA,(byte) 0x6A, (byte) 0x6B, (byte) 0xAB, (byte) 0x69, (byte) 0xA9,(byte) 0xA8, (byte) 0x68, (byte) 0x78, (byte) 0xB8, (byte) 0xB9,(byte) 0x79, (byte) 0xBB, (byte) 0x7B, (byte) 0x7A, (byte) 0xBA,(byte) 0xBE, (byte) 0x7E, (byte) 0x7F, (byte) 0xBF, (byte) 0x7D,(byte) 0xBD, (byte) 0xBC, (byte) 0x7C, (byte) 0xB4, (byte) 0x74,(byte) 0x75, (byte) 0xB5, (byte) 0x77, (byte) 0xB7, (byte) 0xB6,(byte) 0x76, (byte) 0x72, (byte) 0xB2, (byte) 0xB3, (byte) 0x73,(byte) 0xB1, (byte) 0x71, (byte) 0x70, (byte) 0xB0, (byte) 0x50,(byte) 0x90, (byte) 0x91, (byte) 0x51, (byte) 0x93, (byte) 0x53,(byte) 0x52, (byte) 0x92, (byte) 0x96, (byte) 0x56, (byte) 0x57,(byte) 0x97, (byte) 0x55, (byte) 0x95, (byte) 0x94, (byte) 0x54,(byte) 0x9C, (byte) 0x5C, (byte) 0x5D, (byte) 0x9D, (byte) 0x5F,(byte) 0x9F, (byte) 0x9E, (byte) 0x5E, (byte) 0x5A, (byte) 0x9A,(byte) 0x9B, (byte) 0x5B, (byte) 0x99, (byte) 0x59, (byte) 0x58,(byte) 0x98, (byte) 0x88, (byte) 0x48, (byte) 0x49, (byte) 0x89,(byte) 0x4B, (byte) 0x8B, (byte) 0x8A, (byte) 0x4A, (byte) 0x4E,(byte) 0x8E, (byte) 0x8F, (byte) 0x4F, (byte) 0x8D, (byte) 0x4D,(byte) 0x4C, (byte) 0x8C, (byte) 0x44, (byte) 0x84, (byte) 0x85,(byte) 0x45, (byte) 0x87, (byte) 0x47, (byte) 0x46, (byte) 0x86,(byte) 0x82, (byte) 0x42, (byte) 0x43, (byte) 0x83, (byte) 0x41,(byte) 0x81, (byte) 0x80, (byte) 0x40 };public int value;public CRC16M() {value = 0;}public void update(byte[] puchMsg, int usDataLen) {int uIndex;for (int i = 0; i < usDataLen; i++) {uIndex = (uchCRCHi ^ puchMsg[i]) & 0xff;uchCRCHi = (byte) (uchCRCLo ^ auchCRCHi[uIndex]);uchCRCLo = auchCRCLo[uIndex];}value = ((((int) uchCRCHi) << 8 | (((int) uchCRCLo) & 0xff))) & 0xffff;return;}public void reset() {value = 0;uchCRCHi = (byte) 0xff;uchCRCLo = (byte) 0xff;}public int getValue() {return value;}private static byte uniteBytes(byte src0, byte src1) {byte _b0 = Byte.decode("0x" + new String(new byte[] { src0 })).byteValue();_b0 = (byte) (_b0 << 4);byte _b1 = Byte.decode("0x" + new String(new byte[] { src1 })).byteValue();byte ret = (byte) (_b0 ^ _b1);return ret;}private static byte[] HexString2Buf(String src) {int len = src.length();byte[] ret = new byte[len / 2+2];byte[] tmp = src.getBytes();for (int i = 0; i < len; i += 2) {ret[i / 2] = uniteBytes(tmp[i], tmp[i + 1]);}return ret;}public static byte[] getSendBuf(String toSend){byte[] bb = HexString2Buf(toSend);CRC16M crc16 = new CRC16M();crc16.update(bb, bb.length-2);int ri = crc16.getValue();bb[bb.length-1]=(byte) (0xff & ri);bb[bb.length-2]=(byte) ((0xff00 & ri) >> 8);return bb;}public static boolean checkBuf(byte[] bb){CRC16M crc16 = new CRC16M();crc16.update(bb, bb.length-2);int ri = crc16.getValue();if(bb[bb.length-1]==(byte)(ri&0xff) && bb[bb.length-2]==(byte) ((0xff00 & ri) >> 8))return true;return false;}}
复制代码
import java.io.*;
import java.nio.ByteBuffer;/*** Created by Bolex on 2018/6/17.*/
public class AirCondMain {public static void main(String[] args) {String sn="1234567890123";AirCondBaseStructure powerOpen =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.POWER, new byte[]{0x01});System.out.println("空调打开报文："+hex2Str(powerOpen.toBytes()));AirCondBaseStructure powerCloce =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.POWER, new byte[]{(byte)0x00});System.out.println("空调关闭报文："+hex2Str(powerCloce.toBytes()));AirCondBaseStructure modeAuto =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.MODE, new byte[]{(byte)0x03});System.out.println("空调自动报文："+hex2Str(modeAuto.toBytes()));AirCondBaseStructure modeDeh =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.MODE, new byte[]{(byte)0x05});System.out.println("空调除湿报文："+hex2Str(modeDeh.toBytes()));AirCondBaseStructure temperature =new AirCondBaseStructure(sn, AirCondBaseStructure.CodeEnum.TEMPERATURE,  new byte[]{(byte)0x00, (byte) 0x19});System.out.println("空调25度报文："+hex2Str(temperature.toBytes()));}static String hex2Str(byte[] raw){String HEXES = "0123456789ABCDEF";if ( raw == null ) {return null;}final StringBuilder hex = new StringBuilder( 2 * raw.length );for ( final byte b : raw ) {hex.append("0x");hex.append(HEXES.charAt((b & 0xF0) >> 4)).append(HEXES.charAt((b & 0x0F)));hex.append(" ");}return hex.toString();}}复制代码

解析报文

解析报文的过程就是把字节数组再反过来转换成对象，也叫反序列化。

这里由于是文章演示（偷懒），就不像前面组装报文的时候再做封装了。

import java.io.ByteArrayInputStream;
import java.io.DataInputStream;
import java.io.IOException;/*** Created by Bolex on 2018/6/17.*/
public class AirCondAnalyzeMain {public static void main(String[] args) throws IOException {byte[] powerOpenBytes = hexStringToBytes("00000011313233343536373839303132332101579D");ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(powerOpenBytes);DataInputStream dis = new DataInputStream(byteArrayInputStream);int len = dis.readInt(); //报长byte[] sn = new byte[13]; //序列号byte[] code = new byte[1]; //功能码byte[] crc = new byte[2]; //校验byte[] data = new byte[len - sn.length - code.length - crc.length];dis.read(sn);dis.read(code);dis.read(data);dis.read(crc);System.out.println("报文长度：" + len);System.out.println("sn：" + new String(sn));System.out.println("功能码：" + hex2Str(code));System.out.println("数据：" + hex2Str(data));System.out.println("校验：" + hex2Str(crc));dis.close();}private static byte[] hexStringToBytes(String hexString) {if (hexString == null || hexString.equals("")) {return null;}hexString = hexString.toUpperCase();int length = hexString.length() / 2;char[] hexChars = hexString.toCharArray();byte[] d = new byte[length];for (int i = 0; i < length; i++) {int pos = i * 2;d[i] = (byte) (charToByte(hexChars[pos]) << 4 | charToByte(hexChars[pos + 1]));}return d;}/*** Convert char to byte** @param c char* @return byte*/private static byte charToByte(char c) {return (byte) "0123456789ABCDEF".indexOf(c);}private static String hex2Str(byte[] raw) {String HEXES = "0123456789ABCDEF";if (raw == null) {return null;}final StringBuilder hex = new StringBuilder(2 * raw.length);for (final byte b : raw) {hex.append("0x");hex.append(HEXES.charAt((b & 0xF0) >> 4)).append(HEXES.charAt((b & 0x0F)));hex.append(" ");}return hex.toString();}}复制代码

我们看到到main方法。主要就是解析一组电源打开的报文。其实没有什么东西，就是利用DataInputStream来读取。只是长度是变动的，所以我们需要先读出长度，然后根据长度再向后读出其它字段。

然后控制台就会输出

报文长度：17
sn：1234567890123
功能码：0x21
数据：0x01
校验：0x57 0x9D 复制代码

实际的业务情况会比这个复杂,所以最好做一些抽象和封装。不要像我文章里写的流水式编程。因为如果不封装后面维护会看起来很痛苦。还会有大量重复代码。不应该对每一组报文都重复的手写一次解析的过程。

总结

组装和解析字节报文其实是一项非常基础的能力。在java中已经有比较方便的DataInput类型套接字方便解析了。我们平时调试和开发的过程中尽量做到log日志，见行知意，并最好把hex格式转换成字符串来查看。一般出先两头碰协议的时候容易引发bug。

再一个可能会有小伙伴疑惑为什么不直接用json来做透传。这个问题很早之前就讨论过，要尽量避免透传内容太大。用字节位来做字段会增加传播的效率和稳定性。学习本篇的内容后，其实还可以尝试去用字节的方式读取MP3、jpg、apk等文件中的头信息。也是一个好练手的办法。

Android与物联网设备通信 - 字节报文组装与解析相关推荐

  1. Android与物联网设备通信-自定义报文与字节序

    前几节我们把网络通信中的基础都过了一遍,今天真正开始秀操作了.本节主要讲解如何在应用层上去定义报文的结构体.良好的报文设计会让今后的业务扩展变得轻松.顺带会讲解一下字节序. 可以发现最近的章节都把两个 ...

  2. 基于 P2P 技术的 Android 局域网内设备通信实践

    Android 局域网内的多设备通信方式有多种,其中常见的方式有: 基于 TCP/UDP 的 Socket 通信 基于 Bluetooth 的近场通信 基于 Wifi 的 Wi-Fi Direct 连 ...

  3. Android APP物联网设备无网模式设计

    1APP缓存 APP缓存是为了支持APP和设备在没有网络的情况下任然可以使用,APP在启动时如果有网络会从平台缓存当前用户的所有数据,包括家庭,房间,设备,设备控制信息,场景信息等 2双mqtt模式 ...

  4. 物联网设备模糊：DIANE：识别应用程序中的模糊触发器，为物联网设备生成受限制的输入

      本文记录阅读DIANE论文的内容总结和一些阅读过程中不理解地方的补充,我是搬运工. 简介 发表会议 IEEE S&P 2021 作者 Nilo Redini∗, Andrea Contin ...

  5. ISO8583报文组装解析工具和定义器示例

    8583报文组装和解析工具类(Send8583Util),代码如下: import com.alibaba.fastjson.JSONObject; import org.apache.commons ...

  6. 合宙Air780e+luatos接入华为云物联网平台完成设备通信与控制

    一.简介 1.项目介绍 之前发布的文章有esp8266的wifi模块和BC20的NB模块与华为云物联网通信为主,本期文章采用了合宙的4G LTE Cat.1模块,编程语言用的是lua,整体来说代码比较 ...

  7. Android 通过USB与PLC设备通信(USB转串口)

    经朋友介绍接的一个外包,要求用USB和PLC设备通信,于是乎就有了本文.内容不深,权当做个记录整理一下当时的思路. 一.解决思路 1. 首先,PLC设备通常都是用串口进行通讯,走的Modbus协议.这 ...

  8. 物联网平台搭建的全过程介绍（三）阿里云物联网设备接入订阅发布之Android studio例程

    物联网平台搭建系列内容前两节介绍的都是功能性的描述,今天以一个小例子,介绍具体的设备接入.订阅.发布的操作,例子的名字为:学生成绩录入平台,例子的界面如下图所示. 功能描述:当在阿里云物联网平台内下发 ...

  9. Android应用利用libusb设备通信权限问题

    应用层执行"chmod -R 777 /dev/bus/usb/" 来解决 Android 应用访问libusb没有权限的问题. 在应用层代码里执行这句就可以. 参考链接1:And ...

最新文章

  1. spring官方文档阅读笔记
  2. DevOps：软件架构师行动指南1.7　障碍
  3. python---4
  4. 【CF1047D】Little C Loves 3 II【构造】【赛瓦维斯特定理】
  5. 搭建Android的jenkins持续集成环境
  6. ICE学习之C# Java之间通讯
  7. 基于Linux2.6下的按键驱动开发步骤
  8. 独家揭秘！抖音爆款实时视频漫画变身特效背后技术
  9. java 判断客户端是手机端还是PC端（SSH框架）
  10. 不能右键新建html文件,鼠标右键没有新建文本文档选项怎么办？
  11. RETINA 屏幕1px 边框实现
  12. bootstrap--表格（table的各种样式）
  13. 分布式卷积神经网络计算平台（通用神经网络数据处理卡 Kintex Ultra Scale 系列 KU115）
  14. 从iOS 11看怎样设计APP图标
  15. 给小伙伴们的json数据
  16. 污水处理常用指标、公式及水质标准
  17. 58同城MySQL30条军规
  18. matlab 嵌套循环
  19. Dwarves （有向图判环）
  20. php提取新闻图片,php新闻采集并生成图片

热门文章

  1. Armbian 笔记六_使用 armbian-ddbr 命令 备份/还原 eMMC 系统
  2. golang服务器代理
  3. 什么是卷积神经网络算法,卷积神经网络运算公式
  4. webapi + windows计划 + mshta 实现定时执行任务
  5. 生活英语词汇：常用电器，常见的公共标志和说明
  6. python微信公众号开发教程_python微信公众号开发简单流程实现
  7. (0)UOS第三方源支持（Debian源）
  8. P1091 [NOIP2004 提高组] 合唱队形（动态规划+LIS）
  9. CSM认证介绍及部分题目
  10. 做招聘直播的好处有哪些？注意事项有？