From e5f53b520bc0bcb0477208f068b8b3074e2d2186 Mon Sep 17 00:00:00 2001 From: wujiawei <1207537021@qq.com> Date: Wed, 16 Jul 2025 21:49:01 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=E6=8E=88=E6=9D=83?= =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../heartbeat/protocol/filter/NettyTcpProxyFilter.java | 7 ++++++- .../protocol/handler/NettySocks5InitialRequestHandler.java | 5 ----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/filter/NettyTcpProxyFilter.java b/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/filter/NettyTcpProxyFilter.java index d44b250e..9c7b93f0 100644 --- a/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/filter/NettyTcpProxyFilter.java +++ b/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/filter/NettyTcpProxyFilter.java @@ -45,8 +45,13 @@ public class NettyTcpProxyFilter extends DebugChannelInitializer pipeline.addLast(Socks5ServerEncoder.DEFAULT); // 初始化连接 pipeline.addLast(new Socks5InitialRequestDecoder()); - pipeline.addLast(new NettySocks5InitialRequestHandler(protocolProxyProperties,nettyPasswordAuth)); + pipeline.addLast(new NettySocks5InitialRequestHandler(protocolProxyProperties, nettyPasswordAuth)); + if (protocolProxyProperties.getAuthentication()) { + // 认证 + pipeline.addLast(new Socks5PasswordAuthRequestDecoder()); + pipeline.addLast(new NettySocks5PasswordAuthRequestInboundHandler(nettyPasswordAuth)); + } // 连接请求 pipeline.addLast(new Socks5CommandRequestDecoder()); diff --git a/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocks5InitialRequestHandler.java b/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocks5InitialRequestHandler.java index b906039e..f931d881 100644 --- a/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocks5InitialRequestHandler.java +++ b/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocks5InitialRequestHandler.java @@ -34,11 +34,6 @@ public class NettySocks5InitialRequestHandler extends SimpleChannelInboundHandle Socks5InitialResponse socks5InitialResponse = new DefaultSocks5InitialResponse(Socks5AuthMethod.PASSWORD); ctx.writeAndFlush(socks5InitialResponse); - // 认证 - ctx.pipeline().addLast(new Socks5PasswordAuthRequestDecoder()); - ctx.pipeline().addLast(new NettySocks5PasswordAuthRequestInboundHandler(nettyPasswordAuth)); - - }else { // 不验证账号密码 Socks5InitialResponse socks5InitialResponse =