From 4382b9af8858afd503626f68eab50f91dcc7f04e Mon Sep 17 00:00:00 2001 From: godotg Date: Fri, 21 Oct 2022 10:29:59 +0800 Subject: [PATCH] =?UTF-8?q?test[buffer]:=20unsafe=E6=93=8D=E4=BD=9C?= =?UTF-8?q?=E5=8F=AF=E8=83=BD=E4=BC=9A=E5=BD=B1=E5=93=8D=E6=80=A7=E8=83=BD?= =?UTF-8?q?=E7=9A=84=E5=AF=B9=E6=AF=94?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/test/java/com/zfoo/protocol/SpeedTest.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java b/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java index 575aa165..974b41de 100644 --- a/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java +++ b/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java @@ -15,8 +15,8 @@ package com.zfoo.protocol; import com.esotericsoftware.kryo.Kryo; -import com.esotericsoftware.kryo.unsafe.UnsafeInput; -import com.esotericsoftware.kryo.unsafe.UnsafeOutput; +import com.esotericsoftware.kryo.io.Input; +import com.esotericsoftware.kryo.io.Output; import com.google.protobuf.ByteString; import com.google.protobuf.CodedInputStream; import com.google.protobuf.CodedOutputStream; @@ -27,7 +27,6 @@ import com.zfoo.protocol.util.StringUtils; import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBufAllocator; import io.netty.buffer.UnpooledHeapByteBuf; -import io.netty.buffer.UnpooledUnsafeHeapByteBuf; import org.junit.Ignore; import org.junit.Test; @@ -100,7 +99,7 @@ public class SpeedTest { System.setProperty("io.netty.buffer.checkAccessible", "false"); System.setProperty("io.netty.buffer.checkBounds", "false"); - ByteBuf buffer = new UnpooledUnsafeHeapByteBuf(ByteBufAllocator.DEFAULT, 100, 1_0000); + ByteBuf buffer = new UnpooledHeapByteBuf(ByteBufAllocator.DEFAULT, 100, 1_0000); // 序列化和反序列化简单对象 long startTime = System.currentTimeMillis(); @@ -142,8 +141,8 @@ public class SpeedTest { try { var kryo = kryos.get(); - var output = new UnsafeOutput(1024 * 8); - var input = new UnsafeInput(output.getBuffer()); + var output = new Output(1024 * 8); + var input = new Input(output.getBuffer()); // 序列化和反序列化简单对象 long startTime = System.currentTimeMillis();