diff --git a/ssjygl-xsx-common/src/main/java/com/cowr/common/plugin/NettyServerPlugin.java b/ssjygl-xsx-common/src/main/java/com/cowr/common/plugin/NettyServerPlugin.java index 0076932..9761d60 100644 --- a/ssjygl-xsx-common/src/main/java/com/cowr/common/plugin/NettyServerPlugin.java +++ b/ssjygl-xsx-common/src/main/java/com/cowr/common/plugin/NettyServerPlugin.java @@ -42,7 +42,7 @@ public class NettyServerPlugin implements IPlugin { ch.pipeline().addLast( new IdleStateHandler(5, 5, 5), new StringEncoder(CharsetUtil.UTF_8), - new LineBasedFrameDecoder(4096), + new LineBasedFrameDecoder(1024 * 4096), new StringDecoder(CharsetUtil.UTF_8), new MsgHandler() ); diff --git a/ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/netty/NettyClient.java b/ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/netty/NettyClient.java index 272aa30..b4248a1 100644 --- a/ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/netty/NettyClient.java +++ b/ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/netty/NettyClient.java @@ -78,7 +78,7 @@ public class NettyClient { new ReadTimeoutHandler(15), new IdleStateHandler(5, 5, 5), // 处理心跳包 new StringEncoder(CharsetUtil.UTF_8), - new LineBasedFrameDecoder(20 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值,会导致数据发送失败 + new LineBasedFrameDecoder(1024 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值,会导致数据发送失败 new StringDecoder(CharsetUtil.UTF_8), new MsgHandler(supermarket_id) ); diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/netty/NettyServer.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/netty/NettyServer.java index 4410698..5ecf119 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/netty/NettyServer.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/netty/NettyServer.java @@ -79,7 +79,7 @@ public class NettyServer { ch.pipeline().addLast( new IdleStateHandler(5, 5, 5), // 处理心跳包 new StringEncoder(CharsetUtil.UTF_8), - new LineBasedFrameDecoder(20 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值,会导致数据发送失败 + new LineBasedFrameDecoder(1024 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值,会导致数据发送失败 new StringDecoder(CharsetUtil.UTF_8), new MsgHandler() );