[fix] 优化tcp、udp架构

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/application/impl/LazyNettyServerPropertiesApplicationImpl.java

@@ -6,7 +6,7 @@ import org.framework.lazy.cloud.network.heartbeat.client.application.assembler.L
 import org.framework.lazy.cloud.network.heartbeat.client.application.dto.LazyNettyServerPropertiesDTO;
 import org.framework.lazy.cloud.network.heartbeat.client.domain.model.lazy.netty.server.properties.LazyNettyServerProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.domain.model.lazy.netty.server.properties.LazyNettyServerPropertiesRepository;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientSocket;
 import org.framework.lazy.cloud.network.heartbeat.client.application.LazyNettyServerPropertiesApplication;
 import org.framework.lazy.cloud.network.heartbeat.client.application.command.lazy.netty.server.properties.*;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/config/ClientAutoConfiguration.java

@@ -1,86 +1,175 @@
 package org.framework.lazy.cloud.network.heartbeat.client.config;
 
 
-import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientSocket;
-import org.springframework.boot.CommandLineRunner;
-import org.springframework.context.annotation.Bean;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.event.ClientChangeEvent;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced.*;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
-import org.wu.framework.core.NormalUsedString;
+import org.springframework.beans.factory.config.BeanDefinition;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Role;
 
 import java.util.List;
