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