This commit is contained in:
wujiawei 2024-01-08 18:49:21 +08:00
parent ef5deb2fcb
commit 3f63d7f595
73 changed files with 159 additions and 161 deletions

View File

@ -3,7 +3,7 @@ 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.client.netty.config.NettyServerProperties;
import wu.framework.lazy.cloud.heartbeat.common.*; import wu.framework.lazy.cloud.heartbeat.common.*;
import wu.framework.middleground.cloud.heartbeat.common.*; import wu.framework.lazy.cloud.heartbeat.common.*;
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter; import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced; import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils; import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;

View File

@ -3,8 +3,8 @@ package wu.framework.lazy.cloud.heartbeat.common;
import wu.framework.lazy.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.client.*;
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.*; import wu.framework.lazy.cloud.heartbeat.common.advanced.server.*;
import wu.framework.middleground.cloud.heartbeat.common.advanced.client.*; import wu.framework.lazy.cloud.heartbeat.common.advanced.client.*;
import wu.framework.middleground.cloud.heartbeat.common.advanced.server.*; import wu.framework.lazy.cloud.heartbeat.common.advanced.server.*;
import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums; import wu.framework.lazy.cloud.heartbeat.common.enums.MessageTypeEnums;
/** /**

View File

@ -6,8 +6,6 @@ import wu.framework.lazy.cloud.heartbeat.common.MessageType;
import wu.framework.lazy.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.client.*;
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.*; 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.server.*;
/** /**
* @see MessageType * @see MessageType

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain; package wu.framework.lazy.cloud.heartbeat.server;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication; import org.springframework.boot.SpringApplication;

View File

@ -1,9 +1,9 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;

View File

@ -1,8 +1,8 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;

View File

@ -1,11 +1,11 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
import java.util.List; import java.util.List;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application;
/** /**
* 云下心跳客户端操作nacos 配置 * 云下心跳客户端操作nacos 配置

View File

@ -1,8 +1,8 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
/** /**

View File

@ -1,8 +1,8 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
/** /**

View File

@ -1,8 +1,8 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
/** /**

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
import com.wu.framework.response.mark.ValidType; import com.wu.framework.response.mark.ValidType;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
import wu.framework.lazy.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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
import wu.framework.lazy.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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
import wu.framework.lazy.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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
import wu.framework.lazy.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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
import wu.framework.lazy.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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import io.netty.channel.ChannelId; import io.netty.channel.ChannelId;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto;
import wu.framework.lazy.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;

View File

@ -1,20 +1,20 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.impl; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.impl;
import wu.framework.lazy.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.lazy.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler.InternalNetworkPenetrationMappingDTOAssembler; import wu.framework.lazy.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.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMappingRepository; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMappingRepository;
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
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 jakarta.annotation.Resource; import jakarta.annotation.Resource;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter.VisitorFilter; import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter.VisitorFilter;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.socket.NettyVisitorSocket; import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.socket.NettyVisitorSocket;
import java.util.List; import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;

View File

@ -1,15 +1,15 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.impl; package wu.framework.lazy.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.lazy.cloud.heartbeat.common.ChannelContext; import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
import wu.framework.lazy.cloud.heartbeat.common.MessageType; import wu.framework.lazy.cloud.heartbeat.common.MessageType;
import wu.framework.lazy.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.lazy.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler.NettyClientBlacklistDTOAssembler; import wu.framework.lazy.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.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklistRepository; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklistRepository;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;
import io.netty.channel.Channel; import io.netty.channel.Channel;

View File

@ -1,14 +1,14 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.impl; package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.impl;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.NettyClientStateApplication; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.NettyClientStateApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.assembler.NettyClientStateDTOAssembler; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler.NettyClientStateDTOAssembler;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state.NettyClientStateStoryCommand; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state.NettyClientStateStoryCommand;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientStateRepository; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientStateRepository;
import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; import com.wu.framework.database.lazy.web.plus.stereotype.LazyApplication;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;

View File

@ -1,13 +1,13 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.application.impl; package wu.framework.lazy.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.lazy.cloud.heartbeat.common.constant.ClientConfigKeyUtils; import wu.framework.lazy.cloud.heartbeat.common.constant.ClientConfigKeyUtils;
import wu.framework.lazy.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.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientStateRepository; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientStateRepository;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.controller; package wu.framework.lazy.on.cloud.heartbeat.server.domain.controller;

View File

@ -1,10 +1,10 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.controller; package wu.framework.lazy.on.cloud.heartbeat.server.domain.controller;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
import com.wu.framework.inner.layer.web.EasyController; import com.wu.framework.inner.layer.web.EasyController;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;

View File

@ -1,10 +1,10 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.controller; package wu.framework.lazy.on.cloud.heartbeat.server.domain.controller;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
import com.wu.framework.inner.layer.web.EasyController; import com.wu.framework.inner.layer.web.EasyController;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.controller; package wu.framework.lazy.on.cloud.heartbeat.server.domain.controller;
import com.wu.framework.inner.layer.web.EasyController; import com.wu.framework.inner.layer.web.EasyController;
@ -9,10 +9,10 @@ import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.NettyClientStateApplication; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.NettyClientStateApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
import java.util.List; import java.util.List;

View File

@ -1,9 +1,9 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.converter; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity.InternalNetworkPenetrationMappingDO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.InternalNetworkPenetrationMappingDO;
/** /**
* describe 内网穿透映射 * describe 内网穿透映射
* *

View File

@ -1,10 +1,10 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.converter; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientBlacklistDO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientBlacklistDO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.*; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.*;
/** /**
* describe 客户端黑名单 * describe 客户端黑名单

View File

@ -1,7 +1,7 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.converter; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientStateDO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientStateDO;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
/** /**

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity;
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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity;
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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity;
import wu.framework.lazy.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.*;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.mapper; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.mapper;
/** /**
* describe 内网穿透映射 * describe 内网穿透映射

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.mapper; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.mapper;
/** /**
* describe 客户端黑名单 * describe 客户端黑名单

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.mapper; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.mapper;
/** /**
* describe 客户端状态 * describe 客户端状态

View File

@ -1,9 +1,9 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.persistence; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.persistence;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.converter.InternalNetworkPenetrationMappingConverter; import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter.InternalNetworkPenetrationMappingConverter;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity.InternalNetworkPenetrationMappingDO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.InternalNetworkPenetrationMappingDO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMappingRepository; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMappingRepository;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.lambda.LazyLambdaStream; import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.lambda.LazyLambdaStream;
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.wrapper.LazyWrappers; import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.wrapper.LazyWrappers;

View File

@ -1,9 +1,9 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.persistence; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.persistence;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.converter.NettyClientBlacklistConverter; import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter.NettyClientBlacklistConverter;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientBlacklistDO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientBlacklistDO;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklistRepository; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklistRepository;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.lambda.LazyLambdaStream; import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.lambda.LazyLambdaStream;
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.wrapper.LazyWrappers; import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.wrapper.LazyWrappers;

View File

@ -1,8 +1,8 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.persistence; package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.persistence;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.converter.NettyClientStateConverter; import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter.NettyClientStateConverter;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientStateRepository; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientStateRepository;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.lambda.LazyLambdaStream; import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.lambda.LazyLambdaStream;
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.wrapper.LazyWrappers; import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.wrapper.LazyWrappers;
@ -10,7 +10,7 @@ import com.wu.framework.response.Result;
import com.wu.framework.response.ResultFactory; import com.wu.framework.response.ResultFactory;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientStateDO; import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientStateDO;
import java.util.List; import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping; package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping;
import com.wu.framework.inner.lazy.stereotype.LazyTableField; import com.wu.framework.inner.lazy.stereotype.LazyTableField;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping; package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist; package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist; package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state; package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state;
import wu.framework.lazy.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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.state; package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state;
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage; import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
import com.wu.framework.response.Result; import com.wu.framework.response.Result;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
import wu.framework.lazy.cloud.heartbeat.common.MessageType; import wu.framework.lazy.cloud.heartbeat.common.MessageType;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg; import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
@ -7,10 +7,10 @@ import wu.framework.lazy.cloud.heartbeat.common.MessageType;
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg; import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
import wu.framework.lazy.cloud.heartbeat.common.advanced.server.AbstractReportConnectSuccessTypeAdvanced; import wu.framework.lazy.cloud.heartbeat.common.advanced.server.AbstractReportConnectSuccessTypeAdvanced;
import wu.framework.lazy.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.lazy.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist; import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext; import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
@ -9,7 +9,7 @@ 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;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
import java.util.List; import java.util.List;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext; import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg; import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext; import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg; import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;

View File

@ -1,5 +1,5 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext; import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
import wu.framework.lazy.cloud.heartbeat.common.MessageType; import wu.framework.lazy.cloud.heartbeat.common.MessageType;
@ -10,7 +10,7 @@ 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;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.List; import java.util.List;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.advanced; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext; import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
import wu.framework.lazy.cloud.heartbeat.common.MessageType; import wu.framework.lazy.cloud.heartbeat.common.MessageType;
@ -8,7 +8,7 @@ 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;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication; import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.List; import java.util.List;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.config; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.config;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -6,8 +6,8 @@ import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.autoconfigure.web.ServerProperties; import org.springframework.boot.autoconfigure.web.ServerProperties;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter.NettyServerFilter; import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter.NettyServerFilter;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.socket.NettyOnCloudNettyServerSocket; import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.socket.NettyOnCloudNettyServerSocket;
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter;
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter; import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced; import wu.framework.lazy.cloud.heartbeat.common.advanced.ChannelTypeAdvanced;
@ -11,7 +11,7 @@ import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder; import io.netty.handler.codec.string.StringEncoder;
import io.netty.handler.timeout.IdleStateHandler; import io.netty.handler.timeout.IdleStateHandler;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler.NettyServerHandler; import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler.NettyServerHandler;
import java.util.List; import java.util.List;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;

View File

@ -1,9 +1,9 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter;
import wu.framework.lazy.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.lazy.on.cloud.heartbeat.server.domain.netty.handler.VisitorHandler;
public class VisitorFilter extends ChannelInitializer<SocketChannel> { public class VisitorFilter extends ChannelInitializer<SocketChannel> {
private final InternalNetworkPenetrationRealClient internalNetworkPenetrationRealClient; private final InternalNetworkPenetrationRealClient internalNetworkPenetrationRealClient;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler;
import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.channel.ChannelInboundHandlerAdapter;

View File

@ -13,7 +13,7 @@
* License for the specific language governing permissions and limitations * License for the specific language governing permissions and limitations
* under the License. * under the License.
*/ */
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler;
import io.netty.bootstrap.ServerBootstrap; import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*; import io.netty.channel.*;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler;
import wu.framework.lazy.cloud.heartbeat.common.MessageType; import wu.framework.lazy.cloud.heartbeat.common.MessageType;
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext; import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;

