tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-18 08:25:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

test[protocol]: 试极端大的对象序列化和反序列化测试

Browse Source
This commit is contained in:
godotg
2022-11-14 20:50:28 +08:00
parent 3ea0490067
commit def164a2a9
2 changed files with 55 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
protocol/src/test/java/com/zfoo/protocol/SpeedTest.java
+2 -23
View File
@@ -99,7 +99,7 @@ public class SpeedTest {
System.setProperty("io.netty.buffer.checkAccessible", "false");
System.setProperty("io.netty.buffer.checkBounds", "false");
ByteBuf buffer = new UnpooledHeapByteBuf(ByteBufAllocator.DEFAULT, 100, 10_0000);
ByteBuf buffer = new UnpooledHeapByteBuf(ByteBufAllocator.DEFAULT, 100, 1_0000);
// 序列化和反序列化简单对象
long startTime = System.currentTimeMillis();
@@ -133,17 +133,6 @@ public class SpeedTest {
}
System.out.println(StringUtils.format("[zfoo] [复杂对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.writerIndex(), System.currentTimeMillis() - startTime));
// 序列化和反序列化极端大的对象
startTime = System.currentTimeMillis();
for (int i = 0; i < benchmark; i++) {
buffer.clear();
ProtocolManager.write(buffer, VeryBigObject.veryBigObject);
var packet = ProtocolManager.read(buffer);
}
System.out.println(StringUtils.format("[zfoo] [超大对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.writerIndex(), System.currentTimeMillis() - startTime));
}
@Ignore
@@ -152,7 +141,7 @@ public class SpeedTest {
try {
var kryo = kryos.get();
var output = new Output(10_0000);
var output = new Output(1024 * 8);
var input = new Input(output.getBuffer());
// 序列化和反序列化简单对象
@@ -186,16 +175,6 @@ public class SpeedTest {
var mess = kryo.readObject(input, ComplexObject.class);
}
System.out.println(StringUtils.format("[kryo] [复杂对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), output.position(), System.currentTimeMillis() - startTime));
// 序列化和反序列化极端大的对象
startTime = System.currentTimeMillis();
for (int i = 0; i < benchmark; i++) {
input.reset();
output.reset();
kryo.writeObject(output, VeryBigObject.veryBigObject);
var mess = kryo.readObject(input, ComplexObject.class);
}
System.out.println(StringUtils.format("[kryo] [超大对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), output.position(), System.currentTimeMillis() - startTime));
} catch (Exception e) {
System.err.println(e.getMessage());
System.err.println("JDK17 运行kryo会报错，等kryo修复bug");
protocol/src/test/java/com/zfoo/protocol/packet/VeryBigObject.java
+53
View File
@@ -13,7 +13,16 @@
package com.zfoo.protocol.packet;
import com.esotericsoftware.kryo.io.Input;
import com.esotericsoftware.kryo.io.Output;
import com.zfoo.protocol.IPacket;
import com.zfoo.protocol.ProtocolManager;
import com.zfoo.protocol.util.StringUtils;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufAllocator;
import io.netty.buffer.UnpooledHeapByteBuf;
import org.junit.Ignore;
import org.junit.Test;
import java.util.List;
import java.util.Map;
@@ -23,9 +32,53 @@ import static com.zfoo.protocol.SpeedTest.*;
/**
* 主要来测试极端大的对象序列化和反序列化情况，极端大的对象指的是字段多，对象大，方法大
*
* zfoo依然能够稳定运行，protobuf直接协议体文件爆炸无法编译卡死，kryo运行直接报错
*/
public class VeryBigObject implements IPacket {
@Ignore
@Test
public void veryBigObjectTest() {
if (benchmark <= 0 || benchmark >= 10_0000_0000) {
return;
}
ByteBuf buffer = new UnpooledHeapByteBuf(ByteBufAllocator.DEFAULT, 100, 100_0000);
// 序列化和反序列化极端大的对象
long startTime = System.currentTimeMillis();
for (int i = 0; i < benchmark; i++) {
buffer.clear();
ProtocolManager.write(buffer, VeryBigObject.veryBigObject);
var packet = ProtocolManager.read(buffer);
}
System.out.println(StringUtils.format("[zfoo] [超大对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.writerIndex(), System.currentTimeMillis() - startTime));
try {
var kryo = kryos.get();
var output = new Output(100_0000);
var input = new Input(output.getBuffer());
// 序列化和反序列化极端大的对象
startTime = System.currentTimeMillis();
for (int i = 0; i < benchmark; i++) {
input.reset();
output.reset();
kryo.writeObject(output, VeryBigObject.veryBigObject);
var mess = kryo.readObject(input, ComplexObject.class);
}
System.out.println(StringUtils.format("[kryo] [超大对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), output.position(), System.currentTimeMillis() - startTime));
} catch (Exception e) {
e.printStackTrace();
}
veryBigObjectTest();
}
public byte a1;
public Byte aa1;
public byte[] aaa1;