From d1c958864d2226fcdc2aea8df99359e755a2694d Mon Sep 17 00:00:00 2001 From: "lisai17@sina.com" Date: Sat, 31 Oct 2020 14:02:00 +0800 Subject: [PATCH] . --- .../src/main/java/com/cowr/common/plugin/NettyServerPlugin.java | 2 +- .../src/main/java/com/cowr/local/ssjygl/netty/NettyClient.java | 2 +- .../java/com/cowr/local/ssjygl/synctask/SyncTaskService.java | 2 +- .../main/java/com/cowr/service/ssjygl/netty/NettyServer.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) 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..fe35e67 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(1020 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值，会导致数据发送失败 new StringDecoder(CharsetUtil.UTF_8), new MsgHandler(supermarket_id) ); diff --git a/ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/synctask/SyncTaskService.java b/ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/synctask/SyncTaskService.java index b7855db..610c413 100644 --- a/ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/synctask/SyncTaskService.java +++ b/ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/synctask/SyncTaskService.java @@ -98,7 +98,7 @@ public class SyncTaskService { List list = unsynclist(); if (!list.isEmpty()) { - log.debug("开始下发未同步完成的数据"); + log.debug("开始上报未同步完成的数据"); } // TODO:一次同步的数量不多，连续发送 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() );