add netty length field length

changmingxie · Aug 2, 2022 · 7a0a13c · 7a0a13c
1 parent fb56a4f
commit 7a0a13c
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/...ion-core/src/main/java/org/mengyun/tcctransaction/remoting/netty/NettyRemotingClient.java b/...ion-core/src/main/java/org/mengyun/tcctransaction/remoting/netty/NettyRemotingClient.java
@@ -119,9 +119,9 @@ protected void initChannel(SocketChannel ch) throws Exception {
                                         new LoggingHandler(LogLevel.DEBUG),
                                         new IdleStateHandler(0, nettyClientConfig.getChannelMaxIdleTimeSeconds(), 0),
                                         new LengthFieldBasedFrameDecoder(nettyClientConfig.getFrameMaxLength(),
-                                                0, 2, 0,
-                                                2),
-                                        new LengthFieldPrepender(2),
+                                                0, 4, 0,
+                                                4),
+                                        new LengthFieldPrepender(4),
                                         new NettyEncoder(serializer),
                                         new NettyDecoder(serializer),
                                         new HeartBeatReqHandler(),

diff --git a/...ion-core/src/main/java/org/mengyun/tcctransaction/remoting/netty/NettyRemotingServer.java b/...ion-core/src/main/java/org/mengyun/tcctransaction/remoting/netty/NettyRemotingServer.java
@@ -134,9 +134,9 @@ protected void initChannel(SocketChannel ch) throws Exception {
                                 eventExecutorGroup,
                                 new LoggingHandler(LogLevel.DEBUG),
                                 new LengthFieldBasedFrameDecoder(nettyServerConfig.getFrameMaxLength(),
-                                        0, 2, 0,
-                                        2),
-                                new LengthFieldPrepender(2),
+                                        0, 4, 0,
+                                        4),
+                                new LengthFieldPrepender(4),
                                 new NettyDecoder(serializer),
                                 new NettyEncoder(serializer),
                                 new ReadTimeoutHandler(nettyServerConfig.getChannelIdleTimeoutSeconds()),