tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-05-26 01:59:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf[protocol]: 提升kryo的benchmark效率

Browse Source
This commit is contained in:
jaysunxiao
2022-05-23 16:31:44 +08:00
parent d0fca6248b
commit f946af79a8
1 changed files with 16 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files
protocol/src/test/java/com/zfoo/protocol/SpeedTest.java
+16 -34
View File
@@ -17,6 +17,8 @@ package com.zfoo.protocol;
import com.esotericsoftware.kryo.Kryo;
import com.esotericsoftware.kryo.io.ByteBufferInput;
import com.esotericsoftware.kryo.io.ByteBufferOutput;
import com.esotericsoftware.kryo.io.Input;
import com.esotericsoftware.kryo.io.Output;
import com.google.protobuf.ByteString;
import com.google.protobuf.CodedOutputStream;
import com.zfoo.protocol.collection.ArrayUtils;
@@ -137,56 +139,40 @@ public class SpeedTest {
public void kryoTest() {
var kryo = kryos.get();
var buffer = ByteBuffer.allocate(1024 * 8);
var output = new ByteBufferOutput(buffer);
var input = new ByteBufferInput(buffer);
var output = new Output(1024 * 8);
var input = new Input(output.getBuffer());
// 序列化和反序列化简单对象
long startTime = System.currentTimeMillis();
for (int i = 0; i < benchmark; i++) {
buffer.clear();
output.setBuffer(buffer);
input.reset();
output.reset();
kryo.writeObject(output, simpleObject);
output.flush();
buffer.flip();
input.setBuffer(buffer);
var mess = kryo.readObject(input, SimpleObject.class);
}
System.out.println(StringUtils.format("[kryo] [简单对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.limit(), System.currentTimeMillis() - startTime));
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++) {
buffer.clear();
output.setBuffer(buffer);
input.reset();
output.reset();
kryo.writeObject(output, normalObject);
output.flush();
buffer.flip();
input.setBuffer(buffer);
var mess = kryo.readObject(input, NormalObject.class);
}
System.out.println(StringUtils.format("[kryo] [常规对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.limit(), System.currentTimeMillis() - startTime));
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++) {
buffer.clear();
output.setBuffer(buffer);
input.reset();
output.reset();
kryo.writeObject(output, complexObject);
output.flush();
buffer.flip();
input.setBuffer(buffer);
var mess = kryo.readObject(input, ComplexObject.class);
}
System.out.println(StringUtils.format("[kryo] [复杂对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.limit(), System.currentTimeMillis() - startTime));
System.out.println(StringUtils.format("[kryo] [复杂对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), output.position(), System.currentTimeMillis() - startTime));
}
@Ignore
@@ -207,8 +193,7 @@ public class SpeedTest {
var mess = ProtobufObject.ProtobufSimpleObject.parseFrom(buffer);
}
System.out.println(StringUtils.format("[protobuf] [简单对象] [thread:{}] [size:{}] [time:{}]",
Thread.currentThread().getName(), buffer.limit(), System.currentTimeMillis() - startTime));
System.out.println(StringUtils.format("[protobuf] [简单对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.limit(), System.currentTimeMillis() - startTime));
// 序列化和反序列化常规对象
@@ -222,9 +207,7 @@ public class SpeedTest {
var mess = ProtobufObject.ProtobufSimpleObject.parseFrom(buffer);
}
System.out.println(StringUtils.format("[protobuf] [常规对象] [thread:{}] [size:{}] [time:{}]",
Thread.currentThread().getName(), buffer.limit(), System.currentTimeMillis() - startTime));
System.out.println(StringUtils.format("[protobuf] [常规对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.limit(), System.currentTimeMillis() - startTime));
// 序列化和反序列化复杂对象
startTime = System.currentTimeMillis();
@@ -237,8 +220,7 @@ public class SpeedTest {
var mess = ProtobufObject.ProtobufSimpleObject.parseFrom(buffer);
}
System.out.println(StringUtils.format("[protobuf] [复杂对象] [thread:{}] [size:{}] [time:{}]",
Thread.currentThread().getName(), buffer.limit(), System.currentTimeMillis() - startTime));
System.out.println(StringUtils.format("[protobuf] [复杂对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.limit(), System.currentTimeMillis() - startTime));
} catch (Exception e) {
throw new RuntimeException(e);
}