diff --git a/neutrino-proxy-client/src/main/resources/app.yml b/neutrino-proxy-client/src/main/resources/app.yml index 57b09b0f..a6f65766 100644 --- a/neutrino-proxy-client/src/main/resources/app.yml +++ b/neutrino-proxy-client/src/main/resources/app.yml @@ -10,7 +10,7 @@ neutrino: initial-bytes-to-strip: 0 length-adjustment: 0 read-idle-time: 40 - write-idle-time: 8 + write-idle-time: 5 all-idle-time-seconds: 0 client: thread-count: 50 diff --git a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/ServerChannelHandler.java b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/ServerChannelHandler.java index ec5e994d..239e1e30 100644 --- a/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/ServerChannelHandler.java +++ b/neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/ServerChannelHandler.java @@ -71,19 +71,21 @@ public class ServerChannelHandler extends SimpleChannelInboundHandler InetSocketAddress sa = (InetSocketAddress) visitorChannel.localAddress(); Channel cmdChannel = ProxyUtil.getCmdChannelByServerPort(sa.getPort()); - if (cmdChannel == null) { - + if (null == cmdChannel) { // 该端口还没有代理客户端 ctx.channel().close(); } else { @@ -127,12 +126,12 @@ public class VisitorChannelHandler extends SimpleChannelInboundHandler InetSocketAddress sa = (InetSocketAddress) visitorChannel.localAddress(); Channel cmdChannel = ProxyUtil.getCmdChannelByServerPort(sa.getPort()); - if (cmdChannel == null) { + if (null == cmdChannel) { // 该端口还没有代理客户端 ctx.channel().close(); } else { Channel proxyChannel = visitorChannel.attr(Constants.NEXT_CHANNEL).get(); - if (proxyChannel != null) { + if (null != proxyChannel) { proxyChannel.config().setOption(ChannelOption.AUTO_READ, visitorChannel.isWritable()); } } diff --git a/neutrino-proxy-server/src/main/resources/app.yml b/neutrino-proxy-server/src/main/resources/app.yml index d92ac187..6ff69f89 100644 --- a/neutrino-proxy-server/src/main/resources/app.yml +++ b/neutrino-proxy-server/src/main/resources/app.yml @@ -10,7 +10,7 @@ neutrino: initial-bytes-to-strip: 0 length-adjustment: 0 read-idle-time: 40 - write-idle-time: 10 + write-idle-time: 5 all-idle-time-seconds: 0 server: boss-thread-count: 10