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

.

dev
lisai17@sina.com 2020-10-31 13:50:25 +08:00
parent 5c67cb6618
commit 4b565e841f
3 changed files with 3 additions and 3 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(1024 * 4096), // 处理粘包问题 // 数据内容超过这里设置的值，会导致数据发送失败
new StringDecoder(CharsetUtil.UTF_8), new StringDecoder(CharsetUtil.UTF_8),
new MsgHandler(supermarket_id) new MsgHandler(supermarket_id)
); );

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()
); );