mirror of
https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git
synced 2025-06-06 21:37:56 +08:00
fix
This commit is contained in:
wujiawei
parent
3f63d7f595
commit
902aaaef63
@ -1,9 +1,9 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application;
|
||||
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.internal.network.penetration.mapping.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.InternalNetworkPenetrationMappingDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
|
||||
import com.wu.framework.response.Result;
|
||||
|
||||
|
||||
@ -1,8 +1,8 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.blacklist.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyClientBlacklistDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
|
||||
import com.wu.framework.response.Result;
|
||||
|
||||
|
||||
@ -1,11 +1,11 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application;
|
||||
|
||||
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
|
||||
import com.wu.framework.response.Result;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyClientStateDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state.NettyClientState;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application;
|
||||
|
||||
/**
|
||||
* 云下心跳客户端操作nacos 配置
|
||||
|
||||
@ -1,8 +1,8 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.assembler;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.internal.network.penetration.mapping.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.InternalNetworkPenetrationMappingDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import org.mapstruct.Mapper;
|
||||
import org.mapstruct.factory.Mappers;
|
||||
/**
|
||||
|
||||
@ -1,8 +1,8 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.assembler;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.blacklist.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyClientBlacklistDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import org.mapstruct.Mapper;
|
||||
import org.mapstruct.factory.Mappers;
|
||||
/**
|
||||
|
||||
@ -1,8 +1,8 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.assembler;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyClientStateDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state.NettyClientState;
|
||||
import org.mapstruct.Mapper;
|
||||
import org.mapstruct.factory.Mappers;
|
||||
/**
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.internal.network.penetration.mapping;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.internal.network.penetration.mapping;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.internal.network.penetration.mapping;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.internal.network.penetration.mapping;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.internal.network.penetration.mapping;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.blacklist;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.blacklist;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.blacklist;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.blacklist;
|
||||
|
||||
|
||||
import com.wu.framework.response.mark.ValidType;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.blacklist;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.dto;
|
||||
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelId;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.dto;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.dto;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.dto;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,20 +1,20 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.impl;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.impl;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler.InternalNetworkPenetrationMappingDTOAssembler;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO;
|
||||
import wu.framework.lazy.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.InternalNetworkPenetrationMappingRepository;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.InternalNetworkPenetrationMappingApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.assembler.InternalNetworkPenetrationMappingDTOAssembler;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.internal.network.penetration.mapping.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.InternalNetworkPenetrationMappingDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.internal.network.penetration.mapping.InternalNetworkPenetrationMappingRepository;
|
||||
|
||||
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.response.Result;
|
||||
import com.wu.framework.response.ResultFactory;
|
||||
import jakarta.annotation.Resource;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter.VisitorFilter;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.socket.NettyVisitorSocket;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.netty.filter.VisitorFilter;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.netty.socket.NettyVisitorSocket;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
@ -1,15 +1,15 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.impl;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.impl;
|
||||
|
||||
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.MessageType;
|
||||
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler.NettyClientBlacklistDTOAssembler;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklistRepository;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.NettyClientBlacklistApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.assembler.NettyClientBlacklistDTOAssembler;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.blacklist.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyClientBlacklistDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist.NettyClientBlacklistRepository;
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
|
||||
import com.wu.framework.response.Result;
|
||||
import io.netty.channel.Channel;
|
||||
|
||||
@ -1,14 +1,14 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.impl;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.impl;
|
||||
|
||||
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.NettyClientStateApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.assembler.NettyClientStateDTOAssembler;
|
||||
import wu.framework.lazy.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.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientStateRepository;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.NettyClientStateApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.assembler.NettyClientStateDTOAssembler;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state.NettyClientStateStoryCommand;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyClientStateDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state.NettyClientStateRepository;
|
||||
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.response.Result;
|
||||
|
||||
@ -1,13 +1,13 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.application.impl;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.application.impl;
|
||||
|
||||
|
||||
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.enums.NettyClientStatus;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientStateRepository;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.ServerNettyConfigApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state.NettyClientStateRepository;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
|
||||
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.controller;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.controller;
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,10 +1,10 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.controller;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.controller;
|
||||
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.internal.network.penetration.mapping.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.InternalNetworkPenetrationMappingDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.InternalNetworkPenetrationMappingApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.internal.network.penetration.mapping.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.InternalNetworkPenetrationMappingDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import com.wu.framework.inner.layer.web.EasyController;
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
|
||||
import com.wu.framework.response.Result;
|
||||
|
||||
@ -1,10 +1,10 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.controller;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.controller;
|
||||
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.blacklist.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientBlacklistDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.NettyClientBlacklistApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.blacklist.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyClientBlacklistDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import com.wu.framework.inner.layer.web.EasyController;
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
|
||||
import com.wu.framework.response.Result;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.controller;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.controller;
|
||||
|
||||
|
||||
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 jakarta.annotation.Resource;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.NettyClientStateApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.command.netty.client.state.*;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.dto.NettyClientStateDTO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.NettyClientStateApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.command.netty.client.state.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.dto.NettyClientStateDTO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state.NettyClientState;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
|
||||
@ -1,9 +1,9 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.converter;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import org.mapstruct.Mapper;
|
||||
import org.mapstruct.factory.Mappers;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.InternalNetworkPenetrationMappingDO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity.InternalNetworkPenetrationMappingDO;
|
||||
/**
|
||||
* describe 内网穿透映射
|
||||
*
|
||||
|
||||
@ -1,10 +1,10 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.converter;
|
||||
|
||||
|
||||
import org.mapstruct.Mapper;
|
||||
import org.mapstruct.factory.Mappers;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientBlacklistDO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.*;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity.NettyClientBlacklistDO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist.*;
|
||||
|
||||
/**
|
||||
* describe 客户端黑名单
|
||||
|
||||
@ -1,7 +1,7 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.converter;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientStateDO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity.NettyClientStateDO;
|
||||
import org.mapstruct.Mapper;
|
||||
import org.mapstruct.factory.Mappers;
|
||||
/**
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity;
|
||||
|
||||
import com.wu.framework.inner.lazy.stereotype.*;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity;
|
||||
|
||||
import com.wu.framework.inner.lazy.stereotype.*;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||
import com.wu.framework.inner.lazy.stereotype.*;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.mapper;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.mapper;
|
||||
|
||||
/**
|
||||
* describe 内网穿透映射
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.mapper;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.mapper;
|
||||
|
||||
/**
|
||||
* describe 客户端黑名单
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.mapper;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.mapper;
|
||||
|
||||
/**
|
||||
* describe 客户端状态
|
||||
|
||||
@ -1,9 +1,9 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.persistence;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.persistence;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter.InternalNetworkPenetrationMappingConverter;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.InternalNetworkPenetrationMappingDO;
|
||||
import wu.framework.lazy.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.InternalNetworkPenetrationMappingRepository;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.converter.InternalNetworkPenetrationMappingConverter;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity.InternalNetworkPenetrationMappingDO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.internal.network.penetration.mapping.InternalNetworkPenetrationMapping;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.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.stream.lambda.LazyLambdaStream;
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.wrapper.LazyWrappers;
|
||||
|
||||
@ -1,9 +1,9 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.persistence;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.persistence;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter.NettyClientBlacklistConverter;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientBlacklistDO;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklistRepository;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.converter.NettyClientBlacklistConverter;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity.NettyClientBlacklistDO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.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.stream.lambda.LazyLambdaStream;
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.stream.wrapper.LazyWrappers;
|
||||
|
||||
@ -1,8 +1,8 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.persistence;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.infrastructure.persistence;
|
||||
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.converter.NettyClientStateConverter;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state.NettyClientStateRepository;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.converter.NettyClientStateConverter;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state.NettyClientState;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.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.stream.lambda.LazyLambdaStream;
|
||||
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 jakarta.annotation.Resource;
|
||||
import org.springframework.stereotype.Repository;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.infrastructure.entity.NettyClientStateDO;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.infrastructure.entity.NettyClientStateDO;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.model.internal.network.penetration.mapping;
|
||||
|
||||
import com.wu.framework.inner.lazy.stereotype.LazyTableField;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.internal.network.penetration.mapping;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.model.internal.network.penetration.mapping;
|
||||
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
|
||||
import com.wu.framework.response.Result;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist;
|
||||
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import lombok.Data;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist;
|
||||
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
|
||||
import com.wu.framework.response.Result;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.enums.NettyClientStatus;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.state;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.model.netty.client.state;
|
||||
|
||||
import com.wu.framework.inner.lazy.database.expand.database.persistence.domain.LazyPage;
|
||||
import com.wu.framework.response.Result;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.advanced;
|
||||
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.advanced;
|
||||
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.advanced;
|
||||
|
||||
|
||||
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.advanced.server.AbstractReportConnectSuccessTypeAdvanced;
|
||||
import wu.framework.lazy.cloud.heartbeat.common.utils.ChannelAttributeKeyUtils;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.InternalNetworkPenetrationMappingApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.NettyClientBlacklistApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.InternalNetworkPenetrationMappingApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.NettyClientBlacklistApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.ServerNettyConfigApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.model.netty.client.blacklist.NettyClientBlacklist;
|
||||
import io.netty.channel.Channel;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.advanced;
|
||||
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||
@ -9,7 +9,7 @@ import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelId;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Component;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.ServerNettyConfigApplication;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.advanced;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
|
||||
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.advanced;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
|
||||
import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg;
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.advanced;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||
@ -10,7 +10,7 @@ import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelId;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Component;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.ServerNettyConfigApplication;
|
||||
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.util.List;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.advanced;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.advanced;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.ChannelContext;
|
||||
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||
@ -8,7 +8,7 @@ import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelId;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Component;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.application.ServerNettyConfigApplication;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.application.ServerNettyConfigApplication;
|
||||
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.util.List;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.config;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.config;
|
||||
|
||||
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
@ -6,8 +6,8 @@ import org.springframework.boot.CommandLineRunner;
|
||||
import org.springframework.boot.autoconfigure.web.ServerProperties;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter.NettyServerFilter;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.socket.NettyOnCloudNettyServerSocket;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.netty.filter.NettyServerFilter;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.netty.socket.NettyOnCloudNettyServerSocket;
|
||||
|
||||
import java.util.concurrent.ArrayBlockingQueue;
|
||||
import java.util.concurrent.ThreadPoolExecutor;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.filter;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter;
|
||||
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.timeout.IdleStateHandler;
|
||||
import org.springframework.stereotype.Component;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler.NettyServerHandler;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.netty.handler.NettyServerHandler;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
@ -1,9 +1,9 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.filter;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.InternalNetworkPenetrationRealClient;
|
||||
import io.netty.channel.*;
|
||||
import io.netty.channel.socket.SocketChannel;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler.VisitorHandler;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.netty.handler.VisitorHandler;
|
||||
|
||||
public class VisitorFilter extends ChannelInitializer<SocketChannel> {
|
||||
private final InternalNetworkPenetrationRealClient internalNetworkPenetrationRealClient;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.handler;
|
||||
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelInboundHandlerAdapter;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.handler;
|
||||
|
||||
import io.netty.bootstrap.ServerBootstrap;
|
||||
import io.netty.channel.*;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.handler;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.MessageType;
|
||||
import wu.framework.lazy.cloud.heartbeat.common.NettyCommunicationIdContext;
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.handler;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.handler;
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.socket;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.socket;
|
||||
|
||||
|
||||
import io.netty.bootstrap.ServerBootstrap;
|
||||
@ -8,7 +8,7 @@ import io.netty.channel.ChannelOption;
|
||||
import io.netty.channel.EventLoopGroup;
|
||||
import io.netty.channel.nio.NioEventLoopGroup;
|
||||
import io.netty.channel.socket.nio.NioServerSocketChannel;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter.NettyServerFilter;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.netty.filter.NettyServerFilter;
|
||||
|
||||
public class NettyOnCloudNettyServerSocket {
|
||||
private final EventLoopGroup bossGroup = new NioEventLoopGroup();
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
package wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.socket;
|
||||
package wu.framework.lazy.cloud.heartbeat.server.netty.socket;
|
||||
|
||||
import wu.framework.lazy.cloud.heartbeat.common.NettyVisitorContext;
|
||||
import io.netty.bootstrap.ServerBootstrap;
|
||||
@ -9,7 +9,7 @@ import io.netty.channel.EventLoopGroup;
|
||||
import io.netty.channel.nio.NioEventLoopGroup;
|
||||
import io.netty.channel.socket.nio.NioServerSocketChannel;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import wu.framework.lazy.on.cloud.heartbeat.server.domain.netty.filter.VisitorFilter;
|
||||
import wu.framework.lazy.cloud.heartbeat.server.netty.filter.VisitorFilter;
|
||||
|
||||
/**
|
||||
* 访客链接socket
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user