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