From def164a2a9c44d0f890729b2c41a1a27261deac2 Mon Sep 17 00:00:00 2001 From: godotg Date: Mon, 14 Nov 2022 20:50:28 +0800 Subject: [PATCH] =?UTF-8?q?test[protocol]:=20=E8=AF=95=E6=9E=81=E7=AB=AF?= =?UTF-8?q?=E5=A4=A7=E7=9A=84=E5=AF=B9=E8=B1=A1=E5=BA=8F=E5=88=97=E5=8C=96?= =?UTF-8?q?=E5=92=8C=E5=8F=8D=E5=BA=8F=E5=88=97=E5=8C=96=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/zfoo/protocol/SpeedTest.java | 25 +-------- .../zfoo/protocol/packet/VeryBigObject.java | 53 +++++++++++++++++++ 2 files changed, 55 insertions(+), 23 deletions(-) diff --git a/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java b/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java index fb5d6057..f12b3cf7 100644 --- a/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java +++ b/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java @@ -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"); diff --git a/protocol/src/test/java/com/zfoo/protocol/packet/VeryBigObject.java b/protocol/src/test/java/com/zfoo/protocol/packet/VeryBigObject.java index e06cdb4b..52310dd0 100644 --- a/protocol/src/test/java/com/zfoo/protocol/packet/VeryBigObject.java +++ b/protocol/src/test/java/com/zfoo/protocol/packet/VeryBigObject.java @@ -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;