diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyServerPermeateServerConnectVisitorSocket.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyServerPermeateServerConnectVisitorSocket.java index 8a0af85..3b8ea66 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyServerPermeateServerConnectVisitorSocket.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyServerPermeateServerConnectVisitorSocket.java @@ -68,10 +68,10 @@ public class NettyServerPermeateServerConnectVisitorSocket { sync.addListener((ChannelFutureListener) future -> { if (future.isSuccess()) { // 这里时异步处理 - log.info("内网渗透服务端端口:[{}] 开启", visitorPort); + log.info("服务端渗透服务端:[{}] 开启", visitorPort); } else { - log.error("内网渗透服务端端口:[{}] 开启失败", visitorPort); + log.error("服务端渗透服务端:[{}] 开启失败", visitorPort); } }); NettyServerPermeateServerVisitorContext.pushServerPermeateServerVisitorSocket(visitorPort,this); diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkServerPermeateClientMappingApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkServerPermeateClientMappingApplicationImpl.java index 5ec5983..2758700 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkServerPermeateClientMappingApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkServerPermeateClientMappingApplicationImpl.java @@ -1,24 +1,24 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application.impl; +import jakarta.annotation.Resource; +import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.NettyClientVisitorContext; +import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelFlowAdapter; import org.framework.lazy.cloud.network.heartbeat.server.netty.socket.NettyServerPermeateClientVisitorSocket; import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.LazyInternalNetworkServerPermeateClientMappingApplication; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.assembler.InternalNetworkPenetrationMappingDTOAssembler; import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.server.permeate.client.mapping.*; +import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkPenetrationMappingDTO; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.client.mapping.LazyInternalNetworkServerPermeateClientMapping; import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.server.permeate.client.mapping.LazyInternalNetworkServerPermeateClientMappingRepository; -import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkPenetrationMappingDTO; import org.springframework.transaction.annotation.Transactional; import org.wu.framework.core.utils.ObjectUtils; import org.wu.framework.database.lazy.web.plus.stereotype.LazyApplication; +import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplicationImpl; import org.wu.framework.lazy.orm.database.lambda.domain.LazyPage; import org.wu.framework.web.response.Result; import org.wu.framework.web.response.ResultFactory; -import jakarta.annotation.Resource; -import lombok.extern.slf4j.Slf4j; -import org.wu.framework.lazy.orm.core.persistence.reverse.lazy.ddd.DefaultDDDLazyApplicationImpl; -import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelFlowAdapter; import java.util.List; import java.util.stream.Collectors; @@ -277,18 +277,21 @@ public class LazyInternalNetworkServerPermeateClientMappingApplicationImpl imple * @param visitorPort 访客端口 */ private void createVisitor(String clientId, String clientTargetIp, Integer clientTargetPort, Integer visitorPort) { - // 更新 客户端映射 - NettyServerPermeateClientVisitorSocket nettyServerPermeateClientVisitorSocket = NettyServerPermeateClientVisitorSocket.NettyVisitorSocketBuilder - .builder() - .builderClientId(clientId) - .builderClientTargetIp(clientTargetIp) - .builderClientTargetPort(clientTargetPort) - .builderVisitorPort(visitorPort) - .builderChannelFlowAdapter(channelFlowAdapter) - .build(); + + try { + // 更新 客户端映射 + NettyServerPermeateClientVisitorSocket nettyServerPermeateClientVisitorSocket = NettyServerPermeateClientVisitorSocket.NettyVisitorSocketBuilder + .builder() + .builderClientId(clientId) + .builderClientTargetIp(clientTargetIp) + .builderClientTargetPort(clientTargetPort) + .builderVisitorPort(visitorPort) + .builderChannelFlowAdapter(channelFlowAdapter) + .build(); nettyServerPermeateClientVisitorSocket.start(); } catch (Exception e) { + e.printStackTrace(); log.error("客户端:{},网络端口:{},开放失败", clientId, visitorPort); throw new RuntimeException(e); }