yeyinlaoying/neutrino-proxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

服务端客户端，cmd通道读写超时处理调整.

Browse Source
This commit is contained in:
aoshiguchen
2023-06-30 18:06:03 +08:00
parent f423056361
commit c20a6db44a
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
neutrino-proxy-client/src/main/java/org/dromara/neutrinoproxy/client/core/CmdChannelHandler.java
+3 -3
View File
@@ -61,14 +61,14 @@ public class CmdChannelHandler extends SimpleChannelInboundHandler<ProxyMessage>
switch (event.state()) {
case READER_IDLE:
// 读超时，断开连接
// log.info("读超时");
// ctx.channel().close();
log.error("Client CmdChannel 读超时，断开连接");
ctx.channel().close();
break;
case WRITER_IDLE:
ctx.channel().writeAndFlush(ProxyMessage.buildHeartbeatMessage());
break;
case ALL_IDLE:
log.info("Client CmdChannel 读写超时");
log.error("Client CmdChannel 读写超时，断开连接");
ctx.close();
break;
}
neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/ProxyTunnelChannelHandler.java
+1
View File
@@ -131,6 +131,7 @@ public class ProxyTunnelChannelHandler extends SimpleChannelInboundHandler<Proxy
ctx.channel().close();
break;
case WRITER_IDLE:
ctx.channel().writeAndFlush(ProxyMessage.buildHeartbeatMessage());
break;
case ALL_IDLE:
break;