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

Merge pull request #14 from 445990772/v3 

fix(单元测试): 单元测试类生成报文无法上线，优化输出报文显示
This commit is contained in:
老周 2023-08-02 09:17:44 +08:00 committed by GitHub
parent e0dc88251e fe8ef8a1c4
commit ec45b7c16d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -10,7 +10,6 @@ import org.jetlinks.core.message.function.FunctionInvokeMessageReply;
import org.jetlinks.core.message.property.*; import org.jetlinks.core.message.property.*;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
import reactor.test.StepVerifier;
import java.util.Collections; import java.util.Collections;
@ -27,11 +26,14 @@ public class BinaryMessageTypeTest {
ByteBuf byteBuf = BinaryMessageType.write(message, Unpooled.buffer()); ByteBuf byteBuf = BinaryMessageType.write(message, Unpooled.buffer());
System.out.println(ByteBufUtil.prettyHexDump(byteBuf)); System.out.println(ByteBufUtil.prettyHexDump(byteBuf));
ByteBuf buf = Unpooled
System.out.println(ByteBufUtil.prettyHexDump(Unpooled
.buffer() .buffer()
.writeInt(byteBuf.readableBytes()) .writeInt(byteBuf.readableBytes())
.writeBytes(byteBuf))); .writeBytes(byteBuf);
System.out.println(ByteBufUtil.prettyHexDump(buf));
//登录报文
System.out.println(ByteBufUtil.hexDump(buf));
} }
@Test @Test
@ -97,11 +99,19 @@ public class BinaryMessageTypeTest {
ByteBuf data = BinaryMessageType.write(message, Unpooled.buffer()); ByteBuf data = BinaryMessageType.write(message, Unpooled.buffer());
System.out.println(ByteBufUtil.prettyHexDump(data)); // System.out.println(ByteBufUtil.prettyHexDump(data));
DeviceMessage read = BinaryMessageType.read(data); ByteBuf buf = Unpooled.buffer()
.writeInt(data.readableBytes())
.writeBytes(data);
System.out.println(ByteBufUtil.prettyHexDump(buf));
System.out.println(ByteBufUtil.hexDump(buf));
//将长度字节读取后，直接解析报文正文
buf.readInt();
DeviceMessage read = BinaryMessageType.read(buf);
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);
Assert.assertEquals(read.toString(), message.toString()); Assert.assertEquals(read.toString(), message.toString());
} }