From daeba59a43e5a7984e37dac9776e6e940205b812 Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Mon, 16 Dec 2024 18:53:08 +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 --- ...yNettyServerPropertiesApplicationImpl.java | 2 +- .../config/ClientAutoConfiguration.java | 229 ++++++++++++------ .../config/HeartbeatClientConfiguration.java | 165 ------------- ...AdvancedHandleDistributeTcpDistribute.java | 2 +- ...rmeateServerTransferCloseTypeAdvanced.java | 2 +- ...HandleTcpClientChannelActiveAdvanced.java} | 6 +- ...ClientPermeateClientCloseTypeAdvanced.java | 2 +- ...eClientPermeateClientInitTypeAdvanced.java | 4 +- ...rmeateClientTransferCloseTypeAdvanced.java | 2 +- ...ClientPermeateServerCloseTypeAdvanced.java | 2 +- ...eClientPermeateServerInitTypeAdvanced.java | 4 +- ...entPermeateServerTransferTypeAdvanced.java | 2 +- ...annelConnectionSuccessfulTypeAdvanced.java | 4 +- ...eateChannelInitSuccessfulTypeAdvanced.java | 2 +- ...ientTransferClientRequestTypeAdvanced.java | 2 +- ...annelConnectionSuccessfulTypeAdvanced.java | 6 +- ...uccessNotificationTypeAdvancedHandle.java} | 6 +- ...stributeDisconnectTypeAdvancedHandle.java} | 6 +- ...PermeateClientRealConnectTypeAdvanced.java | 4 +- ...entTransferClientResponseTypeAdvanced.java | 2 +- ...ributeSingleClientMessageTypeAdvanced.java | 2 +- ...ClientRealAutoReadConnectTypeAdvanced.java | 2 +- ...gleClientRealCloseVisitorTypeAdvanced.java | 2 +- ...pDistributeStagingClosedTypeAdvanced.java} | 4 +- ...pDistributeStagingOpenedTypeAdvanced.java} | 6 +- ...TcpHandleChannelHeartbeatTypeAdvanced.java | 2 +- .../{ => tcp}/filter/NettyClientFilter.java | 6 +- .../NettyClientPermeateClientRealFilter.java | 5 +- ...ttyClientPermeateClientTransferFilter.java | 4 +- ...lientPermeateClientTransferRealFilter.java | 4 +- ...ettyClientPermeateClientVisitorFilter.java | 4 +- ...ttyClientPermeateServerTransferFilter.java | 4 +- ...ettyClientPermeateServerVisitorFilter.java | 4 +- .../NettyServerPermeateClientRealFilter.java | 4 +- ...ttyServerPermeateClientTransferFilter.java | 4 +- .../handler/HeartBeatClientHandler.java | 2 +- .../{ => tcp}/handler/NettyClientHandler.java | 4 +- .../NettyClientPermeateClientRealHandler.java | 2 +- ...tyClientPermeateClientTransferHandler.java | 2 +- ...ientPermeateClientTransferRealHandler.java | 2 +- ...ttyClientPermeateClientVisitorHandler.java | 8 +- ...tyClientPermeateServerTransferHandler.java | 2 +- ...ttyClientPermeateServerVisitorHandler.java | 6 +- .../NettyServerPermeateClientRealHandler.java | 2 +- ...tyServerPermeateClientTransferHandler.java | 2 +- .../NettyClientPermeateClientRealSocket.java | 6 +- ...ettyClientPermeateClientVisitorSocket.java | 4 +- ...ntPermeateClientVisitorTransferSocket.java | 4 +- ...ettyClientPermeateServerVisitorSocket.java | 4 +- ...ntPermeateServerVisitorTransferSocket.java | 4 +- .../{ => tcp}/socket/NettyClientSocket.java | 4 +- .../NettyServerPermeateClientRealSocket.java | 6 +- .../heartbeat/client/netty/tcp/xx.java | 4 + .../main/resources/META-INF/spring.factories | 2 +- ...ot.autoconfigure.AutoConfiguration.imports | 2 +- .../LazyNettyClusterNodeApplicationImpl.java | 2 +- .../server/netty/udp/advanced/xx.java | 0 57 files changed, 256 insertions(+), 329 deletions(-) delete mode 100644 wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/config/HeartbeatClientConfiguration.java rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{advanced/HandleTcpClientChannelActiveAdvanced.java => tcp/advanced/ClientHandleTcpClientChannelActiveAdvanced.java} (83%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java (96%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java (95%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java (95%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java (86%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{advanced/HandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java => tcp/advanced/ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java} (80%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{advanced/HandleTcpDistributeDisconnectTypeAdvancedHandle.java => tcp/advanced/ClientHandleTcpDistributeDisconnectTypeAdvancedHandle.java} (80%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced.java (95%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeSingleClientMessageTypeAdvanced.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{advanced/HandleTcpDistributeStagingClosedTypeAdvanced.java => tcp/advanced/ClientHandleTcpDistributeStagingClosedTypeAdvanced.java} (86%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{advanced/HandleTcpDistributeStagingOpenedTypeAdvanced.java => tcp/advanced/ClientHandleTcpDistributeStagingOpenedTypeAdvanced.java} (82%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/advanced/ClientTcpHandleChannelHeartbeatTypeAdvanced.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/filter/NettyClientFilter.java (91%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/filter/NettyClientPermeateClientRealFilter.java (87%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/filter/NettyClientPermeateClientTransferFilter.java (94%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/filter/NettyClientPermeateClientTransferRealFilter.java (94%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/filter/NettyClientPermeateClientVisitorFilter.java (93%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/filter/NettyClientPermeateServerTransferFilter.java (94%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/filter/NettyClientPermeateServerVisitorFilter.java (93%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/filter/NettyServerPermeateClientRealFilter.java (90%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/filter/NettyServerPermeateClientTransferFilter.java (94%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/HeartBeatClientHandler.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/NettyClientHandler.java (97%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/NettyClientPermeateClientRealHandler.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/NettyClientPermeateClientTransferHandler.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/NettyClientPermeateClientTransferRealHandler.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/NettyClientPermeateClientVisitorHandler.java (93%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/NettyClientPermeateServerTransferHandler.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/NettyClientPermeateServerVisitorHandler.java (95%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/NettyServerPermeateClientRealHandler.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/handler/NettyServerPermeateClientTransferHandler.java (99%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/socket/NettyClientPermeateClientRealSocket.java (97%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/socket/NettyClientPermeateClientVisitorSocket.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/socket/NettyClientPermeateClientVisitorTransferSocket.java (97%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/socket/NettyClientPermeateServerVisitorSocket.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/socket/NettyClientPermeateServerVisitorTransferSocket.java (97%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/socket/NettyClientSocket.java (98%) rename wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/{ => tcp}/socket/NettyServerPermeateClientRealSocket.java (98%) create mode 100644 wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/xx.java delete mode 100644 wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/xx.java diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/application/impl/LazyNettyServerPropertiesApplicationImpl.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/application/impl/LazyNettyServerPropertiesApplicationImpl.java index 4959023..38751f3 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/application/impl/LazyNettyServerPropertiesApplicationImpl.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/config/ClientAutoConfiguration.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/config/ClientAutoConfiguration.java index b84c32d..95391d7 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/config/ClientAutoConfiguration.java +++ b/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; -/** - * description 自动配置 - * - * @author 吴佳伟 - * @date 2023/09/12 18:22 - * @see InitConfig - */ -@Deprecated -@Slf4j -public class ClientAutoConfiguration implements CommandLineRunner { - - private final NettyClientProperties nettyClientProperties; - private final ClientChangeEvent clientChangeEvent; - - private final List handleChannelTypeAdvancedList; // 处理服务端发送过来的数据类型 +@Role(BeanDefinition.ROLE_INFRASTRUCTURE) +@ConditionalOnProperty(prefix = NettyClientProperties.PREFIX, name = "enabled", havingValue = "true", matchIfMissing = true) +public class ClientAutoConfiguration { - public static final ThreadPoolExecutor NETTY_CLIENT_EXECUTOR = new ThreadPoolExecutor(1, 1, 200, TimeUnit.MILLISECONDS, - new ArrayBlockingQueue<>(1)); + @Configuration() + static class ClientTcpConfiguration { + /** + * 服务端 处理客户端心跳 + * + * @return ClientTcpHandleChannelHeartbeatTypeAdvanced + */ + @Bean + public ClientTcpHandleChannelHeartbeatTypeAdvanced clientTcpHandleChannelHeartbeatTypeAdvanced() { + return new ClientTcpHandleChannelHeartbeatTypeAdvanced(); + } - public ClientAutoConfiguration(NettyClientProperties nettyClientProperties, - ClientChangeEvent clientChangeEvent, - List handleChannelTypeAdvancedList) { - this.nettyClientProperties = nettyClientProperties; - this.clientChangeEvent = clientChangeEvent; - this.handleChannelTypeAdvancedList = handleChannelTypeAdvancedList; - } + /** + * 处理 客户端代理的真实端口自动读写 + * + * @return ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced + */ + @Bean + public ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced clientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced() { + return new ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced(); + } + + /** + * 处理 接收服务端发送过来的聊天信息 + * + * @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(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); - } - - /** - * @param args - * @throws Exception - */ - @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); - } - - }); - log.info("当前服务连接Netty客户端:{},Netty端口:{}", inetHost, inetPort); - NETTY_CLIENT_EXECUTOR.execute(thread); - + @Bean + public ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced clientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced( + NettyClientProperties nettyClientProperties, + List handleChannelTypeAdvancedList) { + return new ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced(nettyClientProperties, handleChannelTypeAdvancedList); + } + @Bean + public ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced clientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced() { + return new ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced(); + } } } diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/config/HeartbeatClientConfiguration.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/config/HeartbeatClientConfiguration.java deleted file mode 100644 index a54d7cc..0000000 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/config/HeartbeatClientConfiguration.java +++ /dev/null @@ -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 handleChannelTypeAdvancedList) { - return new ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced(nettyClientProperties, handleChannelTypeAdvancedList); - } - - @Bean - public ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced clientHandleHandleDistributeClientPermeateServerTransferCloseTypeAdvanced() { - return new ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced(); - } -} diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java index a7fe165..59f186b 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleChannelTransferTypeAdvancedHandleDistributeTcpDistribute.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java index 35514e6..a694a8a 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleHandleTcpDistributeClientPermeateServerTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpClientChannelActiveAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpClientChannelActiveAdvanced.java similarity index 83% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpClientChannelActiveAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpClientChannelActiveAdvanced.java index bfa8a4d..11bbe07 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpClientChannelActiveAdvanced.java +++ b/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 { +public class ClientHandleTcpClientChannelActiveAdvanced extends AbstractHandleTcpClientChannelActiveAdvanced { private final NettyClientProperties nettyClientProperties; - public HandleTcpClientChannelActiveAdvanced(NettyClientProperties nettyClientProperties) { + public ClientHandleTcpClientChannelActiveAdvanced(NettyClientProperties nettyClientProperties) { this.nettyClientProperties = nettyClientProperties; } diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java index bc5f425..276741f 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java similarity index 96% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java index 3b514a8..8f5c87f 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java index 7ce2186..afc01fb 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateClientTransferCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java index fcd7312..3772f82 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerCloseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java similarity index 95% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java index 181999d..0007958 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerInitTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java index 835172e..f646eac 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientPermeateServerTransferTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java similarity index 95% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java index 675cd6e..17b47ae 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java index e73088d..37c7e6a 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientPermeateChannelInitSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java index a24e246..d22d7fd 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferClientRequestTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java similarity index 86% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java index d2c7324..ac77a34 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeClientTransferServerPermeateChannelConnectionSuccessfulTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java similarity index 80% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java index ddf52c0..50080a1 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle.java +++ b/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 { +public class ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle extends AbstractHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle { private final ClientChangeEvent clientChangeEvent; - public HandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) { + public ClientHandleTcpDistributeConnectSuccessNotificationTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) { this.clientChangeEvent = clientChangeEvent; } diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeDisconnectTypeAdvancedHandle.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeDisconnectTypeAdvancedHandle.java similarity index 80% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeDisconnectTypeAdvancedHandle.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeDisconnectTypeAdvancedHandle.java index 4e398d2..ec72c10 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeDisconnectTypeAdvancedHandle.java +++ b/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 { +public class ClientHandleTcpDistributeDisconnectTypeAdvancedHandle extends AbstractHandleTcpDistributeDisconnectTypeAdvancedHandle { private final ClientChangeEvent clientChangeEvent; - public HandleTcpDistributeDisconnectTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) { + public ClientHandleTcpDistributeDisconnectTypeAdvancedHandle(ClientChangeEvent clientChangeEvent) { this.clientChangeEvent = clientChangeEvent; } diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced.java similarity index 95% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced.java index 73954bb..1f2af60 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientRealConnectTypeAdvanced.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java index 38c36de..df08d10 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeServicePermeateClientTransferClientResponseTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeSingleClientMessageTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeSingleClientMessageTypeAdvanced.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeSingleClientMessageTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeSingleClientMessageTypeAdvanced.java index bbd18c0..6589f34 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeSingleClientMessageTypeAdvanced.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java index 1b44574..4f3e94c 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeSingleClientRealAutoReadConnectTypeAdvanced.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java index 93a54e2..5c7f7c6 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientHandleTcpDistributeSingleClientRealCloseVisitorTypeAdvanced.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeStagingClosedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeStagingClosedTypeAdvanced.java similarity index 86% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeStagingClosedTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeStagingClosedTypeAdvanced.java index e36a187..96a835b 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeStagingClosedTypeAdvanced.java +++ b/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 { +public class ClientHandleTcpDistributeStagingClosedTypeAdvanced extends AbstractHandleTcpDistributeStagingClosedTypeAdvanced { /** diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeStagingOpenedTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeStagingOpenedTypeAdvanced.java similarity index 82% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeStagingOpenedTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientHandleTcpDistributeStagingOpenedTypeAdvanced.java index 8867e7a..aeb2fea 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/HandleTcpDistributeStagingOpenedTypeAdvanced.java +++ b/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 { +public class ClientHandleTcpDistributeStagingOpenedTypeAdvanced extends AbstractHandleTcpDistributeStagingOpenedTypeAdvanced { - public HandleTcpDistributeStagingOpenedTypeAdvanced() { + public ClientHandleTcpDistributeStagingOpenedTypeAdvanced() { } diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientTcpHandleChannelHeartbeatTypeAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientTcpHandleChannelHeartbeatTypeAdvanced.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientTcpHandleChannelHeartbeatTypeAdvanced.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/advanced/ClientTcpHandleChannelHeartbeatTypeAdvanced.java index 7bd700f..0f2c1ad 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/advanced/ClientTcpHandleChannelHeartbeatTypeAdvanced.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientFilter.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientFilter.java similarity index 91% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientFilter.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientFilter.java index c922719..3c2339a 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientFilter.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientRealFilter.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientRealFilter.java similarity index 87% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientRealFilter.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientRealFilter.java index bf77a3f..8ca5f39 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientRealFilter.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientTransferFilter.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientTransferFilter.java similarity index 94% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientTransferFilter.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientTransferFilter.java index a421093..6e49ce6 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientTransferFilter.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientTransferRealFilter.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientTransferRealFilter.java similarity index 94% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientTransferRealFilter.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientTransferRealFilter.java index 13e5eac..d8cffc0 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientTransferRealFilter.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientVisitorFilter.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientVisitorFilter.java similarity index 93% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientVisitorFilter.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateClientVisitorFilter.java index e8c66bf..58a4d42 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateClientVisitorFilter.java +++ b/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 { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateServerTransferFilter.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateServerTransferFilter.java similarity index 94% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateServerTransferFilter.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateServerTransferFilter.java index 0d0be95..a9e50fc 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateServerTransferFilter.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateServerVisitorFilter.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateServerVisitorFilter.java similarity index 93% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateServerVisitorFilter.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyClientPermeateServerVisitorFilter.java index 8ba44d3..f237f89 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyClientPermeateServerVisitorFilter.java +++ b/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 { diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyServerPermeateClientRealFilter.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyServerPermeateClientRealFilter.java similarity index 90% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyServerPermeateClientRealFilter.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyServerPermeateClientRealFilter.java index e4c8ed7..1384ffc 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyServerPermeateClientRealFilter.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyServerPermeateClientTransferFilter.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyServerPermeateClientTransferFilter.java similarity index 94% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyServerPermeateClientTransferFilter.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/filter/NettyServerPermeateClientTransferFilter.java index 580c41e..b8bdbe0 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/filter/NettyServerPermeateClientTransferFilter.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/HeartBeatClientHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/HeartBeatClientHandler.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/HeartBeatClientHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/HeartBeatClientHandler.java index f4c0108..0837f91 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/HeartBeatClientHandler.java +++ b/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; 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/tcp/handler/NettyClientHandler.java similarity index 97% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientHandler.java index eb6c192..6df4af8 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/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientRealHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientRealHandler.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientRealHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientRealHandler.java index c2f6c02..671859d 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientRealHandler.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientTransferHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientTransferHandler.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientTransferHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientTransferHandler.java index 4ea086b..97ab4d4 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientTransferHandler.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientTransferRealHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientTransferRealHandler.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientTransferRealHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientTransferRealHandler.java index 76728f3..2763274 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientTransferRealHandler.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientVisitorHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientVisitorHandler.java similarity index 93% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientVisitorHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateClientVisitorHandler.java index c8b8f58..1f434db 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateClientVisitorHandler.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerTransferHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateServerTransferHandler.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerTransferHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateServerTransferHandler.java index f791d7b..9a3fe4a 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerTransferHandler.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerVisitorHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateServerVisitorHandler.java similarity index 95% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerVisitorHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyClientPermeateServerVisitorHandler.java index aaf81f3..3cd1578 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyClientPermeateServerVisitorHandler.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyServerPermeateClientRealHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyServerPermeateClientRealHandler.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyServerPermeateClientRealHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyServerPermeateClientRealHandler.java index 000eedd..8b29393 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyServerPermeateClientRealHandler.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyServerPermeateClientTransferHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyServerPermeateClientTransferHandler.java similarity index 99% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyServerPermeateClientTransferHandler.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/handler/NettyServerPermeateClientTransferHandler.java index 9135fc1..d30bfb7 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/handler/NettyServerPermeateClientTransferHandler.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientRealSocket.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateClientRealSocket.java similarity index 97% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientRealSocket.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateClientRealSocket.java index 61c83a3..6ce7ae8 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientRealSocket.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientVisitorSocket.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateClientVisitorSocket.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientVisitorSocket.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateClientVisitorSocket.java index 540e759..95dd9bb 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientVisitorSocket.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientVisitorTransferSocket.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateClientVisitorTransferSocket.java similarity index 97% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientVisitorTransferSocket.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateClientVisitorTransferSocket.java index 262af10..31b472f 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientVisitorTransferSocket.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateServerVisitorSocket.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateServerVisitorSocket.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateServerVisitorSocket.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateServerVisitorSocket.java index fa825c0..3ab9bf2 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateServerVisitorSocket.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateServerVisitorTransferSocket.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateServerVisitorTransferSocket.java similarity index 97% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateServerVisitorTransferSocket.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientPermeateServerVisitorTransferSocket.java index 0a2d0d5..085dfa5 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateServerVisitorTransferSocket.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientSocket.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientSocket.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientSocket.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyClientSocket.java index 7652fd7..84471e0 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientSocket.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyServerPermeateClientRealSocket.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyServerPermeateClientRealSocket.java similarity index 98% rename from wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyServerPermeateClientRealSocket.java rename to wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/socket/NettyServerPermeateClientRealSocket.java index 8a558ed..e9cc665 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyServerPermeateClientRealSocket.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/xx.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/tcp/xx.java new file mode 100644 index 0000000..93ad16e --- /dev/null +++ b/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 { +} diff --git a/wu-lazy-cloud-heartbeat-client/src/main/resources/META-INF/spring.factories b/wu-lazy-cloud-heartbeat-client/src/main/resources/META-INF/spring.factories index b3dda73..edede42 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/resources/META-INF/spring.factories +++ b/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 diff --git a/wu-lazy-cloud-heartbeat-client/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/wu-lazy-cloud-heartbeat-client/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports index 1d41411..cdfba9a 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports +++ b/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 diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/cluster/application/impl/LazyNettyClusterNodeApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/cluster/application/impl/LazyNettyClusterNodeApplicationImpl.java index 1b46543..bae79f8 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/cluster/application/impl/LazyNettyClusterNodeApplicationImpl.java +++ b/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; diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/xx.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/udp/advanced/xx.java deleted file mode 100644 index e69de29..0000000