[add] 客户端渗透优化

ClientPermeateClient.md

@@ -19,7 +19,7 @@ docker run -d -it --privileged --name my-home-client --restart=always -e spring.
 ```
 #### 操作步骤：配置端口
 ![client_permeate_port_pool.png](client_permeate_port_pool.png)
-#### 操作步骤：打开页面配置菜单看到如下界面（from客户端ID：你老家网络中的电脑，to客户端ID）
+#### 操作步骤：打开页面配置菜单看到如下界面（源客户端ID：你老家网络中的电脑，目标客户端ID）
 ![client_permeate_client_mapping.png](client_permeate_client_mapping.png)
 
 #### 连接使用：在你老家使用my-home这个客户端所在机器上的ip+13306 即可访问杭州机房内的数据库的服务3306

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/NettyClientPermeateClientVisitor.java

@@ -20,11 +20,11 @@ public class NettyClientPermeateClientVisitor implements InternalNetworkPermeate
     /**
      * 当前客户端ID
      */
-    private String fromClientId;
+    private String originClientId;
     /**
      * 目标客户端ID
      */
-    private String toClientId;
+    private String targetClientId;
     /**
      * 目标地址
      */

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/advanced/ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced.java

@@ -37,14 +37,14 @@ public class ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced
     public void doHandler(NettyChannelContext nettyChannelContext, NettyProxyMsg nettyProxyMsg) {
         // 初始化 客户端渗透服务端socket
         String namespace = nettyProxyMsg.namespace();
-        byte[] fromClientIdBytes = nettyProxyMsg.getClientId();
+        byte[] originClientIdBytes = nettyProxyMsg.getClientId();
         byte[] visitorPortBytes = nettyProxyMsg.getVisitorPort();
         byte[] clientTargetIpBytes = nettyProxyMsg.getTargetIp();
         byte[] clientTargetPortBytes = nettyProxyMsg.getTargetPort();
-        byte[] toClientIdBytes = nettyProxyMsg.getData();
+        byte[] targetClientIdBytes = nettyProxyMsg.getData();
 
-        String fromClientId = new String(fromClientIdBytes);
-        String toClientId = new String(toClientIdBytes);
+        String originClientId = new String(originClientIdBytes);
+        String targetClientId = new String(targetClientIdBytes);
         Integer visitorPort = Integer.parseInt(new String(visitorPortBytes));
         String clientTargetIp = new String(clientTargetIpBytes);
         Integer clientTargetPort = Integer.parseInt(new String(clientTargetPortBytes));
@@ -52,18 +52,18 @@ public class ClientHandleTcpDistributeClientPermeateClientInitTypeAdvanced
         List<HandleChannelTypeAdvanced> handleChannelTypeAdvancedList = new ArrayList<>(SpringContextHolder.getApplicationContext().getBeansOfType(HandleChannelTypeAdvanced.class).values());
 //        ChannelFlowAdapter channelFlowAdapter = SpringContextHolder.getBean(ChannelFlowAdapter.class);
         NettyClientProperties nettyClientProperties = SpringContextHolder.getBean(NettyClientProperties.class);
-        log.info("client permeate client from client_id:【{}】 to_client_id【{}】with visitor_port【{}】, clientTargetIp:【{}】clientTargetPort:【{}】",
-                fromClientId, toClientId, visitorPort, clientTargetIp, clientTargetPort);
+        log.info("client permeate client from client_id:【{}】 target_client_id【{}】with visitor_port【{}】, clientTargetIp:【{}】clientTargetPort:【{}】",
+                originClientId, targetClientId, visitorPort, clientTargetIp, clientTargetPort);
         NettyTcpClientPermeateClientVisitorSocket nettyTcpClientPermeateClientVisitorSocket =
                 NettyTcpClientPermeateClientVisitorSocket.NettyClientPermeateClientVisitorSocketBuilder.builder()
                         .builderNamespace(namespace)
-                        .builderClientId(fromClientId)
+                        .builderClientId(originClientId)
                         .builderClientTargetIp(clientTargetIp)
                         .builderClientTargetPort(clientTargetPort)
                         .builderVisitorPort(visitorPort)
                         .builderNettyClientProperties(nettyClientProperties)
                         //.builderChannelFlowAdapter(channelFlowAdapter)
-                        .builderToClientId(toClientId)
+                        .builderToClientId(targetClientId)
                         .builderHandleChannelTypeAdvancedList(handleChannelTypeAdvancedList)
 
                 .build();

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/socket/NettyTcpClientPermeateClientVisitorSocket.java

@@ -145,7 +145,7 @@ public class NettyTcpClientPermeateClientVisitorSocket implements PermeateVisito
  /**
          * 目标客户端ID
          */
-        private String toClientId;
+        private String targetClientId;
 
         /**
          * 流量适配器
@@ -263,11 +263,11 @@ public class NettyTcpClientPermeateClientVisitorSocket implements PermeateVisito
         /**
          * 目标客户端ID
          *
-         * @param toClientId 目标客户端ID
+         * @param targetClientId 目标客户端ID
          * @return 当前对象
          */
-        public NettyClientPermeateClientVisitorSocketBuilder builderToClientId(String toClientId) {
-            this.toClientId = toClientId;
+        public NettyClientPermeateClientVisitorSocketBuilder builderToClientId(String targetClientId) {
+            this.targetClientId = targetClientId;
             return this;
         }
         public NettyTcpClientPermeateClientVisitorSocket build() {
@@ -286,8 +286,8 @@ public class NettyTcpClientPermeateClientVisitorSocket implements PermeateVisito
             NettyClientPermeateClientVisitor nettyClientPermeateClientVisitor = new NettyClientPermeateClientVisitor();
 
             nettyClientPermeateClientVisitor.setNamespace(namespace);
-            nettyClientPermeateClientVisitor.setFromClientId(nettyClientProperties.getClientId());
-            nettyClientPermeateClientVisitor.setToClientId(toClientId);
+            nettyClientPermeateClientVisitor.setOriginClientId(nettyClientProperties.getClientId());
+            nettyClientPermeateClientVisitor.setTargetClientId(targetClientId);
             nettyClientPermeateClientVisitor.setTargetIp(clientTargetIp);
             nettyClientPermeateClientVisitor.setTargetPort(clientTargetPort);
             nettyClientPermeateClientVisitor.setVisitorPort(visitorPort);

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/tcp/socket/NettyTcpClientPermeateClientVisitorTransferSocket.java

@@ -58,10 +58,10 @@ public class NettyTcpClientPermeateClientVisitorTransferSocket {
 
         String visitorId = ChannelAttributeKeyUtils.getVisitorId(visitorChannel);
         Integer visitorPort = nettyClientPermeateClientVisitor.getVisitorPort();
-        String toClientId = nettyClientPermeateClientVisitor.getToClientId();
+        String targetClientId = nettyClientPermeateClientVisitor.getTargetClientId();
 
         // 客户端新建访客通道 连接服务端IP:{},连接服务端端口:{}
-        log.info("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {} with clientId:【{}】 toClientId:【{}】 & visitorId:【{}】", inetHost, inetPort, clientId, toClientId, visitorId);
+        log.info("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {} with clientId:【{}】 targetClientId:【{}】 & visitorId:【{}】", inetHost, inetPort, clientId, targetClientId, visitorId);
         ChannelFuture future = bootstrap.connect(inetHost, inetPort);
 
         // 使用的客户端ID:{}
@@ -73,7 +73,7 @@ public class NettyTcpClientPermeateClientVisitorTransferSocket {
                 nettyProxyMsg.setType(TcpMessageType.TCP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL);
                 nettyProxyMsg.setNamespace(namespace);
                 // other clientId
-                nettyProxyMsg.setClientId(toClientId);
+                nettyProxyMsg.setClientId(targetClientId);
                 nettyProxyMsg.setVisitorPort(visitorPort);
                 nettyProxyMsg.setTargetIp(targetIp);
                 nettyProxyMsg.setTargetPort(targetPort);

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/advanced/ClientHandleUdpDistributeClientPermeateClientInitTypeAdvanced.java

@@ -35,14 +35,14 @@ public class ClientHandleUdpDistributeClientPermeateClientInitTypeAdvanced exten
     @Override
     public void doHandler(NettyChannelContext nettyChannelContext, NettyProxyMsg nettyProxyMsg) {
         // 初始化 客户端渗透服务端socket
-        byte[] fromClientIdBytes = nettyProxyMsg.getClientId();
+        byte[] originClientIdBytes = nettyProxyMsg.getClientId();
         byte[] visitorPortBytes = nettyProxyMsg.getVisitorPort();
         byte[] clientTargetIpBytes = nettyProxyMsg.getTargetIp();
         byte[] clientTargetPortBytes = nettyProxyMsg.getTargetPort();
-        byte[] toClientIdBytes = nettyProxyMsg.getData();
+        byte[] targetClientIdBytes = nettyProxyMsg.getData();
 
-        String fromClientId = new String(fromClientIdBytes);
-        String toClientId = new String(toClientIdBytes);
+        String originClientId = new String(originClientIdBytes);
+        String targetClientId = new String(targetClientIdBytes);
         Integer visitorPort = Integer.parseInt(new String(visitorPortBytes));
         String clientTargetIp = new String(clientTargetIpBytes);
         Integer clientTargetPort = Integer.parseInt(new String(clientTargetPortBytes));
@@ -50,17 +50,17 @@ public class ClientHandleUdpDistributeClientPermeateClientInitTypeAdvanced exten
         List<HandleChannelTypeAdvanced> handleChannelTypeAdvancedList = new ArrayList<>(SpringContextHolder.getApplicationContext().getBeansOfType(HandleChannelTypeAdvanced.class).values());
 //        ChannelFlowAdapter channelFlowAdapter = SpringContextHolder.getBean(ChannelFlowAdapter.class);
         NettyClientProperties nettyClientProperties = SpringContextHolder.getBean(NettyClientProperties.class);
-        log.info("client permeate client from client_id:【{}】 to_client_id【{}】with visitor_port【{}】, clientTargetIp:【{}】clientTargetPort:【{}】",
-                fromClientId, toClientId, visitorPort, clientTargetIp, clientTargetPort);
+        log.info("client permeate client from client_id:【{}】 target_client_id【{}】with visitor_port【{}】, clientTargetIp:【{}】clientTargetPort:【{}】",
+                originClientId, targetClientId, visitorPort, clientTargetIp, clientTargetPort);
         NettyUdpClientPermeateClientVisitorSocket nettyTcpClientPermeateClientVisitorSocket =
                 NettyUdpClientPermeateClientVisitorSocket.NettyClientPermeateClientVisitorSocketBuilder.builder()
-                        .builderClientId(fromClientId)
+                        .builderClientId(originClientId)
                         .builderClientTargetIp(clientTargetIp)
                         .builderClientTargetPort(clientTargetPort)
                         .builderVisitorPort(visitorPort)
                 .builderNettyClientProperties(nettyClientProperties)
 //                .builderChannelFlowAdapter(channelFlowAdapter)
-                        .builderToClientId(toClientId)
+                        .builderToClientId(targetClientId)
                 .builderHandleChannelTypeAdvancedList(handleChannelTypeAdvancedList)
 
                 .build();

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/socket/NettyUdpClientPermeateClientVisitorSocket.java

@@ -140,7 +140,7 @@ public class NettyUdpClientPermeateClientVisitorSocket implements PermeateVisito
  /**
          * 目标客户端ID
          */
-        private String toClientId;
+        private String targetClientId;
 
         /**
          * 流量适配器
@@ -248,11 +248,11 @@ public class NettyUdpClientPermeateClientVisitorSocket implements PermeateVisito
         /**
          * 目标客户端ID
          *
-         * @param toClientId 目标客户端ID
+         * @param targetClientId 目标客户端ID
          * @return 当前对象
          */
-        public NettyClientPermeateClientVisitorSocketBuilder builderToClientId(String toClientId) {
-            this.toClientId = toClientId;
+        public NettyClientPermeateClientVisitorSocketBuilder builderToClientId(String targetClientId) {
+            this.targetClientId = targetClientId;
             return this;
         }
         public NettyUdpClientPermeateClientVisitorSocket build() {
@@ -267,8 +267,8 @@ public class NettyUdpClientPermeateClientVisitorSocket implements PermeateVisito
             }
             NettyClientPermeateClientVisitor nettyClientPermeateClientVisitor = new NettyClientPermeateClientVisitor();
 
-            nettyClientPermeateClientVisitor.setFromClientId(nettyClientProperties.getClientId());
-            nettyClientPermeateClientVisitor.setToClientId(toClientId);
+            nettyClientPermeateClientVisitor.setOriginClientId(nettyClientProperties.getClientId());
+            nettyClientPermeateClientVisitor.setTargetClientId(targetClientId);
             nettyClientPermeateClientVisitor.setTargetIp(clientTargetIp);
             nettyClientPermeateClientVisitor.setTargetPort(clientTargetPort);
             nettyClientPermeateClientVisitor.setVisitorPort(visitorPort);

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/permeate/udp/socket/NettyUdpClientPermeateClientVisitorTransferSocket.java

@@ -58,10 +58,10 @@ public class NettyUdpClientPermeateClientVisitorTransferSocket {
 
         String visitorId = ChannelAttributeKeyUtils.getVisitorId(visitorChannel);
         Integer visitorPort = nettyClientPermeateClientVisitor.getVisitorPort();
-        String toClientId = nettyClientPermeateClientVisitor.getToClientId();
+        String targetClientId = nettyClientPermeateClientVisitor.getTargetClientId();
 
         // 客户端新建访客通道 连接服务端IP:{},连接服务端端口:{}
-        log.info("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {} with clientId:【{}】 toClientId:【{}】 & visitorId:【{}】", inetHost, inetPort, clientId, toClientId, visitorId);
+        log.info("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {} with clientId:【{}】 targetClientId:【{}】 & visitorId:【{}】", inetHost, inetPort, clientId, targetClientId, visitorId);
         ChannelFuture future = bootstrap.connect(inetHost, inetPort);
 
         // 使用的客户端ID:{}
@@ -73,7 +73,7 @@ public class NettyUdpClientPermeateClientVisitorTransferSocket {
                 nettyProxyMsg.setType(UdpMessageType.UDP_REPORT_CLIENT_TRANSFER_CLIENT_PERMEATE_CHANNEL_CONNECTION_SUCCESSFUL);
                 // other clientId
                 nettyProxyMsg.setNamespace(namespace);
-                nettyProxyMsg.setClientId(toClientId);
+                nettyProxyMsg.setClientId(targetClientId);
                 nettyProxyMsg.setVisitorPort(visitorPort);
                 nettyProxyMsg.setTargetIp(targetIp);
                 nettyProxyMsg.setTargetPort(targetPort);

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/socket/NettyHttpClientProxyClientProxySocket.java

@@ -60,7 +60,7 @@ public class NettyHttpClientProxyClientProxySocket {
 
 
         // 客户端链接服务端
-        log.info("Client creates a new proxy channel to connect to server IP: {}, connecting to server port: {} with clientId:【{}】 toClientId:【{}】 & visitorId:【{}】",
+        log.info("Client creates a new proxy channel to connect to server IP: {}, connecting to server port: {} with clientId:【{}】 targetClientId:【{}】 & visitorId:【{}】",
                 inetHost, inetPort, clientId, targetClientId, visitorId);
         ChannelFuture future = bootstrap.connect(inetHost, inetPort);
 

wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/socket/NettyHttpClientProxyServerProxySocket.java

@@ -64,7 +64,7 @@ public class NettyHttpClientProxyServerProxySocket {
 
 
         // 客户端新建访客通道 连接服务端IP:{},连接服务端端口:{}
-        log.info("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {} with clientId:【{}】 toClientId:【{}】 & visitorId:【{}】", inetHost, inetPort, clientId, clientId, visitorId);
+        log.info("Client creates a new visitor channel to connect to server IP: {}, connecting to server port: {} with clientId:【{}】 targetClientId:【{}】 & visitorId:【{}】", inetHost, inetPort, clientId, clientId, visitorId);
         ChannelFuture future = bootstrap.connect(inetHost, inetPort);
 
         // 使用的客户端ID:{}

wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java

@@ -121,6 +121,7 @@ public class ChannelContext {
         try {
             return cacheClientChannelConcurrentHashMap.get(new String(namespace, StandardCharsets.UTF_8)).get(new String(clientId, StandardCharsets.UTF_8));
         } catch (Exception e) {
+            e.printStackTrace();
             // 无法通过客户端ID[{}]获取通道信息
             log.error("Unable to obtain channel information through namespace:{} client ID [{}]", new String(namespace), new String(clientId));
             return null;

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/permeate/tcp/advanced/ServerHandleTcpClientConnectSuccessTypeAdvanced.java

@@ -168,17 +168,17 @@ public class ServerHandleTcpClientConnectSuccessTypeAdvanced extends AbstractHan
 
         // 查询客户端渗透客户端信息
         LazyClientPermeateClientMappingQueryListCommand lazyClientPermeateClientMappingQueryListCommand = new LazyClientPermeateClientMappingQueryListCommand();
-        lazyClientPermeateClientMappingQueryListCommand.setFromClientId(clientId);
+        lazyClientPermeateClientMappingQueryListCommand.setOriginClientId(clientId);
         lazyClientPermeateClientMappingQueryListCommand.setIsDeleted(false);
         lazyClientPermeateClientMappingApplication.findList(lazyClientPermeateClientMappingQueryListCommand)
                 .accept(lazyInternalNetworkClientPermeateServerMappingDTOS -> {
                     for (LazyClientPermeateClientMappingDTO lazyClientPermeateClientMappingDTO : lazyInternalNetworkClientPermeateServerMappingDTOS) {
 
-                        String selfNamespace = lazyClientPermeateClientMappingDTO.getToNamespace();
+                        String selfNamespace = lazyClientPermeateClientMappingDTO.getTargetNamespace();
                         String permeateTargetIp = lazyClientPermeateClientMappingDTO.getPermeateTargetIp();
                         Integer permeateTargetPort = lazyClientPermeateClientMappingDTO.getPermeateTargetPort();
                         Integer visitorPort = lazyClientPermeateClientMappingDTO.getVisitorPort();
-                        String toClientId = lazyClientPermeateClientMappingDTO.getToClientId();
+                        String targetClientId = lazyClientPermeateClientMappingDTO.getTargetClientId();
                         NettyProxyMsg nettyMsg = new NettyProxyMsg();
                         nettyMsg.setNamespace(selfNamespace);
                         nettyMsg.setType(TcpMessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT);
@@ -186,7 +186,7 @@ public class ServerHandleTcpClientConnectSuccessTypeAdvanced extends AbstractHan
                         nettyMsg.setTargetPort(permeateTargetPort);
                         nettyMsg.setVisitorPort(visitorPort);
                         nettyMsg.setClientId(clientId);
-                        nettyMsg.setData(toClientId.getBytes(StandardCharsets.UTF_8));
+                        nettyMsg.setData(targetClientId.getBytes(StandardCharsets.UTF_8));
                         newChannel.writeAndFlush(nettyMsg);
                     }
                 });

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/permeate/udp/advanced/ServerHandleUdpClientConnectSuccessTypeAdvanced.java

@@ -157,7 +157,7 @@ public class ServerHandleUdpClientConnectSuccessTypeAdvanced extends AbstractHan
 
         // 查询客户端渗透客户端信息
         LazyClientPermeateClientMappingQueryListCommand lazyClientPermeateClientMappingQueryListCommand = new LazyClientPermeateClientMappingQueryListCommand();
-        lazyClientPermeateClientMappingQueryListCommand.setFromClientId(clientId);
+        lazyClientPermeateClientMappingQueryListCommand.setOriginClientId(clientId);
         lazyClientPermeateClientMappingQueryListCommand.setIsDeleted(false);
         lazyClientPermeateClientMappingApplication.findList(lazyClientPermeateClientMappingQueryListCommand)
                 .accept(lazyInternalNetworkClientPermeateServerMappingDTOS -> {
@@ -166,14 +166,14 @@ public class ServerHandleUdpClientConnectSuccessTypeAdvanced extends AbstractHan
                         String permeateTargetIp = lazyClientPermeateClientMappingDTO.getPermeateTargetIp();
                         Integer permeateTargetPort = lazyClientPermeateClientMappingDTO.getPermeateTargetPort();
                         Integer visitorPort = lazyClientPermeateClientMappingDTO.getVisitorPort();
-                        String toClientId = lazyClientPermeateClientMappingDTO.getToClientId();
+                        String targetClientId = lazyClientPermeateClientMappingDTO.getTargetClientId();
                         NettyProxyMsg nettyMsg = new NettyProxyMsg();
                         nettyMsg.setType(TcpMessageType.TCP_DISTRIBUTE_CLIENT_PERMEATE_CLIENT_INIT);
                         nettyMsg.setTargetIp(permeateTargetIp);
                         nettyMsg.setTargetPort(permeateTargetPort);
                         nettyMsg.setVisitorPort(visitorPort);
                         nettyMsg.setClientId(clientId);
-                        nettyMsg.setData(toClientId.getBytes(StandardCharsets.UTF_8));
+                        nettyMsg.setData(targetClientId.getBytes(StandardCharsets.UTF_8));
                         newChannel.writeAndFlush(nettyMsg);
                     }
                 });

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/client/mapping/LazyClientPermeateClientMappingQueryListCommand.java

@@ -39,17 +39,17 @@ public class LazyClientPermeateClientMappingQueryListCommand {
 
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
 
     /**
      * 
-     * from客户端ID
+     * 源客户端ID
      */
-    @Schema(description ="from客户端ID",name ="fromClientId",example = "")
-    private String fromClientId;
+    @Schema(description ="源客户端ID",name ="originClientId",example = "")
+    private String originClientId;
 
     /**
      * 
@@ -81,17 +81,17 @@ public class LazyClientPermeateClientMappingQueryListCommand {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 
-     * to客户端ID
+     * 目标客户端ID
      */
-    @Schema(description ="to客户端ID",name ="toClientId",example = "")
-    private String toClientId;
+    @Schema(description ="目标客户端ID",name ="targetClientId",example = "")
+    private String targetClientId;
 
     /**
      * 
@@ -107,10 +107,10 @@ public class LazyClientPermeateClientMappingQueryListCommand {
     @Schema(description ="渗透端口",name ="visitorPort",example = "")
     private Integer visitorPort;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/client/mapping/LazyClientPermeateClientMappingQueryOneCommand.java

@@ -39,16 +39,16 @@ public class LazyClientPermeateClientMappingQueryOneCommand {
 
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
-     * from客户端ID
+     * 源客户端ID
      */
-    @Schema(description ="from客户端ID",name ="fromClientId",example = "")
-    private String fromClientId;
+    @Schema(description ="源客户端ID",name ="originClientId",example = "")
+    private String originClientId;
 
     /**
      * 
@@ -80,17 +80,17 @@ public class LazyClientPermeateClientMappingQueryOneCommand {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 
-     * to客户端ID
+     * 目标客户端ID
      */
-    @Schema(description ="to客户端ID",name ="toClientId",example = "")
-    private String toClientId;
+    @Schema(description ="目标客户端ID",name ="targetClientId",example = "")
+    private String targetClientId;
 
     /**
      * 
@@ -106,10 +106,10 @@ public class LazyClientPermeateClientMappingQueryOneCommand {
     @Schema(description ="渗透端口",name ="visitorPort",example = "")
     private Integer visitorPort;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/client/mapping/LazyClientPermeateClientMappingRemoveCommand.java

@@ -39,16 +39,16 @@ public class LazyClientPermeateClientMappingRemoveCommand {
 
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
-     * from客户端ID
+     * 源客户端ID
      */
-    @Schema(description ="from客户端ID",name ="fromClientId",example = "")
-    private String fromClientId;
+    @Schema(description ="源客户端ID",name ="originClientId",example = "")
+    private String originClientId;
 
     /**
      * 
@@ -80,17 +80,17 @@ public class LazyClientPermeateClientMappingRemoveCommand {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 
-     * to客户端ID
+     * 目标客户端ID
      */
-    @Schema(description ="to客户端ID",name ="toClientId",example = "")
-    private String toClientId;
+    @Schema(description ="目标客户端ID",name ="targetClientId",example = "")
+    private String targetClientId;
 
     /**
      * 
@@ -106,10 +106,10 @@ public class LazyClientPermeateClientMappingRemoveCommand {
     @Schema(description ="渗透端口",name ="visitorPort",example = "")
     private Integer visitorPort;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/client/mapping/LazyClientPermeateClientMappingStoryCommand.java

@@ -40,16 +40,16 @@ public class LazyClientPermeateClientMappingStoryCommand {
 
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
-     * from客户端ID
+     * 源客户端ID
      */
-    @Schema(description ="from客户端ID",name ="fromClientId",example = "")
-    private String fromClientId;
+    @Schema(description ="源客户端ID",name ="originClientId",example = "")
+    private String originClientId;
 
     /**
      * 
@@ -81,17 +81,17 @@ public class LazyClientPermeateClientMappingStoryCommand {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 
-     * to客户端ID
+     * 目标客户端ID
      */
-    @Schema(description ="to客户端ID",name ="toClientId",example = "")
-    private String toClientId;
+    @Schema(description ="目标客户端ID",name ="targetClientId",example = "")
+    private String targetClientId;
 
     /**
      * 
@@ -114,10 +114,10 @@ public class LazyClientPermeateClientMappingStoryCommand {
     @Schema(description ="是否是ssl",name ="is_ssl",example = "")
     private Boolean isSsl;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/client/mapping/LazyClientPermeateClientMappingUpdateCommand.java

@@ -39,16 +39,16 @@ public class LazyClientPermeateClientMappingUpdateCommand {
 
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
-     * from客户端ID
+     * 源客户端ID
      */
-    @Schema(description ="from客户端ID",name ="fromClientId",example = "")
-    private String fromClientId;
+    @Schema(description ="源客户端ID",name ="originClientId",example = "")
+    private String originClientId;
 
     /**
      * 
@@ -86,10 +86,10 @@ public class LazyClientPermeateClientMappingUpdateCommand {
 
     /**
      * 
-     * to客户端ID
+     * 目标客户端ID
      */
-    @Schema(description ="to客户端ID",name ="toClientId",example = "")
-    private String toClientId;
+    @Schema(description ="目标客户端ID",name ="targetClientId",example = "")
+    private String targetClientId;
 
     /**
      * 
@@ -112,10 +112,10 @@ public class LazyClientPermeateClientMappingUpdateCommand {
     private Boolean isSsl;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/server/mapping/LazyClientPermeateServerMappingQueryListCommand.java

@@ -31,10 +31,10 @@ public class LazyClientPermeateServerMappingQueryListCommand {
     private String clientId;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
      * 
@@ -79,10 +79,10 @@ public class LazyClientPermeateServerMappingQueryListCommand {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 
@@ -98,10 +98,10 @@ public class LazyClientPermeateServerMappingQueryListCommand {
     @Schema(description ="渗透端口",name ="visitorPort",example = "")
     private Integer visitorPort;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/server/mapping/LazyClientPermeateServerMappingQueryOneCommand.java

@@ -31,10 +31,10 @@ public class LazyClientPermeateServerMappingQueryOneCommand {
     private String clientId;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
      * 
@@ -79,10 +79,10 @@ public class LazyClientPermeateServerMappingQueryOneCommand {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 
@@ -99,10 +99,10 @@ public class LazyClientPermeateServerMappingQueryOneCommand {
     private Integer visitorPort;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/server/mapping/LazyClientPermeateServerMappingRemoveCommand.java

@@ -31,10 +31,10 @@ public class LazyClientPermeateServerMappingRemoveCommand {
     private String clientId;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
      * 
@@ -79,10 +79,10 @@ public class LazyClientPermeateServerMappingRemoveCommand {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 
@@ -98,10 +98,10 @@ public class LazyClientPermeateServerMappingRemoveCommand {
     @Schema(description ="渗透端口",name ="visitorPort",example = "")
     private Integer visitorPort;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/server/mapping/LazyClientPermeateServerMappingStoryCommand.java

@@ -31,10 +31,10 @@ public class LazyClientPermeateServerMappingStoryCommand {
     private String clientId;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
      * 
@@ -79,10 +79,10 @@ public class LazyClientPermeateServerMappingStoryCommand {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
     /**
      * 
      * 
@@ -103,10 +103,10 @@ public class LazyClientPermeateServerMappingStoryCommand {
     @Schema(description ="是否是ssl",name ="is_ssl",example = "")
     private Boolean isSsl;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/client/permeate/server/mapping/LazyClientPermeateServerMappingUpdateCommand.java

@@ -31,10 +31,10 @@ public class LazyClientPermeateServerMappingUpdateCommand {
     private String clientId;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
      * 
@@ -79,10 +79,10 @@ public class LazyClientPermeateServerMappingUpdateCommand {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 
@@ -104,10 +104,10 @@ public class LazyClientPermeateServerMappingUpdateCommand {
     @Schema(description ="是否是ssl",name ="is_ssl",example = "")
     private Boolean isSsl;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/client/mapping/LazyServerPermeateClientMappingQueryListCommand.java

@@ -74,10 +74,10 @@ public class LazyServerPermeateClientMappingQueryListCommand {
     @Schema(description = "命名空间", name = "namespace", example = "")
     private String namespace;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/client/mapping/LazyServerPermeateClientMappingQueryOneCommand.java

@@ -73,10 +73,10 @@ public class LazyServerPermeateClientMappingQueryOneCommand {
     @Schema(description = "命名空间", name = "namespace", example = "")
     private String namespace;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/client/mapping/LazyServerPermeateClientMappingRemoveCommand.java

@@ -65,10 +65,10 @@ public class LazyServerPermeateClientMappingRemoveCommand {
     @Schema(description = "命名空间", name = "namespace", example = "")
     private String namespace;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/client/mapping/LazyServerPermeateClientMappingStoryCommand.java

@@ -64,10 +64,10 @@ public class LazyServerPermeateClientMappingStoryCommand {
     @Schema(description ="是否是ssl",name ="is_ssl",example = "")
     private Boolean isSsl;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/client/mapping/LazyServerPermeateClientMappingUpdateCommand.java

@@ -70,10 +70,10 @@ public class LazyServerPermeateClientMappingUpdateCommand {
     @Schema(description ="是否是ssl",name ="is_ssl",example = "")
     private Boolean isSsl;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/server/mapping/LazyServerPermeateServerMappingQueryListCommand.java

@@ -86,10 +86,10 @@ public class LazyServerPermeateServerMappingQueryListCommand {
     private Integer visitorPort;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/server/mapping/LazyServerPermeateServerMappingQueryOneCommand.java

@@ -86,10 +86,10 @@ public class LazyServerPermeateServerMappingQueryOneCommand {
     private Integer visitorPort;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/server/mapping/LazyServerPermeateServerMappingRemoveCommand.java

@@ -88,10 +88,10 @@ public class LazyServerPermeateServerMappingRemoveCommand {
     @Schema(description ="渗透端口",name ="visitorPort",example = "")
     private Integer visitorPort;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/server/mapping/LazyServerPermeateServerMappingStoryCommand.java

@@ -91,10 +91,10 @@ public class LazyServerPermeateServerMappingStoryCommand {
     @Schema(description ="是否是ssl",name ="is_ssl",example = "")
     private Boolean isSsl;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/command/lazy/netty/server/permeate/server/mapping/LazyServerPermeateServerMappingUpdateCommand.java

@@ -91,10 +91,10 @@ public class LazyServerPermeateServerMappingUpdateCommand {
     @Schema(description ="是否是ssl",name ="is_ssl",example = "")
     private Boolean isSsl;
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyClientPermeateClientMappingDTO.java

@@ -38,16 +38,16 @@ public class LazyClientPermeateClientMappingDTO {
     private String describe;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
-     * from客户端ID
+     * 源客户端ID
      */
-    @Schema(description ="from客户端ID",name ="fromClientId",example = "")
-    private String fromClientId;
+    @Schema(description ="源客户端ID",name ="originClientId",example = "")
+    private String originClientId;
 
     /**
      * 
@@ -79,17 +79,17 @@ public class LazyClientPermeateClientMappingDTO {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 
-     * to客户端ID
+     * 目标客户端ID
      */
-    @Schema(description ="to客户端ID",name ="toClientId",example = "")
-    private String toClientId;
+    @Schema(description ="目标客户端ID",name ="targetClientId",example = "")
+    private String targetClientId;
 
     /**
      * 
@@ -112,10 +112,10 @@ public class LazyClientPermeateClientMappingDTO {
     private Boolean isSsl;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyClientPermeateServerMappingDTO.java

@@ -31,10 +31,10 @@ public class LazyClientPermeateServerMappingDTO {
     private String clientId;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
      * 
@@ -79,10 +79,10 @@ public class LazyClientPermeateServerMappingDTO {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
     /**
      * 
      * 
@@ -104,10 +104,10 @@ public class LazyClientPermeateServerMappingDTO {
     private Boolean isSsl;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyServerPermeateClientMappingDTO.java

@@ -88,10 +88,10 @@ public class LazyServerPermeateClientMappingDTO {
     private Boolean isSsl;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/dto/LazyServerPermeateServerMappingDTO.java

@@ -92,10 +92,10 @@ public class LazyServerPermeateServerMappingDTO {
     private Boolean isSsl;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientPermeateClientMappingApplicationImpl.java

@@ -152,8 +152,8 @@ public class LazyClientPermeateClientMappingApplicationImpl implements LazyClien
      */
     public void closeClientPermeateClientSocketMessage(LazyNettyClientPermeateClientMapping lazyNettyClientPermeateClientMapping) {
         // 发送客户端初始化渗透
-        String namespace = lazyNettyClientPermeateClientMapping.getFromNamespace();
-        String clientId = lazyNettyClientPermeateClientMapping.getFromClientId();
+        String namespace = lazyNettyClientPermeateClientMapping.getOriginNamespace();
+        String clientId = lazyNettyClientPermeateClientMapping.getOriginClientId();
         Channel clientChannel = ChannelContext.getLoadBalance(namespace, clientId);
         if (clientChannel != null && clientChannel.isActive()) {
 
@@ -176,10 +176,10 @@ public class LazyClientPermeateClientMappingApplicationImpl implements LazyClien
      */
     public void createClientPermeateClientSocketMessage(LazyNettyClientPermeateClientMapping lazyNettyClientPermeateClientMapping) {
         // 发送客户端初始化渗透
-        String namespace = lazyNettyClientPermeateClientMapping.getFromNamespace();
-        String fromClientId = lazyNettyClientPermeateClientMapping.getFromClientId();
-        String toClientId = lazyNettyClientPermeateClientMapping.getToClientId();
-        Channel clientChannel = ChannelContext.getLoadBalance(namespace, fromClientId);
+        String namespace = lazyNettyClientPermeateClientMapping.getOriginNamespace();
+        String originClientId = lazyNettyClientPermeateClientMapping.getOriginClientId();
+        String targetClientId = lazyNettyClientPermeateClientMapping.getTargetClientId();
+        Channel clientChannel = ChannelContext.getLoadBalance(namespace, originClientId);
         if (clientChannel != null && clientChannel.isActive()) {
             String permeateTargetIp = lazyNettyClientPermeateClientMapping.getPermeateTargetIp();
             Integer permeateTargetPort = lazyNettyClientPermeateClientMapping.getPermeateTargetPort();
@@ -189,9 +189,9 @@ public class LazyClientPermeateClientMappingApplicationImpl implements LazyClien
             nettyMsg.setTargetIp(permeateTargetIp);
             nettyMsg.setTargetPort(permeateTargetPort);
             nettyMsg.setVisitorPort(visitorPort);
-            nettyMsg.setClientId(fromClientId);
+            nettyMsg.setClientId(originClientId);
             nettyMsg.setNamespace(namespace);
-            nettyMsg.setData(toClientId.getBytes(StandardCharsets.UTF_8));
+            nettyMsg.setData(targetClientId.getBytes(StandardCharsets.UTF_8));
             clientChannel.writeAndFlush(nettyMsg);
         }
     }

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientPermeateServerMappingApplicationImpl.java

@@ -163,7 +163,7 @@ public class LazyClientPermeateServerMappingApplicationImpl implements LazyClien
      */
     public void closeClientPermeateServerSocketMessage(LazyNettyClientPermeateServerMapping lazyNettyClientPermeateServerMapping) {
         // 发送客户端初始化渗透
-        String serverId = lazyNettyClientPermeateServerMapping.getFromNamespace();
+        String serverId = lazyNettyClientPermeateServerMapping.getOriginNamespace();
         String clientId = lazyNettyClientPermeateServerMapping.getClientId();
         Channel clientChannel = ChannelContext.getLoadBalance(serverId, clientId);
         if (clientChannel != null && clientChannel.isActive()) {
@@ -186,7 +186,7 @@ public class LazyClientPermeateServerMappingApplicationImpl implements LazyClien
      */
     public void createClientPermeateServerSocketMessage(LazyNettyClientPermeateServerMapping lazyNettyClientPermeateServerMapping) {
         // 发送客户端初始化渗透
-        String serverId = lazyNettyClientPermeateServerMapping.getFromNamespace();
+        String serverId = lazyNettyClientPermeateServerMapping.getOriginNamespace();
         String clientId = lazyNettyClientPermeateServerMapping.getClientId();
 
         Channel clientChannel = ChannelContext.getLoadBalance(serverId, clientId);

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/permeate/client/mapping/LazyNettyClientPermeateClientMapping.java

@@ -39,16 +39,16 @@ public class LazyNettyClientPermeateClientMapping {
 
     /**
      * 
-     * from客户端ID
+     * 源客户端ID
      */
-    @Schema(description ="from客户端ID",name ="fromClientId",example = "")
-    private String fromClientId;
+    @Schema(description ="源客户端ID",name ="originClientId",example = "")
+    private String originClientId;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
      * 
@@ -80,16 +80,16 @@ public class LazyNettyClientPermeateClientMapping {
 
     /**
      * 
-     * to客户端ID
+     * 目标客户端ID
      */
-    @Schema(description ="to客户端ID",name ="toClientId",example = "")
-    private String toClientId;
+    @Schema(description ="目标客户端ID",name ="targetClientId",example = "")
+    private String targetClientId;
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
 
     /**
      * 

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/client/permeate/server/mapping/LazyNettyClientPermeateServerMapping.java

@@ -29,10 +29,10 @@ public class LazyNettyClientPermeateServerMapping {
     private String clientId;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    private String originNamespace;
     /**
      * 
      * 
@@ -77,10 +77,10 @@ public class LazyNettyClientPermeateServerMapping {
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    private String targetNamespace;
     /**
      * 
      * 

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/domain/model/lazy/netty/server/permeate/server/mapping/LazyNettyServerPermeateServerMapping.java

@@ -94,10 +94,10 @@ public class LazyNettyServerPermeateServerMapping {
 
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * to 客户端 协议类型

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyClientPermeateClientMappingDO.java

@@ -24,19 +24,19 @@ public class LazyNettyClientPermeateClientMappingDO {
 
     /**
      * 
-     * from客户端ID
+     * 源客户端ID
      */
-    @Schema(description = "from客户端ID", name = "fromClientId", example = "")
-    @LazyTableFieldUnique(name = "from_client_id", comment = "from客户端ID", columnType = "varchar(25)")
-    private String fromClientId;
+    @Schema(description = "源客户端ID", name = "originClientId", example = "")
+    @LazyTableFieldUnique(name = "origin_client_id", comment = "源客户端ID", columnType = "varchar(25)")
+    private String originClientId;
 
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    @LazyTableFieldUnique(name = "from_namespace", comment = "from命名空间", columnType = "varchar(25)")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    @LazyTableFieldUnique(name = "origin_namespace", comment = "源命名空间", columnType = "varchar(25)")
+    private String originNamespace;
 
 
     /**
@@ -48,27 +48,27 @@ public class LazyNettyClientPermeateClientMappingDO {
     private Integer visitorPort;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @LazyTableField(name="from_protocol_type",comment="from 客户端 协议类型",columnType="varchar(255)",defaultValue = "'TCP'")
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @LazyTableField(name="origin_protocol_type",comment="源 客户端 协议类型",columnType="varchar(255)",defaultValue = "'TCP'")
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      *
-     * to客户端ID
+     * 目标客户端ID
      */
-    @Schema(description = "to客户端ID", name = "toClientId", example = "")
-    @LazyTableField(name = "to_client_id", comment = "to客户端ID", columnType = "varchar(255)")
-    private String toClientId;
+    @Schema(description = "目标客户端ID", name = "targetClientId", example = "")
+    @LazyTableField(name = "target_client_id", comment = "目标客户端ID", columnType = "varchar(255)")
+    private String targetClientId;
 
     /**
      *
-     * to命名空间
+     * 目标命名空间
      */
-    @Schema(description = "to命名空间", name = "toNamespace", example = "")
-    @LazyTableFieldUnique(name = "to_namespace", comment = "to命名空间", columnType = "varchar(25)")
-    private String toNamespace;
+    @Schema(description = "目标命名空间", name = "targetNamespace", example = "")
+    @LazyTableFieldUnique(name = "target_namespace", comment = "目标命名空间", columnType = "varchar(25)")
+    private String targetNamespace;
     /**
      * 
      * 
@@ -123,12 +123,7 @@ public class LazyNettyClientPermeateClientMappingDO {
     @LazyTableField(name="to_protocol_type",comment="to 客户端 协议类型",columnType="varchar(255)",defaultValue = "'TCP'")
     @Schema(description = "to 客户端协议类型", name = "to_protocol_type", example = "")
     private ProtocolType toProtocolType;
-    /**
-     * 命名空间
-     */
-    @Schema(description ="命名空间",name ="namespace",example = "")
-    @LazyTableFieldUnique(name="namespace",comment="命名空间",columnType="varchar(25)",defaultValue = "DEFAULT")
-    private String namespace;
+
 
     /**
      * 

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyClientPermeateServerMappingDO.java

@@ -37,11 +37,11 @@ public class LazyNettyClientPermeateServerMappingDO {
     private String clientId;
     /**
      *
-     * from命名空间
+     * 源命名空间
      */
-    @Schema(description = "from命名空间", name = "fromNamespace", example = "")
-    @LazyTableFieldUnique(name = "from_namespace", comment = "from命名空间", columnType = "varchar(25)")
-    private String fromNamespace;
+    @Schema(description = "源命名空间", name = "originNamespace", example = "")
+    @LazyTableFieldUnique(name = "origin_namespace", comment = "源命名空间", columnType = "varchar(25)")
+    private String originNamespace;
 
     /**
      *
@@ -52,11 +52,11 @@ public class LazyNettyClientPermeateServerMappingDO {
     private Integer visitorPort;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @LazyTableField(name="from_protocol_type",comment="from 客户端 协议类型",columnType="varchar(255)",defaultValue = "'TCP'")
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @LazyTableField(name="origin_protocol_type",comment="源 客户端 协议类型",columnType="varchar(255)",defaultValue = "'TCP'")
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
     /**
      * 
      * 
@@ -114,9 +114,9 @@ public class LazyNettyClientPermeateServerMappingDO {
     /**
      * 命名空间
      */
-    @Schema(description ="命名空间",name ="toNamespace",example = "")
-    @LazyTableFieldUnique(name="to_namespace",comment="命名空间",columnType="varchar(25)",defaultValue = "DEFAULT")
-    private String toNamespace;
+    @Schema(description ="命名空间",name ="targetNamespace",example = "")
+    @LazyTableFieldUnique(name="target_namespace",comment="命名空间",columnType="varchar(25)",defaultValue = "DEFAULT")
+    private String targetNamespace;
 
     /**
      * 

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerPermeateClientMappingDO.java

@@ -83,11 +83,11 @@ public class LazyNettyServerPermeateClientMappingDO {
 
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @LazyTableField(name="from_protocol_type",comment="from 客户端 协议类型",columnType="varchar(255)",defaultValue = "'TCP'")
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @LazyTableField(name="origin_protocol_type",comment="源 客户端 协议类型",columnType="varchar(255)",defaultValue = "'TCP'")
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
 
     /**
      * 访问端口

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/entity/LazyNettyServerPermeateServerMappingDO.java

@@ -97,11 +97,11 @@ public class LazyNettyServerPermeateServerMappingDO {
     private LocalDateTime updateTime;
 
     /**
-     * from 客户端 协议类型
+     * 源 客户端 协议类型
      */
-    @LazyTableField(name="from_protocol_type",comment="from 客户端 协议类型",columnType="varchar(255)",defaultValue = "'TCP'")
-    @Schema(description = "from 客户端协议类型", name = "from_protocol_type", example = "")
-    private ProtocolType fromProtocolType;
+    @LazyTableField(name="origin_protocol_type",comment="源 客户端 协议类型",columnType="varchar(255)",defaultValue = "'TCP'")
+    @Schema(description = "源 客户端协议类型", name = "origin_protocol_type", example = "")
+    private ProtocolType originProtocolType;
     /**
      * 
      * 渗透端口

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/infrastructure/xml/LazyInternalNetworkClientPermeateClientMappingMapper.xml

@@ -5,13 +5,13 @@
 <resultMap id="BaseResultMap" type="org.framework.lazy.cloud.network.heartbeat.server.standalone.infrastructure.entity.LazyNettyClientPermeateClientMappingDO">
 <result column="create_time" property="createTime" />
 <result column="`describe`" property="describe" />
-<result column="form_client_id" property="fromClientId" />
+<result column="form_client_id" property="originClientId" />
 <id column="id" property="id" />
 <result column="is_deleted" property="isDeleted" />
 <result column="permeate_target_ip" property="permeateTargetIp" />
 <result column="permeate_target_port" property="permeateTargetPort" />
 <result column="server_id" property="serverId" />
-<result column="to_client_id" property="toClientId" />
+<result column="target_client_id" property="targetClientId" />
 <result column="update_time" property="updateTime" />
 <result column="visitor_port" property="visitorPort" />
 </resultMap>

wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start/src/main/resources/application-dev.yml

@@ -4,14 +4,15 @@ spring:
       client:
 #        inet-host: 124.222.48.62
 #        inet-port: 30676
-        inet-host: 124.222.152.160
-        inet-port: 30560
-        namespace: tencent
+#        inet-host: 124.222.152.160
+#        inet-port: 30560
+#        namespace: tencent
 #        inet-host: 192.168.15.121
 #        inet-port: 7001
-#        server-id: win
-#        inet-host: 127.0.0.1
-#        inet-port: 7001
+#        namespace: win
+        inet-host: 127.0.0.1
+        inet-port: 7001
+        namespace: local-proxy
         inet-path: wu-lazy-cloud-heartbeat-server
         client-id: socks-local-proxy # 客户端ID
         app-key: a4bf4415-25aa-4007-914b-31ec77d1292f