test[fastjson2]: jsonb test

zfoo-project · Nov 28, 2023 · 0991fa3 · 0991fa3
1 parent b645a88
commit 0991fa3
Show file tree

Hide file tree

Showing 2 changed files with 55 additions and 3 deletions.
diff --git a/protocol/pom.xml b/protocol/pom.xml
@@ -142,6 +142,13 @@
             </exclusions>
         </dependency>
 
+        <dependency>
+            <groupId>com.alibaba.fastjson2</groupId>
+            <artifactId>fastjson2</artifactId>
+            <version>2.0.42</version>
+            <scope>test</scope>
+        </dependency>
+
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>

diff --git a/protocol/src/test/java/com/zfoo/protocol/BenchmarkTesting.java b/protocol/src/test/java/com/zfoo/protocol/BenchmarkTesting.java
@@ -14,6 +14,7 @@
 package com.zfoo.protocol;
 
 
+import com.alibaba.fastjson2.JSONB;
 import com.esotericsoftware.kryo.Kryo;
 import com.esotericsoftware.kryo.io.Input;
 import com.esotericsoftware.kryo.io.Output;
@@ -68,6 +69,7 @@ public void singleThreadBenchmarks() {
             System.out.println(StringUtils.format("[单线程性能测试-->[benchmark:{}]]", benchmark));
 
             zfooTest();
+            jsonbTest();
             furyTest();
             kryoTest();
             protobufTest();
@@ -178,6 +180,49 @@ public void furyTest() {
         System.out.println(StringUtils.format("[fury]     [复杂对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.writerIndex(), System.currentTimeMillis() - startTime));
     }
 
+    @Test
+    public void jsonbTest() {
+        try {
+            var output = new Output(1024 * 8);
+            var input = new Input(output.getBuffer());
+
+            // 序列化和反序列化简单对象
+            long startTime = System.currentTimeMillis();
+            for (int i = 0; i < benchmark; i++) {
+                input.reset();
+                output.reset();
+                var bytes = JSONB.toBytes(simpleObject);
+                var mess = JSONB.parseObject(bytes, SimpleObject.class);
+            }
+
+            System.out.println(StringUtils.format("[fastjsonb]     [简单对象] [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();
+                var bytes = JSONB.toBytes(normalObject);
+                var mess = JSONB.parseObject(bytes, NormalObject.class);
+            }
+
+            System.out.println(StringUtils.format("[fastjsonb]     [常规对象] [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();
+
+                var bytes = JSONB.toBytes(complexObject);
+                var mess = JSONB.parseObject(bytes, ComplexObject.class);
+            }
+            System.out.println(StringUtils.format("[fastjsonb]     [复杂对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), output.position(), System.currentTimeMillis() - startTime));
+        } catch (Exception e) {
+            System.err.println(e.getMessage());
+        }
+    }
+
     @Test
     public void kryoTest() {
         try {
@@ -357,7 +402,7 @@ protected Kryo initialValue() {
 
     static {
         // zfoo协议注册(其实就是：将Set里面的协议号和对应的类注册好，这样子就可以根据协议号知道是反序列化为哪个类)
-        ProtocolManager.initProtocolAuto(List.of(ComplexObject.class, NormalObject.class, SimpleObject.class, EmptyObject.class, VeryBigObject.class),  GenerateOperation.NO_OPERATION);
+        ProtocolManager.initProtocolAuto(List.of(ComplexObject.class, NormalObject.class, SimpleObject.class, EmptyObject.class, VeryBigObject.class), GenerateOperation.NO_OPERATION);
 
         for (int i = 0; i < executors.length; i++) {
             executors[i] = Executors.newSingleThreadExecutor();
@@ -405,9 +450,9 @@ protected Kryo initialValue() {
     public static final Map<Integer, String> mapWithInteger = new HashMap<>(Map.of(Integer.MIN_VALUE, "a", -99, "b", 0, "c", 99, "d", Integer.MAX_VALUE, "e"));
 
     public static final ObjectB objectB = new ObjectB(true);
-//    public static final ObjectB objectB = new ObjectB(true, 44);
+    //    public static final ObjectB objectB = new ObjectB(true, 44);
     public static final ObjectA objectA = new ObjectA(Integer.MAX_VALUE, mapWithInteger, objectB);
-//    public static final ObjectA objectA = new ObjectA(Integer.MAX_VALUE, mapWithInteger, objectB, 66);
+    //    public static final ObjectA objectA = new ObjectA(Integer.MAX_VALUE, mapWithInteger, objectB, 66);
     public static final List<Integer> listWithInteger = new ArrayList<>(ArrayUtils.toList(intArray));
     public static final List<Integer> listWithInteger1 = new ArrayList<>(ArrayUtils.toList(intArray1));
     public static final List<Integer> listWithInteger2 = new ArrayList<>(ArrayUtils.toList(intArray2));