diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/InternalNetworkPermeateRealServer.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/InternalNetworkPermeateRealServer.java index bee2638..2245b68 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/InternalNetworkPermeateRealServer.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/InternalNetworkPermeateRealServer.java @@ -32,4 +32,8 @@ public class InternalNetworkPermeateRealServer { * 访问端口 */ private Integer visitorPort; + /** + * 是否是ssl + */ + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/NettyMsg.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/NettyMsg.java index 7f68361..735bd5e 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/NettyMsg.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/NettyMsg.java @@ -5,6 +5,7 @@ import lombok.Setter; import java.util.Arrays; +@Deprecated @Setter @Getter public class NettyMsg { diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/NettyProxyMsg.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/NettyProxyMsg.java index 66fe439..fd76d6a 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/NettyProxyMsg.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/NettyProxyMsg.java @@ -14,7 +14,7 @@ import java.nio.charset.StandardCharsets; @Getter public class NettyProxyMsg { // body 长度 type 1 clientId 4 clientTargetIp 4 clientTargetPort 4 visitorPort 4 visitorId 4 data 4 - public static final int bodyLength = 1 + 4 + 4 + 4 + 4 + 4 + 4; + public static final int bodyLength = 1 + 1 + 4 + 4 + 4 + 4 + 4 + 4; /** @@ -25,6 +25,13 @@ public class NettyProxyMsg { */ private byte type; + /** + * 是否是ssl + * byte 长度 1 + * 1 true + * 0 false + */ + private byte isSsl = 0; /** * 客户端ID * byte[] 长度 4 @@ -110,4 +117,23 @@ public class NettyProxyMsg { } + public Boolean isSsl() { + return isSsl == 1; + } + + public void isSsl(Boolean isSsl) { + if (isSsl) { + this.isSsl = 1; + } else { + this.isSsl = 0; + } + } + + public byte getIsSsl() { + return isSsl; + } + + public void setIsSsl(byte isSsl) { + this.isSsl = isSsl; + } } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/decoder/NettyProxyMsgDecoder.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/decoder/NettyProxyMsgDecoder.java index 5793fdd..a62a966 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/decoder/NettyProxyMsgDecoder.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/decoder/NettyProxyMsgDecoder.java @@ -109,6 +109,8 @@ public class NettyProxyMsgDecoder extends LengthFieldBasedFrameDecoder { int bodyLength = in.readInt(); byte type = in.readByte(); nettyProxyMsg.setType(type); + byte isSsl = in.readByte(); + nettyProxyMsg.setIsSsl(isSsl); int clientIdLength = in.readInt(); byte[] clientIdBytes = new byte[clientIdLength]; diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/encoder/NettyProxyMsgEncoder.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/encoder/NettyProxyMsgEncoder.java index 014f086..ddc7b0f 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/encoder/NettyProxyMsgEncoder.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/encoder/NettyProxyMsgEncoder.java @@ -23,6 +23,7 @@ public class NettyProxyMsgEncoder extends MessageToByteEncoder { // body 长度 type 1 clientId 4 clientTargetIp 4 clientTargetPort 4 visitorPort 4 visitorId 4 data 4 int bodyLength = NettyProxyMsg.bodyLength; byte typeBytes = msg.getType(); + byte isSsl = msg.getIsSsl(); byte[] clientIdBytes = msg.getClientId(); byte[] clientTargetIpBytes = msg.getClientTargetIp(); byte[] clientTargetPortBytes = msg.getClientTargetPort(); @@ -30,7 +31,6 @@ public class NettyProxyMsgEncoder extends MessageToByteEncoder { byte[] visitorIdBytes = msg.getVisitorId(); byte[] msgDataBytes = msg.getData(); - if (clientIdBytes != null) { bodyLength += clientIdBytes.length; } @@ -54,6 +54,7 @@ public class NettyProxyMsgEncoder extends MessageToByteEncoder { out.writeInt(bodyLength); out.writeByte(typeBytes); + out.writeByte(isSsl); // 防止数据读错位置 clientId if (clientIdBytes != null) { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/InitServerPermeateSocket.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/InitServerPermeateSocket.java index b2ce848..7c3b864 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/InitServerPermeateSocket.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/init/InitServerPermeateSocket.java @@ -19,6 +19,10 @@ public class InitServerPermeateSocket implements CommandLineRunner { @Override public void run(String... args) throws Exception { - lazyInternalNetworkServerPermeateMappingApplication.initPermeateSocket(); + try { + lazyInternalNetworkServerPermeateMappingApplication.initPermeateSocket(); + } catch (Exception e) { + e.printStackTrace(); + } } } diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/PermeateClientRealFilter.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/NettyServerPermeateServerRealFilter.java similarity index 61% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/PermeateClientRealFilter.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/NettyServerPermeateServerRealFilter.java index da4321d..2235ede 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/PermeateClientRealFilter.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/filter/NettyServerPermeateServerRealFilter.java @@ -1,13 +1,14 @@ package org.framework.lazy.cloud.network.heartbeat.server.netty.filter; +import io.netty.channel.Channel; import io.netty.channel.ChannelPipeline; import io.netty.channel.socket.SocketChannel; import org.framework.lazy.cloud.network.heartbeat.common.decoder.TransferDecoder; import org.framework.lazy.cloud.network.heartbeat.common.encoder.TransferEncoder; import org.framework.lazy.cloud.network.heartbeat.common.filter.DebugChannelInitializer; -import org.framework.lazy.cloud.network.heartbeat.server.netty.handler.PermeateClientRealHandler; +import org.framework.lazy.cloud.network.heartbeat.server.netty.handler.NettyServerPermeateServerRealHandler; -public class PermeateClientRealFilter extends DebugChannelInitializer { +public class NettyServerPermeateServerRealFilter extends DebugChannelInitializer { /** * This method will be called once the {@link Channel} was registered. After the method returns this instance * will be removed from the {@link ChannelPipeline} of the {@link Channel}. @@ -17,10 +18,18 @@ public class PermeateClientRealFilter extends DebugChannelInitializer { +public class NettyServerPermeateServerVisitorFilter extends DebugChannelInitializer { private final InternalNetworkPermeateRealServer internalNetworkPermeateRealServer; private final ChannelFlowAdapter channelFlowAdapter; - public PermeateVisitorFilter(InternalNetworkPermeateRealServer internalNetworkPermeateRealServer, ChannelFlowAdapter channelFlowAdapter) { + public NettyServerPermeateServerVisitorFilter(InternalNetworkPermeateRealServer internalNetworkPermeateRealServer, ChannelFlowAdapter channelFlowAdapter) { this.internalNetworkPermeateRealServer = internalNetworkPermeateRealServer; this.channelFlowAdapter = channelFlowAdapter; } @@ -32,6 +32,6 @@ public class PermeateVisitorFilter extends DebugChannelInitializer { +public class NettyServerPermeateServerRealHandler extends SimpleChannelInboundHandler { @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/PermeateVisitorHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/NettyServerPermeateServerVisitorHandler.java similarity index 95% rename from wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/PermeateVisitorHandler.java rename to wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/NettyServerPermeateServerVisitorHandler.java index f213867..8dcf869 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/PermeateVisitorHandler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/handler/NettyServerPermeateServerVisitorHandler.java @@ -17,12 +17,12 @@ import org.framework.lazy.cloud.network.heartbeat.server.netty.socket.NettyServe import java.util.UUID; @Slf4j -public class PermeateVisitorHandler extends SimpleChannelInboundHandler { +public class NettyServerPermeateServerVisitorHandler extends SimpleChannelInboundHandler { private final InternalNetworkPermeateRealServer internalNetworkPermeateRealServer; private final ChannelFlowAdapter channelFlowAdapter;// 流量适配器 // private final NettyChannelPool nettyChannelPool = new DefaultNettyChannelPool(10); - public PermeateVisitorHandler(InternalNetworkPermeateRealServer internalNetworkPermeateRealServer, ChannelFlowAdapter channelFlowAdapter) { + public NettyServerPermeateServerVisitorHandler(InternalNetworkPermeateRealServer internalNetworkPermeateRealServer, ChannelFlowAdapter channelFlowAdapter) { this.internalNetworkPermeateRealServer = internalNetworkPermeateRealServer; this.channelFlowAdapter = channelFlowAdapter; } diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyServerPermeateServerConnectRealSocket.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyServerPermeateServerConnectRealSocket.java index 3bb26c7..48fa565 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyServerPermeateServerConnectRealSocket.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/socket/NettyServerPermeateServerConnectRealSocket.java @@ -8,7 +8,7 @@ import io.netty.channel.socket.nio.NioSocketChannel; import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPermeateRealServer; import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils; -import org.framework.lazy.cloud.network.heartbeat.server.netty.filter.PermeateClientRealFilter; +import org.framework.lazy.cloud.network.heartbeat.server.netty.filter.NettyServerPermeateServerRealFilter; import java.util.concurrent.TimeUnit; @@ -50,7 +50,7 @@ public class NettyServerPermeateServerConnectRealSocket { // .option(ChannelOption.SO_BACKLOG, 128)//务端接受连接的队列长度 默认128 // .option(ChannelOption.RCVBUF_ALLOCATOR, new NettyRecvByteBufAllocator(1024 * 1024))//用于Channel分配接受Buffer的分配器 默认AdaptiveRecvByteBufAllocator.DEFAULT .option(ChannelOption.WRITE_BUFFER_WATER_MARK, new WriteBufferWaterMark(1024 * 1024, 1024 * 1024 * 2)) - .handler(new PermeateClientRealFilter()) + .handler(new NettyServerPermeateServerRealFilter()) ; 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 e227655..8b3b8c7 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 @@ -11,7 +11,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.InternalNetworkPermeate import org.framework.lazy.cloud.network.heartbeat.common.NettyPermeateVisitorContext; import org.framework.lazy.cloud.network.heartbeat.common.NettyVisitorPortContext; import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelFlowAdapter; -import org.framework.lazy.cloud.network.heartbeat.server.netty.filter.PermeateVisitorFilter; +import org.framework.lazy.cloud.network.heartbeat.server.netty.filter.NettyServerPermeateServerVisitorFilter; import java.io.IOException; @@ -22,19 +22,16 @@ import java.io.IOException; public class NettyServerPermeateServerConnectVisitorSocket { private final EventLoopGroup bossGroup = new NioEventLoopGroup(); private final EventLoopGroup workerGroup = new NioEventLoopGroup(); - private final PermeateVisitorFilter permeateVisitorFilter; + private final NettyServerPermeateServerVisitorFilter nettyServerPermeateServerVisitorFilter; @Getter private final int visitorPort; - private final InternalNetworkPermeateRealServer internalNetworkPermeateRealServer; - public NettyServerPermeateServerConnectVisitorSocket(PermeateVisitorFilter permeateVisitorFilter, - InternalNetworkPermeateRealServer internalNetworkPermeateRealServer, + public NettyServerPermeateServerConnectVisitorSocket(NettyServerPermeateServerVisitorFilter nettyServerPermeateServerVisitorFilter, int visitorPort) { - this.permeateVisitorFilter = permeateVisitorFilter; + this.nettyServerPermeateServerVisitorFilter = nettyServerPermeateServerVisitorFilter; this.visitorPort = visitorPort; - this.internalNetworkPermeateRealServer = internalNetworkPermeateRealServer; } @@ -66,7 +63,7 @@ public class NettyServerPermeateServerConnectVisitorSocket { .childOption(ChannelOption.WRITE_BUFFER_WATER_MARK, new WriteBufferWaterMark(1024 * 1024, 1024 * 1024 * 2)) - .childHandler(permeateVisitorFilter); + .childHandler(nettyServerPermeateServerVisitorFilter); ChannelFuture sync = bootstrap.bind(visitorPort).sync(); sync.addListener((ChannelFutureListener) future -> { if (future.isSuccess()) { @@ -122,10 +119,11 @@ public class NettyServerPermeateServerConnectVisitorSocket { * 访问端口 */ private Integer permeateVisitorPort; + /** - * 访客ID + * 是否是ssl */ - private String visitorId; + private Boolean isSsl; /** * 流量适配器 @@ -179,6 +177,16 @@ public class NettyServerPermeateServerConnectVisitorSocket { this.channelFlowAdapter = channelFlowAdapter; return this; } + /** + * 是否是ssl + * + * @param isSsl 是否是ssl + * @return 当前对象 + */ + public NettyPermeateVisitorSocketBuilder builderIsSsl(Boolean isSsl) { + this.isSsl = isSsl; + return this; + } public NettyServerPermeateServerConnectVisitorSocket build() { @@ -197,10 +205,11 @@ public class NettyServerPermeateServerConnectVisitorSocket { .clientTargetIp(clientTargetIp) .clientTargetPort(clientTargetPort) .visitorPort(permeateVisitorPort) + .isSsl(isSsl) .build(); - PermeateVisitorFilter permeateVisitorFilter = new PermeateVisitorFilter(internalNetworkPermeateRealServer, channelFlowAdapter); - return new NettyServerPermeateServerConnectVisitorSocket(permeateVisitorFilter, internalNetworkPermeateRealServer, permeateVisitorPort); + NettyServerPermeateServerVisitorFilter nettyServerPermeateServerVisitorFilter = new NettyServerPermeateServerVisitorFilter(internalNetworkPermeateRealServer, channelFlowAdapter); + return new NettyServerPermeateServerConnectVisitorSocket(nettyServerPermeateServerVisitorFilter, permeateVisitorPort); } diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMappingStoryCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMappingStoryCommand.java index 6498d63..36a5cd8 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMappingStoryCommand.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMappingStoryCommand.java @@ -56,4 +56,10 @@ public class LazyInternalNetworkPenetrationMappingStoryCommand { */ @Schema(description = "服务端ID", name = "serverId", example = "") private String serverId; + + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMappingUpdateCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMappingUpdateCommand.java index f76b7b9..c37a7b4 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMappingUpdateCommand.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMappingUpdateCommand.java @@ -61,4 +61,10 @@ public class LazyInternalNetworkPenetrationMappingUpdateCommand { */ @Schema(description = "服务端ID", name = "serverId", example = "") private String serverId; + + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMappingStoryCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMappingStoryCommand.java index 257fe45..3a66af0 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMappingStoryCommand.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMappingStoryCommand.java @@ -98,4 +98,11 @@ public class LazyInternalNetworkClientPermeateClientMappingStoryCommand { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; + } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMappingUpdateCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMappingUpdateCommand.java index dec521e..a35e92a 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMappingUpdateCommand.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMappingUpdateCommand.java @@ -98,4 +98,10 @@ public class LazyInternalNetworkClientPermeateClientMappingUpdateCommand { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; + } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMappingStoryCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMappingStoryCommand.java index c9d6859..02ec6bd 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMappingStoryCommand.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMappingStoryCommand.java @@ -91,4 +91,9 @@ public class LazyInternalNetworkClientPermeateServerMappingStoryCommand { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMappingUpdateCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMappingUpdateCommand.java index d42fff9..8ae84a3 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMappingUpdateCommand.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMappingUpdateCommand.java @@ -91,4 +91,9 @@ public class LazyInternalNetworkClientPermeateServerMappingUpdateCommand { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMappingStoryCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMappingStoryCommand.java index 7a7b982..61e3912 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMappingStoryCommand.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMappingStoryCommand.java @@ -84,4 +84,9 @@ public class LazyInternalNetworkServerPermeateMappingStoryCommand { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMappingUpdateCommand.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMappingUpdateCommand.java index 0110b93..a46936f 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMappingUpdateCommand.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMappingUpdateCommand.java @@ -84,4 +84,9 @@ public class LazyInternalNetworkServerPermeateMappingUpdateCommand { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkClientPermeateClientMappingDTO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkClientPermeateClientMappingDTO.java index 2c1a544..a87520f 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkClientPermeateClientMappingDTO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkClientPermeateClientMappingDTO.java @@ -98,4 +98,9 @@ public class LazyInternalNetworkClientPermeateClientMappingDTO { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkClientPermeateServerMappingDTO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkClientPermeateServerMappingDTO.java index c5a736d..b4dd8e1 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkClientPermeateServerMappingDTO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkClientPermeateServerMappingDTO.java @@ -91,4 +91,9 @@ public class LazyInternalNetworkClientPermeateServerMappingDTO { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkPenetrationMappingDTO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkPenetrationMappingDTO.java index 1d6b6cd..ec871ca 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkPenetrationMappingDTO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkPenetrationMappingDTO.java @@ -79,4 +79,10 @@ public class LazyInternalNetworkPenetrationMappingDTO { */ @Schema(description = "服务端ID", name = "serverId", example = "") private String serverId; + + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkServerPermeateMappingDTO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkServerPermeateMappingDTO.java index 1b03214..31f4954 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkServerPermeateMappingDTO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyInternalNetworkServerPermeateMappingDTO.java @@ -84,4 +84,9 @@ public class LazyInternalNetworkServerPermeateMappingDTO { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkServerPermeateMappingApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkServerPermeateMappingApplicationImpl.java index 8fe0d76..92320d6 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkServerPermeateMappingApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyInternalNetworkServerPermeateMappingApplicationImpl.java @@ -59,7 +59,8 @@ public class LazyInternalNetworkServerPermeateMappingApplicationImpl implements String permeateTargetIp = lazyInternalNetworkServerPermeateMapping.getPermeateTargetIp(); Integer permeateTargetPort = lazyInternalNetworkServerPermeateMapping.getPermeateTargetPort(); Integer visitorPort = lazyInternalNetworkServerPermeateMapping.getVisitorPort(); - this.changePermeateSocket(permeateTargetIp, permeateTargetPort, visitorPort); + Boolean isSsl = lazyInternalNetworkServerPermeateMapping.getIsSsl(); + this.changePermeateSocket(permeateTargetIp, permeateTargetPort, visitorPort,isSsl); return lazyInternalNetworkServerPermeateMappingRepository.story(lazyInternalNetworkServerPermeateMapping); } @@ -82,7 +83,8 @@ public class LazyInternalNetworkServerPermeateMappingApplicationImpl implements String permeateTargetIp = lazyInternalNetworkServerPermeateMapping.getPermeateTargetIp(); Integer permeateTargetPort = lazyInternalNetworkServerPermeateMapping.getPermeateTargetPort(); Integer visitorPort = lazyInternalNetworkServerPermeateMapping.getVisitorPort(); - this.changePermeateSocket(permeateTargetIp, permeateTargetPort, visitorPort); + Boolean isSsl = lazyInternalNetworkServerPermeateMapping.getIsSsl(); + this.changePermeateSocket(permeateTargetIp, permeateTargetPort, visitorPort,isSsl); } return lazyInternalNetworkServerPermeateMappingRepository.batchStory(lazyInternalNetworkServerPermeateMappingList); } @@ -105,7 +107,8 @@ public class LazyInternalNetworkServerPermeateMappingApplicationImpl implements String permeateTargetIp = lazyInternalNetworkServerPermeateMapping.getPermeateTargetIp(); Integer permeateTargetPort = lazyInternalNetworkServerPermeateMapping.getPermeateTargetPort(); Integer visitorPort = lazyInternalNetworkServerPermeateMapping.getVisitorPort(); - this.changePermeateSocket(permeateTargetIp, permeateTargetPort, visitorPort); + Boolean isSsl = lazyInternalNetworkServerPermeateMapping.getIsSsl(); + this.changePermeateSocket(permeateTargetIp, permeateTargetPort, visitorPort,isSsl); return lazyInternalNetworkServerPermeateMappingRepository.story(lazyInternalNetworkServerPermeateMapping); } @@ -189,8 +192,9 @@ public class LazyInternalNetworkServerPermeateMappingApplicationImpl implements String permeateTargetIp = internalNetworkServerPermeateMapping.getPermeateTargetIp(); Integer permeateTargetPort = internalNetworkServerPermeateMapping.getPermeateTargetPort(); Integer visitorPort = internalNetworkServerPermeateMapping.getVisitorPort(); + Boolean isSsl = internalNetworkServerPermeateMapping.getIsSsl(); log.info("init permeate socket ip:{}, port:{},visitorPort:{}", permeateTargetIp, permeateTargetPort, visitorPort); - this.createPermeateVisitor(permeateTargetIp, permeateTargetPort, visitorPort); + this.createPermeateVisitor(permeateTargetIp, permeateTargetPort, visitorPort,isSsl); } }); @@ -203,11 +207,11 @@ public class LazyInternalNetworkServerPermeateMappingApplicationImpl implements * @param permeateTargetPort 客户端莫表端口 * @param visitorPort 访客端口 */ - private void changePermeateSocket(String permeateTargetIp, Integer permeateTargetPort, Integer visitorPort) { + private void changePermeateSocket(String permeateTargetIp, Integer permeateTargetPort, Integer visitorPort, Boolean isSsl) { // 删除 客户端映射 this.closePermeateSocket(visitorPort); // 更新 客户端映射 - createPermeateVisitor(permeateTargetIp, permeateTargetPort, visitorPort); + createPermeateVisitor(permeateTargetIp, permeateTargetPort, visitorPort,isSsl); } @@ -236,13 +240,14 @@ public class LazyInternalNetworkServerPermeateMappingApplicationImpl implements * @param permeateTargetPort 客户端目标端口 * @param visitorPort 访客端口 */ - private void createPermeateVisitor(String permeateTargetIp, Integer permeateTargetPort, Integer visitorPort) { + private void createPermeateVisitor(String permeateTargetIp, Integer permeateTargetPort, Integer visitorPort, Boolean isSsl) { // 更新 客户端映射 NettyServerPermeateServerConnectVisitorSocket nettyServerPermeateServerConnectVisitorSocket = NettyServerPermeateServerConnectVisitorSocket.NettyPermeateVisitorSocketBuilder .builder() .builderClientTargetIp(permeateTargetIp) .builderClientTargetPort(permeateTargetPort) .builderVisitorPort(visitorPort) + .builderIsSsl(isSsl) .builderChannelFlowAdapter(channelFlowAdapter) .build(); try { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMapping.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMapping.java index ca3937d..160b03a 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMapping.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/internal/network/penetration/mapping/LazyInternalNetworkPenetrationMapping.java @@ -79,4 +79,11 @@ public class LazyInternalNetworkPenetrationMapping { @Schema(description = "服务端ID", name = "serverId", example = "") private String serverId; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; + + } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMapping.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMapping.java index e19d4e6..3de991f 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMapping.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/client/permeate/client/mapping/LazyInternalNetworkClientPermeateClientMapping.java @@ -3,6 +3,8 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.mode import lombok.Data; import lombok.experimental.Accessors; import io.swagger.v3.oas.annotations.media.Schema; +import org.wu.framework.lazy.orm.core.stereotype.LazyTableField; + import java.time.LocalDateTime; import java.lang.String; import java.lang.Long; @@ -97,5 +99,10 @@ public class LazyInternalNetworkClientPermeateClientMapping { */ @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMapping.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMapping.java index 2867662..904fb9a 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMapping.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/client/permeate/server/mapping/LazyInternalNetworkClientPermeateServerMapping.java @@ -90,5 +90,10 @@ public class LazyInternalNetworkClientPermeateServerMapping { */ @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMapping.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMapping.java index 7301d6e..b6c835f 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMapping.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/internal/network/server/permeate/mapping/LazyInternalNetworkServerPermeateMapping.java @@ -84,4 +84,10 @@ public class LazyInternalNetworkServerPermeateMapping { @Schema(description ="渗透端口",name ="visitorPort",example = "") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + private Boolean isSsl; + } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkClientPermeateClientMappingDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkClientPermeateClientMappingDO.java index 07ef0c6..b3a7c15 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkClientPermeateClientMappingDO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkClientPermeateClientMappingDO.java @@ -110,5 +110,10 @@ public class LazyInternalNetworkClientPermeateClientMappingDO { @LazyTableField(name="update_time",comment="",defaultValue="CURRENT_TIMESTAMP",upsertStrategy = LazyFieldStrategy.NEVER,columnType="datetime",extra=" on update CURRENT_TIMESTAMP") private LocalDateTime updateTime; - + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + @LazyTableField(name="is_ssl",comment="是否是ssl",defaultValue = "'0'") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkClientPermeateServerMappingDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkClientPermeateServerMappingDO.java index 10885e3..edfc446 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkClientPermeateServerMappingDO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkClientPermeateServerMappingDO.java @@ -110,4 +110,10 @@ public class LazyInternalNetworkClientPermeateServerMappingDO { @LazyTableFieldUnique(name="visitor_port",comment="渗透端口",notNull=true,columnType="int") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + @LazyTableField(name="is_ssl",comment="是否是ssl",defaultValue = "'0'") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkPenetrationMappingDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkPenetrationMappingDO.java index 14f531e..7650ece 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkPenetrationMappingDO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkPenetrationMappingDO.java @@ -91,4 +91,10 @@ public class LazyInternalNetworkPenetrationMappingDO { @Schema(description = "服务端ID", name = "serverId", example = "") private String serverId; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + @LazyTableField(name="is_ssl",comment="是否是ssl",defaultValue = "'0'") + private Boolean isSsl; } \ No newline at end of file diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateMappingDO.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateMappingDO.java index fa826b6..cf688a4 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateMappingDO.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyInternalNetworkServerPermeateMappingDO.java @@ -102,4 +102,11 @@ public class LazyInternalNetworkServerPermeateMappingDO { @LazyTableFieldUnique(name="visitor_port",comment="渗透端口",notNull=true,columnType="int") private Integer visitorPort; + /** + * 是否是ssl + */ + @Schema(description ="是否是ssl",name ="is_ssl",example = "") + @LazyTableField(name="is_ssl",comment="是否是ssl",defaultValue = "'0'") + private Boolean isSsl; + } \ No newline at end of file