alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2026-02-04 23:15:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

【fix】授权调整

Browse Source
This commit is contained in:
wujiawei
2025-07-16 21:49:01 +08:00
parent 50b2b1866c
commit e5f53b520b
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/filter/NettyTcpProxyFilter.java
View File

@@ -45,8 +45,13 @@ public class NettyTcpProxyFilter extends DebugChannelInitializer<SocketChannel>
pipeline.addLast(Socks5ServerEncoder.DEFAULT); pipeline.addLast(Socks5ServerEncoder.DEFAULT);
// 初始化连接 // 初始化连接
pipeline.addLast(new Socks5InitialRequestDecoder()); 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()); pipeline.addLast(new Socks5CommandRequestDecoder());

5
wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocks5InitialRequestHandler.java
View File

@@ -34,11 +34,6 @@ public class NettySocks5InitialRequestHandler extends SimpleChannelInboundHandle
Socks5InitialResponse socks5InitialResponse = Socks5InitialResponse socks5InitialResponse =
new DefaultSocks5InitialResponse(Socks5AuthMethod.PASSWORD); new DefaultSocks5InitialResponse(Socks5AuthMethod.PASSWORD);
ctx.writeAndFlush(socks5InitialResponse); ctx.writeAndFlush(socks5InitialResponse);
// 认证
ctx.pipeline().addLast(new Socks5PasswordAuthRequestDecoder());
ctx.pipeline().addLast(new NettySocks5PasswordAuthRequestInboundHandler(nettyPasswordAuth));
}else { }else {
// 不验证账号密码 // 不验证账号密码
Socks5InitialResponse socks5InitialResponse = Socks5InitialResponse socks5InitialResponse =