diff --git a/cloud-rule-common/src/main/java/com/muyu/rule/common/utils/OssUtil.java b/cloud-rule-common/src/main/java/com/muyu/rule/common/utils/OssUtil.java index d435c8f..59d21de 100644 --- a/cloud-rule-common/src/main/java/com/muyu/rule/common/utils/OssUtil.java +++ b/cloud-rule-common/src/main/java/com/muyu/rule/common/utils/OssUtil.java @@ -171,15 +171,15 @@ public class OssUtil { * 直接读取OSS中的文件内容 * * @param bucketName 存储空间名称 - * @param objectName OSS中的对象名称 + * @param ossFilePath OSS中的对象名称 * @return 文件内容 */ - public static String readFileContentFromOSS(String bucketName, String objectName) { + public static String readFileContentFromOSS(String bucketName, String ossFilePath) { // 创建OSSClient实例。 OSS ossClient = new OSSClientBuilder().build(endPoint,accessKeyId,accessKeySecret); try { - GetObjectRequest getObjectRequest = new GetObjectRequest(bucketName, objectName); + GetObjectRequest getObjectRequest = new GetObjectRequest(bucketName, ossFilePath); OSSObject ossObject = ossClient.getObject(getObjectRequest); BufferedReader reader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent())); StringBuilder content = new StringBuilder(); @@ -187,6 +187,7 @@ public class OssUtil { while ((line = reader.readLine()) != null) { content.append(line).append("\n"); } + return content.toString(); } catch (Exception e) { e.printStackTrace(); diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/DataTest.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/DataTest.java index 8eeb8b2..c7bb7cc 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/DataTest.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/DataTest.java @@ -5,14 +5,19 @@ import com.aliyun.oss.OSSClientBuilder; import com.aliyun.oss.model.GetObjectRequest; import com.aliyun.oss.model.OSSObject; import com.aliyun.oss.model.PutObjectRequest; -import com.muyu.rule.common.domain.DataValue; -import com.muyu.rule.common.utils.OssUtil; +import javax.lang.model.element.Modifier; +import javax.lang.model.element.NestingKind; +import javax.tools.JavaFileObject; import java.io.*; -import java.nio.charset.StandardCharsets; -import java.nio.file.Files; -import java.nio.file.Path; -import java.nio.file.Paths; + +import javax.tools.*; +import java.net.URI; +import java.util.Arrays; +import java.util.Collections; +import java.util.List; +import java.util.Map; + /** * @Author：张承志 @@ -54,7 +59,7 @@ String sourceCode ="public class HelloWorld {\n" + byte[] contentBytes = sourceCode.getBytes(); // 创建PutObjectRequest。 - PutObjectRequest put = new PutObjectRequest(bucketName, "test", new ByteArrayInputStream(contentBytes)); + PutObjectRequest put = new PutObjectRequest(bucketName, "path/to/java/source/file", new ByteArrayInputStream(contentBytes)); // 上传字符串到OSS。 ossClient.putObject(put); @@ -75,6 +80,13 @@ String sourceCode ="public class HelloWorld {\n" + content.append(line).append("\n"); } System.out.println("读出的内容{}[]:"+content); + + String string = content.toString(); + + System.out.println("==>"+string); + + + } catch (Exception e) { throw new RuntimeException("读取失败：" + e.getMessage()); } finally { @@ -82,12 +94,12 @@ String sourceCode ="public class HelloWorld {\n" + ossClient.shutdown(); } - - - - - } + + + + + } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/EngineConfig.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/EngineConfig.java index c272e40..c933be8 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/EngineConfig.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/EngineConfig.java @@ -11,7 +11,7 @@ import java.util.concurrent.atomic.AtomicReference; */ public class EngineConfig { - public static final AtomicReference executionMethodName = new AtomicReference<>("execute"); + public static final AtomicReference executionMethodName = new AtomicReference<>("run"); /** * 包名称 diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/EngineTest.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/EngineTest.java index 049b5ad..ddb6770 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/EngineTest.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/EngineTest.java @@ -12,6 +12,7 @@ import javax.tools.ToolProvider; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.InputStream; +import java.nio.file.Path; import java.nio.file.Paths; import java.util.HashMap; import java.util.Map; @@ -29,35 +30,15 @@ public class EngineTest { EngineConfig engineConfig = new EngineConfig(); - JavaCompiler compiler = ToolProvider.getSystemJavaCompiler(); - - -// String string = OssUtil.uploadFileInputStreamForBucket("zcz-vfd-1000", engineConfig.getPack(),"E:\\practical_training\\cloud-etl-rule\\cloud-rule-server\\src\\main\\java\\com\\muyu\\rule\\server\\engine\\Engine_2024_8_23_2347.java"); -// -// try { -// InputStream fileInputStream = new FileInputStream("src/main/java/com/muyu/rule/server/engine/Engine_2024_8_23_2347.java"); -// } catch (FileNotFoundException e) { -// throw new RuntimeException(e); -// } -// -// System.out.println(string); -// -// String ossFilePath = OssUtil.getOssFilePath(engineConfig.getPack()); -// -// System.out.println("===>"+ossFilePath); -////读取 -//String s = OssUtil.readFileContentFromOSS("zcz-vfd-1000", engineConfig.getPack()); - -// System.out.println(s); - //扫描原码进行编译+-+- SourceCodeComplier.javaCompilerPath(engineConfig.getLocation()); //对class文件进行自定义类加载规则引擎 Map> stringClassMap = JavaBinaryClassLoader.loadClassesByLocation(engineConfig.getPack(),engineConfig.getLocation()); - System.out.println("====>"+stringClassMap); + stringClassMap.forEach((key,value)->{ - EngineContainer.loadEngineInstance(key,value); + System.out.println(key+"_____"+value); }); + stringClassMap.forEach(EngineContainer::loadEngineInstance); Map params = new HashMap<>(); params.put("idcard","142021200212215977"); @@ -65,9 +46,6 @@ params.put("idcard","142021200212215977"); System.out.println("====>"+engineObject); - - } - } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/FileCreator.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/FileCreator.java new file mode 100644 index 0000000..0086b1c --- /dev/null +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/FileCreator.java @@ -0,0 +1,45 @@ +package com.muyu.rule.server; + +import java.nio.file.*; +import java.nio.charset.StandardCharsets; +import java.io.IOException; + +public class FileCreator { + + public static void main(String[] args) { + String moduleRelativePath = "com.muyu.rule.server.NewService"; + String fileName = "NewService.java"; + String sourceCode = "package com.example.module;\n" + + "\n" + + "public class NewService {\n" + + " public String getServiceName() {\n" + + " return \"New Service\";\n" + + " }\n" + + "}\n"; + + createJavaFile(moduleRelativePath, fileName, sourceCode); + } + + private static void createJavaFile(String moduleRelativePath, String fileName, String sourceCode) { + Path modulePath = Paths.get(moduleRelativePath); + Path filePath = modulePath.resolve(fileName); + + try { + // 创建模块目录，如果不存在 + Files.createDirectories(modulePath); + + // 如果文件已存在，则删除它 + if (Files.exists(filePath)) { + Files.delete(filePath); + } + + // 创建新文件并写入源码 + Files.createFile(filePath); + Files.write(filePath, sourceCode.getBytes(StandardCharsets.UTF_8)); + + System.out.println("Java source file generated successfully at " + filePath.toAbsolutePath()); + } catch (IOException e) { + System.err.println("Failed to generate Java source file: " + e.getMessage()); + } + } +} diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/Main.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/Main.java index 383c032..b4e7da8 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/Main.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/Main.java @@ -15,15 +15,16 @@ import java.util.concurrent.ConcurrentHashMap; */ public class Main { - static Map> engineMap = new ConcurrentHashMap<>(); + static Map> engineMap = new ConcurrentHashMap<>(); static { try { Class aClass = Class.forName("com.muyu.rule.server.basic.engine.value.ENGINE_VALUE_VFD1000_V1"); - + Class aClass2 = Class.forName("com.muyu.rule.server.basic.engine.value.ENGINE_VALUE_VFD1000_V2"); try { engineMap.put("ENGINE_VALUE_VFD1000_V1", (BasicEngine) aClass.newInstance()); + engineMap.put("ENGINE_VALUE_VFD1000_V2", (BasicEngine) aClass2.newInstance()); } catch (InstantiationException e) { throw new RuntimeException(e); } catch (IllegalAccessException e) { @@ -51,6 +52,10 @@ public class Main { engineValue.execution(); + + + + } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/OSSClassLoaderExample.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/OSSClassLoaderExample.java new file mode 100644 index 0000000..e430ba7 --- /dev/null +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/OSSClassLoaderExample.java @@ -0,0 +1,155 @@ +package com.muyu.rule.server; + +import com.aliyun.oss.OSS; +import com.aliyun.oss.OSSClientBuilder; +import com.aliyun.oss.model.OSSObject; +import com.muyu.rule.common.domain.DataValue; +import com.muyu.rule.common.utils.OssUtil; +import com.muyu.rule.server.basic.BasicEngine; +import com.muyu.rule.server.complie.SourceCodeComplier; +import com.muyu.rule.server.execution.EngineExecution; +import com.muyu.rule.server.load.JavaBinaryClassLoader; +import com.muyu.rule.server.pool.container.EngineContainer; + +import javax.tools.JavaCompiler; +import javax.tools.ToolProvider; +import java.io.*; +import java.lang.reflect.Method; +import java.util.HashMap; +import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; +public class OSSClassLoaderExample { + + + static Map> engineMap = new ConcurrentHashMap<>(); + public static void main(String[] args) throws Exception { + + + + + +// String packageName = "com.muyu.rule.server.engine"; // 指定的包名 +// String className = "TempClass"; // 指定的类名 +// +// // 构建目标文件的完整路径 +// String projectPath = System.getProperty("cloud-etl-rule"); // 获取项目的根目录 +// System.out.println(projectPath); +// String packagePath = projectPath + File.separator + "src" + File.separator + "main" + File.separator + "java"; +// System.out.println(packagePath); +// // 分割包名并构建包路径 +// String[] packageParts = packageName.split("\\."); +// for (String part : packageParts) { +// packagePath += File.separator + part; +// } +// +// // 创建包路径对应的目录 +// File packageDir = new File(packagePath); +// if (!packageDir.exists() && !packageDir.mkdirs()) { +// System.err.println("Failed to create directory: " + packagePath); +// return; +// } +// +// // 构建文件的完整路径 +// String filePath = packagePath + File.separator + className + ".java"; +// +// System.out.println(filePath); +// +// // 创建文件 +// File sourceFile = new File(filePath); +// try { +// if (sourceFile.createNewFile()) { // 尝试创建新文件 +// System.out.println("Java source file created: " + sourceFile.getAbsolutePath()); +// +// // 写入一些内容到文件中 +// try (FileWriter writer = new FileWriter(sourceFile)) { +// writer.write("package " + packageName + ";\n\n"); +// writer.write("public class " + className + " {\n"); +// writer.write(" public static void main(String[] args) {\n"); +// writer.write(" System.out.println(\"Hello, this is a new Java file.\");\n"); +// writer.write(" }\n"); +// writer.write("}"); +// } +// } else { +// System.out.println("File already exists. Consider renaming or deleting the existing file."); +// } +// } catch (IOException e) { +// System.out.println("An error occurred while creating the file."); +// e.printStackTrace(); +// } + + +// +// System.out.println(string); +// +// +//// 将读取到的源代码写入临时文件。 +// String fileName = "ENGINE_phone_65321_V7.java"; // 指定文件名 +// File file = new File(fileName); +// boolean newFile = file.createNewFile(); +// + +// +//// 使用Java编译器编译临时文件。 +// JavaCompiler compiler = ToolProvider.getSystemJavaCompiler(); +// int result = compiler.run(null, null, null, file.getAbsolutePath()); +// if (result == 0) { +// System.out.println("编译成功"); +// } else { +// System.out.println("编译失败"); +// } +// +// +// +// +// +// +// 清理临时文件。 + //file.delete(); +//对class文件进行自定义类加载规则引擎 + + + + + +// +// +// Map> stringClassMap = JavaBinaryClassLoader.loadClassesByLocation("com.muyu.rule.server.basic.engine.",file.getAbsolutePath()); +// +// +// stringClassMap.forEach(EngineContainer::loadEngineInstance); +// +// Map params = new HashMap<>(); +// DataValue dataValue = DataValue.builder() +// .type("String") +// .label("姓名") +// .key("name") +// .value(null) +// .build(); +// params.put("dataValue",dataValue); +// Object engineObject = EngineExecution.engineExe("ENGINE_phone_65321_V7", params); +// +// System.out.println("====>"+engineObject); + + + +// Map params = new HashMap<>(); +// params.put("","142021200212215977"); +// Object engineObject = EngineExecution.engineExe("Engine_2024_8_23_2347", params); +// +// System.out.println("====>"+engineObject); + + + + + + + + + } + + + + + + +} diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/basic/engine/value/ENGINE_VALUE_VFD1000_V1.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/basic/engine/value/ENGINE_VALUE_VFD1000_V1.java index 82aa49f..ff43044 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/basic/engine/value/ENGINE_VALUE_VFD1000_V1.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/basic/engine/value/ENGINE_VALUE_VFD1000_V1.java @@ -2,6 +2,7 @@ package com.muyu.rule.server.basic.engine.value; import com.muyu.rule.common.domain.DataValue; import com.muyu.rule.server.basic.abstracts.DataEngineValueActuator; +import com.muyu.rule.server.exception.RuleEngineException; /** * @Author：张承志 @@ -16,6 +17,7 @@ public class ENGINE_VALUE_VFD1000_V1 extends DataEngineValueActuator { DataValue dataValue = get(); if (dataValue.getValue() == null){ System.out.println("数据为空"); + throw new RuleEngineException("数据为空"); } } } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java index 04b4a63..b9eb304 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java @@ -1,9 +1,13 @@ package com.muyu.rule.server.controller; import com.muyu.common.core.domain.Result; +import com.muyu.rule.common.domain.DataValue; import com.muyu.rule.common.domain.RuleEngineVersion; import com.muyu.rule.common.domain.req.VersionAddReq; import com.muyu.rule.common.utils.OssUtil; +import com.muyu.rule.server.basic.BasicEngine; +import com.muyu.rule.server.complie.SourceCodeComplier; +import com.muyu.rule.server.load.JavaBinaryClassLoader; import com.muyu.rule.server.service.RuleEngineVersionService; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.tags.Tag; @@ -13,6 +17,11 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; +import java.io.File; +import java.io.FileWriter; +import java.io.IOException; +import java.util.Map; + /** * @Author：张承志 * @Package：com.muyu.rule.server.controller @@ -35,8 +44,6 @@ public class RuleEngineVersionController { * @param versionAddReq 引擎版本添加实体类 * @return */ - - @PostMapping("/insertVersion") @Operation(summary = "增加规则引擎版本",description = "通过传入版本添加的实体类,进行规则引擎的版本添加") public Result insertVersion(@Validated @RequestBody VersionAddReq versionAddReq){ @@ -45,11 +52,8 @@ public class RuleEngineVersionController { if (true==save){ //添加成功则把增加的代码进行java编译,进行热加载 versionService.HotLoadClass(versionAddReq.getClassName(),versionAddReq.getVersionClazz()); - - } - return Result.success(); } @@ -71,7 +75,6 @@ public class RuleEngineVersionController { * 取消引擎请求 */ - @PostMapping("/disable/{id}") @Operation(summary = "规则引擎的取消", description = "通过Id取消规则引擎") public Result disable(@PathVariable("id") Long id){ @@ -111,6 +114,51 @@ Object o= versionService.readByOss(className); } + @PostMapping("/testvalue/{versionClazz}") +public Result testValue(@PathVariable("versionClazz") String versionClazz,@RequestBody DataValue dataValue){ + + versionService.testValue(versionClazz,dataValue); + + return Result.success(); +} + +@PostMapping("/test") +public Result test(){ + + String filePath = "cloud-rule-server/src/main/java/com/muyu/rule/server/basic/engine/value/"; + + String pack = "com.muyu.rule.server.basic.engine.value."; + + + File file = new File(filePath+"ENGINE_phone_zzzzz_V9.java"); + + String ossFilePath = "ENGINE_phone_zzzzz_V9.java"; + + try { + boolean newFile = file.createNewFile(); + + + String string = OssUtil.readFileContentFromOSS("zcz-vfd-1000",ossFilePath); + System.out.println(string); + try (FileWriter writer = new FileWriter(file)) { + writer.write(string); + }catch (IOException e) { + // 处理异常，例如记录日志或者通知用户 + e.printStackTrace(); + } + + //扫描原码进行编译+-+- + SourceCodeComplier.javaCompilerPath(filePath); +//对class文件进行自定义类加载规则引擎 + Map> stringClassMap = JavaBinaryClassLoader.loadClassesByLocation(pack,filePath); + + } catch (IOException e) { + throw new RuntimeException(e); + } + + + + // stringClassMap.forEach(EngineContainer::loadEngineInstance); @@ -118,5 +166,41 @@ Object o= versionService.readByOss(className); + return Result.success(); +} +@PostMapping("/look") +public Result look (){ + + + Class aClass = null; + try { + aClass = Class.forName("com.muyu.rule.server.basic.engine.value.ENGINE_phone_zzzzz_V9"); + + BasicEngine object =(BasicEngine)aClass.newInstance(); + + DataValue dataValue = DataValue.builder() + .type("String") + .label("姓名") + .key("name") + .value(null) + .build(); + object.set(dataValue); + + object.execution(); + + + } catch (Exception e) { + throw new RuntimeException(e); + } + + + + + +return Result.success(); +} + + + } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/RuleEngineVersionService.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/RuleEngineVersionService.java index 006a2c6..d042683 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/RuleEngineVersionService.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/RuleEngineVersionService.java @@ -1,6 +1,7 @@ package com.muyu.rule.server.service; import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.rule.common.domain.DataValue; import com.muyu.rule.common.domain.RuleEngineVersion; import java.util.List; @@ -45,4 +46,5 @@ public interface RuleEngineVersionService extends IService { void HotLoadClass(String className, String versionClazz); + void testValue(String versionClazz, DataValue dataValue); } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineServiceImpl.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineServiceImpl.java index 3e627a3..0e1cd33 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineServiceImpl.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineServiceImpl.java @@ -6,12 +6,15 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.muyu.common.core.enums.SystemYesNo; +import com.muyu.rule.common.domain.DataValue; import com.muyu.rule.common.domain.RuleEngine; import com.muyu.rule.common.domain.RuleEngineVersion; import com.muyu.rule.common.utils.OssUtil; +import com.muyu.rule.server.basic.BasicEngine; import com.muyu.rule.server.mapper.RuleEngineVersionMapper; import com.muyu.rule.server.scan.JavaCodeScan; import com.muyu.rule.server.service.RuleEngineVersionService; +import lombok.extern.log4j.Log4j2; import org.springframework.stereotype.Service; import java.io.ByteArrayInputStream; @@ -21,6 +24,8 @@ import java.nio.file.Path; import java.nio.file.Paths; import java.util.Base64; import java.util.List; +import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; import static com.muyu.rule.server.constant.SuffixClass.Suffix_JAVA; @@ -31,6 +36,7 @@ import static com.muyu.rule.server.constant.SuffixClass.Suffix_JAVA; * @name：RuleEngineServiceImpl * @Date：2024/8/25 14:17 */ +@Log4j2 @Service public class RuleEngineServiceImpl extends ServiceImpl implements RuleEngineVersionService { @@ -102,8 +108,40 @@ public class RuleEngineServiceImpl extends ServiceImpl> engineMap = new ConcurrentHashMap<>(); + + + static { + try { + Class aClass = Class.forName("com.muyu.rule.server.basic.engine.value.ENGINE_VALUE_VFD1000_V1"); + Class aClass2 = Class.forName("com.muyu.rule.server.basic.engine.value.ENGINE_VALUE_VFD1000_V2"); + try { + engineMap.put("ENGINE_VALUE_VFD1000_V1", (BasicEngine) aClass.newInstance()); + engineMap.put("ENGINE_VALUE_VFD1000_V2", (BasicEngine) aClass2.newInstance()); + } catch (InstantiationException e) { + throw new RuntimeException(e); + } catch (IllegalAccessException e) { + throw new RuntimeException(e); + } + } catch (ClassNotFoundException e) { + throw new RuntimeException(e); + } + + } + + @Override + public void testValue(String versionClazz, DataValue dataValue) { + + BasicEngine valueBasicEngine = engineMap.get(versionClazz); + + valueBasicEngine.set(dataValue); + + valueBasicEngine.execution(); } diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/util/FileLoadUtil.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/util/FileLoadUtil.java deleted file mode 100644 index dde0c68..0000000 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/util/FileLoadUtil.java +++ /dev/null @@ -1,82 +0,0 @@ -package com.muyu.rule.server.util; - -import com.muyu.rule.server.constant.SuffixClass; -import lombok.extern.log4j.Log4j2; - -import java.io.*; - -/** - * @Author：张承志 - * @Package：com.muyu.rule.server.util - * @Project：cloud-etl-rule - * @name：FileUtil - * @Date：2024/8/29 8:39 - */ -@Log4j2 -public class FileLoadUtil { - - public static void writeFile(String filePath,String fileName,String content){ - try { - String javaFile = fileName + filePath.split(".")[0]; - - // File file = new File(filePath + "//" + fileName + ".java"); - - BufferedWriter bufferedWriter = new BufferedWriter(new FileWriter(javaFile)); - //写入 - bufferedWriter.write(content); - //刷新 - bufferedWriter.flush(); - bufferedWriter.close(); - } catch (IOException e) { - throw new RuntimeException(e); - } - - } - -public static String readFile(String filePath,String fileName){ - File file = new File(filePath + '\\' + fileName + ".java"); - - try { - BufferedReader bufferedReader = new BufferedReader(new FileReader(file)); - - String content; - String len; - for (content = "";(len=bufferedReader.readLine())!= null;content = content +len + "\n"){ - } - - - return null; - } catch (IOException e) { - log.info("读取[{}]文件失败 ---> {}",fileName,e.getMessage(),e); - return ""; - } - - -} - - public static void main(String[] args) { - - - - - - - - } - - - - - - - - - - - - - - - - -} diff --git a/logs/cloud-etl/error.log b/logs/cloud-etl/error.log new file mode 100644 index 0000000..b28199b --- /dev/null +++ b/logs/cloud-etl/error.log @@ -0,0 +1,206 @@ +03:18:30.996 [xxl-job, executor ExecutorRegistryThread] ERROR c.x.j.c.u.XxlJobRemotingUtil - [postBody,143] - Connect timed out +java.net.SocketTimeoutException: Connect timed out + at java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:551) + at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:602) + at java.base/java.net.Socket.connect(Socket.java:633) + at java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:178) + at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:534) + at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:639) + at java.base/sun.net.www.http.HttpClient.(HttpClient.java:282) + at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:387) + at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:409) + at java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1309) + at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1242) + at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1128) + at java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1057) + at com.xxl.job.core.util.XxlJobRemotingUtil.postBody(XxlJobRemotingUtil.java:99) + at com.xxl.job.core.biz.client.AdminBizClient.registry(AdminBizClient.java:42) + at com.xxl.job.core.thread.ExecutorRegistryThread$1.run(ExecutorRegistryThread.java:48) + at java.base/java.lang.Thread.run(Thread.java:842) +03:18:43.649 [xxl-job, executor ExecutorRegistryThread] ERROR c.x.j.c.u.XxlJobRemotingUtil - [postBody,143] - Connect timed out +java.net.SocketTimeoutException: Connect timed out + at java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:551) + at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:602) + at java.base/java.net.Socket.connect(Socket.java:633) + at java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:178) + at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:534) + at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:639) + at java.base/sun.net.www.http.HttpClient.(HttpClient.java:282) + at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:387) + at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:409) + at java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1309) + at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1242) + at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1128) + at java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1057) + at com.xxl.job.core.util.XxlJobRemotingUtil.postBody(XxlJobRemotingUtil.java:99) + at com.xxl.job.core.biz.client.AdminBizClient.registryRemove(AdminBizClient.java:47) + at com.xxl.job.core.thread.ExecutorRegistryThread$1.run(ExecutorRegistryThread.java:84) + at java.base/java.lang.Thread.run(Thread.java:842) +03:21:13.064 [http-nio-13000-exec-1] ERROR c.m.c.s.h.GlobalExceptionHandler - [handleRuntimeException,98] - 请求地址'/version/testvalue/ENGINE_VALUE_VFD1000_V1',发生未知异常. +java.lang.IllegalArgumentException: Name for argument of type [java.lang.String] not specified, and parameter name information not available via reflection. Ensure that the compiler uses the '-parameters' flag. + at org.springframework.web.method.annotation.AbstractNamedValueMethodArgumentResolver.updateNamedValueInfo(AbstractNamedValueMethodArgumentResolver.java:187) + at org.springframework.web.method.annotation.AbstractNamedValueMethodArgumentResolver.getNamedValueInfo(AbstractNamedValueMethodArgumentResolver.java:162) + at org.springframework.web.method.annotation.AbstractNamedValueMethodArgumentResolver.resolveArgument(AbstractNamedValueMethodArgumentResolver.java:108) + at org.springframework.web.method.support.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:122) + at org.springframework.web.method.support.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:224) + at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:178) + at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:118) + at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:926) + at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:831) + at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) + at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1089) + at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:979) + at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1014) + at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:914) + at jakarta.servlet.http.HttpServlet.service(HttpServlet.java:590) + at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:885) + at jakarta.servlet.http.HttpServlet.service(HttpServlet.java:658) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:195) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:51) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.ServerHttpObservationFilter.doFilterInternal(ServerHttpObservationFilter.java:109) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:167) + at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:90) + at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:482) + at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:115) + at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:93) + at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) + at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:344) + at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:389) + at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:63) + at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:896) + at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1741) + at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:52) + at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1190) + at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659) + at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:63) + at java.base/java.lang.Thread.run(Thread.java:842) +03:22:11.660 [http-nio-13000-exec-2] ERROR c.m.c.s.h.GlobalExceptionHandler - [handleRuntimeException,98] - 请求地址'/version/testvalue/ENGINE_VALUE_VFD1000_V1',发生未知异常. +java.lang.IllegalArgumentException: Name for argument of type [java.lang.String] not specified, and parameter name information not available via reflection. Ensure that the compiler uses the '-parameters' flag. + at org.springframework.web.method.annotation.AbstractNamedValueMethodArgumentResolver.updateNamedValueInfo(AbstractNamedValueMethodArgumentResolver.java:187) + at org.springframework.web.method.annotation.AbstractNamedValueMethodArgumentResolver.getNamedValueInfo(AbstractNamedValueMethodArgumentResolver.java:162) + at org.springframework.web.method.annotation.AbstractNamedValueMethodArgumentResolver.resolveArgument(AbstractNamedValueMethodArgumentResolver.java:108) + at org.springframework.web.method.support.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:122) + at org.springframework.web.method.support.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:224) + at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:178) + at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:118) + at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:926) + at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:831) + at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) + at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1089) + at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:979) + at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1014) + at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:914) + at jakarta.servlet.http.HttpServlet.service(HttpServlet.java:590) + at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:885) + at jakarta.servlet.http.HttpServlet.service(HttpServlet.java:658) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:195) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:51) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.ServerHttpObservationFilter.doFilterInternal(ServerHttpObservationFilter.java:109) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:167) + at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:90) + at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:482) + at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:115) + at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:93) + at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) + at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:344) + at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:389) + at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:63) + at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:896) + at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1741) + at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:52) + at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1190) + at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659) + at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:63) + at java.base/java.lang.Thread.run(Thread.java:842) +03:23:05.991 [http-nio-13000-exec-3] ERROR c.m.c.s.h.GlobalExceptionHandler - [handleRuntimeException,98] - 请求地址'/version/testvalue/ENGINE_VALUE_VFD1000_V1',发生未知异常. +java.lang.IllegalArgumentException: Name for argument of type [java.lang.String] not specified, and parameter name information not available via reflection. Ensure that the compiler uses the '-parameters' flag. + at org.springframework.web.method.annotation.AbstractNamedValueMethodArgumentResolver.updateNamedValueInfo(AbstractNamedValueMethodArgumentResolver.java:187) + at org.springframework.web.method.annotation.AbstractNamedValueMethodArgumentResolver.getNamedValueInfo(AbstractNamedValueMethodArgumentResolver.java:162) + at org.springframework.web.method.annotation.AbstractNamedValueMethodArgumentResolver.resolveArgument(AbstractNamedValueMethodArgumentResolver.java:108) + at org.springframework.web.method.support.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:122) + at org.springframework.web.method.support.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:224) + at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:178) + at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:118) + at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:926) + at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:831) + at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) + at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1089) + at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:979) + at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1014) + at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:914) + at jakarta.servlet.http.HttpServlet.service(HttpServlet.java:590) + at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:885) + at jakarta.servlet.http.HttpServlet.service(HttpServlet.java:658) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:195) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:51) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.ServerHttpObservationFilter.doFilterInternal(ServerHttpObservationFilter.java:109) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) + at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:116) + at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:164) + at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:140) + at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:167) + at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:90) + at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:482) + at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:115) + at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:93) + at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) + at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:344) + at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:389) + at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:63) + at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:896) + at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1741) + at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:52) + at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1190) + at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659) + at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:63) + at java.base/java.lang.Thread.run(Thread.java:842) diff --git a/logs/cloud-etl/info.log b/logs/cloud-etl/info.log new file mode 100644 index 0000000..c075ce9 --- /dev/null +++ b/logs/cloud-etl/info.log @@ -0,0 +1,341 @@ +03:18:13.481 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev" +03:18:13.489 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.a.AbstractAbilityControlManager - [initAbilityTable,61] - Ready to get current node abilities... +03:18:13.490 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.a.AbstractAbilityControlManager - [initAbilityTable,89] - Ready to initialize current node abilities, support modes: [SDK_CLIENT] +03:18:13.491 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.a.AbstractAbilityControlManager - [initAbilityTable,94] - Initialize current abilities finish... +03:18:13.492 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.a.d.NacosAbilityManagerHolder - [initAbilityControlManager,85] - [AbilityControlManager] Successfully initialize AbilityControlManager +03:18:13.567 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5d0d1b83-4905-4d0b-a004-7bdb7fdc4620_config-0] Success to connect a server [12.2.0.252:8848], connectionId = 1725131891794_12.2.0.3_62623 +03:18:13.568 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5d0d1b83-4905-4d0b-a004-7bdb7fdc4620_config-0] Notify connected event to listeners. +03:18:13.568 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.c.i.ClientWorker - [onConnected,713] - [5d0d1b83-4905-4d0b-a004-7bdb7fdc4620_config-0] Connected,notify listen context... +03:18:16.267 [restartedMain] INFO c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface +03:18:17.108 [restartedMain] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat] +03:18:17.109 [restartedMain] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24] +03:18:17.226 [restartedMain] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext +03:18:17.887 [restartedMain] INFO c.m.c.d.MyMetaObjectHandler - [,17] - 元对象字段填充控制器 ------- 加载完成 +03:18:18.897 [restartedMain] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**]. +03:18:24.507 [restartedMain] INFO c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功 +03:18:25.017 [restartedMain] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success. +03:18:27.654 [restartedMain] INFO c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@47822098[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam] +03:18:27.656 [restartedMain] INFO c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@3cd8aa67[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam] +03:18:27.981 [Thread-18] INFO c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999 +03:18:28.973 [restartedMain] INFO c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null +03:18:28.974 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null +03:18:28.974 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null +03:18:28.980 [restartedMain] INFO c.a.n.client.naming - [,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource +03:18:29.003 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success. +03:18:29.003 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success. +03:18:29.336 [restartedMain] INFO c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 8d92dcdf-af0d-4533-a9f3-741c2585912a +03:18:29.339 [restartedMain] INFO c.a.n.client.naming - [,109] - Create naming rpc client for uuid->8d92dcdf-af0d-4533-a9f3-741c2585912a +03:18:29.340 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d92dcdf-af0d-4533-a9f3-741c2585912a] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager +03:18:29.340 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d92dcdf-af0d-4533-a9f3-741c2585912a] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService +03:18:29.340 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d92dcdf-af0d-4533-a9f3-741c2585912a] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler +03:18:29.341 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d92dcdf-af0d-4533-a9f3-741c2585912a] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848} +03:18:29.341 [restartedMain] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:12.2.0.252 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false} +03:18:29.658 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d92dcdf-af0d-4533-a9f3-741c2585912a] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1725131907950_12.2.0.3_62630 +03:18:29.659 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d92dcdf-af0d-4533-a9f3-741c2585912a] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler +03:18:29.659 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d92dcdf-af0d-4533-a9f3-741c2585912a] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$644/0x00000192d9510ad8 +03:18:29.659 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d92dcdf-af0d-4533-a9f3-741c2585912a] Notify connected event to listeners. +03:18:29.659 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.client.naming - [onConnected,90] - Grpc connection connect +03:18:29.660 [restartedMain] INFO c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] muyu-cloud registering service cloud-etl-rule with instance Instance{instanceId='null', ip='192.168.170.140', port=13000, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:9123:b096:80:b912:8c24:34ca], preserved.register.source=SPRING_CLOUD}} +03:18:29.784 [restartedMain] INFO c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl-rule 192.168.170.140:13000 register finished +03:18:30.978 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStarted,56] - Started EtlRuleApplication in 36.466 seconds (process running for 37.297) +03:18:30.990 [restartedMain] INFO c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis +03:18:30.990 [restartedMain] INFO c.a.n.c.c.i.CacheData - [,99] - nacos.cache.data.init.snapshot = true +03:18:30.991 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule+DEFAULT_GROUP+muyu-cloud +03:18:30.997 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl-rule', registryValue='http://192.168.170.140:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connect timed out), for url : http://47.103.41.248:20800/api/registry, content=null] +03:18:30.999 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule, group=DEFAULT_GROUP, cnt=1 +03:18:30.999 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule, group=DEFAULT_GROUP +03:18:31.000 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule-dev.yml+DEFAULT_GROUP+muyu-cloud +03:18:31.000 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP, cnt=1 +03:18:31.000 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP +03:18:31.000 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule.yml+DEFAULT_GROUP+muyu-cloud +03:18:31.000 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP, cnt=1 +03:18:31.002 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP +03:18:31.452 [nacos.client.config.listener.task-0] INFO c.a.n.c.c.i.CacheData - [safeNotifyListener,480] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-listener] task execute in nacos thread, dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=e4a2fb824aab26a5659c05dd328d77c8, listener=com.alibaba.cloud.nacos.refresh.NacosContextRefresher$1@b8c1f99 +03:18:31.453 [nacos.client.config.listener.task-0] INFO c.a.n.c.c.i.CacheData - [run,420] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-context] dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=e4a2fb824aab26a5659c05dd328d77c8 +03:18:31.651 [RMI TCP Connection(4)-192.168.170.140] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet' +03:18:33.401 [nacos.client.config.listener.task-0] INFO c.a.n.c.c.i.CacheData - [run,451] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-ok] dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=e4a2fb824aab26a5659c05dd328d77c8, listener=com.alibaba.cloud.nacos.refresh.NacosContextRefresher$1@b8c1f99 ,job run cost=1948 millis. +03:18:40.637 [Thread-18] INFO c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop. +03:18:43.650 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,90] - >>>>>>>>>>> xxl-job registry-remove fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl-rule', registryValue='http://192.168.170.140:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connect timed out), for url : http://47.103.41.248:20800/api/registryRemove, content=null] +03:18:43.650 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy. +03:18:43.651 [SpringApplicationShutdownHook] INFO c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success. +03:18:43.651 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy. +03:18:43.652 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy. +03:18:43.653 [Thread-17] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy. +03:18:43.670 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now... +03:18:43.671 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] muyu-cloud deregistering service cloud-etl-rule with instance: Instance{instanceId='null', ip='192.168.170.140', port=13000, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}} +03:18:43.729 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished. +03:18:43.732 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin +03:18:43.732 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin +03:18:43.733 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop +03:18:43.735 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop +03:18:43.736 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin +03:18:43.737 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin +03:18:43.738 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop +03:18:43.740 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin +03:18:43.740 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop +03:18:43.741 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin +03:18:43.742 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop +03:18:43.743 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for uuid->8d92dcdf-af0d-4533-a9f3-741c2585912a +03:18:43.743 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@59cf9230[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 4] +03:18:43.743 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown +03:18:43.743 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@70b2135d[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0] +03:18:43.743 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [closeConnection,584] - Close current connection 1725131907950_12.2.0.3_62630 +03:18:43.745 [SpringApplicationShutdownHook] INFO c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@51a32284[Running, pool size = 2, active threads = 0, queued tasks = 0, completed tasks = 11] +03:18:43.746 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client for uuid ->8d92dcdf-af0d-4533-a9f3-741c2585912a +03:18:43.748 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped +03:18:43.749 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed +03:18:43.749 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop +03:18:43.752 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing .... +03:18:43.752 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye +03:18:53.661 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev" +03:18:56.043 [restartedMain] INFO c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface +03:18:56.621 [restartedMain] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat] +03:18:56.621 [restartedMain] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24] +03:18:56.688 [restartedMain] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext +03:19:01.410 [restartedMain] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited +03:19:01.413 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success +03:19:01.414 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master] +03:19:01.479 [restartedMain] INFO c.m.c.d.MyMetaObjectHandler - [,17] - 元对象字段填充控制器 ------- 加载完成 +03:19:02.447 [restartedMain] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**]. +03:19:09.759 [restartedMain] INFO c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功 +03:19:10.162 [restartedMain] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success. +03:19:12.701 [restartedMain] INFO c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@3de736a7[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam] +03:19:12.701 [restartedMain] INFO c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@1e5a8615[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam] +03:19:13.010 [Thread-18] INFO c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999 +03:19:14.014 [restartedMain] INFO c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null +03:19:14.019 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null +03:19:14.019 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null +03:19:14.026 [restartedMain] INFO c.a.n.client.naming - [,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource +03:19:14.032 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success. +03:19:14.032 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success. +03:19:14.202 [restartedMain] INFO c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 7a535b25-ecf4-4b75-8eeb-c9ea11340417 +03:19:14.205 [restartedMain] INFO c.a.n.client.naming - [,109] - Create naming rpc client for uuid->7a535b25-ecf4-4b75-8eeb-c9ea11340417 +03:19:14.205 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7a535b25-ecf4-4b75-8eeb-c9ea11340417] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager +03:19:14.206 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7a535b25-ecf4-4b75-8eeb-c9ea11340417] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService +03:19:14.207 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7a535b25-ecf4-4b75-8eeb-c9ea11340417] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler +03:19:14.207 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7a535b25-ecf4-4b75-8eeb-c9ea11340417] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848} +03:19:14.208 [restartedMain] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:12.2.0.252 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false} +03:19:14.477 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7a535b25-ecf4-4b75-8eeb-c9ea11340417] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1725131952829_12.2.0.3_62645 +03:19:14.478 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7a535b25-ecf4-4b75-8eeb-c9ea11340417] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler +03:19:14.478 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7a535b25-ecf4-4b75-8eeb-c9ea11340417] Notify connected event to listeners. +03:19:14.478 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7a535b25-ecf4-4b75-8eeb-c9ea11340417] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$647/0x000001e423510000 +03:19:14.478 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.client.naming - [onConnected,90] - Grpc connection connect +03:19:14.480 [restartedMain] INFO c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] muyu-cloud registering service cloud-etl-rule with instance Instance{instanceId='null', ip='192.168.170.140', port=13000, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:9123:b096:80:b912:8c24:34ca], preserved.register.source=SPRING_CLOUD}} +03:19:14.572 [restartedMain] INFO c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl-rule 192.168.170.140:13000 register finished +03:19:15.767 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStarted,56] - Started EtlRuleApplication in 27.916 seconds (process running for 28.657) +03:19:15.780 [restartedMain] INFO c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis +03:19:15.781 [restartedMain] INFO c.a.n.c.c.i.CacheData - [,99] - nacos.cache.data.init.snapshot = true +03:19:15.781 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule+DEFAULT_GROUP+muyu-cloud +03:19:15.791 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule, group=DEFAULT_GROUP, cnt=1 +03:19:15.791 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule, group=DEFAULT_GROUP +03:19:15.792 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule-dev.yml+DEFAULT_GROUP+muyu-cloud +03:19:15.793 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP, cnt=1 +03:19:15.793 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP +03:19:15.793 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule.yml+DEFAULT_GROUP+muyu-cloud +03:19:15.793 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP, cnt=1 +03:19:15.793 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP +03:19:16.255 [RMI TCP Connection(5)-192.168.170.140] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet' +03:24:48.218 [Thread-18] INFO c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop. +03:24:48.282 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,87] - >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl-rule', registryValue='http://192.168.170.140:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null] +03:24:48.283 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy. +03:24:48.283 [SpringApplicationShutdownHook] INFO c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success. +03:24:48.284 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy. +03:24:48.285 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy. +03:24:48.285 [Thread-17] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy. +03:24:48.302 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now... +03:24:48.302 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] muyu-cloud deregistering service cloud-etl-rule with instance: Instance{instanceId='null', ip='192.168.170.140', port=13000, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}} +03:24:48.410 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished. +03:24:48.413 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin +03:24:48.413 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin +03:24:48.414 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop +03:24:48.414 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop +03:24:48.415 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin +03:24:48.415 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin +03:24:48.415 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop +03:24:48.415 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin +03:24:48.415 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop +03:24:48.415 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin +03:24:48.415 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop +03:24:48.416 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for uuid->7a535b25-ecf4-4b75-8eeb-c9ea11340417 +03:24:48.416 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@e5c30c2[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 111] +03:24:48.416 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown +03:24:48.417 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@19090936[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0] +03:24:48.417 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [closeConnection,584] - Close current connection 1725131952829_12.2.0.3_62645 +03:24:48.430 [SpringApplicationShutdownHook] INFO c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@b8c89c1[Running, pool size = 4, active threads = 0, queued tasks = 0, completed tasks = 71] +03:24:48.430 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client for uuid ->7a535b25-ecf4-4b75-8eeb-c9ea11340417 +03:24:48.431 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped +03:24:48.432 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed +03:24:48.432 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop +03:24:48.437 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing .... +03:24:48.443 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ... +03:24:48.456 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed +03:24:48.456 [SpringApplicationShutdownHook] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success, +03:24:48.456 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye +03:25:02.355 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev" +03:25:05.035 [restartedMain] INFO c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface +03:25:05.718 [restartedMain] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat] +03:25:05.719 [restartedMain] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24] +03:25:05.785 [restartedMain] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext +03:25:10.189 [restartedMain] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited +03:25:10.191 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success +03:25:10.192 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master] +03:25:10.262 [restartedMain] INFO c.m.c.d.MyMetaObjectHandler - [,17] - 元对象字段填充控制器 ------- 加载完成 +03:25:11.179 [restartedMain] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**]. +03:25:15.825 [restartedMain] INFO c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功 +03:25:16.203 [restartedMain] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success. +03:25:18.788 [restartedMain] INFO c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@787ae2d2[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam] +03:25:18.788 [restartedMain] INFO c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@414d1343[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam] +03:25:19.082 [Thread-18] INFO c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999 +03:25:20.112 [restartedMain] INFO c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null +03:25:20.112 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null +03:25:20.113 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null +03:25:20.120 [restartedMain] INFO c.a.n.client.naming - [,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource +03:25:20.126 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success. +03:25:20.126 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success. +03:25:20.284 [restartedMain] INFO c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of b309f106-169c-444e-84f9-14f278e85ed0 +03:25:20.287 [restartedMain] INFO c.a.n.client.naming - [,109] - Create naming rpc client for uuid->b309f106-169c-444e-84f9-14f278e85ed0 +03:25:20.287 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [b309f106-169c-444e-84f9-14f278e85ed0] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager +03:25:20.287 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [b309f106-169c-444e-84f9-14f278e85ed0] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService +03:25:20.289 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [b309f106-169c-444e-84f9-14f278e85ed0] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler +03:25:20.289 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [b309f106-169c-444e-84f9-14f278e85ed0] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848} +03:25:20.307 [restartedMain] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:12.2.0.252 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false} +03:25:20.606 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [b309f106-169c-444e-84f9-14f278e85ed0] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1725132318945_12.2.0.3_62693 +03:25:20.607 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [b309f106-169c-444e-84f9-14f278e85ed0] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler +03:25:20.607 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [b309f106-169c-444e-84f9-14f278e85ed0] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$647/0x0000017cc052f060 +03:25:20.607 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [b309f106-169c-444e-84f9-14f278e85ed0] Notify connected event to listeners. +03:25:20.608 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.client.naming - [onConnected,90] - Grpc connection connect +03:25:20.610 [restartedMain] INFO c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] muyu-cloud registering service cloud-etl-rule with instance Instance{instanceId='null', ip='192.168.170.140', port=13000, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:9123:b096:80:b912:8c24:34ca], preserved.register.source=SPRING_CLOUD}} +03:25:20.717 [restartedMain] INFO c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl-rule 192.168.170.140:13000 register finished +03:25:21.923 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStarted,56] - Started EtlRuleApplication in 25.464 seconds (process running for 27.019) +03:25:21.942 [restartedMain] INFO c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis +03:25:21.942 [restartedMain] INFO c.a.n.c.c.i.CacheData - [,99] - nacos.cache.data.init.snapshot = true +03:25:21.943 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule+DEFAULT_GROUP+muyu-cloud +03:25:21.954 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule, group=DEFAULT_GROUP, cnt=1 +03:25:21.954 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule, group=DEFAULT_GROUP +03:25:21.957 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule-dev.yml+DEFAULT_GROUP+muyu-cloud +03:25:21.957 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP, cnt=1 +03:25:21.957 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP +03:25:21.957 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule.yml+DEFAULT_GROUP+muyu-cloud +03:25:21.958 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP, cnt=1 +03:25:21.958 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP +03:25:22.561 [RMI TCP Connection(1)-192.168.170.140] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet' +03:32:00.335 [Thread-18] INFO c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop. +03:32:00.375 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,87] - >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl-rule', registryValue='http://192.168.170.140:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null] +03:32:00.375 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy. +03:32:00.375 [SpringApplicationShutdownHook] INFO c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success. +03:32:00.375 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy. +03:32:00.377 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy. +03:32:00.377 [Thread-17] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy. +03:32:00.389 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now... +03:32:00.389 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] muyu-cloud deregistering service cloud-etl-rule with instance: Instance{instanceId='null', ip='192.168.170.140', port=13000, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}} +03:32:00.439 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished. +03:32:00.440 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin +03:32:00.441 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin +03:32:00.441 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop +03:32:00.441 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop +03:32:00.441 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin +03:32:00.441 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin +03:32:00.441 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop +03:32:00.441 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin +03:32:00.442 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop +03:32:00.442 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin +03:32:00.442 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop +03:32:00.442 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for uuid->b309f106-169c-444e-84f9-14f278e85ed0 +03:32:00.442 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@3d40fe30[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 128] +03:32:00.442 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown +03:32:00.442 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@33bb3bc5[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0] +03:32:00.442 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [closeConnection,584] - Close current connection 1725132318945_12.2.0.3_62693 +03:32:00.447 [SpringApplicationShutdownHook] INFO c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@13024588[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 81] +03:32:00.447 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client for uuid ->b309f106-169c-444e-84f9-14f278e85ed0 +03:32:00.448 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped +03:32:00.448 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed +03:32:00.448 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop +03:32:00.450 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing .... +03:32:00.454 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ... +03:32:00.460 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed +03:32:00.460 [SpringApplicationShutdownHook] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success, +03:32:00.460 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye +09:08:19.984 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev" +09:08:21.800 [restartedMain] INFO c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface +09:08:22.212 [restartedMain] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat] +09:08:22.212 [restartedMain] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24] +09:08:22.257 [restartedMain] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext +09:08:24.857 [restartedMain] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited +09:08:24.858 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success +09:08:24.858 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master] +09:08:24.916 [restartedMain] INFO c.m.c.d.MyMetaObjectHandler - [,17] - 元对象字段填充控制器 ------- 加载完成 +09:08:25.474 [restartedMain] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**]. +09:08:30.582 [restartedMain] INFO c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功 +09:08:30.876 [restartedMain] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success. +09:08:32.842 [restartedMain] INFO c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@1b171127[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam] +09:08:32.842 [restartedMain] INFO c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@2e52eab8[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam] +09:08:33.056 [Thread-18] INFO c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999 +09:08:34.075 [restartedMain] INFO c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null +09:08:34.076 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null +09:08:34.076 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null +09:08:34.079 [restartedMain] INFO c.a.n.client.naming - [,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource +09:08:34.081 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success. +09:08:34.081 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success. +09:08:34.344 [restartedMain] INFO c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 8258ba59-b1d2-4c85-8abd-b63c50084d93 +09:08:34.346 [restartedMain] INFO c.a.n.client.naming - [,109] - Create naming rpc client for uuid->8258ba59-b1d2-4c85-8abd-b63c50084d93 +09:08:34.346 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8258ba59-b1d2-4c85-8abd-b63c50084d93] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager +09:08:34.346 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8258ba59-b1d2-4c85-8abd-b63c50084d93] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService +09:08:34.346 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8258ba59-b1d2-4c85-8abd-b63c50084d93] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler +09:08:34.347 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8258ba59-b1d2-4c85-8abd-b63c50084d93] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848} +09:08:34.347 [restartedMain] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:12.2.0.252 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false} +09:08:34.555 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8258ba59-b1d2-4c85-8abd-b63c50084d93] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1725152912965_12.2.0.3_63602 +09:08:34.555 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8258ba59-b1d2-4c85-8abd-b63c50084d93] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler +09:08:34.555 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8258ba59-b1d2-4c85-8abd-b63c50084d93] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$647/0x0000020437510228 +09:08:34.555 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8258ba59-b1d2-4c85-8abd-b63c50084d93] Notify connected event to listeners. +09:08:34.556 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.client.naming - [onConnected,90] - Grpc connection connect +09:08:34.556 [restartedMain] INFO c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] muyu-cloud registering service cloud-etl-rule with instance Instance{instanceId='null', ip='192.168.170.140', port=13000, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:90c1:c714:67e3:343c:d52a:5481], preserved.register.source=SPRING_CLOUD}} +09:08:34.621 [restartedMain] INFO c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl-rule 192.168.170.140:13000 register finished +09:08:35.727 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStarted,56] - Started EtlRuleApplication in 20.575 seconds (process running for 21.126) +09:08:35.734 [restartedMain] INFO c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis +09:08:35.734 [restartedMain] INFO c.a.n.c.c.i.CacheData - [,99] - nacos.cache.data.init.snapshot = true +09:08:35.734 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule+DEFAULT_GROUP+muyu-cloud +09:08:35.739 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule, group=DEFAULT_GROUP, cnt=1 +09:08:35.739 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule, group=DEFAULT_GROUP +09:08:35.741 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule-dev.yml+DEFAULT_GROUP+muyu-cloud +09:08:35.741 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP, cnt=1 +09:08:35.741 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP +09:08:35.741 [restartedMain] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-rule.yml+DEFAULT_GROUP+muyu-cloud +09:08:35.741 [restartedMain] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP, cnt=1 +09:08:35.741 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP +09:08:36.278 [RMI TCP Connection(3)-192.168.170.140] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet' +09:16:05.340 [Thread-18] INFO c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop. +09:16:05.379 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,87] - >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl-rule', registryValue='http://192.168.170.140:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null] +09:16:05.379 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy. +09:16:05.379 [SpringApplicationShutdownHook] INFO c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success. +09:16:05.379 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy. +09:16:05.380 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy. +09:16:05.380 [Thread-17] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy. +09:16:05.388 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now... +09:16:05.388 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] muyu-cloud deregistering service cloud-etl-rule with instance: Instance{instanceId='null', ip='192.168.170.140', port=13000, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}} +09:16:05.424 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished. +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin +09:16:05.426 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop +09:16:05.427 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for uuid->8258ba59-b1d2-4c85-8abd-b63c50084d93 +09:16:05.427 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@1e7361aa[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 149] +09:16:05.427 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown +09:16:05.427 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@31ab3002[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0] +09:16:05.427 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [closeConnection,584] - Close current connection 1725152912965_12.2.0.3_63602 +09:16:05.430 [SpringApplicationShutdownHook] INFO c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@2bdb170d[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 99] +09:16:05.430 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client for uuid ->8258ba59-b1d2-4c85-8abd-b63c50084d93 +09:16:05.430 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped +09:16:05.431 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed +09:16:05.431 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop +09:16:05.432 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing .... +09:16:05.433 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ... +09:16:05.438 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed +09:16:05.438 [SpringApplicationShutdownHook] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success, +09:16:05.438 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye