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();