From cb4c9c0b41c4456299ae3798ea1610109be0407e Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Mon, 16 Dec 2024 18:45:17 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=20=20=E4=BC=98=E5=8C=96tcp=E3=80=81udp?= =?UTF-8?q?=E6=9E=B6=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../netty/handler/NettyClientHandler.java | 2 +- .../network/heartbeat/common/MessageType.java | 9 +- .../heartbeat/common/UdpMessageType.java | 403 ++++++++++++++++++ ...tHandleTcpClientChannelActiveAdvanced.java | 2 +- ...ermeateClientCloseVisitorTypeAdvanced.java | 2 +- ...UdpHandleChannelHeartbeatTypeAdvanced.java | 2 +- ...tHandleUdpClientChannelActiveAdvanced.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 +- ...leUdpClientConnectSuccessTypeAdvanced.java | 2 +- ...ClientPermeateClientCloseTypeAdvanced.java | 4 +- ...tClientPermeateClientInitTypeAdvanced.java | 4 +- ...rmeateClientTransferCloseTypeAdvanced.java | 4 +- ...ClientPermeateServerCloseTypeAdvanced.java | 4 +- ...tClientPermeateServerInitTypeAdvanced.java | 4 +- ...rmeateServerTransferCloseTypeAdvanced.java | 4 +- ...entPermeateServerTransferTypeAdvanced.java | 4 +- ...annelConnectionSuccessfulTypeAdvanced.java | 4 +- ...eateChannelInitSuccessfulTypeAdvanced.java | 4 +- ...entTransferClientResponseTypeAdvanced.java | 4 +- ...eportClientTransferClientTypeAdvanced.java | 4 +- ...annelConnectionSuccessfulTypeAdvanced.java | 4 +- ...ReportClusterNodeRegisterTypeAdvanced.java | 4 +- ...HandleUdpReportDisconnectTypeAdvanced.java | 4 +- ...ReportServerChannelActiveTypeAdvanced.java | 4 +- ...ermeateClientCloseVisitorTypeAdvanced.java | 4 +- ...PermeateClientRealConnectTypeAdvanced.java | 4 +- ...icePermeateClientTransferTypeAdvanced.java | 4 +- ...ClientMessage2OtherClientTypeAdvanced.java | 4 +- ...dleUdpReportStagingClosedTypeAdvanced.java | 2 +- ...dleUdpReportStagingOpenedTypeAdvanced.java | 2 +- .../common/enums/MessageTypeEnums.java | 339 ++++++++++++--- .../config/ServerAutoConfiguration.java | 34 +- 53 files changed, 792 insertions(+), 161 deletions(-) create mode 100644 wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/UdpMessageType.java 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 4e67657..eb6c192 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 @@ -62,7 +62,7 @@ public class NettyClientHandler extends SimpleChannelInboundHandler extends */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.CLIENT_CHANNEL_ACTIVE.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_CLIENT_CHANNEL_ACTIVE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/server/AbstractHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/server/AbstractHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced.java index 0d831e8..3c944cd 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/server/AbstractHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/tcp/server/AbstractHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced.java @@ -22,6 +22,6 @@ public abstract class AbstractHandleTcpReportServicePermeateClientCloseVisitorTy */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.REPORT_SINGLE_CLIENT_CLOSE_VISITOR.getTypeByte() == msg.getType(); + return MessageTypeEnums.TCP_REPORT_SINGLE_CLIENT_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/AbstractUdpHandleChannelHeartbeatTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/AbstractUdpHandleChannelHeartbeatTypeAdvanced.java index a526911..af6ea9b 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/AbstractUdpHandleChannelHeartbeatTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/AbstractUdpHandleChannelHeartbeatTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 服务端 处理客户端心跳 - * TCP_TYPE_HEARTBEAT + * UDP_TYPE_HEARTBEAT */ public abstract class AbstractUdpHandleChannelHeartbeatTypeAdvanced 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/AbstractHandleUdpClientChannelActiveAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpClientChannelActiveAdvanced.java index dcfc3af..04124c2 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpClientChannelActiveAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/client/AbstractHandleUdpClientChannelActiveAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleUdpClientChannelActiveAdvanced extends */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.CLIENT_CHANNEL_ACTIVE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_CLIENT_CHANNEL_ACTIVE.getTypeByte() == msg.getType(); } } 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 055a597..5ffec72 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#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 67f9ad3..590f44f 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#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 2123f94..16e65f2 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#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 cab96ae..c5e466c 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#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 f9e44e5..f18b4ca 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#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 22a10f1..d16de2b 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#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 65e6943..8582261 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#TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 571e8b1..67ba0b5 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#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 ac83a78..fc38e62 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#TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 feea51b..d1101dc 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#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 14a2b68..1b74808 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#TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 1a2e43c..bda7bf3 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#TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 2f918cf..95c562f 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.TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 ee40cf7..4137a7b 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; /** * 下发客户端断开连接通知 - * TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION + * UDP_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.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 f7b0334..ce7c318 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; /** * 客户端处理服务端下发数据 - * TCP_DISTRIBUTE_CLIENT_TRANSFER + * UDP_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.TCP_DISTRIBUTE_CLIENT_TRANSFER.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 6f13197..19f9f64 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.TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 f2f0304..08a3b13 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#TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ + * @see MessageTypeEnums#UDP_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.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 b645a84..b7bee40 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.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 2fe4f25..61a776b 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.TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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 4afe0bc..d48e232 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.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_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/AbstractHandleUdpClientConnectSuccessTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpClientConnectSuccessTypeAdvanced.java index fa857a7..ab98604 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpClientConnectSuccessTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpClientConnectSuccessTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleUdpClientConnectSuccessTypeAdvanced ext */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_CONNECT_SUCCESS.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_CLIENT_CONNECT_SUCCESS.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientCloseTypeAdvanced.java index 1fcd9a2..dae4449 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientCloseTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报 客户端渗透客户端init close 信息 - * TCP_REPORT_CLIENT_PERMEATE_CLIENT_CLOSE + * UDP_REPORT_CLIENT_PERMEATE_CLIENT_CLOSE */ public abstract class AbstractHandleUdpReportClientPermeateClientCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientPermeateClientCloseTypeAdvanc */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_PERMEATE_CLIENT_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportClientPermeateClientInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientInitTypeAdvanced.java index 69d3437..04436e3 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientInitTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报 客户端渗透客户端init信息 - * TCP_REPORT_CLIENT_PERMEATE_CLIENT_INIT + * UDP_REPORT_CLIENT_PERMEATE_CLIENT_INIT */ public abstract class AbstractHandleUdpReportClientPermeateClientInitTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientPermeateClientInitTypeAdvance */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_PERMEATE_CLIENT_INIT.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced.java index 532c56d..f5f7dc6 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报客户端渗透客户端通信通道关闭 - *@see MessageTypeEnums#TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE + *@see MessageTypeEnums#UDP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE */ public abstract class AbstractHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientPermeateClientTransferCloseTy */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportClientPermeateServerCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerCloseTypeAdvanced.java index 4b196c5..3e2eecb 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerCloseTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报 客户端渗透服务端init close 信息 - * TCP_REPORT_CLIENT_PERMEATE_SERVER_CLOSE + * UDP_REPORT_CLIENT_PERMEATE_SERVER_CLOSE */ public abstract class AbstractHandleUdpReportClientPermeateServerCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientPermeateServerCloseTypeAdvanc */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_PERMEATE_SERVER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportClientPermeateServerInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerInitTypeAdvanced.java index 3f04d0e..ad0feb9 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerInitTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报 客户端渗透服务端init信息 - * TCP_REPORT_CLIENT_PERMEATE_SERVER_INIT + * UDP_REPORT_CLIENT_PERMEATE_SERVER_INIT */ public abstract class AbstractHandleUdpReportClientPermeateServerInitTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientPermeateServerInitTypeAdvance */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_PERMEATE_SERVER_INIT.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportClientPermeateServerTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerTransferCloseTypeAdvanced.java index e9c25bd..d2b604f 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerTransferCloseTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报 客户端渗透服务端通信通道关闭 - * TCP_TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE + * UDP_UDP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE */ public abstract class AbstractHandleUdpReportClientPermeateServerTransferCloseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientPermeateServerTransferCloseTy */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_UDP_REPORT_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/server/AbstractHandleUdpReportClientPermeateServerTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerTransferTypeAdvanced.java index 6f8b31d..e5ce991 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientPermeateServerTransferTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报 客户端渗透服务端通信 - * TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER + * UDP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER */ public abstract class AbstractHandleUdpReportClientPermeateServerTransferTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientPermeateServerTransferTypeAdv */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java index 1eebe82..5c27ed5 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报 客户端渗透客户端数据传输通道连接成功 - * TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL + * UDP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL */ public abstract class AbstractHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientTransferClientPermeateChannel */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java index c142836..f171d76 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报 客户端渗透客户端数据传输通道init - * TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL + * UDP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL */ public abstract class AbstractHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientTransferClientPermeateChannel */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_INIT_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_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/server/AbstractHandleUdpReportClientTransferClientResponseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientResponseTypeAdvanced.java index beb8249..229dd6d 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientResponseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientResponseTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报客户端渗透客户端数据传输结果 - * TCP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE + * UDP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE */ public abstract class AbstractHandleUdpReportClientTransferClientResponseTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientTransferClientResponseTypeAdv */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientTypeAdvanced.java index 8b31ac1..21028d6 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClientTransferClientTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报客户端渗透客户端数据传输 - * TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST + * UDP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST */ public abstract class AbstractHandleUdpReportClientTransferClientTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientTransferClientTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClientTransferServerPermeateChannel */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportClusterNodeRegisterTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClusterNodeRegisterTypeAdvanced.java index 5ae8dc1..309bb9b 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClusterNodeRegisterTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportClusterNodeRegisterTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 上报 集群注册 - * TCP_REPORT_CLUSTER_NODE_REGISTER_MESSAGE + * UDP_REPORT_CLUSTER_NODE_REGISTER_MESSAGE */ public abstract class AbstractHandleUdpReportClusterNodeRegisterTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportClusterNodeRegisterTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportDisconnectTypeAdvanced extends @Override public boolean doSupport(NettyProxyMsg msg) { // 下发 客户端断开连接通知 - return MessageTypeEnums.TCP_REPORT_CLIENT_DISCONNECTION.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_CLIENT_DISCONNECTION.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServerChannelActiveTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServerChannelActiveTypeAdvanced.java index 54f4094..d032b3c 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServerChannelActiveTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServerChannelActiveTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 服务端通道 is active - * TCP_SERVER_CHANNEL_ACTIVE + * UDP_SERVER_CHANNEL_ACTIVE */ public abstract class AbstractHandleUdpReportServerChannelActiveTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportServerChannelActiveTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportServicePermeateClientCloseVisitorTy */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.REPORT_SINGLE_CLIENT_CLOSE_VISITOR.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_SINGLE_CLIENT_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/server/AbstractHandleUdpReportServicePermeateClientRealConnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServicePermeateClientRealConnectTypeAdvanced.java index 8e16ea9..5a2a93c 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServicePermeateClientRealConnectTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServicePermeateClientRealConnectTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 服务端处理客户端绑定真实服务成功 - * TCP_REPORT_SINGLE_CLIENT_REAL_CONNECT + * UDP_REPORT_SINGLE_CLIENT_REAL_CONNECT */ public abstract class AbstractHandleUdpReportServicePermeateClientRealConnectTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportServicePermeateClientRealConnectTyp */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_SINGLE_CLIENT_REAL_CONNECT.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_SINGLE_CLIENT_REAL_CONNECT.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServicePermeateClientTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServicePermeateClientTransferTypeAdvanced.java index 6ea1442..fe15d09 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServicePermeateClientTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportServicePermeateClientTransferTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 服务端处理客户端上报数据 - * TCP_REPORT_CLIENT_STAGING_CLOSED + * UDP_REPORT_CLIENT_STAGING_CLOSED */ public abstract class AbstractHandleUdpReportServicePermeateClientTransferTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportServicePermeateClientTransferTypeAd */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_TRANSFER.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportSingleClientMessage2OtherClientTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportSingleClientMessage2OtherClientTypeAdvanced.java index 05e3091..d2e8c2e 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportSingleClientMessage2OtherClientTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportSingleClientMessage2OtherClientTypeAdvanced.java @@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums; /** * 服务端处理客户端 关闭一个访客 - * TCP_REPORT_SERVICE_PERMEATE_CLIENT_CLIENT_CLOSE_VISITOR + * UDP_REPORT_SERVICE_PERMEATE_CLIENT_CLIENT_CLOSE_VISITOR */ public abstract class AbstractHandleUdpReportSingleClientMessage2OtherClientTypeAdvanced extends AbstractHandleChannelTypeAdvanced implements HandleChannelTypeAdvanced { @@ -22,6 +22,6 @@ public abstract class AbstractHandleUdpReportSingleClientMessage2OtherClientType */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_SINGLE_CLIENT_MESSAGE.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_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/server/AbstractHandleUdpReportStagingClosedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportStagingClosedTypeAdvanced.java index af66f72..7d04e6f 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportStagingClosedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportStagingClosedTypeAdvanced.java @@ -24,6 +24,6 @@ public abstract class AbstractHandleUdpReportStagingClosedTypeAdvanced exte */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_STAGING_CLOSED.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_CLIENT_STAGING_CLOSED.getTypeByte() == msg.getType(); } } diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportStagingOpenedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportStagingOpenedTypeAdvanced.java index adfac49..295648f 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportStagingOpenedTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/advanced/udp/server/AbstractHandleUdpReportStagingOpenedTypeAdvanced.java @@ -20,6 +20,6 @@ public abstract class AbstractHandleUdpReportStagingOpenedTypeAdvanced exte */ @Override public boolean doSupport(NettyProxyMsg msg) { - return MessageTypeEnums.TCP_REPORT_CLIENT_STAGING_OPENED.getTypeByte() == msg.getType(); + return MessageTypeEnums.UDP_REPORT_CLIENT_STAGING_OPENED.getTypeByte() == msg.getType(); } } 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 0523786..c0e1887 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 @@ -3,9 +3,12 @@ package org.framework.lazy.cloud.network.heartbeat.common.enums; import lombok.AllArgsConstructor; import lombok.Getter; import org.framework.lazy.cloud.network.heartbeat.common.MessageType; +import org.framework.lazy.cloud.network.heartbeat.common.UdpMessageType; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.AbstractTcpHandleChannelHeartbeatTypeAdvanced; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.client.*; import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.server.*; +import org.framework.lazy.cloud.network.heartbeat.common.advanced.udp.client.*; +import org.framework.lazy.cloud.network.heartbeat.common.advanced.udp.server.*; /** * @see MessageType @@ -20,36 +23,36 @@ public enum MessageTypeEnums { /** * @see AbstractHandleTcpClientConnectSuccessTypeAdvanced */ - TCP_REPORT_CLIENT_CONNECT_SUCCESS(MessageType.TCP_REPORT_CLIENT_CONNECT_SUCCESS, "上报 客户端连接成功"), + TCP_REPORT_CLIENT_CONNECT_SUCCESS(MessageType.TCP_REPORT_CLIENT_CONNECT_SUCCESS, "TCP 上报 客户端连接成功"), /** * @see AbstractHandleTcpReportDisconnectTypeAdvanced */ - TCP_REPORT_CLIENT_DISCONNECTION(MessageType.TCP_REPORT_CLIENT_DISCONNECTION, "上报 客户端断开连接"), + TCP_REPORT_CLIENT_DISCONNECTION(MessageType.TCP_REPORT_CLIENT_DISCONNECTION, "TCP 上报 客户端断开连接"), /** * @see AbstractHandleTcpReportStagingOpenedTypeAdvanced */ - TCP_REPORT_CLIENT_STAGING_OPENED(MessageType.TCP_REPORT_CLIENT_STAGING_OPENED, "上报 客户端暂存开启"), + TCP_REPORT_CLIENT_STAGING_OPENED(MessageType.TCP_REPORT_CLIENT_STAGING_OPENED, "TCP 上报 客户端暂存开启"), /** * @see AbstractHandleTcpReportStagingClosedTypeAdvanced */ - TCP_REPORT_CLIENT_STAGING_CLOSED(MessageType.TCP_REPORT_CLIENT_STAGING_CLOSED, "上报 客户端暂存关闭"), + TCP_REPORT_CLIENT_STAGING_CLOSED(MessageType.TCP_REPORT_CLIENT_STAGING_CLOSED, "TCP 上报 客户端暂存关闭"), /** * @see AbstractHandleTcpReportServicePermeateClientTransferTypeAdvanced */ - TCP_REPORT_CLIENT_TRANSFER(MessageType.TCP_REPORT_CLIENT_TRANSFER, "上报 客户端数据传输（内网穿透数据回传）"), + TCP_REPORT_CLIENT_TRANSFER(MessageType.TCP_REPORT_CLIENT_TRANSFER, "TCP 上报 客户端数据传输（内网穿透数据回传）"), /** * @see AbstractHandleTcpReportServicePermeateClientRealConnectTypeAdvanced */ - TCP_REPORT_SINGLE_CLIENT_REAL_CONNECT(MessageType.TCP_REPORT_SINGLE_CLIENT_REAL_CONNECT, "上报 客户端创建需要代理的真实端口成功"), + TCP_REPORT_SINGLE_CLIENT_REAL_CONNECT(MessageType.TCP_REPORT_SINGLE_CLIENT_REAL_CONNECT, "TCP 上报 客户端创建需要代理的真实端口成功"), /** * @see AbstractHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced */ - REPORT_SINGLE_CLIENT_CLOSE_VISITOR(MessageType.TCP_REPORT_SERVICE_PERMEATE_CLIENT_CLIENT_CLOSE_VISITOR, "上报 客户端关闭一个访客通道"), + TCP_REPORT_SINGLE_CLIENT_CLOSE_VISITOR(MessageType.TCP_REPORT_SERVICE_PERMEATE_CLIENT_CLIENT_CLOSE_VISITOR, "TCP 上报 客户端关闭一个访客通道"), /** * @see AbstractHandleTcpReportSingleClientMessage2OtherClientTypeAdvanced */ - TCP_REPORT_SINGLE_CLIENT_MESSAGE(MessageType.TCP_REPORT_SINGLE_CLIENT_MESSAGE, "上报 客户端消息到另一个客户端"), + TCP_REPORT_SINGLE_CLIENT_MESSAGE(MessageType.TCP_REPORT_SINGLE_CLIENT_MESSAGE, "TCP 上报 客户端消息到另一个客户端"), /** * @see AbstractHandleTcpReportServerChannelActiveTypeAdvanced */ @@ -57,175 +60,397 @@ public enum MessageTypeEnums { /** * @see AbstractHandleTcpReportClusterNodeRegisterTypeAdvanced */ - TCP_REPORT_CLUSTER_NODE_REGISTER_MESSAGE(MessageType.TCP_REPORT_CLUSTER_NODE_REGISTER_MESSAGE, "上报 集群注册"), + TCP_REPORT_CLUSTER_NODE_REGISTER_MESSAGE(MessageType.TCP_REPORT_CLUSTER_NODE_REGISTER_MESSAGE, "TCP 上报 集群注册"), /** * @see AbstractHandleTcpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced */ - TCP_REPORT_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.TCP_REPORT_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "上报 客户端渗透服务端数据传输通道连接成功"), + TCP_REPORT_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.TCP_REPORT_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "TCP 上报 客户端渗透服务端数据传输通道连接成功"), /** * @see AbstractHandleTcpReportClientPermeateServerInitTypeAdvanced */ - TCP_REPORT_CLIENT_PERMEATE_SERVER_INIT(MessageType.TCP_REPORT_CLIENT_PERMEATE_SERVER_INIT, "上报 客户端渗透服务端init信息"), + TCP_REPORT_CLIENT_PERMEATE_SERVER_INIT(MessageType.TCP_REPORT_CLIENT_PERMEATE_SERVER_INIT, "TCP 上报 客户端渗透服务端init信息"), /** - * 上报 客户端渗透服务端init close 信息 + * TCP 上报 客户端渗透服务端init close 信息 * @see AbstractHandleTcpReportClientPermeateServerCloseTypeAdvanced */ - TCP_REPORT_CLIENT_PERMEATE_SERVER_CLOSE(MessageType.TCP_REPORT_CLIENT_PERMEATE_SERVER_CLOSE, "上报 客户端渗透服务端init close 信息"), + TCP_REPORT_CLIENT_PERMEATE_SERVER_CLOSE(MessageType.TCP_REPORT_CLIENT_PERMEATE_SERVER_CLOSE, "TCP 上报 客户端渗透服务端init close 信息"), /** - * 上报 客户端渗透服务端通信通道关闭 + * TCP 上报 客户端渗透服务端通信通道关闭 * @see AbstractHandleTcpReportClientPermeateServerTransferCloseTypeAdvanced */ - TCP_TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE(MessageType.TCP_TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE, "上报 客户端渗透服务端通信通道关闭"), + TCP_TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE(MessageType.TCP_TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE, "TCP 上报 客户端渗透服务端通信通道关闭"), /** - * 上报 客户端渗透服务端通信传输 + * TCP 上报 客户端渗透服务端通信传输 * @see AbstractHandleTcpReportClientPermeateServerTransferTypeAdvanced */ - TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER(MessageType.TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER, "上报 客户端渗透服务端通信传输"), + TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER(MessageType.TCP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER, "TCP 上报 客户端渗透服务端通信传输"), /** * @see AbstractHandleTcpReportClientPermeateClientInitTypeAdvanced */ - TCP_REPORT_CLIENT_PERMEATE_CLIENT_INIT(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_INIT, "上报 客户端渗透客户端init信息"), + TCP_REPORT_CLIENT_PERMEATE_CLIENT_INIT(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_INIT, "TCP 上报 客户端渗透客户端init信息"), /** - * 上报 客户端渗透客户端init close 信息 + * TCP 上报 客户端渗透客户端init close 信息 * @see AbstractHandleTcpReportClientPermeateClientCloseTypeAdvanced */ - TCP_REPORT_CLIENT_PERMEATE_CLIENT_CLOSE(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_CLOSE, "上报 客户端渗透客户端init close 信息"), + TCP_REPORT_CLIENT_PERMEATE_CLIENT_CLOSE(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_CLOSE, "TCP 上报 客户端渗透客户端init close 信息"), /** - * 上报 客户端渗透客户端数据传输通道连接成功 + * TCP 上报 客户端渗透客户端数据传输通道连接成功 * @see AbstractHandleTcpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced */ - TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "上报 客户端渗透客户端数据传输通道连接成功"), + TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "TCP 上报 客户端渗透客户端数据传输通道连接成功"), /** - * 上报 客户端渗透客户端数据传输通道init 成功 + * TCP 上报 客户端渗透客户端数据传输通道init 成功 * @see AbstractHandleTcpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced */ - TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_INIT_SUCCESSFUL(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL, "上报 客户端渗透客户端数据传输通道init成功"), + TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_INIT_SUCCESSFUL(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL, "TCP 上报 客户端渗透客户端数据传输通道init成功"), /** - * 上报 上报客户端渗透客户端数据传输 + * TCP 上报 TCP 上报客户端渗透客户端数据传输 * @see AbstractHandleTcpReportClientTransferClientTypeAdvanced */ - TCP_REPORT_CLIENT_TRANSFER_CLIENT_REQUEST(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST, "上报客户端渗透客户端数据传输"), + TCP_REPORT_CLIENT_TRANSFER_CLIENT_REQUEST(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST, "TCP 上报客户端渗透客户端数据传输"), /** - * 上报客户端渗透客户端数据传输结果 + * TCP 上报客户端渗透客户端数据传输结果 * @see AbstractHandleTcpReportClientTransferClientResponseTypeAdvanced */ - TCP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE(MessageType.TCP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE, "上报客户端渗透客户端数据传输结果"), + TCP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE(MessageType.TCP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE, "TCP 上报客户端渗透客户端数据传输结果"), /** - * 上报客户端渗透客户端通信通道关闭 + * TCP 上报客户端渗透客户端通信通道关闭 * * @see AbstractHandleTcpReportClientPermeateClientTransferCloseTypeAdvanced */ - TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE, "上报客户端渗透客户端通信通道关闭"), + TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE(MessageType.TCP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE, "TCP 上报客户端渗透客户端通信通道关闭"), /** * @see AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle */ - TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION, "下发 客户端接收连接成功通知"), + TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION, "TCP 下发 客户端接收连接成功通知"), /** * @see AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle */ - TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION, "下发 客户端断开连接通知"), + TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION, "TCP 下发 客户端断开连接通知"), /** * @see AbstractHandleTcpDistributeStagingOpenedTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION, "下发 客户端暂存开启通知"), + TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION, "TCP 下发 客户端暂存开启通知"), /** * @see AbstractHandleTcpDistributeStagingClosedTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION, "下发 客户端暂存关闭通知"), + TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION(MessageType.TCP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION, "TCP 下发 客户端暂存关闭通知"), /** * @see AbstractHandleTcpDistributeServicePermeateClientTransferTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_TRANSFER(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER, "下发 客户端数据传输(内网穿透数据发送)"), + TCP_DISTRIBUTE_CLIENT_TRANSFER(MessageType.TCP_DISTRIBUTE_CLIENT_TRANSFER, "TCP 下发 客户端数据传输(内网穿透数据发送)"), /** * @see AbstractHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced */ - TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT, "下发 客户端创建需要代理的真实端口"), + TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT, "TCP 下发 客户端创建需要代理的真实端口"), /** * @see AbstractHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced */ - TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ, "下发 客户端代理的真实端口自动读写"), + TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ, "TCP 下发 客户端代理的真实端口自动读写"), /** * @see AbstractHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced */ - TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR(MessageType.TCP_DISTRIBUTE_SERVER_PERMEATE_CLIENT_REAL_CLOSE_VISITOR, "下发 客户端关闭代理服务通道"), + TCP_DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR(MessageType.TCP_DISTRIBUTE_SERVER_PERMEATE_CLIENT_REAL_CLOSE_VISITOR, "TCP 下发 客户端关闭代理服务通道"), /** * @see AbstractHandleTcpDistributeSingleClientMessageTypeAdvanced */ - TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE, "下发 客户端消息"), + TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE(MessageType.TCP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE, "TCP 下发 客户端消息"), /** * @see AbstractHandleTcpClientChannelActiveAdvanced */ - CLIENT_CHANNEL_ACTIVE(MessageType.CLIENT_CHANNEL_ACTIVE, "客户端通道 is active"), + TCP_CLIENT_CHANNEL_ACTIVE(MessageType.TCP_CLIENT_CHANNEL_ACTIVE, "客户端通道 is active"), /** * @see AbstractHandleTcpDistributeClusterNodeRegisterTypeAdvanced */ - TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE(MessageType.TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE, "下发 集群注册"), + TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE(MessageType.TCP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE, "TCP 下发 集群注册"), /** * @see AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.TCP_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, "TCP 下发 客户端渗透服务端数据传输通道连接成功"), /** * @see AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT, "下发 客户端渗透服务端init信息"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT, "TCP 下发 客户端渗透服务端init信息"), /** * @see AbstractHandleTcpDistributeClientPermeateServerCloseTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE, "下发 客户端渗透服务端init close信息"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE, "TCP 下发 客户端渗透服务端init close信息"), /** * @see AbstractHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE, "下发 客户端渗透服务端通信通道关闭"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE, "TCP 下发 客户端渗透服务端通信通道关闭"), /** * @see AbstractHandleTcpDistributeClientPermeateServerTransferTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER, "下发 客户端渗透服务端通信传输"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER, "TCP 下发 客户端渗透服务端通信传输"), /** * @see AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT, "下发 客户端渗透客户端init信息"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT, "TCP 下发 客户端渗透客户端init信息"), /** * @see AbstractHandleTcpDistributeClientPermeateClientCloseTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE, "下发 客户端渗透客户端init close信息"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE, "TCP 下发 客户端渗透客户端init close信息"), /** * @see AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(MessageType.TCP_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, "TCP 下发 客户端渗透客户端数据传输通道连接成功"), /** - * 下发 客户端渗透客户端数据传输通道init 成功 + * TCP 下发 客户端渗透客户端数据传输通道init 成功 * @see AbstractHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL(MessageType.TCP_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, "TCP 下发 客户端渗透客户端数据传输通道init 成功"), /** - * 下发客户端渗透客户端数据传输 + * TCP 下发客户端渗透客户端数据传输 * @see AbstractHandleTcpDistributeClientTransferClientRequestTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST, "下发客户端渗透客户端数据传输"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST, "TCP 下发客户端渗透客户端数据传输"), /** - * 下发客户端渗透客户端数据传输 + * TCP 下发客户端渗透客户端数据传输 * @see AbstractHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE, "下发客户端渗透客户端数据传输"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE, "TCP 下发客户端渗透客户端数据传输"), /** - * 下发客户端渗透客户端通信通道关闭 + * TCP 下发客户端渗透客户端通信通道关闭 * * @see MessageTypeEnums#TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE * @see AbstractHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced */ - TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE, "下发客户端渗透客户端通信通道关闭"), + TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE(MessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE, "TCP 下发客户端渗透客户端通信通道关闭"), + + + + + + + + + /** + * @see AbstractHandleUdpClientConnectSuccessTypeAdvanced + */ + UDP_REPORT_CLIENT_CONNECT_SUCCESS(UdpMessageType.UDP_REPORT_CLIENT_CONNECT_SUCCESS, "UDP 上报 客户端连接成功"), + /** + * @see AbstractHandleUdpReportDisconnectTypeAdvanced + */ + UDP_REPORT_CLIENT_DISCONNECTION(UdpMessageType.UDP_REPORT_CLIENT_DISCONNECTION, "UDP 上报 客户端断开连接"), + /** + * @see AbstractHandleUdpReportStagingOpenedTypeAdvanced + */ + UDP_REPORT_CLIENT_STAGING_OPENED(UdpMessageType.UDP_REPORT_CLIENT_STAGING_OPENED, "UDP 上报 客户端暂存开启"), + /** + * @see AbstractHandleUdpReportStagingClosedTypeAdvanced + */ + UDP_REPORT_CLIENT_STAGING_CLOSED(UdpMessageType.UDP_REPORT_CLIENT_STAGING_CLOSED, "UDP 上报 客户端暂存关闭"), + /** + * @see AbstractHandleUdpReportServicePermeateClientTransferTypeAdvanced + */ + + UDP_REPORT_CLIENT_TRANSFER(UdpMessageType.UDP_REPORT_CLIENT_TRANSFER, "UDP 上报 客户端数据传输（内网穿透数据回传）"), + /** + * @see AbstractHandleUdpReportServicePermeateClientRealConnectTypeAdvanced + */ + UDP_REPORT_SINGLE_CLIENT_REAL_CONNECT(UdpMessageType.UDP_REPORT_SINGLE_CLIENT_REAL_CONNECT, "UDP 上报 客户端创建需要代理的真实端口成功"), + /** + * @see AbstractHandleUdpReportServicePermeateClientCloseVisitorTypeAdvanced + */ + UDP_REPORT_SINGLE_CLIENT_CLOSE_VISITOR(UdpMessageType.UDP_REPORT_SERVICE_PERMEATE_CLIENT_CLIENT_CLOSE_VISITOR, "UDP 上报 客户端关闭一个访客通道"), + /** + * @see AbstractHandleUdpReportSingleClientMessage2OtherClientTypeAdvanced + */ + UDP_REPORT_SINGLE_CLIENT_MESSAGE(UdpMessageType.UDP_REPORT_SINGLE_CLIENT_MESSAGE, "UDP 上报 客户端消息到另一个客户端"), + /** + * @see AbstractHandleUdpReportServerChannelActiveTypeAdvanced + */ + UDP_SERVER_CHANNEL_ACTIVE(UdpMessageType.UDP_SERVER_CHANNEL_ACTIVE, "服务端通道 is active"), + /** + * @see AbstractHandleUdpReportClusterNodeRegisterTypeAdvanced + */ + UDP_REPORT_CLUSTER_NODE_REGISTER_MESSAGE(UdpMessageType.UDP_REPORT_CLUSTER_NODE_REGISTER_MESSAGE, "UDP 上报 集群注册"), + /** + * @see AbstractHandleUdpReportClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced + */ + UDP_REPORT_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(UdpMessageType.UDP_REPORT_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "UDP 上报 客户端渗透服务端数据传输通道连接成功"), + /** + * @see AbstractHandleUdpReportClientPermeateServerInitTypeAdvanced + */ + UDP_REPORT_CLIENT_PERMEATE_SERVER_INIT(UdpMessageType.UDP_REPORT_CLIENT_PERMEATE_SERVER_INIT, "UDP 上报 客户端渗透服务端init信息"), + /** + * UDP 上报 客户端渗透服务端init close 信息 + * @see AbstractHandleUdpReportClientPermeateServerCloseTypeAdvanced + */ + UDP_REPORT_CLIENT_PERMEATE_SERVER_CLOSE(UdpMessageType.UDP_REPORT_CLIENT_PERMEATE_SERVER_CLOSE, "UDP 上报 客户端渗透服务端init close 信息"), + + + /** + * UDP 上报 客户端渗透服务端通信通道关闭 + * @see AbstractHandleUdpReportClientPermeateServerTransferCloseTypeAdvanced + */ + UDP_UDP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE(UdpMessageType.UDP_UDP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE, "UDP 上报 客户端渗透服务端通信通道关闭"), + + /** + * UDP 上报 客户端渗透服务端通信传输 + * @see AbstractHandleUdpReportClientPermeateServerTransferTypeAdvanced + */ + UDP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER(UdpMessageType.UDP_REPORT_CLIENT_PERMEATE_SERVER_TRANSFER, "UDP 上报 客户端渗透服务端通信传输"), + + /** + * @see AbstractHandleUdpReportClientPermeateClientInitTypeAdvanced + */ + UDP_REPORT_CLIENT_PERMEATE_CLIENT_INIT(UdpMessageType.UDP_REPORT_CLIENT_PERMEATE_CLIENT_INIT, "UDP 上报 客户端渗透客户端init信息"), + /** + * UDP 上报 客户端渗透客户端init close 信息 + * @see AbstractHandleUdpReportClientPermeateClientCloseTypeAdvanced + */ + UDP_REPORT_CLIENT_PERMEATE_CLIENT_CLOSE(UdpMessageType.UDP_REPORT_CLIENT_PERMEATE_CLIENT_CLOSE, "UDP 上报 客户端渗透客户端init close 信息"), + /** + * UDP 上报 客户端渗透客户端数据传输通道连接成功 + * @see AbstractHandleUdpReportClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced + */ + UDP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(UdpMessageType.UDP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "UDP 上报 客户端渗透客户端数据传输通道连接成功"), + + /** + * UDP 上报 客户端渗透客户端数据传输通道init 成功 + * @see AbstractHandleUdpReportClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced + */ + UDP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_INIT_SUCCESSFUL(UdpMessageType.UDP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL, "UDP 上报 客户端渗透客户端数据传输通道init成功"), + /** + * UDP 上报 UDP 上报客户端渗透客户端数据传输 + * @see AbstractHandleUdpReportClientTransferClientTypeAdvanced + */ + UDP_REPORT_CLIENT_TRANSFER_CLIENT_REQUEST(UdpMessageType.UDP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST, "UDP 上报客户端渗透客户端数据传输"), + /** + * UDP 上报客户端渗透客户端数据传输结果 + * @see AbstractHandleUdpReportClientTransferClientResponseTypeAdvanced + */ + UDP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE(UdpMessageType.UDP_REPORT_CLIENT_TRANSFER_CLIENT_RESPONSE, "UDP 上报客户端渗透客户端数据传输结果"), + /** + * UDP 上报客户端渗透客户端通信通道关闭 + * + * @see AbstractHandleUdpReportClientPermeateClientTransferCloseTypeAdvanced + */ + UDP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE(UdpMessageType.UDP_REPORT_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE, "UDP 上报客户端渗透客户端通信通道关闭"), + /** + * @see AbstractHandleUdpDistributeConnectSuccessNotificationTypeAdvancedHandle + */ + UDP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION(UdpMessageType.UDP_DISTRIBUTE_CLIENT_CONNECTION_SUCCESS_NOTIFICATION, "UDP 下发 客户端接收连接成功通知"), + + + /** + * @see AbstractHandleUdpDistributeDisconnectTypeAdvancedHandle + */ + UDP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION(UdpMessageType.UDP_DISTRIBUTE_CLIENT_DISCONNECTION_NOTIFICATION, "UDP 下发 客户端断开连接通知"), + /** + * @see AbstractHandleUdpDistributeStagingOpenedTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION(UdpMessageType.UDP_DISTRIBUTE_CLIENT_STAGING_OPENED_NOTIFICATION, "UDP 下发 客户端暂存开启通知"), + /** + * @see AbstractHandleUdpDistributeStagingClosedTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION(UdpMessageType.UDP_DISTRIBUTE_CLIENT_STAGING_CLOSED_NOTIFICATION, "UDP 下发 客户端暂存关闭通知"), + /** + * @see AbstractHandleUdpDistributeServicePermeateClientTransferTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_TRANSFER(UdpMessageType.UDP_DISTRIBUTE_CLIENT_TRANSFER, "UDP 下发 客户端数据传输(内网穿透数据发送)"), + /** + * @see AbstractHandleUdpDistributeServicePermeateClientRealConnectTypeAdvanced + */ + UDP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT(UdpMessageType.UDP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT, "UDP 下发 客户端创建需要代理的真实端口"), + /** + * @see AbstractHandleUdpDistributeSingleClientRealAutoReadConnectTypeAdvanced + */ + UDP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ(UdpMessageType.UDP_DISTRIBUTE_SINGLE_CLIENT_REAL_CONNECT_AUTO_READ, "UDP 下发 客户端代理的真实端口自动读写"), + /** + * @see AbstractHandleUdpDistributeSingleClientRealCloseVisitorTypeAdvanced + */ + UDP_DISTRIBUTE_SINGLE_CLIENT_REAL_CLOSE_VISITOR(UdpMessageType.UDP_DISTRIBUTE_SERVER_PERMEATE_CLIENT_REAL_CLOSE_VISITOR, "UDP 下发 客户端关闭代理服务通道"), + /** + * @see AbstractHandleUdpDistributeSingleClientMessageTypeAdvanced + */ + UDP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE(UdpMessageType.UDP_DISTRIBUTE_SINGLE_CLIENT_MESSAGE, "UDP 下发 客户端消息"), + /** + * @see AbstractHandleUdpClientChannelActiveAdvanced + */ + UDP_CLIENT_CHANNEL_ACTIVE(UdpMessageType.UDP_CLIENT_CHANNEL_ACTIVE, "客户端通道 is active"), + /** + * @see AbstractHandleUdpDistributeClusterNodeRegisterTypeAdvanced + */ + UDP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE(UdpMessageType.UDP_DISTRIBUTE_CLUSTER_NODE_REGISTER_MESSAGE, "UDP 下发 集群注册"), + + /** + * @see AbstractHandleUdpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(UdpMessageType.UDP_DISTRIBUTE_CLIENT_TRANSFER_SERVER_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "UDP 下发 客户端渗透服务端数据传输通道连接成功"), + /** + * @see AbstractHandleUdpDistributeClientPermeateServerInitTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_INIT, "UDP 下发 客户端渗透服务端init信息"), + + /** + * @see AbstractHandleUdpDistributeClientPermeateServerCloseTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_CLOSE, "UDP 下发 客户端渗透服务端init close信息"), + /** + * @see AbstractHandleUdpDistributeClientPermeateServerTransferCloseTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER_CLOSE, "UDP 下发 客户端渗透服务端通信通道关闭"), + /** + * @see AbstractHandleUdpDistributeClientPermeateServerTransferTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_SERVER_TRANSFER, "UDP 下发 客户端渗透服务端通信传输"), + + /** + * @see AbstractHandleUdpDistributeClientPermeateClientInitTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT, "UDP 下发 客户端渗透客户端init信息"), + + + /** + * @see AbstractHandleUdpDistributeClientPermeateClientCloseTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_CLOSE, "UDP 下发 客户端渗透客户端init close信息"), + /** + * @see AbstractHandleUdpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL(UdpMessageType.UDP_DISTRIBUTE_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL, "UDP 下发 客户端渗透客户端数据传输通道连接成功"), + /** + * UDP 下发 客户端渗透客户端数据传输通道init 成功 + * @see AbstractHandleUdpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CHANNEL_INIT_SUCCESSFUL, "UDP 下发 客户端渗透客户端数据传输通道init 成功"), + /** + * UDP 下发客户端渗透客户端数据传输 + * @see AbstractHandleUdpDistributeClientTransferClientRequestTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_REQUEST, "UDP 下发客户端渗透客户端数据传输"), + /** + * UDP 下发客户端渗透客户端数据传输 + * @see AbstractHandleUdpDistributeServicePermeateClientTransferClientResponseTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_RESPONSE, "UDP 下发客户端渗透客户端数据传输"), + /** + * UDP 下发客户端渗透客户端通信通道关闭 + * + * @see MessageTypeEnums#UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE + * @see AbstractHandleUdpDistributeClientPermeateClientTransferCloseTypeAdvanced + */ + UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE(UdpMessageType.UDP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_TRANSFER_CLOSE, "UDP 下发客户端渗透客户端通信通道关闭"), + + + + + ; private final byte typeByte; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/config/ServerAutoConfiguration.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/config/ServerAutoConfiguration.java index ade1369..28a708e 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/config/ServerAutoConfiguration.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/config/ServerAutoConfiguration.java @@ -36,13 +36,13 @@ public class ServerAutoConfiguration { */ @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced serverReportChannelTransferTypeAdvanced(ChannelFlowAdapter channelFlowAdapter) { + static ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced serverHandleTcpReportServicePermeateClientTransferTypeAdvanced(ChannelFlowAdapter channelFlowAdapter) { return new ServerHandleTcpReportServicePermeateClientTransferTypeAdvanced(channelFlowAdapter); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleTcpClientConnectSuccessTypeAdvanced serverReportConnectSuccessTypeAdvanced( + static ServerHandleTcpClientConnectSuccessTypeAdvanced serverHandleTcpClientConnectSuccessTypeAdvanced( LazyClientStatsChangeApplication lazyClientStatsChangeApplication, LazyNettyClientBlacklistApplication lazyNettyClientBlacklistApplication, LazyInternalNetworkServerPermeateClientMappingApplication lazyInternalNetworkServerPermeateClientMappingApplication, @@ -69,37 +69,37 @@ public class ServerAutoConfiguration { */ @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleTcpReportClusterNodeRegisterTypeAdvanced serverHandleReportClusterNodeRegisterTypeAdvanced() { + static ServerHandleTcpReportClusterNodeRegisterTypeAdvanced serverHandleTcpReportClusterNodeRegisterTypeAdvanced() { return new ServerHandleTcpReportClusterNodeRegisterTypeAdvanced(); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleTcpReportDisconnectTypeAdvanced serverReportDisconnectTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { + static ServerHandleTcpReportDisconnectTypeAdvanced serverHandleTcpReportDisconnectTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { return new ServerHandleTcpReportDisconnectTypeAdvanced(lazyClientStatsChangeApplication); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced serverReportSingleClientCloseVisitorTypeAdvanced() { + static ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced serverHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced() { return new ServerHandleTcpReportServicePermeateClientCloseVisitorTypeAdvanced(); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced serverReportSingleClientRealConnectTypeAdvanced() { + static ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced serverHandleTcpReportServicePermeateClientRealConnectTypeAdvanced() { return new ServerHandleTcpReportServicePermeateClientRealConnectTypeAdvanced(); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleTcpReportStagingClosedTypeAdvanced serverReportStagingClosedTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { + static ServerHandleTcpReportStagingClosedTypeAdvanced serverHandleTcpReportStagingClosedTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { return new ServerHandleTcpReportStagingClosedTypeAdvanced(lazyClientStatsChangeApplication); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleTcpReportStagingOpenedTypeAdvanced serverReportStagingOpenedTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { + static ServerHandleTcpReportStagingOpenedTypeAdvanced serverHandleTcpReportStagingOpenedTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { return new ServerHandleTcpReportStagingOpenedTypeAdvanced(lazyClientStatsChangeApplication); } } @@ -113,7 +113,7 @@ public class ServerAutoConfiguration { */ @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - public ServerHandleUdpChannelHeartbeatTypeAdvanced serverChannelHeartbeatTypeAdvanced() { + public ServerHandleUdpChannelHeartbeatTypeAdvanced serverHandleUdpChannelHeartbeatTypeAdvanced() { return new ServerHandleUdpChannelHeartbeatTypeAdvanced(); } @@ -124,13 +124,13 @@ public class ServerAutoConfiguration { */ @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleUdpReportServicePermeateClientTransferTypeAdvanced serverReportChannelTransferTypeAdvanced(ChannelFlowAdapter channelFlowAdapter) { + static ServerHandleUdpReportServicePermeateClientTransferTypeAdvanced serverHandleUdpReportServicePermeateClientTransferTypeAdvanced(ChannelFlowAdapter channelFlowAdapter) { return new ServerHandleUdpReportServicePermeateClientTransferTypeAdvanced(channelFlowAdapter); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleUdpClientConnectSuccessTypeAdvanced serverReportConnectSuccessTypeAdvanced( + static ServerHandleUdpClientConnectSuccessTypeAdvanced serverHandleUdpClientConnectSuccessTypeAdvanced( LazyClientStatsChangeApplication lazyClientStatsChangeApplication, LazyNettyClientBlacklistApplication lazyNettyClientBlacklistApplication, LazyInternalNetworkServerPermeateClientMappingApplication lazyInternalNetworkServerPermeateClientMappingApplication, @@ -157,37 +157,37 @@ public class ServerAutoConfiguration { */ @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleUdpReportClusterNodeRegisterTypeAdvanced serverHandleReportClusterNodeRegisterTypeAdvanced() { + static ServerHandleUdpReportClusterNodeRegisterTypeAdvanced serverHandleUdpReportClusterNodeRegisterTypeAdvanced() { return new ServerHandleUdpReportClusterNodeRegisterTypeAdvanced(); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleUdpReportDisconnectTypeAdvanced serverReportDisconnectTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { + static ServerHandleUdpReportDisconnectTypeAdvanced serverHandleUdpReportDisconnectTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { return new ServerHandleUdpReportDisconnectTypeAdvanced(lazyClientStatsChangeApplication); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleUdpReportServicePermeateClientCloseVisitorTypeAdvanced serverReportSingleClientCloseVisitorTypeAdvanced() { + static ServerHandleUdpReportServicePermeateClientCloseVisitorTypeAdvanced serverHandleUdpReportServicePermeateClientCloseVisitorTypeAdvanced() { return new ServerHandleUdpReportServicePermeateClientCloseVisitorTypeAdvanced(); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleUdpReportServicePermeateClientRealConnectTypeAdvanced serverReportSingleClientRealConnectTypeAdvanced() { + static ServerHandleUdpReportServicePermeateClientRealConnectTypeAdvanced serverHandleUdpReportServicePermeateClientRealConnectTypeAdvanced() { return new ServerHandleUdpReportServicePermeateClientRealConnectTypeAdvanced(); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleUdpReportStagingClosedTypeAdvanced serverReportStagingClosedTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { + static ServerHandleUdpReportStagingClosedTypeAdvanced serverHandleUdpReportStagingClosedTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { return new ServerHandleUdpReportStagingClosedTypeAdvanced(lazyClientStatsChangeApplication); } @Role(BeanDefinition.ROLE_INFRASTRUCTURE) @Bean - static ServerHandleUdpReportStagingOpenedTypeAdvanced serverReportStagingOpenedTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { + static ServerHandleUdpReportStagingOpenedTypeAdvanced serverHandleUdpReportStagingOpenedTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication) { return new ServerHandleUdpReportStagingOpenedTypeAdvanced(lazyClientStatsChangeApplication); } }