From 3f71e2790ba43105ccee1bfcf8bd8dec17f639b8 Mon Sep 17 00:00:00 2001 From: aoshiguchen <1052045476@qq.com> Date: Sun, 5 Feb 2023 18:50:48 +0800 Subject: [PATCH] =?UTF-8?q?VisitorChannel=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../proxy/server/proxy/core/VisitorChannelHandler.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/proxy/core/VisitorChannelHandler.java b/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/proxy/core/VisitorChannelHandler.java index 729b2856..23f938a0 100755 --- a/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/proxy/core/VisitorChannelHandler.java +++ b/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/proxy/core/VisitorChannelHandler.java @@ -88,7 +88,9 @@ public class VisitorChannelHandler extends SimpleChannelInboundHandler } else { String visitorId = newVisitorId(); String lanInfo = ProxyUtil.getClientLanInfoByServerPort(sa.getPort()); - if (!StringUtil.isEmpty(lanInfo)) { + if (StringUtil.isEmpty(lanInfo)) { + ctx.channel().close(); + } else { // 用户连接到代理服务器时,设置用户连接不可读,等待代理后端服务器连接成功后再改变为可读状态 visitorChannel.config().setOption(ChannelOption.AUTO_READ, false);