Hessian序列化方法

pom.xml

@@ -25,6 +25,8 @@
         <slf4j.version>1.7.25</slf4j.version>
         <!-- protostuff -->
         <protostuff.version>1.7.2</protostuff.version>
+        <!--hessian-->
+        <hessian.version>4.0.65</hessian.version>
     </properties>
     <modules>
         <module>rpc-framework-simple</module>

rpc-framework-simple/pom.xml

@@ -52,5 +52,10 @@
             <artifactId>protostuff-runtime</artifactId>
             <version>${protostuff.version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.caucho</groupId>
+            <artifactId>hessian</artifactId>
+            <version>${hessian.version}</version>
+        </dependency>
     </dependencies>
 </project>

rpc-framework-simple/src/main/java/github/javaguide/serialize/hessian/HessianSerializer.java

+package github.javaguide.serialize.hessian;
+
+
+import com.caucho.hessian.io.HessianInput;
+import com.caucho.hessian.io.HessianOutput;
+import github.javaguide.exception.SerializeException;
+import github.javaguide.serialize.Serializer;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+
+/**
+ * Hessian is a dynamically-typed, binary serialization and Web Services protocol designed for object-oriented transmission.
+ *
+ * @author Vinlee Xiao
+ * @createTime 2022/2/23 21:11
+ */
+public class HessianSerializer implements Serializer {
+    @Override
+    public byte[] serialize(Object obj) {
+        try (ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream()) {
+            HessianOutput hessianOutput = new HessianOutput(byteArrayOutputStream);
+            hessianOutput.writeObject(obj);
+
+            return byteArrayOutputStream.toByteArray();
+        } catch (Exception e) {
+            throw new SerializeException("Serialization failed");
+        }
+
+    }
+
+    @Override
+    public <T> T deserialize(byte[] bytes, Class<T> clazz) {
+
+        try (ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes)) {
+            HessianInput hessianInput = new HessianInput(byteArrayInputStream);
+            Object o = hessianInput.readObject();
+
+            return clazz.cast(o);
+
+        } catch (Exception e) {
+            throw new SerializeException("Deserialization failed");
+        }
+
+    }
+}