tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-09-04 08:20:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

test[protocol]: compatible test

Browse Source
This commit is contained in:
sun
2023-09-26 15:18:01 +08:00
parent 1e6c69e2c9
commit 22c4295717
1 changed files with 25 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
protocol/src/test/java/com/zfoo/protocol/compatible/CompatibleTesting.java
+25 -2
View File
@@ -95,8 +95,6 @@ public class CompatibleTesting {
public void normalTest() {
var buffer = new UnpooledHeapByteBuf(ByteBufAllocator.DEFAULT, 100, 1_0000);
ProtocolManager.write(buffer, normalObject);
// normalObject.outCompatibleValue = 88;
// FileUtils.writeInputStreamToFile(new File("normal-no-compatible.bytes"), new ByteArrayInputStream(ByteBufUtils.readAllBytes(buffer)));
var packet = ProtocolManager.read(buffer);
@@ -119,4 +117,29 @@ public class CompatibleTesting {
}
System.out.println(StringUtils.format("equal [{}], not equal [{}]", equal, notEqual));
}
@Test
public void normalWriteTest() {
var buffer = new UnpooledHeapByteBuf(ByteBufAllocator.DEFAULT, 100, 1_0000);
// normalObject.outCompatibleValue = 88;
ProtocolManager.write(buffer, normalObject);
FileUtils.writeInputStreamToFile(new File("normal-no-compatible.bytes"), new ByteArrayInputStream(ByteBufUtils.readAllBytes(buffer)));
}
@Test
public void normalReadTest() throws IOException {
ProtocolManager.initProtocolAuto(Set.of(ComplexObject.class, NormalObject.class, SimpleObject.class, EmptyObject.class, VeryBigObject.class), GenerateOperation.NO_OPERATION);
// var bytes = IOUtils.toByteArray(ClassUtils.getFileFromClassPath("compatible/normal-no-compatible.bytes"));
// var bytes = IOUtils.toByteArray(ClassUtils.getFileFromClassPath("compatible/normal-out-compatible.bytes"));
// var bytes = IOUtils.toByteArray(ClassUtils.getFileFromClassPath("compatible/normal-inner-compatible.bytes"));
// var bytes = IOUtils.toByteArray(ClassUtils.getFileFromClassPath("compatible/normal-out-inner-compatible.bytes"));
var bytes = IOUtils.toByteArray(ClassUtils.getFileFromClassPath("compatible/normal-out-inner-inner-compatible.bytes"));
var buffer = new UnpooledHeapByteBuf(ByteBufAllocator.DEFAULT, 100, 1_0000);
buffer.writeBytes(bytes);
var packet = ProtocolManager.read(buffer);
System.out.println(JsonUtils.object2String(packet));
}
}