View File

@ -1,9 +1,9 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.handler; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler;
import wu.framework.lazy.cloud.heartbeat.common.*; import wu.framework.lazy.cloud.heartbeat.common.*;
import wu.framework.middleground.cloud.heartbeat.common.*; import wu.framework.lazy.cloud.heartbeat.common.*;
import wu.framework.lazy.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;

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.socket; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.socket;
import io.netty.bootstrap.ServerBootstrap; import io.netty.bootstrap.ServerBootstrap;
@ -8,7 +8,7 @@ import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup; import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel; import io.netty.channel.socket.nio.NioServerSocketChannel;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter.NettyServerFilter; import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter.NettyServerFilter;
public class NettyOnCloudNettyServerSocket { public class NettyOnCloudNettyServerSocket {
private final EventLoopGroup bossGroup = new NioEventLoopGroup(); private final EventLoopGroup bossGroup = new NioEventLoopGroup();

View File

@ -1,4 +1,4 @@
package wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.socket; package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.socket;
import wu.framework.lazy.cloud.heartbeat.common.NettyVisitorContext; import wu.framework.lazy.cloud.heartbeat.common.NettyVisitorContext;
import io.netty.bootstrap.ServerBootstrap; import io.netty.bootstrap.ServerBootstrap;
@ -9,7 +9,7 @@ import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel; import io.netty.channel.socket.nio.NioServerSocketChannel;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import wu.framework.middleground.on.cloud.heartbeat.server.domain.netty.filter.VisitorFilter; import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter.VisitorFilter;
/** /**
* 访客链接socket * 访客链接socket