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

[fix] update version to 1.2.8-JDK17-SNAPSHOT

Browse Source
This commit is contained in:
wujiawei
2024-09-25 14:48:29 +08:00
parent 6408239029
commit bab2ce0242
114 changed files with 6 additions and 215 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerVisitorHandler.java
View File

@ -49,7 +49,7 @@ public class NettyClientPermeateServerVisitorHandler extends SimpleChannelInboun
// Channel transferChannel = nettyChannelPool.availableChannel(visitorId);
// 创建访客连接服务端通道
NettyClientPermeateServerVisitorTransferSocket.buildTransferServer(internalNetworkPermeateServerVisitor,visitorChannel);
log.info("客户端渗透服务端访客端口连接成功了,访客ID:{}", visitorId);
log.debug("客户端渗透服务端访客端口连接成功了,访客ID:{}", visitorId);
super.channelActive(ctx);
}
@ -77,7 +77,7 @@ public class NettyClientPermeateServerVisitorHandler extends SimpleChannelInboun
nettyProxyMsg.setData(bytes);
nextChannel.writeAndFlush(nettyProxyMsg);
// 处理访客流量
log.info("【客户端渗透服务端】访客端口成功发送数据了 访客ID:{}", visitorId);
log.debug("【客户端渗透服务端】访客端口成功发送数据了 访客ID:{}", visitorId);
}
@Override
@ -100,9 +100,9 @@ public class NettyClientPermeateServerVisitorHandler extends SimpleChannelInboun
nextChannel.writeAndFlush(myMsg);
//通信通道
nextChannel.close();
log.info("关闭访问通道、真实通道 with visitorId:{}", visitorId);
log.debug("关闭访问通道、真实通道 with visitorId:{}", visitorId);
}else {
log.info("channel inactive:{}", nextChannel);
log.debug("channel inactive:{}", nextChannel);
}
// 访客通道关闭
channel.close();

4
wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateServerVisitorTransferSocket.java
View File

@ -61,7 +61,7 @@ public class NettyClientPermeateServerVisitorTransferSocket {
Integer visitorPort = internalNetworkPermeateServerVisitor.getVisitorPort();
// 客户端新建访客通道 连接服务端IP:{},连接服务端端口:{}
log.info("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {}", inetHost, inetPort);
log.debug("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {}", inetHost, inetPort);
ChannelFuture future = bootstrap.connect(inetHost, inetPort);
// 使用的客户端ID:{}
@ -86,7 +86,7 @@ public class NettyClientPermeateServerVisitorTransferSocket {
transferChannel.writeAndFlush(myMsg);
} else {
log.info("客户端渗透服务端通信通道中断....");
log.warn("客户端渗透服务端通信通道中断....");
transferChannel.eventLoop().schedule(() -> {
try {
buildTransferServer(internalNetworkPermeateServerVisitor, visitorChannel);