yuanbiao
/
jetlinks-official-protocol
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加tcp报文说明

This commit is contained in:
zhouhao 2023-07-07 16:27:55 +08:00
parent b234e8ebed
commit 486179b41f
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/test/java/org/jetlinks/protocol/official/binary/BinaryMessageTypeTest.java
View File

@ -97,12 +97,20 @@ public class BinaryMessageTypeTest {
ByteBuf data = BinaryMessageType.write(message, Unpooled.buffer()); ByteBuf data = BinaryMessageType.write(message, Unpooled.buffer());
System.out.println("TCP报文: "+ByteBufUtil.hexDump(Unpooled
.buffer()
.writeInt(data.readableBytes())
.writeBytes(data.duplicate())));
System.out.println(ByteBufUtil.prettyHexDump(data)); System.out.println(ByteBufUtil.prettyHexDump(data));
DeviceMessage read = BinaryMessageType.read(data); DeviceMessage read = BinaryMessageType.read(data);
if (null != read.getHeaders()) { if (null != read.getHeaders()) {
read.getHeaders().forEach(message::addHeader); read.getHeaders().forEach(message::addHeader);
} }
System.out.println(read); System.out.println(read);
//tcp时 发送的完整报文.
Assert.assertEquals(read.toString(), message.toString()); Assert.assertEquals(read.toString(), message.toString());
} }