From b4daa3ba701d27ee27c477f83e18537473257a1f Mon Sep 17 00:00:00 2001 From: wujiawei <1207537021@qq.com> Date: Sat, 21 Sep 2024 00:39:35 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF=E6=B8=97=E9=80=8F=E5=AE=A2=E6=88=B7=E7=AB=AF=E7=BC=96?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../NettyClientPermeateClientVisitorHandler.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientVisitorHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientVisitorHandler.java index b2773cfc..dadc4e11 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientVisitorHandler.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientVisitorHandler.java @@ -54,9 +54,9 @@ public class NettyClientPermeateClientVisitorHandler extends SimpleChannelInboun internalNetworkPermeateServerVisitor.setVisitorId(visitorId); // 判断是否有可用的通道 如果没有创建新的通道 // Channel transferChannel = nettyChannelPool.availableChannel(visitorId); - // 创建访客连接服务端通道 + // 创建访客连接客户端通道 NettyClientTransferClientSocket.buildTransferServer(internalNetworkPermeateServerVisitor); - log.info("客户端渗透服务端访客端口连接成功了"); + log.info("客户端渗透客户端访客端口连接成功了"); super.channelActive(ctx); } @@ -71,7 +71,7 @@ public class NettyClientPermeateClientVisitorHandler extends SimpleChannelInboun byte[] bytes = new byte[buf.readableBytes()]; buf.readBytes(bytes); // 获取客户端通道，而后进行数据下发 - log.debug("【客户端渗透服务端】访客端口成功接收数据:{}", new String(bytes)); + log.debug("【客户端渗透客户端】访客端口成功接收数据:{}", new String(bytes)); // 使用访客的通信通道 Integer visitorPort = internalNetworkPermeateServerVisitor.getVisitorPort(); @@ -81,7 +81,7 @@ public class NettyClientPermeateClientVisitorHandler extends SimpleChannelInboun nettyProxyMsg.setVisitorPort(visitorPort); nettyProxyMsg.setData(bytes); nextChannel.writeAndFlush(nettyProxyMsg); - log.debug("【客户端渗透服务端】访客端口成功发送数据了"); + log.debug("【客户端渗透客户端】访客端口成功发送数据了"); } @Override @@ -100,7 +100,7 @@ public class NettyClientPermeateClientVisitorHandler extends SimpleChannelInboun nextChannel.config().setOption(ChannelOption.AUTO_READ, true); - // 通知服务端 关闭访问通道、真实通道 + // 通知客户端 关闭访问通道、真实通道 NettyProxyMsg myMsg = new NettyProxyMsg(); myMsg.setType(MessageType.DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR); myMsg.setVisitorId(visitorId); @@ -109,7 +109,7 @@ public class NettyClientPermeateClientVisitorHandler extends SimpleChannelInboun // 关闭 访客通信通道、访客真实通道 NettyRealIdContext.clear(visitorId); NettyCommunicationIdContext.clear(visitorId); - log.warn("【客户端渗透服务端】访客端口断开连接"); + log.warn("【客户端渗透客户端】访客端口断开连接"); super.channelInactive(ctx); }