-import java.util.concurrent.ArrayBlockingQueue;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
 
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
+@ConditionalOnProperty(prefix = NettyClientProperties.PREFIX, name = "enabled", havingValue = "true", matchIfMissing = true)
+public class ClientAutoConfiguration {
+
+
+    @Configuration()
+    static class ClientTcpConfiguration {
         /**
- * description 自动配置
+         * 服务端 处理客户端心跳
          *
- * @author 吴佳伟
- * @date 2023/09/12 18:22
- * @see InitConfig
+         * @return ClientTcpHandleChannelHeartbeatTypeAdvanced
          */
-@Deprecated
-@Slf4j
-public class ClientAutoConfiguration implements CommandLineRunner {
-
-    private final NettyClientProperties nettyClientProperties;
-    private final ClientChangeEvent clientChangeEvent;
-
-    private final List<HandleChannelTypeAdvanced> handleChannelTypeAdvancedList; // 处理服务端发送过来的数据类型
-
-
-    public static final ThreadPoolExecutor NETTY_CLIENT_EXECUTOR = new ThreadPoolExecutor(1, 1, 200, TimeUnit.MILLISECONDS,
-            new ArrayBlockingQueue<>(1));
-
-    public ClientAutoConfiguration(NettyClientProperties nettyClientProperties,
-                                   ClientChangeEvent clientChangeEvent,
-                                   List<HandleChannelTypeAdvanced> handleChannelTypeAdvancedList) {
-        this.nettyClientProperties = nettyClientProperties;
-        this.clientChangeEvent = clientChangeEvent;
-        this.handleChannelTypeAdvancedList = handleChannelTypeAdvancedList;
-    }
-
-
-    @Bean(destroyMethod = "shutdown")
-    public NettyClientSocket nettyClientSocket() {
-        String inetHost = nettyClientProperties.getInetHost();
-        int inetPort = nettyClientProperties.getInetPort();
-        String clientId = nettyClientProperties.getClientId();
-        String appKey = nettyClientProperties.getAppKey();
-        String appSecret = nettyClientProperties.getAppSecret();
-        return new NettyClientSocket(inetHost, inetPort, clientId, NormalUsedString.DEFAULT, appKey,appSecret,clientChangeEvent, handleChannelTypeAdvancedList);
+        @Bean
+        public ClientTcpHandleChannelHeartbeatTypeAdvanced clientTcpHandleChannelHeartbeatTypeAdvanced() {
+            return new ClientTcpHandleChannelHeartbeatTypeAdvanced();
         }
 
         /**
-     * @param args
-     * @throws Exception
+         * 处理 客户端代理的真实端口自动读写
+         *
+         * @return ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced
          */
-    @Override
-    public void run(String... args) throws Exception {
-
-
-        String inetHost = nettyClientProperties.getInetHost();
-        int inetPort = nettyClientProperties.getInetPort();
-        String clientId = nettyClientProperties.getClientId();
-        String appKey = nettyClientProperties.getAppKey();
-        String appSecret = nettyClientProperties.getAppSecret();
-        NettyClientSocket nettyClientSocket = new NettyClientSocket(
-                inetHost, inetPort,
-                clientId, NormalUsedString.DEFAULT,appKey,appSecret,
-                clientChangeEvent, handleChannelTypeAdvancedList);
-        Thread thread = new Thread(() -> {
-            try {
-                nettyClientSocket.newConnect2Server();
-            } catch (Exception e) {
-                throw new RuntimeException(e);
+        @Bean
+        public ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced clientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced() {
+            return new ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced();
         }
 
-        });
-        log.info("当前服务连接Netty客户端:{},Netty端口:{}", inetHost, inetPort);
-        NETTY_CLIENT_EXECUTOR.execute(thread);
+        /**
+         * 处理 接收服务端发送过来的聊天信息
+         *
+         * @return ClientHandleTcpDistributeSingleClientMessageTypeAdvanced
+         */
+        @Bean
+        public ClientHandleTcpDistributeSingleClientMessageTypeAdvanced clientHandleTcpDistributeSingleClientMessageTypeAdvanced() {
+            return new ClientHandleTcpDistributeSingleClientMessageTypeAdvanced();
+        }
+
+        /**
+         * 处理 客户端渗透服务端数据传输通道连接成功
+         *
+         * @return ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced
+         */
+        @Bean
+        public ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced clientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced() {
+            return new ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced();
+        }
+
+        /**
+         * 处理 客户端渗透客户端数据传输通道连接成功
+         *
+         * @return ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced
+         */
+        @Bean
+        public ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced clientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced() {
+            return new ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced clientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced() {
+            return new ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced clientHandleTcpDistributeClientTransferClientRequestTypeAdvanced() {
+            return new ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced clientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced() {
+            return new ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced clientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced() {
+            return new ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute clientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute(NettyClientProperties nettyClientProperties) {
+            return new ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute(nettyClientProperties);
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle clientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) {
+            return new ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle(clientChangeEvent);
+        }
+
+        @Bean
+        public ClientHandleTcpClientChannelActiveAdvanced clientHandleTcpClientChannelActiveAdvanced(NettyClientProperties nettyClientProperties) {
+            return new ClientHandleTcpClientChannelActiveAdvanced(nettyClientProperties);
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeDisconnectTypeAdvancedHandle clientHandleTcpDistributeDisconnectTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) {
+            return new ClientHandleTcpDistributeDisconnectTypeAdvancedHandle(clientChangeEvent);
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeStagingClosedTypeAdvanced clientHandleTcpDistributeStagingClosedTypeAdvanced() {
+            return new ClientHandleTcpDistributeStagingClosedTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeStagingOpenedTypeAdvanced clientHandleTcpDistributeStagingOpenedTypeAdvanced() {
+            return new ClientHandleTcpDistributeStagingOpenedTypeAdvanced();
+        }
+
+        /**
+         * 处理 客户端渗透服务端init信息
+         *
+         * @return ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced
+         */
+        @Bean
+        public ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced clientHandleTcpDistributeClientPermeateServerInitTypeAdvanced(NettyClientProperties nettyClientProperties) {
+            return new ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced(nettyClientProperties);
+        }
+
+        /**
+         * 处理 客户端渗透服务端init close 信息
+         *
+         * @return ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced
+         */
+        @Bean
+        public ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced clientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced() {
+            return new ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced clientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced() {
+            return new ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced clientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced() {
+            return new ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced clientHandleTcpDistributeClientPermeateClientInitTypeAdvanced() {
+            return new ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced();
+        }
+
+        @Bean
+        public ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced clientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced() {
+            return new ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced();
+        }
 
 
+        @Bean
+        public ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced clientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced(
+                NettyClientProperties nettyClientProperties,
+                List<HandleChannelTypeAdvanced> handleChannelTypeAdvancedList) {
+            return new ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced(nettyClientProperties, handleChannelTypeAdvancedList);
+        }
+
+        @Bean
+        public ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced clientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced() {
+            return new ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced();
+        }
     }
 }

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/config/HeartbeatClientConfiguration.java

@@ -1,165 +0,0 @@
-package org.framework.lazy.cloud.network.heartbeat.client.config;
-
-
-import org.framework.lazy.cloud.network.heartbeat.client.netty.advanced.*;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.event.ClientChangeEvent;
-import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
-import org.springframework.beans.factory.config.BeanDefinition;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Role;
-
-import java.util.List;
-
-@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
-@ConditionalOnProperty(prefix = NettyClientProperties.PREFIX, name = "enabled", havingValue = "true", matchIfMissing = true)
-public class HeartbeatClientConfiguration {
-
-    /**
-     * 服务端 处理客户端心跳
-     *
-     * @return ClientTcpHandleChannelHeartbeatTypeAdvanced
-     */
-    @Bean
-    public ClientTcpHandleChannelHeartbeatTypeAdvanced clientChannelHeartbeatTypeAdvanced() {
-        return new ClientTcpHandleChannelHeartbeatTypeAdvanced();
-    }
-
-    /**
-     * 处理 客户端代理的真实端口自动读写
-     *
-     * @return ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced
-     */
-    @Bean
-    public ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced handleDistributeSingleClientRealAutoReadConnectTypeAdvanced() {
-        return new ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced();
-    }
-
-    /**
-     * 处理 接收服务端发送过来的聊天信息
-     *
-     * @return ClientHandleTcpDistributeSingleClientMessageTypeAdvanced
-     */
-    @Bean
-    public ClientHandleTcpDistributeSingleClientMessageTypeAdvanced handleDistributeSingleClientMessageTypeAdvanced() {
-        return new ClientHandleTcpDistributeSingleClientMessageTypeAdvanced();
-    }
-    /**
-     * 处理 客户端渗透服务端数据传输通道连接成功
-     *
-     * @return ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced
-     */
-    @Bean
-    public ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced clientHandleDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced() {
-        return new ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced();
-    }
-
-    /**
-     * 处理 客户端渗透客户端数据传输通道连接成功
-     *
-     * @return ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced
-     */
-    @Bean
-    public ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced clientHandleDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced() {
-        return new ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced();
-    }
-
-    @Bean
-    public ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced clientHandleDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced() {
-        return new ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced();
-    }
-
-    @Bean
-    public ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced clientHandleDistributeClientTransferClientTypeAdvanced() {
-        return new ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced();
-    }
-
-    @Bean
-    public ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced clientHandleDistributeClientTransferClientResponseTypeAdvanced() {
-        return new ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced();
-    }
-    @Bean
-    public ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced handleDistributeSingleClientRealCloseVisitorTypeAdvanced() {
-        return new ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced();
-    }
-
-    @Bean
-    public ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute handleChannelTransferTypeAdvancedHandleDistribute(NettyClientProperties nettyClientProperties) {
-        return new ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute(nettyClientProperties);
-    }
-
-    @Bean
-    public HandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle handleDistributeConnectSuccessNotificationTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) {
-        return new HandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle(clientChangeEvent);
-    }
-
-    @Bean
-    public HandleTcpClientChannelActiveAdvanced handleClientChannelActiveAdvanced(NettyClientProperties nettyClientProperties) {
-        return new HandleTcpClientChannelActiveAdvanced(nettyClientProperties);
-    }
-
-    @Bean
-    public HandleTcpDistributeDisconnectTypeAdvancedHandle handleDistributeDisconnectTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) {
-        return new HandleTcpDistributeDisconnectTypeAdvancedHandle(clientChangeEvent);
-    }
-
-    @Bean
-    public HandleTcpDistributeStagingClosedTypeAdvanced handleDistributeStagingClosedTypeAdvanced() {
-        return new HandleTcpDistributeStagingClosedTypeAdvanced();
-    }
-
-    @Bean
-    public HandleTcpDistributeStagingOpenedTypeAdvanced handleDistributeStagingOpenedTypeAdvanced() {
-        return new HandleTcpDistributeStagingOpenedTypeAdvanced();
-    }
-
-    /**
-     * 处理 客户端渗透服务端init信息
-     *
-     * @return ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced
-     */
-    @Bean
-    public ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced clientHandleDistributeClientPermeateServerInitTypeAdvanced(NettyClientProperties nettyClientProperties) {
-        return new ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced(nettyClientProperties);
-    }
-    /**
-     * 处理 客户端渗透服务端init close 信息
-     *
-     * @return ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced
-     */
-    @Bean
-    public ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced clientHandleDistributeClientPermeateServerCloseTypeAdvanced( ) {
-        return new ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced();
-    }
-    @Bean
-    public ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced clientHandleDistributeClientPermeateServerTransferTypeAdvanced( ) {
-        return new ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced();
-    }
-
-    @Bean
-    public ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced clientHandleDistributeClientPermeateClientCloseTypeAdvanced() {
-        return new ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced();
-    }
-
-    @Bean
-    public ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced clientHandleDistributeClientPermeateClientInitTypeAdvanced() {
-        return new ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced();
-    }
-
-    @Bean
-    public ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced clientHandleDistributeClientPermeateClientTransferCloseTypeAdvanced() {
-        return new ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced();
-    }
-
-
-    @Bean
-    public ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced clientHandleDistributeSingleClientRealConnectTypeAdvanced(NettyClientProperties nettyClientProperties,
-                                                                                                                                           List<HandleChannelTypeAdvanced> handleChannelTypeAdvancedList) {
-        return new ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced(nettyClientProperties, handleChannelTypeAdvancedList);
-    }
-
-    @Bean
-    public ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced clientHandleHandleDistributeClientPermeateServerTransferCloseTypeAdvanced() {
-        return new ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced();
-    }
-}

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.buffer.ByteBuf;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 import io.netty.channel.Channel;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
@@ -10,10 +10,10 @@ import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeK
 /**
  * 客户端通道 is active
  */
-public class HandleTcpClientChannelActiveAdvanced extends AbstractHandleTcpClientChannelActiveAdvanced<NettyProxyMsg> {
+public class ClientHandleTcpClientChannelActiveAdvanced extends AbstractHandleTcpClientChannelActiveAdvanced<NettyProxyMsg> {
     private final NettyClientProperties nettyClientProperties;
 
-    public HandleTcpClientChannelActiveAdvanced(NettyClientProperties nettyClientProperties) {
+    public ClientHandleTcpClientChannelActiveAdvanced(NettyClientProperties nettyClientProperties) {
         this.nettyClientProperties = nettyClientProperties;
     }
 

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;

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

@@ -1,10 +1,10 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientPermeateClientVisitorSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientPermeateClientVisitorSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.client.AbstractHandleTcpDistributeClientPermeateClientInitTypeAdvanced;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;

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

@@ -1,10 +1,10 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientPermeateServerVisitorSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientPermeateServerVisitorSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.client.AbstractHandleTcpDistributeClientPermeateServerInitTypeAdvanced;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.buffer.ByteBuf;

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

@@ -1,10 +1,10 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientPermeateClientRealSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientPermeateClientRealSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.client.AbstractHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.buffer.ByteBuf;

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

@@ -1,11 +1,11 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelOption;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyClientPermeateServerVisitorHandler;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientPermeateServerVisitorTransferSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyClientPermeateServerVisitorHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientPermeateServerVisitorTransferSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.client.AbstractHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.enums.MessageTypeEnums;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 import com.alibaba.fastjson.JSONObject;
 import io.netty.channel.Channel;
@@ -13,12 +13,12 @@ import java.util.List;
  * 客户端连接成功通知
  */
 @Slf4j
-public class HandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle extends AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle<NettyProxyMsg> {
+public class ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle extends AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle<NettyProxyMsg> {
 
     private final ClientChangeEvent clientChangeEvent;
 
 
-    public HandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) {
+    public ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) {
         this.clientChangeEvent = clientChangeEvent;
     }
 

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;
@@ -13,12 +13,12 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.client.Abs
  * TYPE_DISCONNECT
  */
 @Slf4j
-public class HandleTcpDistributeDisconnectTypeAdvancedHandle extends AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle<NettyProxyMsg> {
+public class ClientHandleTcpDistributeDisconnectTypeAdvancedHandle extends AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle<NettyProxyMsg> {
 
 
     private final ClientChangeEvent clientChangeEvent;
 
-    public HandleTcpDistributeDisconnectTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) {
+    public ClientHandleTcpDistributeDisconnectTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) {
         this.clientChangeEvent = clientChangeEvent;
     }
 

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

@@ -1,9 +1,9 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyServerPermeateClientRealSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyServerPermeateClientRealSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPenetrationRealClient;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.buffer.ByteBuf;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelOption;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
@@ -9,7 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.client.Abs
  * 服务端下发暂存关闭消息处理
  */
 @Slf4j
-public class HandleTcpDistributeStagingClosedTypeAdvanced extends AbstractHandleTcpDistributeStagingClosedTypeAdvanced<NettyProxyMsg> {
+public class ClientHandleTcpDistributeStagingClosedTypeAdvanced extends AbstractHandleTcpDistributeStagingClosedTypeAdvanced<NettyProxyMsg> {
 
 
     /**

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
@@ -9,10 +9,10 @@ import org.framework.lazy.cloud.network.heartbeat.common.advanced.tcp.client.Abs
  * 服务端下发暂存开启消息处理
  */
 @Slf4j
-public class HandleTcpDistributeStagingOpenedTypeAdvanced extends AbstractHandleTcpDistributeStagingOpenedTypeAdvanced<NettyProxyMsg> {
+public class ClientHandleTcpDistributeStagingOpenedTypeAdvanced extends AbstractHandleTcpDistributeStagingOpenedTypeAdvanced<NettyProxyMsg> {
 
 
-    public HandleTcpDistributeStagingOpenedTypeAdvanced() {
+    public ClientHandleTcpDistributeStagingOpenedTypeAdvanced() {
 
     }
 

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

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.advanced;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced;
 
 
 import io.netty.channel.Channel;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientFilter.java

@@ -1,12 +1,12 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.filter;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter;
 
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.handler.codec.string.StringDecoder;
 import io.netty.handler.codec.string.StringEncoder;
 import io.netty.handler.timeout.IdleStateHandler;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyClientHandler;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyClientHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;
 import org.framework.lazy.cloud.network.heartbeat.common.decoder.NettyProxyMsgDecoder;
 import org.framework.lazy.cloud.network.heartbeat.common.encoder.NettyProxyMsgEncoder;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientRealFilter.java

@@ -1,10 +1,9 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.filter;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter;
 
-import io.netty.buffer.UnpooledDirectByteBuf;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyClientPermeateClientRealHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyClientPermeateClientRealHandler;
 import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder;
 import org.framework.lazy.cloud.network.heartbeat.common.encoder.TransferEncoder;
 import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientTransferFilter.java

@@ -1,11 +1,11 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.filter;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.handler.timeout.IdleStateHandler;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyClientPermeateClientTransferHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyClientPermeateClientTransferHandler;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;
 import org.framework.lazy.cloud.network.heartbeat.common.decoder.NettyProxyMsgDecoder;
 import org.framework.lazy.cloud.network.heartbeat.common.encoder.NettyProxyMsgEncoder;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientTransferRealFilter.java

@@ -1,11 +1,11 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.filter;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.handler.timeout.IdleStateHandler;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyClientPermeateClientTransferRealHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyClientPermeateClientTransferRealHandler;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;
 import org.framework.lazy.cloud.network.heartbeat.common.decoder.NettyProxyMsgDecoder;
 import org.framework.lazy.cloud.network.heartbeat.common.encoder.NettyProxyMsgEncoder;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientVisitorFilter.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.filter;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelDuplexHandler;
@@ -6,7 +6,7 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.InternalNetworkClientPermeateClientVisitor;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyClientPermeateClientVisitorHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyClientPermeateClientVisitorHandler;
 import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer;
 
 public class NettyClientPermeateClientVisitorFilter extends DebugChannelInitializer<SocketChannel> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateServerTransferFilter.java

@@ -1,11 +1,11 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.filter;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.handler.timeout.IdleStateHandler;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyClientPermeateServerTransferHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyClientPermeateServerTransferHandler;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;
 import org.framework.lazy.cloud.network.heartbeat.common.decoder.NettyProxyMsgDecoder;
 import org.framework.lazy.cloud.network.heartbeat.common.encoder.NettyProxyMsgEncoder;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateServerVisitorFilter.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.filter;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelDuplexHandler;
@@ -6,7 +6,7 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.InternalNetworkClientPermeateServerVisitor;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyClientPermeateServerVisitorHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyClientPermeateServerVisitorHandler;
 import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer;
 
 public class NettyClientPermeateServerVisitorFilter extends DebugChannelInitializer<SocketChannel> {

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyServerPermeateClientRealFilter.java

@@ -1,9 +1,9 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.filter;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyServerPermeateClientRealHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyServerPermeateClientRealHandler;
 import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder;
 import org.framework.lazy.cloud.network.heartbeat.common.encoder.TransferEncoder;
 import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyServerPermeateClientTransferFilter.java

@@ -1,10 +1,10 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.filter;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.handler.NettyServerPermeateClientTransferHandler;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler.NettyServerPermeateClientTransferHandler;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;
 import org.framework.lazy.cloud.network.heartbeat.common.decoder.NettyProxyMsgDecoder;
 import org.framework.lazy.cloud.network.heartbeat.common.encoder.NettyProxyMsgEncoder;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/HeartBeatClientHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
@@ -7,7 +7,7 @@ import io.netty.channel.SimpleChannelInboundHandler;
 import io.netty.handler.timeout.IdleState;
 import io.netty.handler.timeout.IdleStateEvent;
 import lombok.extern.slf4j.Slf4j;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientRealHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 
 import io.netty.channel.Channel;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientTransferHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 
 import io.netty.channel.Channel;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientTransferRealHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 
 import io.netty.channel.Channel;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientVisitorHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 
 import io.netty.buffer.ByteBuf;
@@ -9,9 +9,9 @@ import io.netty.channel.SimpleChannelInboundHandler;
 import io.netty.util.internal.StringUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.InternalNetworkClientPermeateClientVisitor;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.advanced.ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientPermeateClientVisitorTransferSocket;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientPermeateServerVisitorTransferSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced.ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientPermeateClientVisitorTransferSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientPermeateServerVisitorTransferSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyCommunicationIdContext;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateServerTransferHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 
 import io.netty.channel.Channel;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateServerVisitorHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 
 import io.netty.buffer.ByteBuf;
@@ -9,8 +9,8 @@ import io.netty.channel.SimpleChannelInboundHandler;
 import io.netty.util.internal.StringUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.InternalNetworkClientPermeateServerVisitor;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.advanced.ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientPermeateServerVisitorTransferSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.advanced.ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientPermeateServerVisitorTransferSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyServerPermeateClientRealHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 
 import io.netty.channel.Channel;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyServerPermeateClientTransferHandler.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.handler;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.handler;
 
 
 import io.netty.channel.Channel;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateClientRealSocket.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.socket;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket;
 
 
 import io.netty.bootstrap.Bootstrap;
@@ -7,8 +7,8 @@ import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioSocketChannel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.filter.NettyClientPermeateClientRealFilter;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.filter.NettyClientPermeateClientTransferRealFilter;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter.NettyClientPermeateClientRealFilter;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter.NettyClientPermeateClientTransferRealFilter;
 import org.framework.lazy.cloud.network.heartbeat.common.*;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateClientVisitorSocket.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.socket;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket;
 
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.*;
@@ -8,7 +8,7 @@ import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.InternalNetworkClientPermeateClientVisitor;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.filter.NettyClientPermeateClientVisitorFilter;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter.NettyClientPermeateClientVisitorFilter;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyClientVisitorContext;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyVisitorPortContext;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelFlowAdapter;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateClientVisitorTransferSocket.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.socket;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket;
 
 
 import io.netty.bootstrap.Bootstrap;
@@ -8,7 +8,7 @@ import io.netty.channel.socket.nio.NioSocketChannel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.InternalNetworkClientPermeateClientVisitor;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.filter.NettyClientPermeateClientTransferFilter;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter.NettyClientPermeateClientTransferFilter;
 import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateServerVisitorSocket.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.socket;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket;
 
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.*;
@@ -8,7 +8,7 @@ import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.InternalNetworkClientPermeateServerVisitor;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.filter.NettyClientPermeateServerVisitorFilter;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter.NettyClientPermeateServerVisitorFilter;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyClientVisitorContext;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyVisitorPortContext;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateServerVisitorTransferSocket.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.socket;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket;
 
 
 import io.netty.bootstrap.Bootstrap;
@@ -8,7 +8,7 @@ import io.netty.channel.socket.nio.NioSocketChannel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.InternalNetworkClientPermeateServerVisitor;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.filter.NettyClientPermeateServerTransferFilter;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter.NettyClientPermeateServerTransferFilter;
 import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientSocket.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.socket;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket;
 
 
 import io.netty.bootstrap.Bootstrap;
@@ -8,7 +8,7 @@ import io.netty.channel.socket.nio.NioSocketChannel;
 import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.event.ClientChangeEvent;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.filter.NettyClientFilter;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter.NettyClientFilter;
 import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyServerContext;

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyServerPermeateClientRealSocket.java

@@ -1,4 +1,4 @@
-package org.framework.lazy.cloud.network.heartbeat.client.netty.socket;
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket;
 
 
 import io.netty.bootstrap.Bootstrap;
@@ -7,8 +7,8 @@ import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.nio.NioSocketChannel;
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.filter.NettyServerPermeateClientRealFilter;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.filter.NettyServerPermeateClientTransferFilter;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter.NettyServerPermeateClientRealFilter;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.filter.NettyServerPermeateClientTransferFilter;
 import org.framework.lazy.cloud.network.heartbeat.common.*;
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelTypeAdapter;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;

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

@@ -0,0 +1,4 @@
+package org.framework.lazy.cloud.network.heartbeat.client.netty.tcp;
+
+public class xx {
+}

wu-lazy-cloud-heartbeat-client/src/main/resources/META-INF/spring.factories

@@ -3,4 +3,4 @@ org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
 org.framework.lazy.cloud.network.heartbeat.client.EnableHeartbeatClientAutoConfiguration,\
 org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties,\
 org.framework.lazy.cloud.network.heartbeat.client.config.InitConfig,\
-org.framework.lazy.cloud.network.heartbeat.client.config.HeartbeatClientConfiguration
+org.framework.lazy.cloud.network.heartbeat.client.config.ClientAutoConfiguration

wu-lazy-cloud-heartbeat-client/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

@@ -1,4 +1,4 @@
 org.framework.lazy.cloud.network.heartbeat.client.EnableHeartbeatClientAutoConfiguration
 org.framework.lazy.cloud.network.heartbeat.client.config.NettyClientProperties
 org.framework.lazy.cloud.network.heartbeat.client.config.InitConfig
-org.framework.lazy.cloud.network.heartbeat.client.config.HeartbeatClientConfiguration
+org.framework.lazy.cloud.network.heartbeat.client.config.ClientAutoConfiguration

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/cluster/application/impl/LazyNettyClusterNodeApplicationImpl.java

@@ -2,7 +2,7 @@ package org.framework.lazy.cloud.network.heartbeat.server.cluster.application.im
 
 import lombok.extern.slf4j.Slf4j;
 import org.framework.lazy.cloud.network.heartbeat.client.netty.event.ClientChangeEvent;
-import org.framework.lazy.cloud.network.heartbeat.client.netty.socket.NettyClientSocket;
+import org.framework.lazy.cloud.network.heartbeat.client.netty.tcp.socket.NettyClientSocket;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.HandleChannelTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.server.cluster.application.dto.LazyNettyClusterNodeDTO;
 import org.framework.lazy.cloud.network.heartbeat.server.cluster.domain.model.cluster.node.LazyNettyClusterNode;