From 1c6f56d31e300113447905eb5b733905004cd74b Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Sat, 9 Nov 2024 20:18:27 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=20=E4=BF=AE=E5=A4=8D=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF=E6=B8=97=E9=80=8F=E6=9C=8D=E5=8A=A1=E7=AB=AF=E6=B5=81?= =?UTF-8?q?=E9=87=8F=E8=AE=A1=E7=AE=97=E9=94=99=E8=AF=AF=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...erHandleReportClientTransferClientResponseTypeAdvanced.java | 1 + .../socket/NettyClientPermeateServerConnectRealSocket.java | 3 +++ 2 files changed, 4 insertions(+) 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 0e0b46c..0639015 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 @@ -56,6 +56,7 @@ public class ServerHandleReportClientTransferClientResponseTypeAdvanced extends .clientId(clientId) .flow(clientConnectTagetNettyProxyMsg.getData().length) .build(); + channelFlowAdapter.asyncHandler(channel, serverChannelFlow); }else { log.error("can not find the client:【{}】 channel",clientId); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyClientPermeateServerConnectRealSocket.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyClientPermeateServerConnectRealSocket.java index 6f057e1..3bf1cf6 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyClientPermeateServerConnectRealSocket.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyClientPermeateServerConnectRealSocket.java @@ -59,6 +59,9 @@ public class NettyClientPermeateServerConnectRealSocket { ChannelAttributeKeyUtils.buildVisitorId(realChannel, visitorId); + String clientId = ChannelAttributeKeyUtils.getClientId(transferChannel); + ChannelAttributeKeyUtils.buildClientId(realChannel, clientId); + NettyProxyMsg myMsg = new NettyProxyMsg(); myMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); myMsg.setVisitorId(visitorId);