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

优化

This commit is contained in:
zhouhao 2023-02-03 19:06:13 +08:00
parent e506623e42
commit 5d4c2c655e
1 changed files with 21 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,8 +1,10 @@
package org.jetlinks.protocol.official.binary; package org.jetlinks.protocol.official.binary;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufUtil;
import io.netty.buffer.Unpooled; import io.netty.buffer.Unpooled;
import org.jetlinks.core.message.DeviceMessage; import org.jetlinks.core.message.DeviceMessage;
import org.jetlinks.core.message.DeviceOnlineMessage;
import org.jetlinks.core.message.function.FunctionInvokeMessage; import org.jetlinks.core.message.function.FunctionInvokeMessage;
import org.jetlinks.core.message.function.FunctionInvokeMessageReply; import org.jetlinks.core.message.function.FunctionInvokeMessageReply;
import org.jetlinks.core.message.property.*; import org.jetlinks.core.message.property.*;
@ -15,6 +17,23 @@ import java.util.Collections;
public class BinaryMessageTypeTest { public class BinaryMessageTypeTest {
@Test
public void testOnline() {
DeviceOnlineMessage message = new DeviceOnlineMessage();
message.setDeviceId("1000");
message.addHeader(BinaryDeviceOnlineMessage.loginToken, "admin");
ByteBuf byteBuf = BinaryMessageType.write(message, Unpooled.buffer());
System.out.println(ByteBufUtil.prettyHexDump(byteBuf));
System.out.println(ByteBufUtil.prettyHexDump(Unpooled
.buffer()
.writeInt(byteBuf.readableBytes())
.writeBytes(byteBuf)));
}
@Test @Test
public void testReport() { public void testReport() {
ReportPropertyMessage message = new ReportPropertyMessage(); ReportPropertyMessage message = new ReportPropertyMessage();
@ -75,10 +94,10 @@ public class BinaryMessageTypeTest {
} }
public void doTest(DeviceMessage message) { public void doTest(DeviceMessage message) {
ByteBuf data = Unpooled.buffer();
BinaryMessageType.write(message, data); ByteBuf data = BinaryMessageType.write(message, Unpooled.buffer());
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);