alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2025-06-06 21:37:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

【fix】 bug fix

Browse Source
This commit is contained in:
wujiawei 2025-04-06 22:43:01 +08:00
parent 532d05d4a8
commit 9c5000f995
3 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/handler/NettyHttpClientProxyClientRealHandler.java
View File

@ -22,9 +22,8 @@ public class NettyHttpClientProxyClientRealHandler extends SimpleChannelInboundH
byte[] bytes = nettyByteBuf.getData(); byte[] bytes = nettyByteBuf.getData();
log.debug("bytes.length:{}",bytes.length); log.debug("bytes.length:{}",bytes.length);
log.debug("接收客户端真实服务数据:{}", new String(bytes)); log.debug("客户端代理客户端，接收目标客户端真实服务数据:{}", new String(bytes));
String visitorId = ChannelAttributeKeyUtils.getVisitorId(ctx.channel()); String visitorId = ChannelAttributeKeyUtils.getVisitorId(ctx.channel());
Integer visitorPort = ChannelAttributeKeyUtils.getVisitorPort(ctx.channel());
String clientId = ChannelAttributeKeyUtils.getClientId(ctx.channel()); String clientId = ChannelAttributeKeyUtils.getClientId(ctx.channel());
// 访客通信通道 上报服务端代理完成 // 访客通信通道 上报服务端代理完成
Channel nextChannel = ChannelAttributeKeyUtils.getNextChannel(ctx.channel()); Channel nextChannel = ChannelAttributeKeyUtils.getNextChannel(ctx.channel());
@ -32,7 +31,6 @@ public class NettyHttpClientProxyClientRealHandler extends SimpleChannelInboundH
returnMessage.setType(TcpMessageType.HTTP_REPORT_CLIENT_PROXY_CLIENT_TRANSFER_RESPONSE_); returnMessage.setType(TcpMessageType.HTTP_REPORT_CLIENT_PROXY_CLIENT_TRANSFER_RESPONSE_);
returnMessage.setVisitorId(visitorId); returnMessage.setVisitorId(visitorId);
returnMessage.setClientId(clientId); returnMessage.setClientId(clientId);
returnMessage.setVisitorPort(visitorPort);
returnMessage.setData(bytes); returnMessage.setData(bytes);
nextChannel.writeAndFlush(returnMessage); nextChannel.writeAndFlush(returnMessage);

2
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/proxy/http/advanced/ServerHandleHttpReportClientProxyClientConnectTransferTypeAdvanced.java
View File

@ -61,7 +61,7 @@ public class ServerHandleHttpReportClientProxyClientConnectTransferTypeAdvanced
// 让客户端主动创建一个数据传输通道 // 让客户端主动创建一个数据传输通道
loadBalance.writeAndFlush(clientConnectTagetNettyProxyMsg); loadBalance.writeAndFlush(clientConnectTagetNettyProxyMsg);
}else { }else {
log.error("can not find the client:【】 channel",clientId); log.error("can not find target client:【】 channel",clientId);
} }
} }

5
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/proxy/http/advanced/ServerHandleHttpReportClientProxyClientTransferResponseTypeAdvanced.java
View File

@ -38,9 +38,10 @@ public class ServerHandleHttpReportClientProxyClientTransferResponseTypeAdvanced
// 将返回数据下发客户端 // 将返回数据下发客户端
Channel transferNextChannel = ChannelAttributeKeyUtils.getTransferNextChannel(transferChannel); Channel transferNextChannel = ChannelAttributeKeyUtils.getTransferNextChannel(transferChannel);
if(ObjectUtils.isNotEmpty(nettyProxyMsg)) { if(ObjectUtils.isNotEmpty(transferNextChannel)) {
transferNextChannel.writeAndFlush(nettyProxyMsg); transferNextChannel.writeAndFlush(nettyProxyMsg);
}else {
log.error("无法将数据下发给原始客户端");
} }
} }