autumn/JChargePointProtocol
1
0
Fork 0
mirror of https://gitee.com/san-bing/JChargePointProtocol synced 2026-06-25 01:19:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化云快充协议消息处理器

Browse Source
This commit is contained in:
三丙
2025-03-15 22:54:14 +08:00
parent 6af381685c
commit 3604630c2b
1 changed files with 6 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/YunKuaiChongProtocolMessageProcessor.java
View File

@@ -76,20 +76,16 @@ public class YunKuaiChongProtocolMessageProcessor extends ProtocolMessageProcess
ByteBuf in = Unpooled.copiedBuffer(msg); ByteBuf in = Unpooled.copiedBuffer(msg);
in.markReaderIndex();
findStartFlag(in);
// 判断是否可以读取报头，8个字节 // 判断是否可以读取报头，8个字节
if (in.readableBytes() < 6) { if (in.readableBytes() < 8) {
in.resetReaderIndex(); in.release();
return; return;
} }
// 起始标识, 固定为0x68 // 起始标识, 固定为0x68
int startFlag = in.readUnsignedByte(); int startFlag = in.readUnsignedByte();
if (startFlag != 0x68) { if (startFlag != 0x68) {
in.resetReaderIndex(); in.release();
return; return;
} }
@@ -108,7 +104,7 @@ public class YunKuaiChongProtocolMessageProcessor extends ProtocolMessageProcess
// 判断是否可以读取消息体，N-4个字节 // 判断是否可以读取消息体，N-4个字节
int msgBodyLength = dataLength - 4; int msgBodyLength = dataLength - 4;
if (in.readableBytes() < msgBodyLength) { if (in.readableBytes() < msgBodyLength) {
in.resetReaderIndex(); in.release();
return; return;
} }
@@ -118,14 +114,13 @@ public class YunKuaiChongProtocolMessageProcessor extends ProtocolMessageProcess
// 判断是否可以读取校验和， 2个字节 // 判断是否可以读取校验和， 2个字节
if (in.readableBytes() < 2) { if (in.readableBytes() < 2) {
in.resetReaderIndex(); in.release();
return; return;
} }
byte[] byCheckSum = new byte[2]; byte[] byCheckSum = new byte[2];
in.readBytes(byCheckSum); in.readBytes(byCheckSum);
ByteBuf csTemp = Unpooled.buffer(); ByteBuf csTemp = Unpooled.copiedBuffer(byCheckSum);
csTemp.writeBytes(byCheckSum);
// 校验校验和 // 校验校验和
int checkSum = csTemp.readUnsignedShort(); int checkSum = csTemp.readUnsignedShort();
@@ -211,16 +206,5 @@ public class YunKuaiChongProtocolMessageProcessor extends ProtocolMessageProcess
downlinkCmdExe.execute(session, message, protocolContext); downlinkCmdExe.execute(session, message, protocolContext);
} }
private static void findStartFlag(ByteBuf buf) {
int count = buf.readableBytes();
for (int index = buf.readerIndex(); index < count - 1; index++) {
if (buf.getByte(index) == (byte) 0x68) {
buf.readerIndex(index);
return;
}
}
buf.resetReaderIndex();
}
} }