xjm
/
ssjygl-xsct-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

.

dev
lisai17@sina.com 2020-10-31 14:02:00 +08:00
parent 5071993be2
commit d1c958864d
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ssjygl-xsx-common/src/main/java/com/cowr/common/plugin/NettyServerPlugin.java
View File

@ -42,7 +42,7 @@ public class NettyServerPlugin implements IPlugin {
ch.pipeline().addLast( ch.pipeline().addLast(
new IdleStateHandler(5, 5, 5), new IdleStateHandler(5, 5, 5),
new StringEncoder(CharsetUtil.UTF_8), new StringEncoder(CharsetUtil.UTF_8),
new LineBasedFrameDecoder(4096), new LineBasedFrameDecoder(1024 * 4096),
new StringDecoder(CharsetUtil.UTF_8), new StringDecoder(CharsetUtil.UTF_8),
new MsgHandler() new MsgHandler()
); );

2
ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/netty/NettyClient.java
View File

@ -78,7 +78,7 @@ public class NettyClient {
new ReadTimeoutHandler(15), new ReadTimeoutHandler(15),
new IdleStateHandler(5, 5, 5), // 处理心跳包 new IdleStateHandler(5, 5, 5), // 处理心跳包
new StringEncoder(CharsetUtil.UTF_8), new StringEncoder(CharsetUtil.UTF_8),
new LineBasedFrameDecoder(20 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值，会导致数据发送失败 new LineBasedFrameDecoder(1020 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值，会导致数据发送失败
new StringDecoder(CharsetUtil.UTF_8), new StringDecoder(CharsetUtil.UTF_8),
new MsgHandler(supermarket_id) new MsgHandler(supermarket_id)
); );

2
ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/synctask/SyncTaskService.java
View File

@ -98,7 +98,7 @@ public class SyncTaskService {
List<SyncTask> list = unsynclist(); List<SyncTask> list = unsynclist();
if (!list.isEmpty()) { if (!list.isEmpty()) {
log.debug("开始下发未同步完成的数据"); log.debug("开始上报未同步完成的数据");
} }
// TODO:一次同步的数量不多，连续发送 // TODO:一次同步的数量不多，连续发送

2
ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/netty/NettyServer.java
View File

@ -79,7 +79,7 @@ public class NettyServer {
ch.pipeline().addLast( ch.pipeline().addLast(
new IdleStateHandler(5, 5, 5), // 处理心跳包 new IdleStateHandler(5, 5, 5), // 处理心跳包
new StringEncoder(CharsetUtil.UTF_8), new StringEncoder(CharsetUtil.UTF_8),
new LineBasedFrameDecoder(20 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值，会导致数据发送失败 new LineBasedFrameDecoder(1024 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值，会导致数据发送失败
new StringDecoder(CharsetUtil.UTF_8), new StringDecoder(CharsetUtil.UTF_8),
new MsgHandler() new MsgHandler()
); );