add SerializerFactory when use hessian (#808)

jcommon/rpc-codes/pom.xml

@@ -10,6 +10,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>rpc-codes</artifactId>
+    <version>1.6.0-SNAPSHOT</version>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>

jcommon/rpc-codes/src/main/java/com/xiaomi/data/push/uds/codes/DefaultHessian2FactoryInitializer.java

@@ -0,0 +1,24 @@
+package com.xiaomi.data.push.uds.codes;
+
+import com.alibaba.com.caucho.hessian.io.SerializerFactory;
+
+/**
+ * @author zhangping17
+ * @date 2024/03/09
+ */
+public class DefaultHessian2FactoryInitializer{
+
+    private static SerializerFactory SERIALIZER_FACTORY;
+
+    public static SerializerFactory getSerializerFactory() {
+        if (SERIALIZER_FACTORY != null) {
+            return SERIALIZER_FACTORY;
+        }
+        synchronized (DefaultHessian2FactoryInitializer.class) {
+            if (SERIALIZER_FACTORY == null) {
+                SERIALIZER_FACTORY = new SerializerFactory();
+            }
+        }
+        return SERIALIZER_FACTORY;
+    }
+}

jcommon/rpc-codes/src/main/java/com/xiaomi/data/push/uds/codes/HessianCodes.java

@@ -35,6 +35,7 @@ public class HessianCodes implements ICodes {
     public <T> T decode(byte[] data, Type type) {
         ByteArrayInputStream is = new ByteArrayInputStream(data);
         Hessian2Input hi = new Hessian2Input(is);
+        hi.setSerializerFactory(DefaultHessian2FactoryInitializer.getSerializerFactory());
         try {
             return (T) hi.readObject();
         } catch (IOException e) {
@@ -53,6 +54,7 @@ public <T> T decode(byte[] data, Type type) {
     public <T> byte[] encode(T t) {
         ByteArrayOutputStream os = new ByteArrayOutputStream();
         Hessian2Output ho = new Hessian2Output(os);
+        ho.setSerializerFactory(DefaultHessian2FactoryInitializer.getSerializerFactory());
         try {
             ho.writeObject(t);
             ho.flush();