Serializer

iamlinhui · May 27, 2022 · 1b5d4b1 · 1b5d4b1
1 parent de4fd00
commit 1b5d4b1
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 9 deletions.
diff --git a/rpt-base/src/main/java/cn/promptness/rpt/base/coder/MessageDecoder.java b/rpt-base/src/main/java/cn/promptness/rpt/base/coder/MessageDecoder.java
@@ -4,7 +4,7 @@
 import cn.promptness.rpt.base.protocol.MessageType;
 import cn.promptness.rpt.base.protocol.Meta;
 import cn.promptness.rpt.base.serialize.Jackson;
-import cn.promptness.rpt.base.serialize.Serialize;
+import cn.promptness.rpt.base.serialize.Serializer;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufUtil;
 import io.netty.channel.ChannelHandlerContext;
@@ -15,7 +15,7 @@
 
 public class MessageDecoder extends MessageToMessageDecoder<ByteBuf> {
 
-    private final Serialize serialize = new Jackson();
+    private static final Serializer SERIALIZER = new Jackson();
 
     @Override
     protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
@@ -27,7 +27,7 @@ protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteB
         if (protobufLength > 0) {
             byte[] metaByte = new byte[protobufLength];
             byteBuf.readBytes(metaByte);
-            Meta meta = serialize.deserialize(metaByte);
+            Meta meta = SERIALIZER.deserialize(metaByte);
             proxyMessage.setMeta(meta);
         }
         if (byteBuf.isReadable()) {

diff --git a/rpt-base/src/main/java/cn/promptness/rpt/base/coder/MessageEncoder.java b/rpt-base/src/main/java/cn/promptness/rpt/base/coder/MessageEncoder.java
@@ -4,7 +4,7 @@
 import cn.promptness.rpt.base.protocol.MessageType;
 import cn.promptness.rpt.base.protocol.Meta;
 import cn.promptness.rpt.base.serialize.Jackson;
-import cn.promptness.rpt.base.serialize.Serialize;
+import cn.promptness.rpt.base.serialize.Serializer;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.MessageToByteEncoder;
@@ -13,15 +13,15 @@
 
 public class MessageEncoder extends MessageToByteEncoder<Message> {
 
-    private final Serialize serialize = new Jackson();
+    private static final Serializer SERIALIZER = new Jackson();
 
     @Override
     protected void encode(ChannelHandlerContext channelHandlerContext, Message message, ByteBuf out) throws Exception {
         MessageType type = message.getType();
         out.writeInt(type.getCode());
 
         Meta meta = message.getMeta();
-        byte[] protobuf = meta == null ? EmptyArrays.EMPTY_BYTES : serialize.serialize(meta);
+        byte[] protobuf = meta == null ? EmptyArrays.EMPTY_BYTES : SERIALIZER.serialize(meta);
         out.writeInt(protobuf.length);
         out.writeBytes(protobuf);
 

diff --git a/rpt-base/src/main/java/cn/promptness/rpt/base/serialize/Jackson.java b/rpt-base/src/main/java/cn/promptness/rpt/base/serialize/Jackson.java
@@ -5,7 +5,7 @@
 
 import java.io.IOException;
 
-public class Jackson implements Serialize {
+public class Jackson implements Serializer {
 
     private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
 

diff --git a/rpt-base/src/main/java/cn/promptness/rpt/base/serialize/Protostuff.java b/rpt-base/src/main/java/cn/promptness/rpt/base/serialize/Protostuff.java
@@ -6,7 +6,7 @@
 import io.protostuff.Schema;
 import io.protostuff.runtime.RuntimeSchema;
 
-public class Protostuff implements Serialize {
+public class Protostuff implements Serializer {
 
     private static final LinkedBuffer BUFFER = LinkedBuffer.allocate(LinkedBuffer.DEFAULT_BUFFER_SIZE);
     private static final Schema<Meta> SCHEMA_CACHE = RuntimeSchema.getSchema(Meta.class);

diff --git a/...mptness/rpt/base/serialize/Serialize.java → ...ptness/rpt/base/serialize/Serializer.java b/...mptness/rpt/base/serialize/Serialize.java → ...ptness/rpt/base/serialize/Serializer.java
@@ -2,7 +2,7 @@
 
 import cn.promptness.rpt.base.protocol.Meta;
 
-public interface Serialize {
+public interface Serializer {
 
     byte[] serialize(Meta meta) throws Exception;