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 =