测试数据

cloud-etl-common/src/main/java/com/muyu/dynamicLoad/DynamicLoader.java

@@ -0,0 +1,78 @@
+package com.muyu.dynamicLoad;
+
+import javax.tools.JavaCompiler;
+import javax.tools.JavaFileObject;
+import javax.tools.StandardJavaFileManager;
+import javax.tools.ToolProvider;
+import java.io.IOException;
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @ClassName DynamicLoader
+ * @author CHX
+ * @Date 2024/5/1 20:37
+ */
+public class DynamicLoader {
+    /**
+     * 通过类名和其代码（Java代码字符串），编译得到字节码，返回类名及其对应类的字节码，封装于Map中，值得注意的是，
+     * 平常类中就编译出来的字节码只有一个类，但是考虑到内部类的情况， 会出现很多个类名及其字节码，所以用Map封装方便。
+     *
+     * @param javaName 类名
+     * @param javaSrc  Java源码
+     * @return map
+     */
+    public static Map<String, byte[]> compile(String javaName, String javaSrc) {
+        // 调用java编译器接口
+        JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
+        StandardJavaFileManager stdManager = compiler
+                .getStandardFileManager(null, null, null);
+
+        try (MemoryJavaFileManager manager = new MemoryJavaFileManager(
+                stdManager)) {
+
+            @SuppressWarnings("static-access")
+            JavaFileObject javaFileObject = manager.makeStringSource(javaName,
+                    javaSrc);
+            JavaCompiler.CompilationTask task = compiler.getTask(null, manager,
+                    null, null, null, Arrays.asList(javaFileObject));
+            if (task.call()) {
+                return manager.getClassBytes();
+            }
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    /**
+     * 先根据类名在内存中查找是否已存在该类，若不存在则调用 URLClassLoader的 defineClass方法加载该类
+     * URLClassLoader的具体作用就是将class文件加载到jvm虚拟机中去
+     *
+     * @author Administrator
+     *
+     */
+    public static class MemoryClassLoader extends URLClassLoader {
+        Map<String, byte[]> classBytes = new HashMap<String, byte[]>();
+
+        public MemoryClassLoader(Map<String, byte[]> classBytes) {
+            super(new URL[0], MemoryClassLoader.class.getClassLoader());
+            this.classBytes.putAll(classBytes);
+        }
+
+        @Override
+        protected Class<?> findClass(String name)
+                throws ClassNotFoundException {
+            byte[] buf = classBytes.get(name);
+            if (buf == null) {
+                return super.findClass(name);
+            }
+            classBytes.remove(name);
+            return defineClass(name, buf, 0, buf.length);
+        }
+    }
+}

cloud-etl-common/src/main/java/com/muyu/dynamicLoad/MemoryJavaFileManager.java

@@ -0,0 +1,134 @@
+package com.muyu.dynamicLoad;
+
+import javax.tools.*;
+import java.io.*;
+import java.net.URI;
+import java.nio.CharBuffer;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 将编译好的.class文件保存到内存当中，这里的内存也就是map映射当中
+ * @ClassName MemoryJavaFileManager
+ * @author CHX
+ * @Date 2024/5/1 20:38
+ */
+@SuppressWarnings("rawtypes")
+public final class MemoryJavaFileManager extends ForwardingJavaFileManager {
+
+    private final static String EXT = ".java";// Java源文件的扩展名
+    private Map<String, byte[]> classBytes;// 用于存放.class文件的内存
+
+    @SuppressWarnings("unchecked")
+    public MemoryJavaFileManager(JavaFileManager fileManager) {
+        super(fileManager);
+        classBytes = new HashMap<String, byte[]>();
+    }
+
+    public Map<String, byte[]> getClassBytes() {
+        return classBytes;
+    }
+
+    @Override
+    public void close() throws IOException {
+        classBytes = new HashMap<String, byte[]>();
+    }
+
+    @Override
+    public void flush() throws IOException {
+    }
+
+    /**
+     * 一个文件对象，用来表示从string中获取到的source，一下类容是按照jkd给出的例子写的
+     */
+    private static class StringInputBuffer extends SimpleJavaFileObject {
+        // The source code of this "file".
+        final String code;
+
+        /**
+         * Constructs a new JavaSourceFromString.
+         *
+         * @param name 此文件对象表示的编译单元的name
+         * @param code 此文件对象表示的编译单元source的code
+         */
+        StringInputBuffer(String name, String code) {
+            super(toURI(name), Kind.SOURCE);
+            this.code = code;
+        }
+
+        @Override
+        public CharBuffer getCharContent(boolean ignoreEncodingErrors) {
+            return CharBuffer.wrap(code);
+        }
+
+        @SuppressWarnings("unused")
+        public Reader openReader() {
+            return new StringReader(code);
+        }
+    }
+
+    /**
+     * 将Java字节码存储到classBytes映射中的文件对象
+     */
+    private class ClassOutputBuffer extends SimpleJavaFileObject {
+        private String name;
+
+        /**
+         * @param name className
+         */
+        ClassOutputBuffer(String name) {
+            super(toURI(name), Kind.CLASS);
+            this.name = name;
+        }
+
+        @Override
+        public OutputStream openOutputStream() {
+            return new FilterOutputStream(new ByteArrayOutputStream()) {
+                @Override
+                public void close() throws IOException {
+                    out.close();
+                    ByteArrayOutputStream bos = (ByteArrayOutputStream) out;
+
+                    // 这里需要修改
+                    classBytes.put(name, bos.toByteArray());
+                }
+            };
+        }
+    }
+
+    @Override
+    public JavaFileObject getJavaFileForOutput(
+            Location location, String className,
+            JavaFileObject.Kind kind, FileObject sibling) throws IOException {
+        if (kind == JavaFileObject.Kind.CLASS) {
+            return new ClassOutputBuffer(className);
+        } else {
+            return super.getJavaFileForOutput(location, className, kind,
+                    sibling);
+        }
+    }
+
+    static JavaFileObject makeStringSource(String name, String code) {
+        return new StringInputBuffer(name, code);
+    }
+
+    static URI toURI(String name) {
+        File file = new File(name);
+        if (file.exists()) {// 如果文件存在，返回他的URI
+            return file.toURI();
+        } else {
+            try {
+                final StringBuilder newUri = new StringBuilder();
+                newUri.append("mfm:///");
+                newUri.append(name.replace('.', '/'));
+                if (name.endsWith(EXT)) {
+                    newUri.replace(newUri.length() - EXT.length(),
+                            newUri.length(), EXT);
+                }
+                return URI.create(newUri.toString());
+            } catch (Exception exp) {
+                return URI.create("mfm:///com/sun/script/java/java_source");
+            }
+        }
+    }
+}

cloud-etl-server/src/main/java/com/muyu/controller/EngineVersionController.java

@@ -3,6 +3,7 @@ package com.muyu.controller;
 import com.muyu.common.core.domain.Result;
 import com.muyu.common.security.annotation.RequiresPermissions;
 import com.muyu.domain.constants.EngineVersion;
+import com.muyu.domain.model.TestData;
 import com.muyu.req.EngineVersionQueryReq;
 import com.muyu.resp.EngineConfigScopeResp;
 import com.muyu.service.EngineVersionService;
@@ -74,14 +75,13 @@ public class EngineVersionController {
         return Result.success(engineVersionService.getScopeInfoById(id));
     }
 
-//    /**
+    /**
-//     * 测试引擎规则配置
+     * 测试引擎规则配置
-//     */
+     */
-//    @RequiresPermissions("rule-engine:version:add")
+    @PostMapping(value = "/test")
-//    @PostMapping(value = "/test")
+    public Result<Object> ruleTest(@RequestBody TestData testData) {
-//    public Result<Object> ruleTest(@RequestBody TestData testData) {
+        return Result.success(engineVersionService.ruleTest(testData));
-//        return Result.success(engineVersionService.ruleTest(testData));
+    }
-//    }
 //
 //    /**
 //     * 新增引擎规则配置

cloud-etl-server/src/main/java/com/muyu/service/EngineVersionService.java

@@ -3,6 +3,7 @@ package com.muyu.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.muyu.common.core.domain.Result;
 import com.muyu.domain.constants.EngineVersion;
+import com.muyu.domain.model.TestData;
 import com.muyu.resp.EngineConfigScopeResp;
 
 import java.util.List;
@@ -33,4 +34,6 @@ public interface EngineVersionService extends IService<EngineVersion> {
     List<EngineConfigScopeResp> getScopeList();
 
     EngineConfigScopeResp getScopeInfoById(Integer id);
+
+    Object ruleTest(TestData testData);
 }

cloud-etl-server/src/main/java/com/muyu/service/serviceImpl/EngineVersionServiceImpl.java

@@ -3,19 +3,25 @@ package com.muyu.service.serviceImpl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.muyu.common.core.domain.Result;
+import com.muyu.common.core.exception.ServiceException;
 import com.muyu.common.core.utils.StringUtils;
 import com.muyu.domain.constants.EngineVersion;
 import com.muyu.domain.constants.ConfigCodeConstants;
+import com.muyu.domain.constants.RuleOperationConstants;
+import com.muyu.domain.model.TestData;
+import com.muyu.dynamicLoad.DynamicLoader;
 import com.muyu.mapper.EngineVersionMapper;
 import com.muyu.resp.EngineConfigScopeResp;
 import com.muyu.service.EngineVersionService;
 import org.springframework.stereotype.Service;
 
 import java.io.IOException;
+import java.lang.reflect.Method;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 
 /**
  * @Author：qdm
@@ -111,4 +117,30 @@ public class EngineVersionServiceImpl extends ServiceImpl<EngineVersionMapper, E
                 .code(code)
                 .build();
     }
+
+    @Override
+    public Object ruleTest(TestData testData) {
+        Object result = null;
+        try {
+            EngineVersion engineVersion = this.getById(testData.getId());
+            String content = engineVersion.getRuleContent().replaceAll("\r\n", "");
+            // 对source进行编译生成class文件存放在Map中，这里用bytecode接收
+            Map<String, byte[]> bytecode = DynamicLoader.compile(RuleOperationConstants.CLASS_NAME +
+                    RuleOperationConstants.FILE_SUFFIX, content);
+
+            // 加载class文件到虚拟机中，然后通过反射执行
+            @SuppressWarnings("resource")
+            DynamicLoader.MemoryClassLoader classLoader = new DynamicLoader.MemoryClassLoader(
+                    bytecode);
+            Class<?> clazz = classLoader.loadClass(RuleOperationConstants.CLASS_NAME);
+
+            // 调用ruleTest方法
+            Method mainMethod = clazz.getDeclaredMethod("ruleTest", List.class);
+            result = mainMethod.invoke(null, testData.getList());
+        } catch (Exception e) {
+            e.printStackTrace();
+            throw new ServiceException("测试失败");
+        }
+        return result;
+    }
 }

logs/cloud-etl-engine/info.log

@@ -396,3 +396,116 @@
 09:41:28.825 [http-nio-9703-exec-4] INFO  o.s.a.AbstractOpenApiResource - [getOpenApi,369] - Init duration for springdoc-openapi is: 406 ms
 10:27:04.540 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
 10:27:04.541 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] cloud-2112 deregistering service cloud-engine with instance: Instance{instanceId='null', ip='192.168.52.1', port=9703, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
+11:08:22.953 [main] INFO  c.m.EngineApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+11:08:25.928 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+11:08:25.928 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+11:08:26.017 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+11:08:27.354 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+11:08:27.355 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+11:08:27.355 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+11:08:28.745 [main] INFO  c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
+11:08:36.362 [main] INFO  c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
+11:08:36.363 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
+11:08:36.363 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
+11:08:36.369 [main] INFO  c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
+11:08:36.374 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
+11:08:36.374 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
+11:08:36.480 [main] INFO  c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 48d55511-ebbe-4bfa-8baa-2d92fd42e904
+11:08:36.483 [main] INFO  c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->48d55511-ebbe-4bfa-8baa-2d92fd42e904
+11:08:36.483 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [48d55511-ebbe-4bfa-8baa-2d92fd42e904] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
+11:08:36.483 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [48d55511-ebbe-4bfa-8baa-2d92fd42e904] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
+11:08:36.484 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [48d55511-ebbe-4bfa-8baa-2d92fd42e904] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
+11:08:36.484 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [48d55511-ebbe-4bfa-8baa-2d92fd42e904] Try to connect to server on start up, server: {serverIp = '47.116.184.54', server main port = 8848}
+11:08:36.484 [main] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+11:08:36.535 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [48d55511-ebbe-4bfa-8baa-2d92fd42e904] Success to connect to server [47.116.184.54:8848] on start up, connectionId = 1724555322850_139.224.212.27_62604
+11:08:36.535 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [48d55511-ebbe-4bfa-8baa-2d92fd42e904] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
+11:08:36.535 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [48d55511-ebbe-4bfa-8baa-2d92fd42e904] Notify connected event to listeners.
+11:08:36.535 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [48d55511-ebbe-4bfa-8baa-2d92fd42e904] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$575/0x000001d7814cea20
+11:08:36.535 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.client.naming - [onConnected,90] - Grpc connection connect
+11:08:36.537 [main] INFO  c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] cloud-2112 registering service cloud-engine with instance Instance{instanceId='null', ip='192.168.52.1', port=9703, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=null, preserved.register.source=SPRING_CLOUD}}
+11:08:36.555 [main] INFO  c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-engine 192.168.52.1:9703 register finished
+11:08:37.758 [main] INFO  c.m.EngineApplication - [logStarted,56] - Started EngineApplication in 21.289 seconds (process running for 22.351)
+11:08:37.767 [main] INFO  c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis 
+11:08:37.767 [main] INFO  c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true 
+11:08:37.768 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-cloud-2112-47.116.184.54_8848] [subscribe] cloud-engine.yml+DEFAULT_GROUP+cloud-2112
+11:08:37.780 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-cloud-2112-47.116.184.54_8848] [add-listener] ok, tenant=cloud-2112, dataId=cloud-engine.yml, group=DEFAULT_GROUP, cnt=1
+11:08:37.780 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-engine.yml, group=DEFAULT_GROUP
+11:08:37.781 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-cloud-2112-47.116.184.54_8848] [subscribe] cloud-engine+DEFAULT_GROUP+cloud-2112
+11:08:37.781 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-cloud-2112-47.116.184.54_8848] [add-listener] ok, tenant=cloud-2112, dataId=cloud-engine, group=DEFAULT_GROUP, cnt=1
+11:08:37.781 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-engine, group=DEFAULT_GROUP
+11:08:37.783 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-cloud-2112-47.116.184.54_8848] [subscribe] cloud-engine-dev.yml+DEFAULT_GROUP+cloud-2112
+11:08:37.783 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-cloud-2112-47.116.184.54_8848] [add-listener] ok, tenant=cloud-2112, dataId=cloud-engine-dev.yml, group=DEFAULT_GROUP, cnt=1
+11:08:37.783 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-engine-dev.yml, group=DEFAULT_GROUP
+11:08:38.241 [RMI TCP Connection(17)-10.100.28.5] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
+11:09:04.534 [http-nio-9703-exec-5] INFO  o.s.a.AbstractOpenApiResource - [getOpenApi,369] - Init duration for springdoc-openapi is: 367 ms
+11:09:28.013 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
+11:09:28.013 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] cloud-2112 deregistering service cloud-engine with instance: Instance{instanceId='null', ip='192.168.52.1', port=9703, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
+11:09:28.029 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
+11:09:28.030 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
+11:09:28.030 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
+11:09:28.030 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
+11:09:28.030 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
+11:09:28.030 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
+11:09:28.030 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
+11:09:28.030 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
+11:09:28.031 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
+11:09:28.031 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
+11:09:28.031 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
+11:09:28.031 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
+11:09:28.031 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for  uuid->48d55511-ebbe-4bfa-8baa-2d92fd42e904
+11:09:28.031 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@1ec7f44a[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 17]
+11:09:28.032 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
+11:09:28.032 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@16da482c[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
+11:09:28.032 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [closeConnection,584] - Close current connection 1724555322850_139.224.212.27_62604
+11:09:28.037 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@7c92d7f4[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 18]
+11:09:28.037 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client  for uuid ->48d55511-ebbe-4bfa-8baa-2d92fd42e904
+11:09:28.037 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
+11:09:28.038 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
+11:09:28.038 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
+11:09:28.043 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+11:09:28.046 [SpringApplicationShutdownHook] INFO  c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
+11:09:28.051 [SpringApplicationShutdownHook] INFO  c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
+11:09:28.051 [SpringApplicationShutdownHook] INFO  c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
+11:09:28.052 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+11:09:41.423 [main] INFO  c.m.EngineApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+11:09:44.181 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+11:09:44.181 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+11:09:44.274 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+11:09:45.517 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+11:09:45.519 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
+11:09:45.519 [main] INFO  c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
+11:09:46.778 [main] INFO  c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
+11:09:54.307 [main] INFO  c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
+11:09:54.308 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
+11:09:54.308 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
+11:09:54.314 [main] INFO  c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
+11:09:54.320 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
+11:09:54.320 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
+11:09:54.424 [main] INFO  c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 729f4ae5-4001-46bf-a30d-db0b64004305
+11:09:54.426 [main] INFO  c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->729f4ae5-4001-46bf-a30d-db0b64004305
+11:09:54.427 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [729f4ae5-4001-46bf-a30d-db0b64004305] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
+11:09:54.427 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [729f4ae5-4001-46bf-a30d-db0b64004305] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
+11:09:54.427 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [729f4ae5-4001-46bf-a30d-db0b64004305] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
+11:09:54.428 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [729f4ae5-4001-46bf-a30d-db0b64004305] Try to connect to server on start up, server: {serverIp = '47.116.184.54', server main port = 8848}
+11:09:54.428 [main] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+11:09:54.492 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [729f4ae5-4001-46bf-a30d-db0b64004305] Success to connect to server [47.116.184.54:8848] on start up, connectionId = 1724555400791_139.224.212.27_62945
+11:09:54.492 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [729f4ae5-4001-46bf-a30d-db0b64004305] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
+11:09:54.492 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [729f4ae5-4001-46bf-a30d-db0b64004305] Notify connected event to listeners.
+11:09:54.492 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [729f4ae5-4001-46bf-a30d-db0b64004305] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$575/0x000001dd944d2da0
+11:09:54.492 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.client.naming - [onConnected,90] - Grpc connection connect
+11:09:54.494 [main] INFO  c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] cloud-2112 registering service cloud-engine with instance Instance{instanceId='null', ip='192.168.52.1', port=9703, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=null, preserved.register.source=SPRING_CLOUD}}
+11:09:54.510 [main] INFO  c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-engine 192.168.52.1:9703 register finished
+11:09:55.720 [main] INFO  c.m.EngineApplication - [logStarted,56] - Started EngineApplication in 19.819 seconds (process running for 20.812)
+11:09:55.729 [main] INFO  c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis 
+11:09:55.730 [main] INFO  c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true 
+11:09:55.730 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-cloud-2112-47.116.184.54_8848] [subscribe] cloud-engine.yml+DEFAULT_GROUP+cloud-2112
+11:09:55.743 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-cloud-2112-47.116.184.54_8848] [add-listener] ok, tenant=cloud-2112, dataId=cloud-engine.yml, group=DEFAULT_GROUP, cnt=1
+11:09:55.743 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-engine.yml, group=DEFAULT_GROUP
+11:09:55.744 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-cloud-2112-47.116.184.54_8848] [subscribe] cloud-engine+DEFAULT_GROUP+cloud-2112
+11:09:55.744 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-cloud-2112-47.116.184.54_8848] [add-listener] ok, tenant=cloud-2112, dataId=cloud-engine, group=DEFAULT_GROUP, cnt=1
+11:09:55.744 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-engine, group=DEFAULT_GROUP
+11:09:55.746 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-cloud-2112-47.116.184.54_8848] [subscribe] cloud-engine-dev.yml+DEFAULT_GROUP+cloud-2112
+11:09:55.746 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-cloud-2112-47.116.184.54_8848] [add-listener] ok, tenant=cloud-2112, dataId=cloud-engine-dev.yml, group=DEFAULT_GROUP, cnt=1
+11:09:55.746 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-engine-dev.yml, group=DEFAULT_GROUP
+11:09:56.248 [RMI TCP Connection(2)-10.100.28.5] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
+11:10:35.907 [http-nio-9703-exec-4] INFO  o.s.a.AbstractOpenApiResource - [getOpenApi,369] - Init duration for springdoc-openapi is: 456 ms