From ddaa5568e0bad04c91dc4ba31134eb8863214f6f Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Fri, 13 Dec 2024 13:26:15 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=20=20=E4=BC=98=E5=8C=96tcp=E6=9E=B6?= =?UTF-8?q?=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ServerHandleTcpClientConnectSuccessTypeAdvanced.java | 3 +++ ...erHandleTcpReportClientPermeateClientCloseTypeAdvanced.java | 3 +++ ...TcpReportClientPermeateClientTransferCloseTypeAdvanced.java | 3 +++ ...TcpReportClientPermeateServerTransferCloseTypeAdvanced.java | 3 +++ ...andleTcpReportClientPermeateServerTransferTypeAdvanced.java | 3 +++ ...rClientPermeateChannelConnectionSuccessfulTypeAdvanced.java | 3 +++ ...ransferClientPermeateChannelInitSuccessfulTypeAdvanced.java | 3 +++ ...andleTcpReportClientTransferClientResponseTypeAdvanced.java | 3 +++ .../ServerHandleTcpReportClientTransferClientTypeAdvanced.java | 3 +++ ...rServerPermeateChannelConnectionSuccessfulTypeAdvanced.java | 3 +++ .../ServerHandleTcpReportClusterNodeRegisterTypeAdvanced.java | 3 +++ .../advanced/ServerHandleTcpReportDisconnectTypeAdvanced.java | 3 +++ ...TcpReportServicePermeateClientCloseVisitorTypeAdvanced.java | 3 +++ ...eTcpReportServicePermeateClientRealConnectTypeAdvanced.java | 3 +++ ...ndleTcpReportServicePermeateClientTransferTypeAdvanced.java | 3 +++ .../ServerHandleTcpReportStagingClosedTypeAdvanced.java | 3 +++ .../ServerHandleTcpReportStagingOpenedTypeAdvanced.java | 3 +++ .../ServerTcpTcpHandleChannelHeartbeatTypeAdvanced.java | 3 +++ 18 files changed, 54 insertions(+) diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpClientConnectSuccessTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpClientConnectSuccessTypeAdvanced.java index b69e5fb..fbd15c8 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpClientConnectSuccessTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpClientConnectSuccessTypeAdvanced.java @@ -17,6 +17,8 @@ import org.framework.lazy.cloud.network.heartbeat.server.standalone.application. import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateClientMappingDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateServerMappingDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import org.wu.framework.web.response.Result; @@ -28,6 +30,7 @@ import java.util.List; * 服务端连接成功处理 * REPORT_CLIENT_CONNECT_SUCCESS */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpClientConnectSuccessTypeAdvanced extends AbstractHandleTcpClientConnectSuccessTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientCloseTypeAdvanced.java index 25ce4a8..4788ffc 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientCloseTypeAdvanced.java @@ -5,11 +5,14 @@ import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientPermeateClientCloseTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; /** * 上报 客户端渗透客户端init close 信息 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportClientPermeateClientCloseTypeAdvanced extends AbstractHandleTcpReportClientPermeateClientCloseTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced.java index 1e645f3..808efa8 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced.java @@ -6,11 +6,14 @@ import org.framework.lazy.cloud.network.heartbeat.common.MessageType; import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; /** * 上报客户端渗透客户端通信通道关闭 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced extends AbstractHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced.java index 2b45eb4..b905426 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced.java @@ -5,11 +5,14 @@ import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; /** * 上报 客户端渗透服务端通信通道关闭 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced extends AbstractHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferTypeAdvanced.java index bc5602e..0da5093 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientPermeateServerTransferTypeAdvanced.java @@ -10,12 +10,15 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerChannelFlow; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; /** * 上报 客户端渗透服务端通信 * REPORT_CLIENT_PERMEATE_SERVER_TRANSFER */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportClientPermeateServerTransferTypeAdvanced extends AbstractHandleTcpReportClientPermeateServerTransferTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java index 7c40976..6eacc75 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -5,11 +5,14 @@ import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.*; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; /** * 上报 客户端渗透客户端数据传输通道连接成功 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java index 8b1547a..0e92c58 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java @@ -7,11 +7,14 @@ import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; import org.framework.lazy.cloud.network.heartbeat.common.NettyTransferChannelContext; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; /** * 上报 客户端渗透客户端数据传输通道init */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced extends AbstractHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientResponseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientResponseTypeAdvanced.java index 5d03445..325ca3f 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientResponseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientResponseTypeAdvanced.java @@ -9,12 +9,15 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerChannelFlow; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import org.wu.framework.spring.utils.SpringContextHolder; /** * 上报客户端渗透客户端数据传输结果 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportClientTransferClientResponseTypeAdvanced extends AbstractHandleTcpReportClientTransferClientResponseTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientTypeAdvanced.java index fba1727..df34e8c 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferClientTypeAdvanced.java @@ -9,12 +9,15 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerChannelFlow; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import org.wu.framework.spring.utils.SpringContextHolder; /** * 上报客户端渗透客户端数据传输 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportClientTransferClientTypeAdvanced extends AbstractHandleTcpReportClientTransferClientTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java index 5db3a48..8105e72 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -5,11 +5,14 @@ import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; import org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.socket.NettyClientPermeateServerConnectRealSocket; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; /** * 上报客户端通信通道连接成功 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Component public class ServerHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced { /** diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClusterNodeRegisterTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClusterNodeRegisterTypeAdvanced.java index f11dbc7..be4a83a 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClusterNodeRegisterTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportClusterNodeRegisterTypeAdvanced.java @@ -5,12 +5,15 @@ import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.AbstractHandleTcpReportClusterNodeRegisterTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.server.cluster.application.LazyNettyClusterNodeApplication; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import org.wu.framework.bean.factory.BeanContext; /** * 集群节点注册 服务端本地处理 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportClusterNodeRegisterTypeAdvanced extends diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportDisconnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportDisconnectTypeAdvanced.java index 23a6e45..d86cc57 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportDisconnectTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportDisconnectTypeAdvanced.java @@ -12,6 +12,8 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK import org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.socket.NettyServerPermeateClientVisitorSocket; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyClientStatsChangeApplication; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.LazyNettyClientLoginCommand; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import org.wu.framework.core.utils.ObjectUtils; @@ -23,6 +25,7 @@ import java.util.List; * 服务端处理客户端断开连接处理 * TYPE_DISCONNECT */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportDisconnectTypeAdvanced extends AbstractHandleTcpReportDisconnectTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced.java index 4c1dc06..a5f2642 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced.java @@ -2,6 +2,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.advanced; import io.netty.channel.Channel; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import org.framework.lazy.cloud.network.heartbeat.common.NettyCommunicationIdContext; import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; @@ -11,6 +13,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs /** * 服务端处理客户端 关闭一个访客 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced extends AbstractHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced.java index 53d450b..3628c4e 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced.java @@ -3,6 +3,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.advanced; import io.netty.channel.Channel; import io.netty.channel.ChannelOption; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import org.framework.lazy.cloud.network.heartbeat.common.NettyCommunicationIdContext; import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; @@ -13,6 +15,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK /** * 服务端渗透客户端通信通道 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced extends AbstractHandleTcpReportServicePermeateClientRealConnectTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced.java index 78168d6..28174fa 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced.java @@ -12,6 +12,8 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.Abs import org.framework.lazy.cloud.network.heartbeat.common.enums.ChannelFlowEnum; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; import org.framework.lazy.cloud.network.heartbeat.server.netty.flow.ServerChannelFlow; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; @@ -19,6 +21,7 @@ import org.springframework.stereotype.Component; * 服务端处理客户端数据传输 * REPORT_CLIENT_TRANSFER */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced extends AbstractHandleTcpReportServicePermeateClientTransferTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingClosedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingClosedTypeAdvanced.java index 9cc9c7d..6844f71 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingClosedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingClosedTypeAdvanced.java @@ -5,6 +5,8 @@ import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyClientStatsChangeApplication; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.LazyNettyClientLoginCommand; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import org.framework.lazy.cloud.network.heartbeat.common.ChannelContext; import org.framework.lazy.cloud.network.heartbeat.common.MessageType; @@ -17,6 +19,7 @@ import java.util.List; /** * 服务端处理上报的暂存关闭 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportStagingClosedTypeAdvanced extends AbstractHandleTcpReportStagingClosedTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingOpenedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingOpenedTypeAdvanced.java index a4c3986..ab87199 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingOpenedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerHandleTcpReportStagingOpenedTypeAdvanced.java @@ -10,6 +10,8 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.NettyClientStatus import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyClientStatsChangeApplication; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.state.LazyNettyClientLoginCommand; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import java.nio.charset.StandardCharsets; @@ -18,6 +20,7 @@ import java.util.List; /** * 服务端处理上报的暂存开启 */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Slf4j @Component public class ServerHandleTcpReportStagingOpenedTypeAdvanced extends AbstractHandleTcpReportStagingOpenedTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerTcpTcpHandleChannelHeartbeatTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerTcpTcpHandleChannelHeartbeatTypeAdvanced.java index fd858b1..be3040e 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerTcpTcpHandleChannelHeartbeatTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/advanced/ServerTcpTcpHandleChannelHeartbeatTypeAdvanced.java @@ -3,6 +3,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.netty.tcp.advanced; import io.netty.channel.Channel; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.AbstractTcpHandleChannelHeartbeatTypeAdvanced; +import org.springframework.beans.factory.config.BeanDefinition; +import org.springframework.context.annotation.Role; import org.springframework.stereotype.Component; import org.framework.lazy.cloud.network.heartbeat.common.MessageType; import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; @@ -12,6 +14,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg; * 服务端 处理客户端心跳 * TYPE_HEARTBEAT */ +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Component public class ServerTcpTcpHandleChannelHeartbeatTypeAdvanced extends AbstractTcpHandleChannelHeartbeatTypeAdvanced {