package com.jsowell.netty.domain; import com.jsowell.common.util.BytesUtil; import lombok.AllArgsConstructor; import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; import lombok.extern.slf4j.Slf4j; import java.nio.charset.StandardCharsets; import java.util.Arrays; @Slf4j @Data @NoArgsConstructor @AllArgsConstructor @Builder public class ChargingPileMessage { private String header; // 包头 (3字节) private int length; // 长度 (2字节) private int physicalId; // 物理ID (4字节) private int messageId; // 消息ID (2字节) private byte command; // 命令 (1字节) private byte[] data; // 数据 (n字节) private int checksum; // 校验 (2字节) // 从字节数组解析消息 public static ChargingPileMessage parseMessage(byte[] messageBytes) { log.info("parseMessage:{}", BytesUtil.binary(messageBytes, 16)); // 读取包头 byte[] headerBytes = Arrays.copyOfRange(messageBytes, 0, 3); System.out.println(new String(headerBytes, StandardCharsets.UTF_8)); // 读取长度 byte[] lengthBytes = {messageBytes[3], messageBytes[4]}; System.out.println(BytesUtil.bcd2StrLittle(lengthBytes)); // 读取物理ID byte[] physicalIdBytes = Arrays.copyOfRange(messageBytes, 5, 9); System.out.println(BytesUtil.bcd2StrLittle(physicalIdBytes)); // 读取消息ID byte[] messageIdBytes = {messageBytes[9], messageBytes[10]}; System.out.println(BytesUtil.bcd2StrLittle(messageIdBytes)); // 读取命令 byte command = messageBytes[11]; System.out.println(BytesUtil.bcd2StrLittle(new byte[] {command})); // 读取数据 byte[] data = Arrays.copyOfRange(messageBytes, 12, messageBytes.length - 2); System.out.println(BytesUtil.bcd2StrLittle(data)); // 读取校验 byte[] checksumBytes = {messageBytes[messageBytes.length - 2], messageBytes[messageBytes.length - 1]}; System.out.println(BytesUtil.bcd2StrLittle(checksumBytes)); return null; } }