[fix] 优化tcp架构

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpClientConnectSuccessTypeAdvanced.java

@@ -17,6 +17,8 @@ import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateClientMappingDTO;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateServerMappingDTO;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 import org.wu.framework.web.response.Result;
 
@@ -28,6 +30,7 @@ import java.util.List;
  * 服务端连接成功处理
  * REPORT_CLIENT_CONNECT_SUCCESS
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpClientConnectSuccessTypeAdvanced extends AbstractHandleTcpClientConnectSuccessTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientCloseTypeAdvanced.java

@@ -5,11 +5,14 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientPermeateClientCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 
 /**
  * 上报 客户端渗透客户端init close 信息
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportClientPermeateClientCloseTypeAdvanced extends AbstractHandleTcpReportClientPermeateClientCloseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced.java

@@ -6,11 +6,14 @@ import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 
 /**
  * 上报客户端渗透客户端通信通道关闭
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced extends AbstractHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced.java

@@ -5,11 +5,14 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 
 /**
  * 上报 客户端渗透服务端通信通道关闭
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced extends AbstractHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferTypeAdvanced.java

@@ -10,12 +10,15 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs
 import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
 import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerChannelFlow;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 
 /**
  * 上报 客户端渗透服务端通信
  * REPORT_CLIENT_PERMEATE_SERVER_TRANSFER
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportClientPermeateServerTransferTypeAdvanced extends AbstractHandleTcpReportClientPermeateServerTransferTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java

@@ -5,11 +5,14 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.*;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 
 /**
  * 上报 客户端渗透客户端数据传输通道连接成功
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java

@@ -7,11 +7,14 @@ import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyTransferChannelContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 
 /**
  * 上报 客户端渗透客户端数据传输通道init
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced extends AbstractHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientResponseTypeAdvanced.java

@@ -9,12 +9,15 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs
 import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
 import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerChannelFlow;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 /**
  * 上报客户端渗透客户端数据传输结果
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportClientTransferClientResponseTypeAdvanced extends AbstractHandleTcpReportClientTransferClientResponseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientTypeAdvanced.java

@@ -9,12 +9,15 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs
 import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
 import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerChannelFlow;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 /**
  * 上报客户端渗透客户端数据传输
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportClientTransferClientTypeAdvanced extends AbstractHandleTcpReportClientTransferClientTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java

@@ -5,11 +5,14 @@ import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
 import org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.socket.NettyClientPermeateServerConnectRealSocket;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 
 /**
  * 上报客户端通信通道连接成功
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Component
 public class ServerHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced<NettyProxyMsg> {
     /**

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClusterNodeRegisterTypeAdvanced.java

@@ -5,12 +5,15 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClusterNodeRegisterTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.server.cluster.application.LazyNettyClusterNodeApplication;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 import org.wu.framework.bean.factory.BeanContext;
 
 /**
  * 集群节点注册 服务端本地处理
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportClusterNodeRegisterTypeAdvanced extends

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportDisconnectTypeAdvanced.java

@@ -12,6 +12,8 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
 import org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.socket.NettyServerPermeateClientVisitorSocket;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyClientStatsChangeApplication;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.LazyNettyClientLoginCommand;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 import org.wu.framework.core.utils.ObjectUtils;
 
@@ -23,6 +25,7 @@ import java.util.List;
  * 服务端处理客户端断开连接处理
  * TYPE_DISCONNECT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportDisconnectTypeAdvanced extends AbstractHandleTcpReportDisconnectTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced.java

@@ -2,6 +2,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.advanced;
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyCommunicationIdContext;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
@@ -11,6 +13,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs
 /**
  * 服务端处理客户端 关闭一个访客
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced extends AbstractHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced.java

@@ -3,6 +3,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.advanced;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelOption;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyCommunicationIdContext;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
@@ -13,6 +15,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
 /**
  * 服务端渗透客户端通信通道
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced extends AbstractHandleTcpReportServicePermeateClientRealConnectTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced.java

@@ -12,6 +12,8 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs
 import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
 import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerChannelFlow;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 
 
@@ -19,6 +21,7 @@ import org.springframework.stereotype.Component;
  * 服务端处理客户端数据传输
  * REPORT_CLIENT_TRANSFER
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced extends AbstractHandleTcpReportServicePermeateClientTransferTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingClosedTypeAdvanced.java

@@ -5,6 +5,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyClientStatsChangeApplication;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.LazyNettyClientLoginCommand;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 import org.framework.lazy.cloud.network.heartbeat.common.ChannelContext;
 import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
@@ -17,6 +19,7 @@ import java.util.List;
 /**
  * 服务端处理上报的暂存关闭
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportStagingClosedTypeAdvanced extends AbstractHandleTcpReportStagingClosedTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingOpenedTypeAdvanced.java

@@ -10,6 +10,8 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.NettyClientStatus
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyClientStatsChangeApplication;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.LazyNettyClientLoginCommand;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 
 import java.nio.charset.StandardCharsets;
@@ -18,6 +20,7 @@ import java.util.List;
 /**
  * 服务端处理上报的暂存开启
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ServerHandleTcpReportStagingOpenedTypeAdvanced extends AbstractHandleTcpReportStagingOpenedTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerTcpTcpHandleChannelHeartbeatTypeAdvanced.java

@@ -3,6 +3,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.advanced;
 
 import io.netty.channel.Channel;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.AbstractTcpHandleChannelHeartbeatTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.springframework.stereotype.Component;
 import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
@@ -12,6 +14,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
  * 服务端 处理客户端心跳
  * TYPE_HEARTBEAT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Component
 public class ServerTcpTcpHandleChannelHeartbeatTypeAdvanced extends AbstractTcpHandleChannelHeartbeatTypeAdvanced<NettyProxyMsg> {