[ISSUE #4677]netty codec enhancement (#4678)

eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/codec/Codec.java

@@ -35,22 +35,37 @@
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.ByteToMessageCodec;
 import io.netty.handler.codec.MessageToByteEncoder;
 import io.netty.handler.codec.ReplayingDecoder;
 
+
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.google.common.base.Preconditions;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
-public class Codec {
+public class Codec extends ByteToMessageCodec<Package> {
 
     private static final int FRAME_MAX_LENGTH = 1024 * 1024 * 4;
 
     private static final byte[] CONSTANT_MAGIC_FLAG = serializeBytes("EventMesh");
     private static final byte[] VERSION = serializeBytes("0000");
 
+    private Encoder encoder = new Encoder();
+    private Decoder decoder = new Decoder();
+
+    @Override
+    protected void encode(ChannelHandlerContext ctx, Package pkg, ByteBuf out) throws Exception {
+        encoder.encode(ctx, pkg, out);
+    }
+
+    @Override
+    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
+        decoder.decode(ctx, in, out);
+    }
+
     public static class Encoder extends MessageToByteEncoder<Package> {
 
         @Override

eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java

@@ -110,7 +110,7 @@ protected synchronized void open(SimpleChannelInboundHandler<Package> handler) t
 
             @Override
             public void initChannel(SocketChannel ch) {
-                ch.pipeline().addLast(new Codec.Encoder(), new Codec.Decoder())
+                ch.pipeline().addLast(new Codec())
                     .addLast(handler, newExceptionHandler());
             }
         });