【fix】添加 @Role(BeanDefinition.ROLE_INFRASTRUCTURE)

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpChannelHeartbeatTypeAdvanced.java

@@ -2,15 +2,18 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 
 
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
-import org.framework.lazy.cloud.network.heartbeat.common.constant.TcpMessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.AbstractTcpHandleChannelHeartbeatTypeAdvanced;
+import org.framework.lazy.cloud.network.heartbeat.common.constant.TcpMessageType;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
  * 服务端 处理客户端心跳
  * TCP_TYPE_HEARTBEAT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public class ClientHandleTcpChannelHeartbeatTypeAdvanced extends AbstractTcpHandleChannelHeartbeatTypeAdvanced<NettyProxyMsg> {
 
     /**

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java

@@ -5,11 +5,13 @@ import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -17,6 +19,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpChannelTransferTypeAdvancedHandleDistributeTcpDistribute extends AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpClientChannelActiveAdvanced.java

@@ -3,14 +3,17 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import io.netty.channel.Channel;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.common.ChannelContext;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpClientChannelActiveAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * 客户端通道 is active
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public class ClientHandleTcpClientChannelActiveAdvanced extends AbstractHandleTcpClientChannelActiveAdvanced<NettyProxyMsg> {
     private final NettyClientProperties nettyClientProperties;
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java

@@ -2,12 +2,14 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyVisitorPortContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientPermeateClientCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorSocket;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -15,6 +17,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorS
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateClientCloseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.socket.NettyTcpClientPermeateClientVisitorSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -20,6 +22,7 @@ import java.util.List;
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java

@@ -3,11 +3,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -15,6 +17,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java

@@ -2,12 +2,14 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyVisitorPortContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorSocket;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -15,6 +17,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorS
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.socket.NettyTcpClientPermeateServerVisitorSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -20,6 +22,7 @@ import java.util.List;
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java

@@ -3,11 +3,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -15,6 +17,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -16,6 +18,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.socket.NettyTcpClientPermeateClientRealSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -21,6 +23,7 @@ import java.util.List;
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelOption;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -17,6 +19,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced extends AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -17,6 +19,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced extends AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java

@@ -6,11 +6,13 @@ import io.netty.channel.ChannelOption;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.handler.NettyTcpClientPermeateServerVisitorHandler;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.socket.NettyTcpClientPermeateServerVisitorTransferSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -20,6 +22,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java

@@ -3,15 +3,18 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import com.alibaba.fastjson.JSONObject;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.event.ClientChangeEvent;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 import java.util.List;
 
 /**
  * 客户端连接成功通知
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle extends AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeDisconnectTypeAdvancedHandle.java

@@ -3,15 +3,18 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.event.ClientChangeEvent;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
  * 服务端处理客户端断开连接处理
  * TYPE_DISCONNECT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeDisconnectTypeAdvancedHandle extends AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced.java

@@ -4,10 +4,12 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.socket.NettyTcpServerPermeateClientRealSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPenetrationRealClient;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -16,6 +18,7 @@ import java.util.List;
 /**
  * 客户端创建真实代理同奥
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced extends AbstractHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -17,6 +19,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced extends AbstractHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeSingleClientMessageTypeAdvanced.java

@@ -1,13 +1,16 @@
 package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.advanced;
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeSingleClientMessageTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * 接收服务端发送过来的聊天信息
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeSingleClientMessageTypeAdvanced extends AbstractHandleTcpDistributeSingleClientMessageTypeAdvanced<NettyProxyMsg> {
     /**

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java

@@ -3,12 +3,15 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelOption;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyRealIdContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced extends AbstractHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced<NettyProxyMsg> {
     /**

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java

@@ -2,11 +2,14 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.adv
 
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyCommunicationIdContext;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyRealIdContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced extends AbstractHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced<NettyProxyMsg> {
     /**

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeStagingClosedTypeAdvanced.java

@@ -1,13 +1,16 @@
 package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.advanced;
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeStagingClosedTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * 服务端下发暂存关闭消息处理
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeStagingClosedTypeAdvanced extends AbstractHandleTcpDistributeStagingClosedTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeStagingOpenedTypeAdvanced.java

@@ -1,13 +1,16 @@
 package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.tcp.advanced;
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.tcp.client.AbstractHandleTcpDistributeStagingOpenedTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * 服务端下发暂存开启消息处理
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleTcpDistributeStagingOpenedTypeAdvanced extends AbstractHandleTcpDistributeStagingOpenedTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpChannelHeartbeatTypeAdvanced.java

@@ -2,15 +2,18 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 
 
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
-import org.framework.lazy.cloud.network.heartbeat.common.constant.UdpMessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.AbstractUdpHandleChannelHeartbeatTypeAdvanced;
+import org.framework.lazy.cloud.network.heartbeat.common.constant.UdpMessageType;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
  * 服务端 处理客户端心跳
  * UDP_TYPE_HEARTBEAT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public class ClientHandleUdpChannelHeartbeatTypeAdvanced extends AbstractUdpHandleChannelHeartbeatTypeAdvanced<NettyProxyMsg> {
 
     /**

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpChannelTransferTypeAdvancedHandleDistribute.java

@@ -5,11 +5,13 @@ import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeServicePermeateClientTransferTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -17,6 +19,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_TRANSFER
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpChannelTransferTypeAdvancedHandleDistribute extends AbstractHandleUdpDistributeServicePermeateClientTransferTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpClientChannelActiveAdvanced.java

@@ -3,14 +3,17 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import io.netty.channel.Channel;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.common.ChannelContext;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpClientChannelActiveAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * 客户端通道 is active
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public class ClientHandleUdpClientChannelActiveAdvanced extends AbstractHandleUdpClientChannelActiveAdvanced<NettyProxyMsg> {
     private final NettyClientProperties nettyClientProperties;
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientPermeateClientCloseTypeAdvanced.java

@@ -2,12 +2,14 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyVisitorPortContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientPermeateClientCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorSocket;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -15,6 +17,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorS
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientPermeateClientCloseTypeAdvanced extends AbstractHandleUdpDistributeClientPermeateClientCloseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientPermeateClientInitTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.socket.NettyUdpClientPermeateClientVisitorSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientPermeateClientInitTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -20,6 +22,7 @@ import java.util.List;
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientPermeateClientInitTypeAdvanced extends AbstractHandleUdpDistributeClientPermeateClientInitTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced.java

@@ -3,11 +3,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -15,6 +17,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced extends AbstractHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientPermeateServerCloseTypeAdvanced.java

@@ -2,12 +2,14 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyVisitorPortContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientPermeateServerCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorSocket;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -15,6 +17,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorS
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientPermeateServerCloseTypeAdvanced extends AbstractHandleUdpDistributeClientPermeateServerCloseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientPermeateServerInitTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.socket.NettyUdpClientPermeateServerVisitorSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientPermeateServerInitTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.TcpMessageTypeEnums;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -20,6 +22,7 @@ import java.util.List;
  *
  * @see TcpMessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientPermeateServerInitTypeAdvanced extends AbstractHandleUdpDistributeClientPermeateServerInitTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced.java

@@ -3,11 +3,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -15,6 +17,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced extends AbstractHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientPermeateServerTransferTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientPermeateServerTransferTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -16,6 +18,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_TRANSFER
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientPermeateServerTransferTypeAdvanced extends AbstractHandleUdpDistributeClientPermeateServerTransferTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java

@@ -4,10 +4,12 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.socket.NettyUdpClientPermeateClientRealSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -20,6 +22,7 @@ import java.util.List;
  *
  * @see MessageTypeEnums#UDP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelOption;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -17,6 +19,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced extends AbstractHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientTransferClientRequestTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientTransferClientRequestTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -17,6 +19,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientTransferClientRequestTypeAdvanced extends AbstractHandleUdpDistributeClientTransferClientRequestTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java

@@ -6,11 +6,13 @@ import io.netty.channel.ChannelOption;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.handler.NettyUdpClientPermeateServerVisitorHandler;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.socket.NettyUdpClientPermeateServerVisitorTransferSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -20,6 +22,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeConnectSuccessNotificationTypeAdvancedHandle.java

@@ -3,15 +3,18 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import com.alibaba.fastjson.JSONObject;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.event.ClientChangeEvent;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeConnectSuccessNotificationTypeAdvancedHandle;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 import java.util.List;
 
 /**
  * 客户端连接成功通知
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeConnectSuccessNotificationTypeAdvancedHandle extends AbstractHandleUdpDistributeConnectSuccessNotificationTypeAdvancedHandle<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeDisconnectTypeAdvancedHandle.java

@@ -3,15 +3,18 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.event.ClientChangeEvent;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeDisconnectTypeAdvancedHandle;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
  * 服务端处理客户端断开连接处理
  * TYPE_DISCONNECT
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeDisconnectTypeAdvancedHandle extends AbstractHandleUdpDistributeDisconnectTypeAdvancedHandle<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeServicePermeateClientRealConnectTypeAdvanced.java

@@ -4,10 +4,12 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.socket.NettyUdpServerPermeateClientRealSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPenetrationRealClient;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeServicePermeateClientRealConnectTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -16,6 +18,7 @@ import java.util.List;
 /**
  * 客户端创建真实代理同奥
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeServicePermeateClientRealConnectTypeAdvanced extends AbstractHandleUdpDistributeServicePermeateClientRealConnectTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java

@@ -4,11 +4,13 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeServicePermeateClientTransferClientResponseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.UdpMessageTypeEnums;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 
 /**
@@ -17,6 +19,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
  *
  * @see UdpMessageTypeEnums#UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeServicePermeateClientTransferClientResponseTypeAdvanced extends AbstractHandleUdpDistributeServicePermeateClientTransferClientResponseTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeSingleClientMessageTypeAdvanced.java

@@ -1,13 +1,16 @@
 package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.advanced;
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeSingleClientMessageTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * 接收服务端发送过来的聊天信息
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeSingleClientMessageTypeAdvanced extends AbstractHandleUdpDistributeSingleClientMessageTypeAdvanced<NettyProxyMsg> {
     /**

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java

@@ -3,12 +3,15 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelOption;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyRealIdContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced extends AbstractHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced<NettyProxyMsg> {
     /**

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeSingleClientRealCloseVisitorTypeAdvanced.java

@@ -2,11 +2,14 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.adv
 
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyCommunicationIdContext;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyRealIdContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeSingleClientRealCloseVisitorTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeSingleClientRealCloseVisitorTypeAdvanced extends AbstractHandleUdpDistributeSingleClientRealCloseVisitorTypeAdvanced<NettyProxyMsg> {
     /**

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeStagingClosedTypeAdvanced.java

@@ -1,13 +1,16 @@
 package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.advanced;
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeStagingClosedTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * 服务端下发暂存关闭消息处理
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeStagingClosedTypeAdvanced extends AbstractHandleUdpDistributeStagingClosedTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeStagingOpenedTypeAdvanced.java

@@ -1,13 +1,16 @@
 package org.framework.lazy.cloud.network.heartbeat.client.netty.permeate.udp.advanced;
 
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.permeate.udp.client.AbstractHandleUdpDistributeStagingOpenedTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * 服务端下发暂存开启消息处理
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleUdpDistributeStagingOpenedTypeAdvanced extends AbstractHandleUdpDistributeStagingOpenedTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyClientConnectionTransferSuccessfulAdvanced.java

@@ -3,10 +3,12 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.advan
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.socket.NettyHttpClientProxyClientRealSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyClientConnectionTransferSuccessfulTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -16,6 +18,7 @@ import java.util.List;
  * http 远程代理
  * 客户端：客户端远程到服务端、客户端远程到客户端
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeHttpClientProxyClientConnectionTransferSuccessfulAdvanced extends
         AbstractHandleHttpDistributeClientProxyClientConnectionTransferSuccessfulTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyClientTransferRequestAdvanced.java

@@ -3,16 +3,19 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.advan
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyClientTransferRequestTypeAdvanced;
 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.wu.framework.core.utils.ObjectUtils;
 
 /**
  * http 远程代理
  * 客户端：客户端远程到服务端、客户端远程到客户端
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeHttpClientProxyClientTransferRequestAdvanced extends
         AbstractHandleHttpDistributeClientProxyClientTransferRequestTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyServerClientRouteCloseTypeAdvanced.java

@@ -5,12 +5,13 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyServerClientRouteCloseTypeAdvanced;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyServerClientRouteTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.ClientProxyRoute;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.RouteContext;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.RouteType;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeHttpClientProxyServerClientRouteCloseTypeAdvanced extends
         AbstractHandleHttpDistributeClientProxyServerClientRouteCloseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyServerClientRouteTypeAdvanced.java

@@ -2,16 +2,19 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.advan
 
 import com.alibaba.fastjson.JSON;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyServerClientRouteTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.ClientProxyRoute;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.RouteContext;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * http 远程代理
  * 客户端：客户端远程到服务端、客户端远程到客户端
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeHttpClientProxyServerClientRouteTypeAdvanced extends
         AbstractHandleHttpDistributeClientProxyServerClientRouteTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyServerServerRouteCloseTypeAdvanced.java

@@ -5,12 +5,13 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyServerServerRouteCloseTypeAdvanced;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyServerServerRouteTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.RouteContext;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.RouteType;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.ServerProxyRoute;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeHttpClientProxyServerServerRouteCloseTypeAdvanced extends
         AbstractHandleHttpDistributeClientProxyServerServerRouteCloseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyServerServerRouteTypeAdvanced.java

@@ -2,16 +2,19 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.advan
 
 import com.alibaba.fastjson.JSON;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyServerServerRouteTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.RouteContext;
 import org.framework.lazy.cloud.network.heartbeat.protocol.route.ServerProxyRoute;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * http 远程代理
  * 客户端：客户端远程到服务端、客户端远程到客户端
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeHttpClientProxyServerServerRouteTypeAdvanced extends
         AbstractHandleHttpDistributeClientProxyServerServerRouteTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyServerTransferTypeAdvanced.java

@@ -3,15 +3,18 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.advan
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyServerTransferTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * http 远程代理
  * 客户端：客户端远程到服务端、客户端远程到客户端
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeHttpClientProxyServerTransferTypeAdvanced extends
         AbstractHandleHttpDistributeClientProxyServerTransferTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpServerProxyClientConnectionSuccessfulTypeAdvanced.java

@@ -3,15 +3,18 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.advan
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.socket.NettyHttpServerProxyClientRealSocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeServerProxyClientConnectionSuccessfulTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
 import java.util.List;
 
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeHttpServerProxyClientConnectionSuccessfulTypeAdvanced extends
         AbstractHandleHttpDistributeServerProxyClientConnectionSuccessfulTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpServerProxyClientTransferRequestAdvanced.java

@@ -4,15 +4,18 @@ import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.handler.NettyHttpServerProxyClientRealHandler;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeServerProxyClientTransferRequestTypeAdvanced;
 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.wu.framework.core.utils.ObjectUtils;
 
 /**
  * @see NettyHttpServerProxyClientRealHandler
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeHttpServerProxyClientTransferRequestAdvanced extends
         AbstractHandleHttpDistributeServerProxyClientTransferRequestTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleHttpClientProxyClientTypeAdvanced.java

@@ -4,10 +4,12 @@ import io.netty.channel.Channel;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.NettyHttpClientProxyClient;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.socket.NettyHttpClientProxyClientProxySocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.AbstractHttpClientProxyClientTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -18,6 +20,7 @@ import java.util.List;
  * 客户端：客户端远程到服务端、客户端远程到客户端
  *
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public class ClientHandleHttpClientProxyClientTypeAdvanced extends
         AbstractHttpClientProxyClientTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleHttpClientProxyServerTypeAdvanced.java

@@ -4,10 +4,12 @@ import io.netty.channel.Channel;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.NettyHttpClientProxyServer;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.socket.NettyHttpClientProxyServerProxySocket;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.AbstractHttpClientProxyServerTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
@@ -17,6 +19,7 @@ import java.util.List;
  * http 远程代理
  * 客户端：客户端远程到服务端、客户端远程到客户端
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public class ClientHandleHttpClientProxyServerTypeAdvanced extends
         AbstractHttpClientProxyServerTypeAdvanced<NettyProxyMsg> {
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleHttpDistributeClientProxyClientTransferCLoseTypeAdvanced.java

@@ -2,15 +2,18 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.advan
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyClientTransferCLoseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
 /**
  * http 远程代理
  * 客户端：客户端远程到服务端、客户端远程到客户端
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleHttpDistributeClientProxyClientTransferCLoseTypeAdvanced extends
         AbstractHandleHttpDistributeClientProxyClientTransferCLoseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleHttpDistributeClientProxyClientTransferResponseTypeAdvanced.java

@@ -3,16 +3,19 @@ package org.framework.lazy.cloud.network.heartbeat.client.netty.proxy.http.advan
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.http.client.AbstractHandleHttpDistributeClientProxyClientTransferResponseTypeAdvanced;
 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.wu.framework.core.utils.ObjectUtils;
 
 /**
  * http 远程代理
  * 客户端：客户端远程到服务端、客户端远程到客户端
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleHttpDistributeClientProxyClientTransferResponseTypeAdvanced extends
         AbstractHandleHttpDistributeClientProxyClientTransferResponseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyClientConnectionTransferFailAdvanced.java

@@ -5,8 +5,10 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyC
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyClientConnectionTransferFailTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyServerConnectionTransferFailTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyClientConnectionTransferFailAdvanced extends
         AbstractHandleSocksDistributeClientProxyClientConnectionTransferFailTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyClientConnectionTransferSuccessfulAdvanced.java

@@ -15,8 +15,10 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.cl
 import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
 import org.framework.lazy.cloud.network.heartbeat.protocol.handler.NettySocks5CommandRequestHandler;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyClientConnectionTransferSuccessfulAdvanced extends
         AbstractHandleSocksDistributeClientProxyClientConnectionTransferSuccessTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyClientOtherConnectionTransferAdvanced.java

@@ -10,12 +10,14 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyC
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyClientOtherConnectionTransferTypeAdvanced;
 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.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
 import java.util.List;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyClientOtherConnectionTransferAdvanced extends
         AbstractHandleSocksDistributeClientProxyClientOtherConnectionTransferTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyClientTransferCloseAdvanced.java

@@ -9,9 +9,11 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyC
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyClientTransferCloseTypeAdvanced;
 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.wu.framework.core.utils.ObjectUtils;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyClientTransferCloseAdvanced extends
         AbstractHandleSocksDistributeClientProxyClientTransferCloseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyClientTransferTransferRequestAdvanced.java

@@ -8,12 +8,12 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyP
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyClientTransferRequestTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyClientTransferResponseTypeAdvanced;
 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.wu.framework.core.utils.ObjectUtils;
 
 
-/**
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
- * @see 
- */
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyClientTransferTransferRequestAdvanced extends
         AbstractHandleSocksDistributeClientProxyClientTransferRequestTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyClientTransferTransferResponseAdvanced.java

@@ -8,9 +8,11 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyP
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyClientTransferResponseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyServerTransferResponseTypeAdvanced;
 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.wu.framework.core.utils.ObjectUtils;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyClientTransferTransferResponseAdvanced extends
         AbstractHandleSocksDistributeClientProxyClientTransferResponseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyServerConnectionTransferFailAdvanced.java

@@ -4,8 +4,10 @@ import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyServerConnectionTransferFailTypeAdvanced;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyServerConnectionTransferFailAdvanced extends
         AbstractHandleSocksDistributeClientProxyServerConnectionTransferFailTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyServerConnectionTransferSuccessfulAdvanced.java

@@ -13,8 +13,10 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.cl
 import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
 import org.framework.lazy.cloud.network.heartbeat.protocol.handler.NettySocks5CommandRequestHandler;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyServerConnectionTransferSuccessfulAdvanced extends
         AbstractHandleSocksDistributeClientProxyServerConnectionTransferSuccessTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyServerTransferCloseAdvanced.java

@@ -6,8 +6,10 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyC
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyServerTransferCloseTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.context.annotation.Role;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyServerTransferCloseAdvanced extends
         AbstractHandleSocksDistributeClientProxyServerTransferCloseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleDistributeSocksClientProxyServerTransferTransferResponseAdvanced.java

@@ -7,9 +7,11 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyC
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocksDistributeClientProxyServerTransferResponseTypeAdvanced;
 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.wu.framework.core.utils.ObjectUtils;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 public class ClientHandleDistributeSocksClientProxyServerTransferTransferResponseAdvanced extends
         AbstractHandleSocksDistributeClientProxyServerTransferResponseTypeAdvanced<NettyProxyMsg> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleNettySocketProtocolHandleSocketClientProxyClientStartTypeAdvanced.java

@@ -12,13 +12,15 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyP
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettySocketChannelContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocketClientProxyClientStartTypeAdvanced;
 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;
 import org.wu.framework.spring.utils.SpringContextHolder;
 
 import java.util.ArrayList;
 import java.util.List;
 
-
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ClientHandleNettySocketProtocolHandleSocketClientProxyClientStartTypeAdvanced

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/socks/advanced/ClientHandleNettySocketProtocolHandleSocketClientProxyServerStartTypeAdvanced.java

@@ -12,6 +12,8 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyP
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettySocketChannelContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.client.AbstractHandleSocketClientProxyServerStartTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.constant.ProxyMessageType;
+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;
 
@@ -19,8 +21,9 @@ import java.util.ArrayList;
 import java.util.List;
 
 /**
- * @see ProxyMessageType#SOCKET_CLIENT_PROXY_SERVER_
+ * @see ProxyMessageType#SOCKS_CLIENT_PROXY_SERVER_
  */
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 @Slf4j
 @Component
 public class ClientHandleNettySocketProtocolHandleSocketClientProxyServerStartTypeAdvanced

wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/proxy/socks/AbstractHandleSocketLocalProxyTypeAdvanced.java

@@ -16,6 +16,6 @@ public abstract class AbstractHandleSocketLocalProxyTypeAdvanced<MSG> extends Ab
      */
     @Override
     protected boolean doSupport(NettyProxyMsg nettyProxyMsg) {
-        return ProxyMessageTypeEnums.SOCKET_LOCAL_PROXY.getTypeByte() == nettyProxyMsg.getType();
+        return ProxyMessageTypeEnums.SOCKS_LOCAL_PROXY.getTypeByte() == nettyProxyMsg.getType();
     }
 }

wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/proxy/socks/client/AbstractHandleSocketClientProxyClientStartTypeAdvanced.java

@@ -16,6 +16,6 @@ public abstract class AbstractHandleSocketClientProxyClientStartTypeAdvanced<MSG
      */
     @Override
     protected boolean doSupport(NettyProxyMsg nettyProxyMsg) {
-        return ProxyMessageTypeEnums.SOCKET_CLIENT_PROXY_CLIENT_.getTypeByte() == nettyProxyMsg.getType();
+        return ProxyMessageTypeEnums.SOCKS_CLIENT_PROXY_CLIENT_.getTypeByte() == nettyProxyMsg.getType();
     }
 }

wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/proxy/socks/client/AbstractHandleSocketClientProxyServerStartTypeAdvanced.java

@@ -16,6 +16,6 @@ public abstract class AbstractHandleSocketClientProxyServerStartTypeAdvanced<MSG
      */
     @Override
     protected boolean doSupport(NettyProxyMsg nettyProxyMsg) {
-        return ProxyMessageTypeEnums.SOCKET_CLIENT_PROXY_SERVER_.getTypeByte() == nettyProxyMsg.getType();
+        return ProxyMessageTypeEnums.SOCKS_CLIENT_PROXY_SERVER_.getTypeByte() == nettyProxyMsg.getType();
     }
 }

wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/proxy/socks/server/AbstractHandleSocksServerProxyClientTypeAdvanced.java

@@ -0,0 +1,21 @@
+package org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.server;
+
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.AbstractHandleChannelTypeAdvanced;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
+import org.framework.lazy.cloud.network.heartbeat.common.enums.ProxyMessageTypeEnums;
+
+public abstract class AbstractHandleSocksServerProxyClientTypeAdvanced<MSG> extends AbstractHandleChannelTypeAdvanced<NettyProxyMsg> implements HandleChannelTypeAdvanced {
+
+
+    /**
+     * 是否支持当前类型
+     *
+     * @param nettyProxyMsg 通道数据
+     * @return 布尔类型 是、否
+     */
+    @Override
+    protected boolean doSupport(NettyProxyMsg nettyProxyMsg) {
+        return ProxyMessageTypeEnums.SOCKS_SERVER_PROXY_CLIENT_.getTypeByte() == nettyProxyMsg.getType();
+    }
+}

wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/constant/ProxyMessageType.java

@@ -131,20 +131,20 @@ public class ProxyMessageType {
     /**
      * socket 本地代理
      *
-     * @see ProxyMessageTypeEnums#SOCKET_LOCAL_PROXY
+     * @see ProxyMessageTypeEnums#SOCKS_LOCAL_PROXY
      * @see AbstractHandleSocketLocalProxyTypeAdvanced
      */
-    public static final byte SOCKET_LOCAL_PROXY = HTTP_REPORT_SERVER_PROXY_CLIENT_TRANSFER_CLOSE_ + 1;
+    public static final byte SOCKS_LOCAL_PROXY = HTTP_REPORT_SERVER_PROXY_CLIENT_TRANSFER_CLOSE_ + 1;
 
 
 
     /**
      * socket 客户端代理服务端
      *
-     * @see ProxyMessageTypeEnums#SOCKET_CLIENT_PROXY_SERVER_
+     * @see ProxyMessageTypeEnums#SOCKS_CLIENT_PROXY_SERVER_
      * @see AbstractHandleSocketClientProxyServerStartTypeAdvanced
      */
-    public static final byte SOCKET_CLIENT_PROXY_SERVER_ = SOCKET_LOCAL_PROXY + 1;
+    public static final byte SOCKS_CLIENT_PROXY_SERVER_ = SOCKS_LOCAL_PROXY + 1;
 
 
     /**
@@ -153,7 +153,7 @@ public class ProxyMessageType {
      * @see ProxyMessageTypeEnums#SOCKS_REPORT_CLIENT_PROXY_SERVER_TRANSFER_CONNECTION_
      * @see AbstractHandleSocksReportClientProxyServerConnectionTransferTypeAdvanced
      */
-    public static final byte SOCKS_REPORT_CLIENT_PROXY_SERVER_TRANSFER_CONNECTION_ = SOCKET_CLIENT_PROXY_SERVER_ + 1;
+    public static final byte SOCKS_REPORT_CLIENT_PROXY_SERVER_TRANSFER_CONNECTION_ = SOCKS_CLIENT_PROXY_SERVER_ + 1;
 
 
 
@@ -184,10 +184,10 @@ public class ProxyMessageType {
     /**
      * socket 客户端代理客户端
      *
-     * @see ProxyMessageTypeEnums#SOCKET_CLIENT_PROXY_CLIENT_
+     * @see ProxyMessageTypeEnums#SOCKS_CLIENT_PROXY_CLIENT_
      * @see AbstractHandleSocketClientProxyClientStartTypeAdvanced
      */
-    public static final byte SOCKET_CLIENT_PROXY_CLIENT_ = SOCKS_REPORT_CLIENT_PROXY_SERVER_TRANSFER_CLOSE_ + 1;
+    public static final byte SOCKS_CLIENT_PROXY_CLIENT_ = SOCKS_REPORT_CLIENT_PROXY_SERVER_TRANSFER_CLOSE_ + 1;
 
 
     /**
@@ -196,7 +196,7 @@ public class ProxyMessageType {
      * @see ProxyMessageTypeEnums#SOCKS_REPORT_CLIENT_PROXY_CLIENT_TRANSFER_CONNECTION_
      * @see AbstractHandleSocksReportClientProxyClientConnectionTransferTypeAdvanced
      */
-    public static final byte SOCKS_REPORT_CLIENT_PROXY_CLIENT_TRANSFER_CONNECTION_ = SOCKET_CLIENT_PROXY_CLIENT_ + 1;
+    public static final byte SOCKS_REPORT_CLIENT_PROXY_CLIENT_TRANSFER_CONNECTION_ = SOCKS_CLIENT_PROXY_CLIENT_ + 1;
 
 
     /**
@@ -238,10 +238,12 @@ public class ProxyMessageType {
     /**
      * socket 服务端代理客户端
      *
-     * @see ProxyMessageTypeEnums#SOCKET_SERVER_PROXY_CLIENT_
+     * @see ProxyMessageTypeEnums#SOCKS_SERVER_PROXY_CLIENT_
-     * @see AbstractHandleSocketServerProxyClientTypeAdvanced
+     * @see AbstractHandleSocksServerProxyClientTypeAdvanced
      */
-    public static final byte SOCKET_SERVER_PROXY_CLIENT_ = SOCKS_REPORT_CLIENT_PROXY_CLIENT_TRANSFER_CLOSE_ + 1;
+    public static final byte SOCKS_SERVER_PROXY_CLIENT_ = SOCKS_REPORT_CLIENT_PROXY_CLIENT_TRANSFER_CLOSE_ + 1;
+
+
 
 
     public static final byte HTTP_DISTRIBUTE_PROXY = -96;

wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/enums/ProxyMessageTypeEnums.java

@@ -168,21 +168,21 @@ public enum ProxyMessageTypeEnums {
      * socket本地代理
      *  @see AbstractHandleSocketLocalProxyTypeAdvanced
      */
-    SOCKET_LOCAL_PROXY(ProxyMessageType.SOCKET_LOCAL_PROXY, "socket本地代理"),
+    SOCKS_LOCAL_PROXY(ProxyMessageType.SOCKS_LOCAL_PROXY, "socket本地代理"),
     /**
      * socket 客户端代理客户端
      *
-     * @see ProxyMessageTypeEnums#SOCKET_CLIENT_PROXY_CLIENT_
+     * @see ProxyMessageTypeEnums#SOCKS_CLIENT_PROXY_CLIENT_
      * @see AbstractHandleSocketClientProxyClientStartTypeAdvanced
      */
-    SOCKET_CLIENT_PROXY_CLIENT_(ProxyMessageType.SOCKET_CLIENT_PROXY_CLIENT_, "socket 客户端代理客户端"),
+    SOCKS_CLIENT_PROXY_CLIENT_(ProxyMessageType.SOCKS_CLIENT_PROXY_CLIENT_, "socket 客户端代理客户端"),
     /**
      * socket 客户端代理服务端
      *
-     * @see ProxyMessageTypeEnums#SOCKET_CLIENT_PROXY_SERVER_
+     * @see ProxyMessageTypeEnums#SOCKS_CLIENT_PROXY_SERVER_
      * @see AbstractHandleSocketClientProxyServerStartTypeAdvanced
      */
-    SOCKET_CLIENT_PROXY_SERVER_(ProxyMessageType.SOCKET_CLIENT_PROXY_SERVER_, "socket 客户端代理服务端"),
+    SOCKS_CLIENT_PROXY_SERVER_(ProxyMessageType.SOCKS_CLIENT_PROXY_SERVER_, "socket 客户端代理服务端"),
 
     /**
      * socket 上报客户端代理服务端传输通道连接成功
@@ -319,10 +319,10 @@ public enum ProxyMessageTypeEnums {
     /**
      * socket 服务端代理客户端
      *
-     * @see ProxyMessageTypeEnums#SOCKET_SERVER_PROXY_CLIENT_
+     * @see ProxyMessageTypeEnums#SOCKS_SERVER_PROXY_CLIENT_
-     * @see AbstractHandleSocketServerProxyClientTypeAdvanced
+     * @see AbstractHandleSocksServerProxyClientTypeAdvanced
      */
-    SOCKET_SERVER_PROXY_CLIENT_(ProxyMessageType.SOCKET_SERVER_PROXY_CLIENT_, "socket 服务端代理客户端"),
+    SOCKS_SERVER_PROXY_CLIENT_(ProxyMessageType.SOCKS_SERVER_PROXY_CLIENT_, "socket 服务端代理客户端"),
 
 
     ;

wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocks5CommandRequestHandler.java

@@ -66,22 +66,22 @@ public class NettySocks5CommandRequestHandler extends SimpleChannelInboundHandle
 
 
             if(ObjectUtils.isEmpty(route)){
-                proxyMsg.setType(ProxyMessageType.SOCKET_LOCAL_PROXY);
+                proxyMsg.setType(ProxyMessageType.SOCKS_LOCAL_PROXY);
             }else {
                 if(RouteType.LOCAL.equals(route.getRouteType())){
-                    proxyMsg.setType(ProxyMessageType.SOCKET_LOCAL_PROXY);
+                    proxyMsg.setType(ProxyMessageType.SOCKS_LOCAL_PROXY);
                 }else if (RouteType.CLIENT_PROXY_CLIENT.equals(route.getRouteType())){
                     ClientProxyRoute clientProxyRoute= (ClientProxyRoute) route;
                     String clientId = clientProxyRoute.getTargetClientId();
                     proxyMsg.setClientId(clientId);
-                    proxyMsg.setType(ProxyMessageType.SOCKET_CLIENT_PROXY_CLIENT_);
+                    proxyMsg.setType(ProxyMessageType.SOCKS_CLIENT_PROXY_CLIENT_);
                 }else if (RouteType.CLIENT_PROXY_SEVER.equals(route.getRouteType())){
-                    proxyMsg.setType(ProxyMessageType.SOCKET_CLIENT_PROXY_SERVER_);
+                    proxyMsg.setType(ProxyMessageType.SOCKS_CLIENT_PROXY_SERVER_);
                 }else if (RouteType.SERVER_PROXY_CLIENT.equals(route.getRouteType())){
                     ClientProxyRoute clientProxyRoute= (ClientProxyRoute) route;
                     String clientId = clientProxyRoute.getTargetClientId();
                     proxyMsg.setClientId(clientId);
-                    proxyMsg.setType(ProxyMessageType.SOCKET_SERVER_PROXY_CLIENT_);
+                    proxyMsg.setType(ProxyMessageType.SOCKS_SERVER_PROXY_CLIENT_);
                 }
             }
 

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/config/ServerAutoConfiguration.java

@@ -289,6 +289,10 @@ public class ServerAutoConfiguration {
             return new ServerHandleSocksReportClientProxyClientTransferResponseTypeAdvanced();
         }
 
+        @Bean
+        public ServerHandleSocksServerProxyClientTypeAdvanced serverHandleSocksServerProxyClientTypeAdvanced() {
+            return new ServerHandleSocksServerProxyClientTypeAdvanced();
+        }
 
     }
 }

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/proxy/socks/advanced/ServerHandleSocksServerProxyClientTypeAdvanced.java

@@ -0,0 +1,123 @@
+package org.framework.lazy.cloud.network.heartbeat.server.netty.proxy.socks.advanced;
+
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.*;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.codec.socksx.v5.DefaultSocks5CommandResponse;
+import io.netty.handler.codec.socksx.v5.Socks5AddressType;
+import io.netty.handler.codec.socksx.v5.Socks5CommandStatus;
+import lombok.extern.slf4j.Slf4j;
+import org.framework.lazy.cloud.network.heartbeat.common.ChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.NettyTransferChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyChannelContext;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.payload.NettyProxyMsg;
+import org.framework.lazy.cloud.network.heartbeat.common.advanced.proxy.socks.server.AbstractHandleSocksServerProxyClientTypeAdvanced;
+import org.framework.lazy.cloud.network.heartbeat.common.constant.ProxyMessageType;
+import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder;
+import org.framework.lazy.cloud.network.heartbeat.common.factory.EventLoopGroupFactory;
+import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.framework.lazy.cloud.network.heartbeat.server.netty.proxy.socks.handler.NettySocksClientProxyServerRealHandler;
+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;
+
+import java.net.InetSocketAddress;
+
+
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
+@Slf4j
+@Component
+public class ServerHandleSocksServerProxyClientTypeAdvanced
+        extends AbstractHandleSocksServerProxyClientTypeAdvanced<NettyProxyMsg> {
+
+
+    /**
+     * 处理当前数据
+     *
+     * @param nettyChannelContext 当前通道
+     * @param nettyProxyMsg       通道数据
+     */
+    @Override
+    public void doHandler(NettyChannelContext nettyChannelContext, NettyProxyMsg nettyProxyMsg) {
+        Channel transferChannel = nettyChannelContext.channel();
+
+        String host = nettyProxyMsg.getTargetIpString();
+        Integer port = Integer.parseInt(nettyProxyMsg.getTargetPortString());
+        byte[] data = nettyProxyMsg.getData();
+        byte[] visitorId = nettyProxyMsg.getVisitorId();
+        byte[] targetClientId = nettyProxyMsg.getClientId();
+        String msgVisitorId = new String(visitorId);
+        ChannelAttributeKeyUtils.buildClientId(transferChannel, targetClientId);
+        ChannelAttributeKeyUtils.buildVisitorId(transferChannel, msgVisitorId);
+
+        NettyTransferChannelContext.pushVisitor(transferChannel, msgVisitorId);
+
+        // 客户端连接客户端传输通道
+        Channel loadBalance = ChannelContext.getLoadBalance(targetClientId);
+        if(ObjectUtils.isNotEmpty(loadBalance)) {
+            // 下发创建新链接指令
+            NettyProxyMsg otherClientConnectServer = new NettyProxyMsg();
+            otherClientConnectServer.setData(data);
+            otherClientConnectServer.setClientTargetIp(host);
+            otherClientConnectServer.setClientTargetPort(port);
+            otherClientConnectServer.setVisitorId(visitorId);
+            otherClientConnectServer.setClientId(targetClientId);
+            otherClientConnectServer.setType(ProxyMessageType.SOCKS_DISTRIBUTE_CLIENT_PROXY_CLIENT_OTHER_TRANSFER_CONNECTION_);
+            loadBalance.writeAndFlush(otherClientConnectServer);
+
+        }else {
+            log.error("无法通过客户端ID获取当前客户端通道");
+        }
+
+
+
+
+        Socks5AddressType socks5AddressType = Socks5AddressType.valueOf(data[0]);
+
+        // 创建真实代理链接
+        EventLoopGroup group = EventLoopGroupFactory.createClientWorkGroup();
+        Bootstrap b = new Bootstrap();
+        b.group(group)
+                .channel(NioSocketChannel.class)
+                .option(ChannelOption.TCP_NODELAY, true)
+                .handler(new ChannelInitializer<SocketChannel>() {
+                    @Override
+                    protected void initChannel(SocketChannel ch) {
+                        ch.pipeline().addLast(new TransferDecoder(Integer.MAX_VALUE, 1024 * 1024 * 10));
+                        ch.pipeline().addLast(new NettySocksClientProxyServerRealHandler());
+                    }
+                });
+        log.info("准备连接目标服务器，ip = {},port = {}", host, port);
+        ChannelFuture f = b.connect(new InetSocketAddress(host, port));
+        f.addListener((ChannelFutureListener) future -> {
+            Channel realChannel = future.channel();
+            if (future.isSuccess()) {
+
+                log.info("目标服务器连接成功");
+                // 通道相互绑定
+                ChannelAttributeKeyUtils.buildNextChannel(transferChannel, realChannel);
+                ChannelAttributeKeyUtils.buildNextChannel(realChannel, transferChannel);
+
+                // 传输通道连接成功下发
+                NettyProxyMsg transferNettyProxyMsg = new NettyProxyMsg();
+
+                transferNettyProxyMsg.setType(ProxyMessageType.SOCKS_DISTRIBUTE_CLIENT_PROXY_CLIENT_TRANSFER_CONNECTION_SUCCESS_);
+                transferChannel.writeAndFlush(transferNettyProxyMsg);
+
+            } else {
+                log.error("连接目标服务器失败,address={},port={}", host, port);
+                DefaultSocks5CommandResponse commandResponse = new DefaultSocks5CommandResponse(Socks5CommandStatus.FAILURE, socks5AddressType);
+                transferChannel.writeAndFlush(commandResponse);
+                realChannel.close();
+            }
+
+        });
+
+        // TODO 下发 连接真实服务成功、客户端可以采集数据了
+
+    }
+
+}