From 0ceb88bfe3e513057a173a27ab1f1882da00f171 Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Fri, 13 Dec 2024 14:30:38 +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 --- ...AdvancedHandleDistributeTcpDistribute.java | 2 +- ...rmeateServerTransferCloseTypeAdvanced.java | 2 +- ...ClientPermeateClientCloseTypeAdvanced.java | 2 +- ...eClientPermeateClientInitTypeAdvanced.java | 2 +- ...rmeateClientTransferCloseTypeAdvanced.java | 2 +- ...ClientPermeateServerCloseTypeAdvanced.java | 2 +- ...eClientPermeateServerInitTypeAdvanced.java | 2 +- ...entPermeateServerTransferTypeAdvanced.java | 2 +- ...annelConnectionSuccessfulTypeAdvanced.java | 2 +- ...eateChannelInitSuccessfulTypeAdvanced.java | 2 +- ...ientTransferClientRequestTypeAdvanced.java | 2 +- ...annelConnectionSuccessfulTypeAdvanced.java | 2 +- ...entTransferClientResponseTypeAdvanced.java | 2 +- .../netty/handler/NettyClientHandler.java | 2 +- .../network/heartbeat/common/MessageType.java | 100 +++++++++--------- ...ClientPermeateClientCloseTypeAdvanced.java | 4 +- ...eClientPermeateClientInitTypeAdvanced.java | 4 +- ...rmeateClientTransferCloseTypeAdvanced.java | 4 +- ...ClientPermeateServerCloseTypeAdvanced.java | 4 +- ...eClientPermeateServerInitTypeAdvanced.java | 4 +- ...rmeateServerTransferCloseTypeAdvanced.java | 4 +- ...entPermeateServerTransferTypeAdvanced.java | 4 +- ...annelConnectionSuccessfulTypeAdvanced.java | 4 +- ...eateChannelInitSuccessfulTypeAdvanced.java | 4 +- ...ientTransferClientRequestTypeAdvanced.java | 4 +- ...annelConnectionSuccessfulTypeAdvanced.java | 4 +- ...ributeClusterNodeRegisterTypeAdvanced.java | 4 +- ...SuccessNotificationTypeAdvancedHandle.java | 2 +- ...istributeDisconnectTypeAdvancedHandle.java | 4 +- ...PermeateClientRealConnectTypeAdvanced.java | 2 +- ...entTransferClientResponseTypeAdvanced.java | 4 +- ...icePermeateClientTransferTypeAdvanced.java | 4 +- ...ributeSingleClientMessageTypeAdvanced.java | 2 +- ...ClientRealAutoReadConnectTypeAdvanced.java | 4 +- ...gleClientRealCloseVisitorTypeAdvanced.java | 2 +- ...cpDistributeStagingClosedTypeAdvanced.java | 2 +- ...cpDistributeStagingOpenedTypeAdvanced.java | 2 +- ...HandleTcpReportDisconnectTypeAdvanced.java | 2 +- ...ClientPermeateClientCloseTypeAdvanced.java | 4 +- ...eClientPermeateClientInitTypeAdvanced.java | 4 +- ...rmeateClientTransferCloseTypeAdvanced.java | 4 +- ...ClientPermeateServerCloseTypeAdvanced.java | 4 +- ...eClientPermeateServerInitTypeAdvanced.java | 4 +- ...rmeateServerTransferCloseTypeAdvanced.java | 4 +- ...entPermeateServerTransferTypeAdvanced.java | 4 +- ...annelConnectionSuccessfulTypeAdvanced.java | 4 +- ...eateChannelInitSuccessfulTypeAdvanced.java | 4 +- ...ientTransferClientRequestTypeAdvanced.java | 4 +- ...annelConnectionSuccessfulTypeAdvanced.java | 4 +- ...ributeClusterNodeRegisterTypeAdvanced.java | 4 +- ...SuccessNotificationTypeAdvancedHandle.java | 2 +- ...istributeDisconnectTypeAdvancedHandle.java | 4 +- ...PermeateClientRealConnectTypeAdvanced.java | 2 +- ...entTransferClientResponseTypeAdvanced.java | 4 +- ...icePermeateClientTransferTypeAdvanced.java | 4 +- ...ributeSingleClientMessageTypeAdvanced.java | 2 +- ...ClientRealAutoReadConnectTypeAdvanced.java | 4 +- ...gleClientRealCloseVisitorTypeAdvanced.java | 2 +- ...dpDistributeStagingClosedTypeAdvanced.java | 2 +- ...dpDistributeStagingOpenedTypeAdvanced.java | 2 +- ...HandleUdpReportDisconnectTypeAdvanced.java | 2 +- .../common/enums/MessageTypeEnums.java | 46 ++++---- ...leTcpClientConnectSuccessTypeAdvanced.java | 6 +- ...rmeateClientTransferCloseTypeAdvanced.java | 2 +- ...annelConnectionSuccessfulTypeAdvanced.java | 2 +- ...eateChannelInitSuccessfulTypeAdvanced.java | 2 +- ...entTransferClientResponseTypeAdvanced.java | 2 +- ...eportClientTransferClientTypeAdvanced.java | 2 +- ...HandleTcpReportDisconnectTypeAdvanced.java | 4 +- ...dleTcpReportStagingClosedTypeAdvanced.java | 2 +- ...dleTcpReportStagingOpenedTypeAdvanced.java | 2 +- ...ttyTcpClientPermeateServerRealHandler.java | 4 +- ...TcpServerPermeateClientVisitorHandler.java | 8 +- ...ClientPermeateServerConnectRealSocket.java | 2 +- ...leUdpClientConnectSuccessTypeAdvanced.java | 6 +- ...rmeateClientTransferCloseTypeAdvanced.java | 2 +- ...annelConnectionSuccessfulTypeAdvanced.java | 2 +- ...eateChannelInitSuccessfulTypeAdvanced.java | 2 +- ...entTransferClientResponseTypeAdvanced.java | 2 +- ...eportClientTransferClientTypeAdvanced.java | 2 +- ...HandleUdpReportDisconnectTypeAdvanced.java | 4 +- ...dleUdpReportStagingClosedTypeAdvanced.java | 2 +- ...dleUdpReportStagingOpenedTypeAdvanced.java | 2 +- ...ttyUdpClientPermeateServerRealHandler.java | 4 +- ...UdpServerPermeateClientVisitorHandler.java | 8 +- ...ClientPermeateServerConnectRealSocket.java | 2 +- ...tPermeateClientMappingApplicationImpl.java | 4 +- ...tPermeateServerMappingApplicationImpl.java | 4 +- .../LazyNettyClientStateApplicationImpl.java | 2 +- .../controller/LazyChannelController.java | 4 +- 90 files changed, 210 insertions(+), 210 deletions(-) diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java index 1c15316..a7fe165 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java @@ -14,7 +14,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK /** * 服务端处理客户端数据传输 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER */ @Slf4j public class ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute extends AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java index d6b11a7..35514e6 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java @@ -12,7 +12,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK /** * 下发 客户端渗透服务端通信通道关闭 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE */ @Slf4j public class ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java index 8d20d00..bc5f425 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java @@ -13,7 +13,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorS /** * 客户端渗透客户端init close 信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE */ @Slf4j public class ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateClientCloseTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java index 62ed030..3b514a8 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java @@ -18,7 +18,7 @@ import java.util.List; /** * 客户端渗透客户端init信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT */ @Slf4j public class ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java index 35fa7a3..7ce2186 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java @@ -12,7 +12,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK /** * 下发客户端渗透客户端通信通道关闭 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE */ @Slf4j public class ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java index 678c03f..fcd7312 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java @@ -13,7 +13,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.socket.PermeateVisitorS /** * 客户端渗透服务端init close 信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE */ @Slf4j public class ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java index ea1bbc8..181999d 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java @@ -18,7 +18,7 @@ import java.util.List; /** * 客户端渗透服务端init信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT */ @Slf4j public class ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java index f293057..835172e 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java @@ -13,7 +13,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK /** * 服务端处理客户端数据传输 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER */ @Slf4j public class ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced extends AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java index 1d5cdce..675cd6e 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -19,7 +19,7 @@ import java.util.List; * 客户端渗透客户端数据传输通道连接成功 * * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ @Slf4j public class ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java index 47ee287..e73088d 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java @@ -14,7 +14,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK * 下发 客户端渗透客户端数据传输通道init 成功 * * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ @Slf4j public class ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced extends AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java index cae0d5f..a24e246 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java @@ -14,7 +14,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK * 下发客户端渗透客户端数据传输 * * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST */ @Slf4j public class ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced extends AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java index c9661c3..d2c7324 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -17,7 +17,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK * @see NettyClientPermeateServerVisitorTransferSocket * @see NettyClientPermeateServerVisitorHandler * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ @Slf4j public class ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java index 7b31122..38c36de 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java @@ -14,7 +14,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK * 下发客户端渗透客户端数据传输响应 * * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE */ @Slf4j public class ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced extends AbstractHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientHandler.java index a76aae4..4e67657 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientHandler.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientHandler.java @@ -106,7 +106,7 @@ public class NettyClientHandler extends SimpleChannelInboundHandler extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientPermeateClientCloseTypeAd */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java index d848098..7bf0cce 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透客户端init信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT */ public abstract class AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientPermeateClientInitTypeAdv */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java index a06d743..9cdbed6 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发客户端渗透客户端通信通道关闭 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE */ public abstract class AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientPermeateClientTransferClo */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java index 5c762e0..d6c8a96 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端init close 信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE */ public abstract class AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientPermeateServerCloseTypeAd */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java index 607bf1a..959f573 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端init信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT */ public abstract class AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientPermeateServerInitTypeAdv */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java index a854caf..20a079f 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端通信通道关闭 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE */ public abstract class AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientPermeateServerTransferClo */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java index 0325125..30e9c54 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端通信传输 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER */ public abstract class AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientPermeateServerTransferTyp */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java index f4cc5a0..785f05d 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透客户端数据传输通道连接成功 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ public abstract class AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientTransferClientPermeateCha */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java index bf07235..4aa6339 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透客户端数据传输通道init 成功 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ public abstract class AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientTransferClientPermeateCha */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java index bde1c53..9dfdf98 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发客户端渗透客户端数据传输 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST */ public abstract class AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientTransferClientRequestType */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java index 2cb3271..6a362aa 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端数据传输通道连接成功 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ public abstract class AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeClientTransferServerPermeateCha */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClusterNodeRegisterTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClusterNodeRegisterTypeAdvanced.java index 260e0a5..e75dda7 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClusterNodeRegisterTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeClusterNodeRegisterTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 集群注册 - * @see MessageTypeEnums#DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE */ public abstract class AbstractHandleTcpDistributeClusterNodeRegisterTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleTcpDistributeClusterNodeRegisterTypeAdvanced */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java index 82c6751..279e77c 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java @@ -18,6 +18,6 @@ public abstract class AbstractHandleTcpDistributeConnectSuccessNotificationTypeA */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle.java index 08c9e8a..e31eff1 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle.java @@ -8,7 +8,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发客户端断开连接通知 - * DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION + * TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION */ public abstract class AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -21,6 +21,6 @@ public abstract class AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleTcpDistributeServicePermeateClientTransferCl */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced.java index 89af0af..577ea2d 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 客户端处理服务端下发数据 - * DISTRIBUTE_CLIENT_TRANSFER + * TCP_DISTRIBUTE_CLIENT_TRANSFER */ public abstract class AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleTcpDistributeServicePermeateClientTransferTy */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_TRANSFER.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_TRANSFER.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientMessageTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientMessageTypeAdvanced.java index e58d95e..cae848b 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientMessageTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientMessageTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleTcpDistributeSingleClientMessageTypeAdvanced */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_SINGLE_CLIENT_MESSAGE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java index ae4dd6f..82643a5 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端代理的真实端口自动读写 * - * @see MessageTypeEnums#DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ + * @see MessageTypeEnums#TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ */ public abstract class AbstractHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleTcpDistributeSingleClientRealAutoReadConnect */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java index 58d6f57..aa3a571 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleTcpDistributeSingleClientRealCloseVisitorTyp */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeStagingClosedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeStagingClosedTypeAdvanced.java index bdffaed..e4aeabc 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeStagingClosedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeStagingClosedTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleTcpDistributeStagingClosedTypeAdvanced */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeStagingOpenedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeStagingOpenedTypeAdvanced.java index a858add..af3f981 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeStagingOpenedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/client/AbstractHandleTcpDistributeStagingOpenedTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleTcpDistributeStagingOpenedTypeAdvanced */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/server/AbstractHandleTcpReportDisconnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/server/AbstractHandleTcpReportDisconnectTypeAdvanced.java index fae972e..99f8ead 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/server/AbstractHandleTcpReportDisconnectTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/server/AbstractHandleTcpReportDisconnectTypeAdvanced.java @@ -8,7 +8,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 客户端上报断开连接通知 - * DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION + * TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION */ public abstract class AbstractHandleTcpReportDisconnectTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientCloseTypeAdvanced.java index 5088bed..055a597 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientCloseTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透客户端init close 信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE */ public abstract class AbstractHandleUdpDistributeClientPermeateClientCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientPermeateClientCloseTypeAd */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientInitTypeAdvanced.java index 9b8af5d..67f9ad3 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientInitTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透客户端init信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT */ public abstract class AbstractHandleUdpDistributeClientPermeateClientInitTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientPermeateClientInitTypeAdv */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced.java index 8e5c1b3..2123f94 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发客户端渗透客户端通信通道关闭 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE */ public abstract class AbstractHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientPermeateClientTransferClo */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerCloseTypeAdvanced.java index f2bab20..cab96ae 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerCloseTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端init close 信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE */ public abstract class AbstractHandleUdpDistributeClientPermeateServerCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientPermeateServerCloseTypeAd */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerInitTypeAdvanced.java index ecc396f..f9e44e5 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerInitTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端init信息 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT */ public abstract class AbstractHandleUdpDistributeClientPermeateServerInitTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientPermeateServerInitTypeAdv */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced.java index aef8a95..22a10f1 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端通信通道关闭 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE */ public abstract class AbstractHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientPermeateServerTransferClo */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerTransferTypeAdvanced.java index 95f814c..65e6943 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientPermeateServerTransferTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端通信传输 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER */ public abstract class AbstractHandleUdpDistributeClientPermeateServerTransferTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientPermeateServerTransferTyp */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java index b49e73d..571e8b1 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透客户端数据传输通道连接成功 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ public abstract class AbstractHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientTransferClientPermeateCha */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java index d0ca6c4..ac83a78 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透客户端数据传输通道init 成功 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ public abstract class AbstractHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientTransferClientPermeateCha */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientRequestTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientRequestTypeAdvanced.java index 728809f..feea51b 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientRequestTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferClientRequestTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发客户端渗透客户端数据传输 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST */ public abstract class AbstractHandleUdpDistributeClientTransferClientRequestTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientTransferClientRequestType */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java index 18d61b0..14a2b68 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -10,7 +10,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端渗透服务端数据传输通道连接成功 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ public abstract class AbstractHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeClientTransferServerPermeateCha */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClusterNodeRegisterTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClusterNodeRegisterTypeAdvanced.java index 933fefb..1a2e43c 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClusterNodeRegisterTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeClusterNodeRegisterTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 集群注册 - * @see MessageTypeEnums#DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE */ public abstract class AbstractHandleUdpDistributeClusterNodeRegisterTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpDistributeClusterNodeRegisterTypeAdvanced */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeConnectSuccessNotificationTypeAdvancedHandle.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeConnectSuccessNotificationTypeAdvancedHandle.java index 94fec0a..2f918cf 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeConnectSuccessNotificationTypeAdvancedHandle.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeConnectSuccessNotificationTypeAdvancedHandle.java @@ -18,6 +18,6 @@ public abstract class AbstractHandleUdpDistributeConnectSuccessNotificationTypeA */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeDisconnectTypeAdvancedHandle.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeDisconnectTypeAdvancedHandle.java index eaa11b4..ee40cf7 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeDisconnectTypeAdvancedHandle.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeDisconnectTypeAdvancedHandle.java @@ -8,7 +8,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发客户端断开连接通知 - * DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION + * TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION */ public abstract class AbstractHandleUdpDistributeDisconnectTypeAdvancedHandle extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -21,6 +21,6 @@ public abstract class AbstractHandleUdpDistributeDisconnectTypeAdvancedHandle extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -23,6 +23,6 @@ public abstract class AbstractHandleUdpDistributeServicePermeateClientTransferCl */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeServicePermeateClientTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeServicePermeateClientTransferTypeAdvanced.java index 211dcb2..f7b0334 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeServicePermeateClientTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeServicePermeateClientTransferTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 客户端处理服务端下发数据 - * DISTRIBUTE_CLIENT_TRANSFER + * TCP_DISTRIBUTE_CLIENT_TRANSFER */ public abstract class AbstractHandleUdpDistributeServicePermeateClientTransferTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpDistributeServicePermeateClientTransferTy */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_TRANSFER.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_TRANSFER.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientMessageTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientMessageTypeAdvanced.java index 47f842a..6f13197 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientMessageTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientMessageTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleUdpDistributeSingleClientMessageTypeAdvanced */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_SINGLE_CLIENT_MESSAGE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java index b249e0e..f2f0304 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 下发 客户端代理的真实端口自动读写 * - * @see MessageTypeEnums#DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ + * @see MessageTypeEnums#TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ */ public abstract class AbstractHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpDistributeSingleClientRealAutoReadConnect */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientRealCloseVisitorTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientRealCloseVisitorTypeAdvanced.java index d861557..b645a84 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientRealCloseVisitorTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeSingleClientRealCloseVisitorTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleUdpDistributeSingleClientRealCloseVisitorTyp */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeStagingClosedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeStagingClosedTypeAdvanced.java index 79f724f..2fe4f25 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeStagingClosedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeStagingClosedTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleUdpDistributeStagingClosedTypeAdvanced */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeStagingOpenedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeStagingOpenedTypeAdvanced.java index 8aaf622..4afe0bc 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeStagingOpenedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpDistributeStagingOpenedTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleUdpDistributeStagingOpenedTypeAdvanced */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportDisconnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportDisconnectTypeAdvanced.java index 27dcc6b..d617f63 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportDisconnectTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportDisconnectTypeAdvanced.java @@ -8,7 +8,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 客户端上报断开连接通知 - * DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION + * TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION */ public abstract class AbstractHandleUdpReportDisconnectTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/enums/MessageTypeEnums.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/enums/MessageTypeEnums.java index 4680fa3..0523786 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/enums/MessageTypeEnums.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/enums/MessageTypeEnums.java @@ -124,41 +124,41 @@ public enum MessageTypeEnums { /** * @see AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle */ - DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION(MessageType.DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION, "下发 客户端接收连接成功通知"), + TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION, "下发 客户端接收连接成功通知"), /** * @see AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle */ - DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION(MessageType.DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION, "下发 客户端断开连接通知"), + TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION, "下发 客户端断开连接通知"), /** * @see AbstractHandleTcpDistributeStagingOpenedTypeAdvanced */ - DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION(MessageType.DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION, "下发 客户端暂存开启通知"), + TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION, "下发 客户端暂存开启通知"), /** * @see AbstractHandleTcpDistributeStagingClosedTypeAdvanced */ - DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION(MessageType.DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION, "下发 客户端暂存关闭通知"), + TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION, "下发 客户端暂存关闭通知"), /** * @see AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced */ - DISTRIBUTE_CLIENT_TRANSFER(MessageType.DISTRIBUTE_CLIENT_TRANSFER, "下发 客户端数据传输(内网穿透数据发送)"), + TCP_DISTRIBUTE_CLIENT_TRANSFER(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER, "下发 客户端数据传输(内网穿透数据发送)"), /** * @see AbstractHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced */ - DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT(MessageType.DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT, "下发 客户端创建需要代理的真实端口"), + TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT, "下发 客户端创建需要代理的真实端口"), /** * @see AbstractHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced */ - DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ(MessageType.DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ, "下发 客户端代理的真实端口自动读写"), + TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ, "下发 客户端代理的真实端口自动读写"), /** * @see AbstractHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced */ - DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR(MessageType.DISTRIBUTE_SERVER_PERMEATE_CLIENT_REAL_CLOSE_VISITOR, "下发 客户端关闭代理服务通道"), + TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR(MessageType.TCP_DISTRIBUTE_SERVER_PERMEATE_CLIENT_REAL_CLOSE_VISITOR, "下发 客户端关闭代理服务通道"), /** * @see AbstractHandleTcpDistributeSingleClientMessageTypeAdvanced */ - DISTRIBUTE_SINGLE_CLIENT_MESSAGE(MessageType.DISTRIBUTE_SINGLE_CLIENT_MESSAGE, "下发 客户端消息"), + TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE, "下发 客户端消息"), /** * @see AbstractHandleTcpClientChannelActiveAdvanced */ @@ -166,66 +166,66 @@ public enum MessageTypeEnums { /** * @see AbstractHandleTcpDistributeClusterNodeRegisterTypeAdvanced */ - DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE(MessageType.DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE, "下发 集群注册"), + TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE(MessageType.TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE, "下发 集群注册"), /** * @see AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced */ - DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "下发 客户端渗透服务端数据传输通道连接成功"), + TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "下发 客户端渗透服务端数据传输通道连接成功"), /** * @see AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT, "下发 客户端渗透服务端init信息"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT, "下发 客户端渗透服务端init信息"), /** * @see AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE, "下发 客户端渗透服务端init close信息"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE, "下发 客户端渗透服务端init close信息"), /** * @see AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE, "下发 客户端渗透服务端通信通道关闭"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE, "下发 客户端渗透服务端通信通道关闭"), /** * @see AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER, "下发 客户端渗透服务端通信传输"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER, "下发 客户端渗透服务端通信传输"), /** * @see AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT, "下发 客户端渗透客户端init信息"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT, "下发 客户端渗透客户端init信息"), /** * @see AbstractHandleTcpDistributeClientPermeateClientCloseTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE, "下发 客户端渗透客户端init close信息"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE, "下发 客户端渗透客户端init close信息"), /** * @see AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced */ - DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "下发 客户端渗透客户端数据传输通道连接成功"), + TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "下发 客户端渗透客户端数据传输通道连接成功"), /** * 下发 客户端渗透客户端数据传输通道init 成功 * @see AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL, "下发 客户端渗透客户端数据传输通道init 成功"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL, "下发 客户端渗透客户端数据传输通道init 成功"), /** * 下发客户端渗透客户端数据传输 * @see AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST, "下发客户端渗透客户端数据传输"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST, "下发客户端渗透客户端数据传输"), /** * 下发客户端渗透客户端数据传输 * @see AbstractHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE, "下发客户端渗透客户端数据传输"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE, "下发客户端渗透客户端数据传输"), /** * 下发客户端渗透客户端通信通道关闭 * - * @see MessageTypeEnums#DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE + * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE * @see AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced */ - DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE, "下发客户端渗透客户端通信通道关闭"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE, "下发客户端渗透客户端通信通道关闭"), ; private final byte typeByte; 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 c0ea965..3236dec 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 @@ -107,7 +107,7 @@ public class ServerHandleTcpClientConnectSuccessTypeAdvanced extends AbstractHan // 通知所有客户端有人上线了 ChannelContext.getChannels().forEach((existClientId, channels) -> { NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION); nettyMsg.setData((JSON.toJSONString(clientIdList) .getBytes(StandardCharsets.UTF_8))); // 发送所有客户端ID @@ -145,7 +145,7 @@ public class ServerHandleTcpClientConnectSuccessTypeAdvanced extends AbstractHan Integer permeateTargetPort = lazyInternalNetworkClientPermeateServerMappingDTO.getPermeateTargetPort(); Integer visitorPort = lazyInternalNetworkClientPermeateServerMappingDTO.getVisitorPort(); NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT); nettyMsg.setClientTargetIp(permeateTargetIp); nettyMsg.setClientTargetPort(permeateTargetPort); nettyMsg.setVisitorPort(visitorPort); @@ -167,7 +167,7 @@ public class ServerHandleTcpClientConnectSuccessTypeAdvanced extends AbstractHan Integer visitorPort = lazyInternalNetworkClientPermeateClientMappingDTO.getVisitorPort(); String toClientId = lazyInternalNetworkClientPermeateClientMappingDTO.getToClientId(); NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT); nettyMsg.setClientTargetIp(permeateTargetIp); nettyMsg.setClientTargetPort(permeateTargetPort); nettyMsg.setVisitorPort(visitorPort); 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 808efa8..6ca5371 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 @@ -34,7 +34,7 @@ public class ServerHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced // 下发关闭客户端真实通道 NettyProxyMsg closeTransferNettyProxyMsg = new NettyProxyMsg(); - closeTransferNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE); + closeTransferNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE); transferNextChannel.writeAndFlush(closeTransferNettyProxyMsg); channel.close(); 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 6eacc75..0d69d71 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 @@ -44,7 +44,7 @@ public class ServerHandleTcpReportClientTransferClientPermeateChannelConnectionS clientConnectTagetNettyProxyMsg.setClientTargetIp(msgClientTargetIp); clientConnectTagetNettyProxyMsg.setClientTargetPort(msgClientTargetPort); clientConnectTagetNettyProxyMsg.setClientId(clientId); - clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); + clientConnectTagetNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); if (clientChannel != null) { clientChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); }else { 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 0e92c58..78f217d 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 @@ -49,7 +49,7 @@ public class ServerHandleTcpReportClientTransferClientPermeateChannelInitSuccess clientConnectTagetNettyProxyMsg.setClientTargetIp(msgClientTargetIp); clientConnectTagetNettyProxyMsg.setClientTargetPort(msgClientTargetPort); clientConnectTagetNettyProxyMsg.setClientId(clientId); - clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL); + clientConnectTagetNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL); if (nextChannel != null) { nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); }else { 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 325ca3f..889e13c 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 @@ -46,7 +46,7 @@ public class ServerHandleTcpReportClientTransferClientResponseTypeAdvanced exten clientConnectTagetNettyProxyMsg.setClientTargetPort(msgClientTargetPort); clientConnectTagetNettyProxyMsg.setClientId(clientId); clientConnectTagetNettyProxyMsg.setData(nettyProxyMsg.getData()); - clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE); + clientConnectTagetNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE); if (nextChannel != null) { nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); 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 df34e8c..ca69699 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 @@ -47,7 +47,7 @@ public class ServerHandleTcpReportClientTransferClientTypeAdvanced extends Abstr clientConnectTagetNettyProxyMsg.setClientTargetPort(msgClientTargetPort); clientConnectTagetNettyProxyMsg.setClientId(clientId); clientConnectTagetNettyProxyMsg.setData(nettyProxyMsg.getData()); - clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST); + clientConnectTagetNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST); if (nextChannel != null) { nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); // 记录进口数据 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 3a21a5f..d95ea32 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 @@ -66,13 +66,13 @@ public class ServerHandleTcpReportDisconnectTypeAdvanced extends AbstractHandleT for (Channel channel : channels) { // 离线通知 NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION); nettyMsg.setClientId(clientId); nettyMsg.setData(clientId.getBytes(StandardCharsets.UTF_8)); channel.writeAndFlush(nettyMsg); // 暂存通知 NettyProxyMsg stagingNettyProxyMsg = new NettyProxyMsg(); - stagingNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION); + stagingNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION); stagingNettyProxyMsg.setData(clientId.getBytes(StandardCharsets.UTF_8)); stagingNettyProxyMsg.setClientId(clientId); channel.writeAndFlush(stagingNettyProxyMsg); 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 6844f71..0b0d7bb 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 @@ -58,7 +58,7 @@ public class ServerHandleTcpReportStagingClosedTypeAdvanced extends AbstractHand for (Channel channel : channels) { // 告诉他们 当前参数这个通道 暂存关闭了 NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION); nettyMsg.setData((clientId .getBytes(StandardCharsets.UTF_8))); nettyMsg.setClientId((clientId 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 ab87199..5c81c51 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 @@ -62,7 +62,7 @@ public class ServerHandleTcpReportStagingOpenedTypeAdvanced extends AbstractHand for (Channel channel : channels) { // 告诉他们 当前参数这个通道 暂存开启了 NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION); nettyMsg.setData((clientId .getBytes(StandardCharsets.UTF_8))); nettyMsg.setClientId((clientId diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/handler/NettyTcpClientPermeateServerRealHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/handler/NettyTcpClientPermeateServerRealHandler.java index 7762e8a..2c2b677 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/handler/NettyTcpClientPermeateServerRealHandler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/handler/NettyTcpClientPermeateServerRealHandler.java @@ -48,7 +48,7 @@ public class NettyTcpClientPermeateServerRealHandler extends SimpleChannelInboun if (nextChannel != null) { NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER); nettyMsg.setData(bytes); nextChannel.writeAndFlush(nettyMsg); @@ -80,7 +80,7 @@ public class NettyTcpClientPermeateServerRealHandler extends SimpleChannelInboun log.info("【客户端渗透服务端】服务端真实连接断开"); // 下发关闭这个客户端的访客通道 NettyProxyMsg closeVisitorMsg = new NettyProxyMsg(); - closeVisitorMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE); + closeVisitorMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE); nextChannel.writeAndFlush(closeVisitorMsg); } diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/handler/NettyTcpServerPermeateClientVisitorHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/handler/NettyTcpServerPermeateClientVisitorHandler.java index dc43ca1..0b5eca3 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/handler/NettyTcpServerPermeateClientVisitorHandler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/handler/NettyTcpServerPermeateClientVisitorHandler.java @@ -48,7 +48,7 @@ public class NettyTcpServerPermeateClientVisitorHandler extends SimpleChannelInb ChannelAttributeKeyUtils.buildVisitorId(visitorChannel, visitorId); ChannelAttributeKeyUtils.buildClientId(visitorChannel, clientId); NettyProxyMsg nettyProxyMsg = new NettyProxyMsg(); - nettyProxyMsg.setType(MessageType.DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT); + nettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT); nettyProxyMsg.setClientId(clientId); nettyProxyMsg.setVisitorPort(visitorPort); nettyProxyMsg.setClientTargetIp(clientTargetIp); @@ -99,7 +99,7 @@ public class NettyTcpServerPermeateClientVisitorHandler extends SimpleChannelInb // 绑定数据流量 ChannelAttributeKeyUtils.buildInFlow(nextChannel, bytes.length); NettyProxyMsg nettyProxyMsg = new NettyProxyMsg(); - nettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER); + nettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER); nettyProxyMsg.setClientId(clientId); nettyProxyMsg.setClientTargetIp(clientTargetIp); nettyProxyMsg.setClientTargetPort(clientTargetPort); @@ -136,7 +136,7 @@ public class NettyTcpServerPermeateClientVisitorHandler extends SimpleChannelInb // 通知服务端 关闭访问通道、真实通道 NettyProxyMsg myMsg = new NettyProxyMsg(); - myMsg.setType(MessageType.DISTRIBUTE_SERVER_PERMEATE_CLIENT_REAL_CLOSE_VISITOR); + myMsg.setType(MessageType.TCP_DISTRIBUTE_SERVER_PERMEATE_CLIENT_REAL_CLOSE_VISITOR); myMsg.setVisitorId(visitorId); nextChannel.writeAndFlush(myMsg); } @@ -194,7 +194,7 @@ public class NettyTcpServerPermeateClientVisitorHandler extends SimpleChannelInb if (nextChannel != null) { // 下发关闭访客 NettyProxyMsg closeRealClient = new NettyProxyMsg(); - closeRealClient.setType(MessageType.DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ); + closeRealClient.setType(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ); closeRealClient.setClientId(clientId); closeRealClient.setVisitorId(visitorId); nextChannel.writeAndFlush(closeRealClient); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/socket/NettyTcpClientPermeateServerConnectRealSocket.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/socket/NettyTcpClientPermeateServerConnectRealSocket.java index 0b01d5a..461b1b6 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/socket/NettyTcpClientPermeateServerConnectRealSocket.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/tcp/socket/NettyTcpClientPermeateServerConnectRealSocket.java @@ -63,7 +63,7 @@ public class NettyTcpClientPermeateServerConnectRealSocket { ChannelAttributeKeyUtils.buildClientId(realChannel, clientId); NettyProxyMsg myMsg = new NettyProxyMsg(); - myMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); + myMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); myMsg.setVisitorId(visitorId); myMsg.setVisitorPort(visitorPort); myMsg.setClientTargetIp(targetIp); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpClientConnectSuccessTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpClientConnectSuccessTypeAdvanced.java index 171b4f3..13a16fa 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpClientConnectSuccessTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpClientConnectSuccessTypeAdvanced.java @@ -107,7 +107,7 @@ public class ServerHandleUdpClientConnectSuccessTypeAdvanced extends AbstractHan // 通知所有客户端有人上线了 ChannelContext.getChannels().forEach((existClientId, channels) -> { NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION); nettyMsg.setData((JSON.toJSONString(clientIdList) .getBytes(StandardCharsets.UTF_8))); // 发送所有客户端ID @@ -145,7 +145,7 @@ public class ServerHandleUdpClientConnectSuccessTypeAdvanced extends AbstractHan Integer permeateTargetPort = lazyInternalNetworkClientPermeateServerMappingDTO.getPermeateTargetPort(); Integer visitorPort = lazyInternalNetworkClientPermeateServerMappingDTO.getVisitorPort(); NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT); nettyMsg.setClientTargetIp(permeateTargetIp); nettyMsg.setClientTargetPort(permeateTargetPort); nettyMsg.setVisitorPort(visitorPort); @@ -167,7 +167,7 @@ public class ServerHandleUdpClientConnectSuccessTypeAdvanced extends AbstractHan Integer visitorPort = lazyInternalNetworkClientPermeateClientMappingDTO.getVisitorPort(); String toClientId = lazyInternalNetworkClientPermeateClientMappingDTO.getToClientId(); NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT); nettyMsg.setClientTargetIp(permeateTargetIp); nettyMsg.setClientTargetPort(permeateTargetPort); nettyMsg.setVisitorPort(visitorPort); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced.java index 0712673..f0f0cc3 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced.java @@ -34,7 +34,7 @@ public class ServerHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced // 下发关闭客户端真实通道 NettyProxyMsg closeTransferNettyProxyMsg = new NettyProxyMsg(); - closeTransferNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE); + closeTransferNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE); transferNextChannel.writeAndFlush(closeTransferNettyProxyMsg); channel.close(); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java index 49e729b..85f7a1e 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -47,7 +47,7 @@ public class ServerHandleUdpReportClientTransferClientPermeateChannelConnectionS clientConnectTagetNettyProxyMsg.setClientTargetIp(msgClientTargetIp); clientConnectTagetNettyProxyMsg.setClientTargetPort(msgClientTargetPort); clientConnectTagetNettyProxyMsg.setClientId(clientId); - clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); + clientConnectTagetNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); if (clientChannel != null) { clientChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); }else { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java index 557e1a2..56ae648 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java @@ -49,7 +49,7 @@ public class ServerHandleUdpReportClientTransferClientPermeateChannelInitSuccess clientConnectTagetNettyProxyMsg.setClientTargetIp(msgClientTargetIp); clientConnectTagetNettyProxyMsg.setClientTargetPort(msgClientTargetPort); clientConnectTagetNettyProxyMsg.setClientId(clientId); - clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL); + clientConnectTagetNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL); if (nextChannel != null) { nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); }else { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientResponseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientResponseTypeAdvanced.java index ccbf1a6..31de992 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientResponseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientResponseTypeAdvanced.java @@ -46,7 +46,7 @@ public class ServerHandleUdpReportClientTransferClientResponseTypeAdvanced exten clientConnectTagetNettyProxyMsg.setClientTargetPort(msgClientTargetPort); clientConnectTagetNettyProxyMsg.setClientId(clientId); clientConnectTagetNettyProxyMsg.setData(nettyProxyMsg.getData()); - clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE); + clientConnectTagetNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE); if (nextChannel != null) { nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientTypeAdvanced.java index 0501d01..7e48f4b 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportClientTransferClientTypeAdvanced.java @@ -47,7 +47,7 @@ public class ServerHandleUdpReportClientTransferClientTypeAdvanced extends Abstr clientConnectTagetNettyProxyMsg.setClientTargetPort(msgClientTargetPort); clientConnectTagetNettyProxyMsg.setClientId(clientId); clientConnectTagetNettyProxyMsg.setData(nettyProxyMsg.getData()); - clientConnectTagetNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST); + clientConnectTagetNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST); if (nextChannel != null) { nextChannel.writeAndFlush(clientConnectTagetNettyProxyMsg); // 记录进口数据 diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportDisconnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportDisconnectTypeAdvanced.java index 0ec50d4..150b59c 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportDisconnectTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportDisconnectTypeAdvanced.java @@ -66,13 +66,13 @@ public class ServerHandleUdpReportDisconnectTypeAdvanced extends AbstractHandleU for (Channel channel : channels) { // 离线通知 NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION); nettyMsg.setClientId(clientId); nettyMsg.setData(clientId.getBytes(StandardCharsets.UTF_8)); channel.writeAndFlush(nettyMsg); // 暂存通知 NettyProxyMsg stagingNettyProxyMsg = new NettyProxyMsg(); - stagingNettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION); + stagingNettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION); stagingNettyProxyMsg.setData(clientId.getBytes(StandardCharsets.UTF_8)); stagingNettyProxyMsg.setClientId(clientId); channel.writeAndFlush(stagingNettyProxyMsg); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportStagingClosedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportStagingClosedTypeAdvanced.java index 751888b..093ab8f 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportStagingClosedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportStagingClosedTypeAdvanced.java @@ -58,7 +58,7 @@ public class ServerHandleUdpReportStagingClosedTypeAdvanced extends AbstractHand for (Channel channel : channels) { // 告诉他们 当前参数这个通道 暂存关闭了 NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION); nettyMsg.setData((clientId .getBytes(StandardCharsets.UTF_8))); nettyMsg.setClientId((clientId diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportStagingOpenedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportStagingOpenedTypeAdvanced.java index fd9097c..69117e4 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportStagingOpenedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/ServerHandleUdpReportStagingOpenedTypeAdvanced.java @@ -62,7 +62,7 @@ public class ServerHandleUdpReportStagingOpenedTypeAdvanced extends AbstractHand for (Channel channel : channels) { // 告诉他们 当前参数这个通道 暂存开启了 NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION); nettyMsg.setData((clientId .getBytes(StandardCharsets.UTF_8))); nettyMsg.setClientId((clientId diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/handler/NettyUdpClientPermeateServerRealHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/handler/NettyUdpClientPermeateServerRealHandler.java index a6680a3..b204280 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/handler/NettyUdpClientPermeateServerRealHandler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/handler/NettyUdpClientPermeateServerRealHandler.java @@ -48,7 +48,7 @@ public class NettyUdpClientPermeateServerRealHandler extends SimpleChannelInboun if (nextChannel != null) { NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER); nettyMsg.setData(bytes); nextChannel.writeAndFlush(nettyMsg); @@ -80,7 +80,7 @@ public class NettyUdpClientPermeateServerRealHandler extends SimpleChannelInboun log.info("【客户端渗透服务端】服务端真实连接断开"); // 下发关闭这个客户端的访客通道 NettyProxyMsg closeVisitorMsg = new NettyProxyMsg(); - closeVisitorMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE); + closeVisitorMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE); nextChannel.writeAndFlush(closeVisitorMsg); } diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/handler/NettyUdpServerPermeateClientVisitorHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/handler/NettyUdpServerPermeateClientVisitorHandler.java index 1287fd5..5798a8d 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/handler/NettyUdpServerPermeateClientVisitorHandler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/handler/NettyUdpServerPermeateClientVisitorHandler.java @@ -48,7 +48,7 @@ public class NettyUdpServerPermeateClientVisitorHandler extends SimpleChannelInb ChannelAttributeKeyUtils.buildVisitorId(visitorChannel, visitorId); ChannelAttributeKeyUtils.buildClientId(visitorChannel, clientId); NettyProxyMsg nettyProxyMsg = new NettyProxyMsg(); - nettyProxyMsg.setType(MessageType.DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT); + nettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT); nettyProxyMsg.setClientId(clientId); nettyProxyMsg.setVisitorPort(visitorPort); nettyProxyMsg.setClientTargetIp(clientTargetIp); @@ -99,7 +99,7 @@ public class NettyUdpServerPermeateClientVisitorHandler extends SimpleChannelInb // 绑定数据流量 ChannelAttributeKeyUtils.buildInFlow(nextChannel, bytes.length); NettyProxyMsg nettyProxyMsg = new NettyProxyMsg(); - nettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER); + nettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER); nettyProxyMsg.setClientId(clientId); nettyProxyMsg.setClientTargetIp(clientTargetIp); nettyProxyMsg.setClientTargetPort(clientTargetPort); @@ -136,7 +136,7 @@ public class NettyUdpServerPermeateClientVisitorHandler extends SimpleChannelInb // 通知服务端 关闭访问通道、真实通道 NettyProxyMsg myMsg = new NettyProxyMsg(); - myMsg.setType(MessageType.DISTRIBUTE_SERVER_PERMEATE_CLIENT_REAL_CLOSE_VISITOR); + myMsg.setType(MessageType.TCP_DISTRIBUTE_SERVER_PERMEATE_CLIENT_REAL_CLOSE_VISITOR); myMsg.setVisitorId(visitorId); nextChannel.writeAndFlush(myMsg); } @@ -194,7 +194,7 @@ public class NettyUdpServerPermeateClientVisitorHandler extends SimpleChannelInb if (nextChannel != null) { // 下发关闭访客 NettyProxyMsg closeRealClient = new NettyProxyMsg(); - closeRealClient.setType(MessageType.DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ); + closeRealClient.setType(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ); closeRealClient.setClientId(clientId); closeRealClient.setVisitorId(visitorId); nextChannel.writeAndFlush(closeRealClient); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/socket/NettyUdpClientPermeateServerConnectRealSocket.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/socket/NettyUdpClientPermeateServerConnectRealSocket.java index 869ce75..df440de 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/socket/NettyUdpClientPermeateServerConnectRealSocket.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/socket/NettyUdpClientPermeateServerConnectRealSocket.java @@ -63,7 +63,7 @@ public class NettyUdpClientPermeateServerConnectRealSocket { ChannelAttributeKeyUtils.buildClientId(realChannel, clientId); NettyProxyMsg myMsg = new NettyProxyMsg(); - myMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); + myMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL); myMsg.setVisitorId(visitorId); myMsg.setVisitorPort(visitorPort); myMsg.setClientTargetIp(targetIp); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkClientPermeateClientMappingApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkClientPermeateClientMappingApplicationImpl.java index a9c4a09..67963b0 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkClientPermeateClientMappingApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkClientPermeateClientMappingApplicationImpl.java @@ -163,7 +163,7 @@ public class LazyInternalNetworkClientPermeateClientMappingApplicationImpl imple Integer permeateTargetPort = lazyNettyClientPermeateClientMapping.getPermeateTargetPort(); Integer visitorPort = lazyNettyClientPermeateClientMapping.getVisitorPort(); NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE); nettyMsg.setClientTargetIp(permeateTargetIp); nettyMsg.setClientTargetPort(permeateTargetPort); nettyMsg.setVisitorPort(visitorPort); @@ -186,7 +186,7 @@ public class LazyInternalNetworkClientPermeateClientMappingApplicationImpl imple Integer permeateTargetPort = lazyNettyClientPermeateClientMapping.getPermeateTargetPort(); Integer visitorPort = lazyNettyClientPermeateClientMapping.getVisitorPort(); NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT); nettyMsg.setClientTargetIp(permeateTargetIp); nettyMsg.setClientTargetPort(permeateTargetPort); nettyMsg.setVisitorPort(visitorPort); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkClientPermeateServerMappingApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkClientPermeateServerMappingApplicationImpl.java index c4dc407..4dc5c82 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkClientPermeateServerMappingApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkClientPermeateServerMappingApplicationImpl.java @@ -178,7 +178,7 @@ public class LazyInternalNetworkClientPermeateServerMappingApplicationImpl imple Integer permeateTargetPort = lazyNettyClientPermeateServerMapping.getPermeateTargetPort(); Integer visitorPort = lazyNettyClientPermeateServerMapping.getVisitorPort(); NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE); nettyMsg.setClientTargetIp(permeateTargetIp); nettyMsg.setClientTargetPort(permeateTargetPort); nettyMsg.setVisitorPort(visitorPort); @@ -199,7 +199,7 @@ public class LazyInternalNetworkClientPermeateServerMappingApplicationImpl imple Integer permeateTargetPort = lazyNettyClientPermeateServerMapping.getPermeateTargetPort(); Integer visitorPort = lazyNettyClientPermeateServerMapping.getVisitorPort(); NettyProxyMsg nettyMsg = new NettyProxyMsg(); - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT); nettyMsg.setClientTargetIp(permeateTargetIp); nettyMsg.setClientTargetPort(permeateTargetPort); nettyMsg.setVisitorPort(visitorPort); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java index de5b64b..26ea883 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java @@ -236,7 +236,7 @@ public class LazyNettyClientStateApplicationImpl implements LazyNettyClientState NettyProxyMsg nettyProxyMsg = new NettyProxyMsg(); nettyProxyMsg.setClientId("服务端"); nettyProxyMsg.setData(message.getBytes(StandardCharsets.UTF_8)); - nettyProxyMsg.setType(MessageType.DISTRIBUTE_SINGLE_CLIENT_MESSAGE); + nettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE); clientChannel.writeAndFlush(nettyProxyMsg); return ResultFactory.successOf(); } diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyChannelController.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyChannelController.java index 20b18cf..30c9a57 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyChannelController.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/controller/LazyChannelController.java @@ -47,7 +47,7 @@ public class LazyChannelController { NettyProxyMsg nettyMsg = new NettyProxyMsg(); nettyMsg.setClientId(clientId); // 下发 客户端消息 - nettyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER); + nettyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER); clientChannel.writeAndFlush(nettyMsg); } @@ -91,7 +91,7 @@ public class LazyChannelController { ChannelContext.getChannels().forEach((clientId, channels) -> { NettyProxyMsg nettyProxyMsg = new NettyProxyMsg(); // 下发 客户端消息 - nettyProxyMsg.setType(MessageType.DISTRIBUTE_CLIENT_TRANSFER); + nettyProxyMsg.setType(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER); nettyProxyMsg.setClientId(clientId); nettyProxyMsg.setVisitorPort(visitorPort); nettyProxyMsg.setClientTargetIp(clientTargetIp);