From b4e2f8ec3cf399f441916496ad9a45096acc3422 Mon Sep 17 00:00:00 2001 From: wujiawei <1207537021@qq.com> Date: Fri, 20 Sep 2024 21:57:02 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF=E6=B8=97=E9=80=8F=E5=AE=A2=E6=88=B7=E7=AB=AF=E7=BC=96?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../netty/handler/NettyClientPermeateClientRealHandler.java | 3 ++- ...erHandleReportClientTransferClientResponseTypeAdvanced.java | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientRealHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientRealHandler.java index 9960a15..5ce7a57 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientRealHandler.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientRealHandler.java @@ -31,6 +31,7 @@ public class NettyClientPermeateClientRealHandler extends SimpleChannelInboundHa String clientId = ChannelAttributeKeyUtils.getClientId(ctx.channel()); // 访客通信通道 上报服务端代理完成 Channel visitorChannel = NettyCommunicationIdContext.getVisitor(visitorId); + Channel nextChannel = ChannelAttributeKeyUtils.getNextChannel(ctx.channel()); NettyProxyMsg returnMessage = new NettyProxyMsg(); returnMessage.setType(MessageType.REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE); returnMessage.setVisitorId(visitorId); @@ -38,7 +39,7 @@ public class NettyClientPermeateClientRealHandler extends SimpleChannelInboundHa returnMessage.setVisitorPort(visitorPort); returnMessage.setData(bytes); - visitorChannel.writeAndFlush(returnMessage); + nextChannel.writeAndFlush(returnMessage); } diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleReportClientTransferClientResponseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleReportClientTransferClientResponseTypeAdvanced.java index 1b7c9a2..e1b69af 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleReportClientTransferClientResponseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleReportClientTransferClientResponseTypeAdvanced.java @@ -28,7 +28,7 @@ public class ServerHandleReportClientTransferClientResponseTypeAdvanced extends byte[] msgClientTargetPort = nettyProxyMsg.getClientTargetPort(); byte[] clientId = nettyProxyMsg.getClientId(); // 下发客户端初始化成功 - Channel nextChannel = ChannelAttributeKeyUtils.getNextChannel(channel); + Channel nextChannel = ChannelAttributeKeyUtils.getTransferNextChannel(channel); NettyProxyMsg clientConnectTagetNettyProxyMsg = new NettyProxyMsg();