From bc1c2b008bc66207c3ff3fb9ea53b603456a41ab Mon Sep 17 00:00:00 2001 From: wujiawei <1207537021@qq.com> Date: Sun, 22 Sep 2024 22:01:28 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E6=B8=97=E9=80=8F=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF=E9=97=AE=E9=A2=98=20=E9=80=9A=E9=81=93=E5=85=B3?= =?UTF-8?q?=E9=97=AD=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../NettyClientPermeateServerVisitorHandler.java | 8 -------- ...eportClientPermeateServerTransferTypeAdvanced.java | 4 ++-- .../handler/NettyClientPermeateServerRealHandler.java | 11 ++++++++++- 3 files changed, 12 insertions(+), 11 deletions(-) diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerVisitorHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerVisitorHandler.java index 301a70c..72265f7 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerVisitorHandler.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerVisitorHandler.java @@ -78,14 +78,6 @@ public class NettyClientPermeateServerVisitorHandler extends SimpleChannelInboun nettyProxyMsg.setData(bytes); nextChannel.writeAndFlush(nettyProxyMsg); // 处理访客流量 -// ServerChannelFlow serverChannelFlow = ServerChannelFlow -// .builder() -// .channelFlowEnum(ChannelFlowEnum.IN_FLOW) -// .port(visitorPort) -// .clientId(clientId) -// .flow(bytes.length) -// .build(); -// channelFlowAdapter.asyncHandler(visitorChannel, serverChannelFlow); log.debug("【客户端渗透服务端】访客端口成功发送数据了"); } diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleReportClientPermeateServerTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleReportClientPermeateServerTransferTypeAdvanced.java index 741dcd4..ca268cd 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleReportClientPermeateServerTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleReportClientPermeateServerTransferTypeAdvanced.java @@ -48,10 +48,10 @@ public class ServerHandleReportClientPermeateServerTransferTypeAdvanced extends ChannelFuture channelFuture = nextChannel.writeAndFlush(buf); boolean success = channelFuture.isSuccess(); log.debug("visitor writerAndFlush status: {}", success); - // 记录出口数据 + // 记录进口数据 ServerChannelFlow serverChannelFlow = ServerChannelFlow .builder() - .channelFlowEnum(ChannelFlowEnum.OUT_FLOW) + .channelFlowEnum(ChannelFlowEnum.IN_FLOW) .port(visitorPort) .clientId(clientId) .flow(msg.getData().length) diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/NettyClientPermeateServerRealHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/NettyClientPermeateServerRealHandler.java index 03a099f..4d26fc5 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/NettyClientPermeateServerRealHandler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/NettyClientPermeateServerRealHandler.java @@ -35,7 +35,7 @@ public class NettyClientPermeateServerRealHandler extends SimpleChannelInboundHa Channel channel = ctx.channel(); byte[] bytes = nettyByteBuf.getData(); log.debug("bytes.length:{}",bytes.length); - log.debug("接收客户端真实服务数据:{}", new String(bytes)); + log.debug("【客户端渗透服务端】服务端真实服务数据:{}", new String(bytes)); Channel nextChannel = ChannelAttributeKeyUtils.getNextChannel(channel); // 消息下发到客户端 @@ -44,6 +44,15 @@ public class NettyClientPermeateServerRealHandler extends SimpleChannelInboundHa nettyMsg.setData(bytes); nextChannel.writeAndFlush(nettyMsg); + // 记录出口数据 +// ServerChannelFlow serverChannelFlow = ServerChannelFlow +// .builder() +// .channelFlowEnum(ChannelFlowEnum.OUT_FLOW) +// .port(visitorPort) +// .clientId(clientId) +// .flow(msg.getData().length) +// .build(); +// channelFlowAdapter.asyncHandler(channel, serverChannelFlow); }