From 21136284c701e7f67398e2557a45ccab02305626 Mon Sep 17 00:00:00 2001 From: wujiawei <1207537021@qq.com> Date: Tue, 17 Jun 2025 13:50:37 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=20=E4=BC=98=E5=8C=96=E7=BB=91=E5=AE=9A?= =?UTF-8?q?=E4=B8=8B=E4=B8=80=E4=B8=AA=E9=80=9A=E9=81=93=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../NettySocksServerProxyClientRealSocket.java | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/socket/NettySocksServerProxyClientRealSocket.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/socket/NettySocksServerProxyClientRealSocket.java index 46309eb1..7481ea02 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/socket/NettySocksServerProxyClientRealSocket.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/socket/NettySocksServerProxyClientRealSocket.java @@ -128,6 +128,14 @@ public class NettySocksServerProxyClientRealSocket { Channel transferChannel = futureListener.channel(); if (futureListener.isSuccess()) { log.info("服务端代理客户端socks，客户端连接服务端传输通道成功"); + // 绑定下一个通道 + ChannelAttributeKeyUtils.buildNextChannel(transferChannel, realChannel); + ChannelAttributeKeyUtils.buildNextChannel(realChannel, transferChannel); + + // 绑定客户端真实通信通道 + ChannelAttributeKeyUtils.buildVisitorId(transferChannel, visitorId); + ChannelAttributeKeyUtils.buildClientId(transferChannel, clientId); + // 开始读取数据 realChannel.config().setOption(ChannelOption.AUTO_READ, true); // 通知服务端访客连接成功 NettyProxyMsg nettyProxyMsg = new NettyProxyMsg(); @@ -137,15 +145,6 @@ public class NettySocksServerProxyClientRealSocket { nettyProxyMsg.setTargetPort(targetPort); nettyProxyMsg.setType(ProxyMessageType.SOCKS_REPORT_SERVER_PROXY_CLIENT_CONNECTION_SUCCESS_); transferChannel.writeAndFlush(nettyProxyMsg); - - ChannelAttributeKeyUtils.buildNextChannel(transferChannel, realChannel); - ChannelAttributeKeyUtils.buildNextChannel(realChannel, transferChannel); - - // 绑定客户端真实通信通道 - ChannelAttributeKeyUtils.buildVisitorId(transferChannel, visitorId); - ChannelAttributeKeyUtils.buildClientId(transferChannel, clientId); - - } else { log.info("无法连接到服务端...."); eventLoopGroup.schedule(() -> {