mirror of
https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git
synced 2025-06-07 22:07:55 +08:00
[fix] spring 依赖问题
This commit is contained in:
wujiawei
parent
105d0cd933
commit
ef5deb2fcb
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client;
|
package wu.framework.lazy.cloud.heartbeat.client;
|
||||||
|
|
||||||
import org.springframework.boot.SpringApplication;
|
import org.springframework.boot.SpringApplication;
|
||||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.application;
|
package wu.framework.lazy.cloud.heartbeat.client.application;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 云下心跳客户端操作nacos 配置
|
* 云下心跳客户端操作nacos 配置
|
||||||
@ -1,7 +1,7 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.application.impl;
|
package wu.framework.lazy.cloud.heartbeat.client.application.impl;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
import wu.framework.lazy.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
||||||
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
|
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|
||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.advanced;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.advanced;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelHeartbeatTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelHeartbeatTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
@ -1,8 +1,8 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.advanced;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.advanced;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyRealIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyRealIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.AbstractDistributeSingleClientRealAutoReadConnectTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.AbstractDistributeSingleClientRealAutoReadConnectTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelOption;
|
import io.netty.channel.ChannelOption;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.advanced;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.advanced;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyCommunicationIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyRealIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyRealIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.AbstractDistributeSingleClientRealCloseVisitorTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.AbstractDistributeSingleClientRealCloseVisitorTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
@ -1,11 +1,11 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.advanced;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.advanced;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.socket.NettyClientRealSocket;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.AbstractDistributeSingleClientRealConnectTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.socket.NettyClientRealSocket;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.AbstractDistributeSingleClientRealConnectTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
@ -1,11 +1,11 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.advanced;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.advanced;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyRealIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.AbstractDistributeChannelTransferTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyRealIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.AbstractDistributeChannelTransferTypeAdvanced;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
@ -1,12 +1,12 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.advanced;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.advanced;
|
||||||
|
|
||||||
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.JSONObject;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.ChannelContext;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.AbstractDistributeConnectSuccessNotificationTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.AbstractDistributeConnectSuccessNotificationTypeAdvanced;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
import wu.framework.lazy.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.advanced;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.advanced;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.AbstractDistributeDisconnectTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.AbstractDistributeDisconnectTypeAdvanced;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
import wu.framework.lazy.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
@ -1,7 +1,7 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.advanced;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.advanced;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.AbstractDistributeStagingClosedTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.AbstractDistributeStagingClosedTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
@ -1,7 +1,7 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.advanced;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.advanced;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.AbstractDistributeStagingOpenedTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.AbstractDistributeStagingOpenedTypeAdvanced;
|
||||||
|
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.config;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.config;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
import wu.framework.lazy.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.socket.NettyClientSocket;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.socket.NettyClientSocket;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.boot.CommandLineRunner;
|
import org.springframework.boot.CommandLineRunner;
|
||||||
import org.springframework.boot.autoconfigure.web.ServerProperties;
|
import org.springframework.boot.autoconfigure.web.ServerProperties;
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.config;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.config;
|
||||||
|
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.filter;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.filter;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.socket.NettyClientSocket;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.decoder.NettyProxyMsgDecoder;
|
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.encoder.NettyProxyMsgEncoder;
|
import wu.framework.lazy.cloud.heartbeat.common.decoder.NettyProxyMsgDecoder;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.handler.NettyClientHandler;
|
import wu.framework.lazy.cloud.heartbeat.common.encoder.NettyProxyMsgEncoder;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.socket.NettyClientSocket;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.handler.NettyClientHandler;
|
||||||
import io.netty.channel.ChannelInitializer;
|
import io.netty.channel.ChannelInitializer;
|
||||||
import io.netty.channel.ChannelPipeline;
|
import io.netty.channel.ChannelPipeline;
|
||||||
import io.netty.channel.socket.SocketChannel;
|
import io.netty.channel.socket.SocketChannel;
|
||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.filter;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.filter;
|
||||||
|
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.handler.NettyClientRealHandler;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.handler.NettyClientRealHandler;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.channel.ChannelInitializer;
|
import io.netty.channel.ChannelInitializer;
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.filter;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.filter;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.handler.NettyClientVisitorRealHandler;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.decoder.NettyProxyMsgDecoder;
|
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.encoder.NettMsgEncoder;
|
import wu.framework.lazy.cloud.heartbeat.common.decoder.NettyProxyMsgDecoder;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.encoder.NettyProxyMsgEncoder;
|
import wu.framework.lazy.cloud.heartbeat.common.encoder.NettMsgEncoder;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.handler.NettyClientVisitorRealHandler;
|
import wu.framework.lazy.cloud.heartbeat.common.encoder.NettyProxyMsgEncoder;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.channel.ChannelInitializer;
|
import io.netty.channel.ChannelInitializer;
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.handler;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.handler;
|
||||||
|
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.channel.ChannelInboundHandlerAdapter;
|
import io.netty.channel.ChannelInboundHandlerAdapter;
|
||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.handler;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.handler;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.socket.NettyClientSocket;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.socket.NettyClientSocket;
|
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.channel.EventLoop;
|
import io.netty.channel.EventLoop;
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.handler;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.handler;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyCommunicationIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
@ -1,11 +1,11 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.handler;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.handler;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.ChannelContext;
|
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.channel.SimpleChannelInboundHandler;
|
import io.netty.channel.SimpleChannelInboundHandler;
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.listener;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.listener;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.constant.RedisChannelConstant;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
||||||
|
import wu.framework.lazy.cloud.heartbeat.client.rpc.StagingNoticeApiRpc;
|
||||||
|
import wu.framework.lazy.cloud.heartbeat.common.constant.RedisChannelConstant;
|
||||||
|
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.rpc.StagingNoticeApiRpc;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
@ -1,13 +1,14 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.socket;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.socket;
|
||||||
|
|
||||||
|
|
||||||
|
import wu.framework.lazy.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
||||||
|
import wu.framework.lazy.cloud.heartbeat.common.*;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.*;
|
import wu.framework.middleground.cloud.heartbeat.common.*;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.config.NettyServerProperties;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.filter.NettyClientRealFilter;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.filter.NettyClientRealFilter;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.filter.NettyClientVisitorRealFilter;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.filter.NettyClientVisitorRealFilter;
|
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.channel.*;
|
import io.netty.channel.*;
|
||||||
import io.netty.channel.nio.NioEventLoopGroup;
|
import io.netty.channel.nio.NioEventLoopGroup;
|
||||||
@ -1,13 +1,13 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.netty.socket;
|
package wu.framework.lazy.cloud.heartbeat.client.netty.socket;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
import wu.framework.lazy.cloud.heartbeat.client.application.ClientNettyConfigApplication;
|
||||||
import wu.framework.middleground.under.cloud.heartbeat.client.netty.filter.NettyClientFilter;
|
import wu.framework.lazy.cloud.heartbeat.client.netty.filter.NettyClientFilter;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
||||||
@ -1,12 +1,11 @@
|
|||||||
package wu.framework.middleground.under.cloud.heartbeat.client.rpc;
|
package wu.framework.lazy.cloud.heartbeat.client.rpc;
|
||||||
|
|
||||||
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
|
|
||||||
import com.wu.framework.database.lazy.web.plus.stereotype.LazyRpc;
|
import com.wu.framework.database.lazy.web.plus.stereotype.LazyRpc;
|
||||||
import com.wu.framework.response.Result;
|
import com.wu.framework.response.Result;
|
||||||
import com.wu.framework.response.ResultFactory;
|
import com.wu.framework.response.ResultFactory;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.ChannelContext;
|
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
|
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
|
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common;
|
package wu.framework.lazy.cloud.heartbeat.common;
|
||||||
|
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelId;
|
import io.netty.channel.ChannelId;
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common;
|
package wu.framework.lazy.cloud.heartbeat.common;
|
||||||
|
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
@ -1,9 +1,11 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common;
|
package wu.framework.lazy.cloud.heartbeat.common;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelHeartbeatTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelHeartbeatTypeAdvanced;
|
||||||
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.*;
|
||||||
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.*;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.*;
|
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.*;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.*;
|
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.*;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @see MessageTypeEnums
|
* @see MessageTypeEnums
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common;
|
package wu.framework.lazy.cloud.heartbeat.common;
|
||||||
|
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
|
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common;
|
package wu.framework.lazy.cloud.heartbeat.common;
|
||||||
|
|
||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
import lombok.Setter;
|
import lombok.Setter;
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common;
|
package wu.framework.lazy.cloud.heartbeat.common;
|
||||||
|
|
||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
import lombok.Setter;
|
import lombok.Setter;
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common;
|
package wu.framework.lazy.cloud.heartbeat.common;
|
||||||
|
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
|
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common;
|
package wu.framework.lazy.cloud.heartbeat.common;
|
||||||
|
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
|
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common;
|
package wu.framework.lazy.cloud.heartbeat.common;
|
||||||
|
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
|
|
||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.adapter;
|
package wu.framework.lazy.cloud.heartbeat.common.adapter;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|
||||||
@ -1,8 +1,8 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced;
|
||||||
|
|
||||||
|
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
@ -1,8 +1,8 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.client;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.client;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.client;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.client;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 下发 客户端连接成功通知
|
* 下发 客户端连接成功通知
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.client;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.client;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 下发客户端断开连接通知
|
* 下发客户端断开连接通知
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.client;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.client;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 下发 客户端代理的真实端口自动读写
|
* 下发 客户端代理的真实端口自动读写
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.client;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.client;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 下发 客户端关闭代理服务通道
|
* 下发 客户端关闭代理服务通道
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.client;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.client;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 下发 客户端 创建真实连接
|
* 下发 客户端 创建真实连接
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.client;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.client;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 下发 客户端暂存关闭
|
* 下发 客户端暂存关闭
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.client;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.client;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 下发 客户端暂存开启
|
* 下发 客户端暂存开启
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.server;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.server;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.server;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.server;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 客户端连接成功上报处理器
|
* 客户端连接成功上报处理器
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.server;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.server;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 客户端上报断开连接通知
|
* 客户端上报断开连接通知
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.server;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.server;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.server;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.server;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.server;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.server;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 客户端暂存通知
|
* 客户端暂存通知
|
||||||
@ -14,7 +14,7 @@ import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
|||||||
* 客户端上报暂存
|
* 客户端上报暂存
|
||||||
*/
|
*/
|
||||||
|
|
||||||
public abstract class AbstractReportStagingClosedTypeAdvanced<MSG> extends AbstractChannelTypeAdvanced<NettyProxyMsg> implements ChannelTypeAdvanced{
|
public abstract class AbstractReportStagingClosedTypeAdvanced<MSG> extends AbstractChannelTypeAdvanced<NettyProxyMsg> implements ChannelTypeAdvanced {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 是否支持当前类型
|
* 是否支持当前类型
|
||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.advanced.server;
|
package wu.framework.lazy.cloud.heartbeat.common.advanced.server;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.MessageTypeEnums;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 上报客户端暂存开启
|
* 上报客户端暂存开启
|
||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.constant;
|
package wu.framework.lazy.cloud.heartbeat.common.constant;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 客户端配置 key 常量
|
* 客户端配置 key 常量
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.constant;
|
package wu.framework.lazy.cloud.heartbeat.common.constant;
|
||||||
|
|
||||||
import io.netty.util.AttributeKey;
|
import io.netty.util.AttributeKey;
|
||||||
|
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.constant;
|
package wu.framework.lazy.cloud.heartbeat.common.constant;
|
||||||
|
|
||||||
public class ProxyConfigConstant {
|
public class ProxyConfigConstant {
|
||||||
public static final String PREFIX ="spring.lazy.proxy";
|
public static final String PREFIX ="spring.lazy.proxy";
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.constant;
|
package wu.framework.lazy.cloud.heartbeat.common.constant;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* redis 通道
|
* redis 通道
|
||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.decoder;
|
package wu.framework.lazy.cloud.heartbeat.common.decoder;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyMsg;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
|
import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
|
||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.decoder;
|
package wu.framework.lazy.cloud.heartbeat.common.decoder;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.handler.codec.ByteToMessageDecoder;
|
import io.netty.handler.codec.ByteToMessageDecoder;
|
||||||
@ -1,7 +1,7 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.encoder;
|
package wu.framework.lazy.cloud.heartbeat.common.encoder;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.handler.codec.MessageToByteEncoder;
|
import io.netty.handler.codec.MessageToByteEncoder;
|
||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.encoder;
|
package wu.framework.lazy.cloud.heartbeat.common.encoder;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.handler.codec.MessageToByteEncoder;
|
import io.netty.handler.codec.MessageToByteEncoder;
|
||||||
@ -1,9 +1,11 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.enums;
|
package wu.framework.lazy.cloud.heartbeat.common.enums;
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
import lombok.AllArgsConstructor;
|
||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelHeartbeatTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelHeartbeatTypeAdvanced;
|
||||||
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.client.*;
|
||||||
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.*;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.*;
|
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.*;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.*;
|
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.*;
|
||||||
|
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.enums;
|
package wu.framework.lazy.cloud.heartbeat.common.enums;
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
import lombok.AllArgsConstructor;
|
||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.state;
|
package wu.framework.lazy.cloud.heartbeat.common.state;
|
||||||
|
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
|
|
||||||
@ -1,4 +1,4 @@
|
|||||||
package wu.framework.middleground.cloud.heartbeat.common.utils;
|
package wu.framework.lazy.cloud.heartbeat.common.utils;
|
||||||
|
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.util.AttributeKey;
|
import io.netty.util.AttributeKey;
|
||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.impl;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.impl;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
import wu.framework.lazy.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler.InternalNetworkPenetrationMappingDTOAssembler;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler.InternalNetworkPenetrationMappingDTOAssembler;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
|
||||||
|
|||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.impl;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.impl;
|
||||||
|
|
||||||
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
|
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.ChannelContext;
|
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler.NettyClientBlacklistDTOAssembler;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler.NettyClientBlacklistDTOAssembler;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
|
||||||
|
|||||||
@ -2,8 +2,8 @@ package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.i
|
|||||||
|
|
||||||
|
|
||||||
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
|
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.constant.ClientConfigKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.constant.ClientConfigKeyUtils;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
|
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
|
||||||
|
|||||||
@ -13,10 +13,10 @@ import org.springframework.web.bind.annotation.GetMapping;
|
|||||||
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.PathVariable;
|
||||||
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.PostMapping;
|
||||||
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestBody;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.ChannelContext;
|
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
import wu.framework.lazy.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
|
|
||||||
import java.nio.charset.StandardCharsets;
|
import java.nio.charset.StandardCharsets;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
import com.wu.framework.inner.lazy.stereotype.*;
|
import com.wu.framework.inner.lazy.stereotype.*;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.enums.NettyClientStatus;
|
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||||
import io.swagger.v3.oas.annotations.media.Schema;
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.experimental.Accessors;
|
import lombok.experimental.Accessors;
|
||||||
|
|||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.AbstractChannelHeartbeatTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.AbstractChannelHeartbeatTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
|||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyRealIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyRealIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.AbstractReportChannelTransferTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.AbstractReportChannelTransferTypeAdvanced;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|||||||
@ -2,11 +2,11 @@ package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advance
|
|||||||
|
|
||||||
|
|
||||||
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSON;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.ChannelContext;
|
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.AbstractReportConnectSuccessTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.AbstractReportConnectSuccessTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
|
||||||
|
|||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||||
|
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.ChannelContext;
|
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.AbstractReportDisconnectTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.AbstractReportDisconnectTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelId;
|
import io.netty.channel.ChannelId;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyCommunicationIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyRealIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyRealIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.AbstractReportSingleClientCloseVisitorTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.AbstractReportSingleClientCloseVisitorTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|||||||
@ -1,10 +1,10 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyCommunicationIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyRealIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyRealIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.AbstractReportSingleClientRealConnectTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.AbstractReportSingleClientRealConnectTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelOption;
|
import io.netty.channel.ChannelOption;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|||||||
@ -1,10 +1,10 @@
|
|||||||
|
|
||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.ChannelContext;
|
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.AbstractReportStagingClosedTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.AbstractReportStagingClosedTypeAdvanced;
|
||||||
|
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelId;
|
import io.netty.channel.ChannelId;
|
||||||
|
|||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.ChannelContext;
|
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.AbstractReportStagingOpenedTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.AbstractReportStagingOpenedTypeAdvanced;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelId;
|
import io.netty.channel.ChannelId;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|||||||
@ -1,9 +1,9 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.decoder.NettyProxyMsgDecoder;
|
import wu.framework.lazy.cloud.heartbeat.common.decoder.NettyProxyMsgDecoder;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.encoder.NettyProxyMsgEncoder;
|
import wu.framework.lazy.cloud.heartbeat.common.encoder.NettyProxyMsgEncoder;
|
||||||
import io.netty.channel.ChannelInitializer;
|
import io.netty.channel.ChannelInitializer;
|
||||||
import io.netty.channel.ChannelPipeline;
|
import io.netty.channel.ChannelPipeline;
|
||||||
import io.netty.channel.socket.SocketChannel;
|
import io.netty.channel.socket.SocketChannel;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
import wu.framework.lazy.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
||||||
import io.netty.channel.*;
|
import io.netty.channel.*;
|
||||||
import io.netty.channel.socket.SocketChannel;
|
import io.netty.channel.socket.SocketChannel;
|
||||||
import wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler.VisitorHandler;
|
import wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler.VisitorHandler;
|
||||||
|
|||||||
@ -1,11 +1,11 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.MessageType;
|
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyCommunicationIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyProxyMsg;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyRealIdContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyRealIdContext;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||||
import io.netty.channel.*;
|
import io.netty.channel.*;
|
||||||
import io.netty.handler.timeout.IdleState;
|
import io.netty.handler.timeout.IdleState;
|
||||||
import io.netty.handler.timeout.IdleStateEvent;
|
import io.netty.handler.timeout.IdleStateEvent;
|
||||||
|
|||||||
@ -2,8 +2,9 @@ package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
import wu.framework.lazy.cloud.heartbeat.common.*;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.*;
|
import wu.framework.middleground.cloud.heartbeat.common.*;
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.socket;
|
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.socket;
|
||||||
|
|
||||||
import wu.framework.middleground.cloud.heartbeat.common.NettyVisitorContext;
|
import wu.framework.lazy.cloud.heartbeat.common.NettyVisitorContext;
|
||||||
import io.netty.bootstrap.ServerBootstrap;
|
import io.netty.bootstrap.ServerBootstrap;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user