11111
parent
9a8703cf12
commit
fd62a00ba5
|
@ -25,118 +25,61 @@ public class OSSClassLoaderExample {
|
|||
public static void main(String[] args) throws Exception {
|
||||
|
||||
|
||||
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 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();
|
||||
// }
|
||||
String ossFilePath = "ENGINE_phone_zzzzz_V9.java";
|
||||
|
||||
try {
|
||||
boolean newFile = file.createNewFile();
|
||||
|
||||
|
||||
//
|
||||
// System.out.println(string);
|
||||
//
|
||||
//
|
||||
//// 将读取到的源代码写入临时文件。
|
||||
// String fileName = "ENGINE_phone_65321_V7.java"; // 指定文件名
|
||||
// File file = new File(fileName);
|
||||
// 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();
|
||||
}
|
||||
|
||||
//
|
||||
//// 使用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();
|
||||
//扫描原码进行编译+-+-
|
||||
SourceCodeComplier.javaCompilerPath(filePath);
|
||||
//对class文件进行自定义类加载规则引擎
|
||||
Map<String ,Class<?>> stringClassMap = JavaBinaryClassLoader.loadClassesByLocation(pack,filePath);
|
||||
|
||||
} catch (IOException e) {
|
||||
throw new RuntimeException(e);
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
// Class<?> aClass = null;
|
||||
// try {
|
||||
// aClass = Class.forName("com.muyu.rule.server.basic.engine.value.ENGINE_phone_zzzzz_V9");
|
||||
//
|
||||
// BasicEngine<DataValue> object =(BasicEngine<DataValue>)aClass.newInstance();
|
||||
//
|
||||
// DataValue dataValue = DataValue.builder()
|
||||
// .type("String")
|
||||
// .label("姓名")
|
||||
// .key("name")
|
||||
// .value(null)
|
||||
// .build();
|
||||
// object.set(dataValue);
|
||||
//
|
||||
// object.execution();
|
||||
//
|
||||
//
|
||||
// Map<String ,Class<?>> stringClassMap = JavaBinaryClassLoader.loadClassesByLocation("com.muyu.rule.server.basic.engine.",file.getAbsolutePath());
|
||||
//
|
||||
//
|
||||
// stringClassMap.forEach(EngineContainer::loadEngineInstance);
|
||||
//
|
||||
// Map<String, Object> 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);
|
||||
// } catch (Exception e) {
|
||||
// throw new RuntimeException(e);
|
||||
// }
|
||||
|
||||
|
||||
|
||||
|
||||
// Map<String, Object> params = new HashMap<>();
|
||||
// params.put("","142021200212215977");
|
||||
// Object engineObject = EngineExecution.engineExe("Engine_2024_8_23_2347", params);
|
||||
//
|
||||
// System.out.println("====>"+engineObject);
|
||||
|
||||
|
||||
|
||||
|
|
Binary file not shown.
Binary file not shown.
|
@ -161,37 +161,17 @@ public Result test(){
|
|||
// stringClassMap.forEach(EngineContainer::loadEngineInstance);
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
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");
|
||||
String ossFilePath = "ENGINE_phone_zzzzz_V9.java";
|
||||
|
||||
BasicEngine<DataValue> object =(BasicEngine<DataValue>)aClass.newInstance();
|
||||
String filePath ="home/"+ossFilePath;
|
||||
|
||||
DataValue dataValue = DataValue.builder()
|
||||
.type("String")
|
||||
.label("姓名")
|
||||
.key("name")
|
||||
.value(null)
|
||||
.build();
|
||||
object.set(dataValue);
|
||||
|
||||
object.execution();
|
||||
|
||||
|
||||
} catch (Exception e) {
|
||||
throw new RuntimeException(e);
|
||||
}
|
||||
OssUtil.downloadFileForBucket("zcz-vfd-1000",ossFilePath,filePath);
|
||||
|
||||
|
||||
|
||||
|
|
|
@ -204,3 +204,68 @@ java.lang.IllegalArgumentException: Name for argument of type [java.lang.String]
|
|||
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)
|
||||
15:50:29.301 [http-nio-13000-exec-6] ERROR c.m.c.s.h.GlobalExceptionHandler - [handleException,108] - 请求地址'/version/test',发生系统异常.
|
||||
jakarta.servlet.ServletException: Handler dispatch failed: java.lang.LinkageError: loader com.muyu.rule.server.load.JavaBinaryClassLoader @d340035 attempted duplicate class definition for com.muyu.rule.server.basic.engine.value.ENGINE_phone_zzzzz_V9. (com.muyu.rule.server.basic.engine.value.ENGINE_phone_zzzzz_V9 is in unnamed module of loader com.muyu.rule.server.load.JavaBinaryClassLoader @d340035, parent loader 'app')
|
||||
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1104)
|
||||
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)
|
||||
Caused by: java.lang.LinkageError: loader com.muyu.rule.server.load.JavaBinaryClassLoader @d340035 attempted duplicate class definition for com.muyu.rule.server.basic.engine.value.ENGINE_phone_zzzzz_V9. (com.muyu.rule.server.basic.engine.value.ENGINE_phone_zzzzz_V9 is in unnamed module of loader com.muyu.rule.server.load.JavaBinaryClassLoader @d340035, parent loader 'app')
|
||||
at java.base/java.lang.ClassLoader.defineClass1(Native Method)
|
||||
at java.base/java.lang.ClassLoader.defineClass(ClassLoader.java:1012)
|
||||
at java.base/java.lang.ClassLoader.defineClass(ClassLoader.java:874)
|
||||
at com.muyu.rule.server.load.JavaBinaryClassLoader.loadClassByNameAndLocation(JavaBinaryClassLoader.java:51)
|
||||
at com.muyu.rule.server.load.JavaBinaryClassLoader.loadClassesByLocation(JavaBinaryClassLoader.java:73)
|
||||
at com.muyu.rule.server.controller.RuleEngineVersionController.test(RuleEngineVersionController.java:153)
|
||||
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
|
||||
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
|
||||
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
|
||||
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
|
||||
at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:255)
|
||||
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:188)
|
||||
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)
|
||||
... 43 common frames omitted
|
||||
|
|
|
@ -339,3 +339,156 @@
|
|||
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
|
||||
15:48:53.317 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
|
||||
15:48:54.840 [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
|
||||
15:48:55.231 [restartedMain] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
|
||||
15:48:55.231 [restartedMain] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
|
||||
15:48:55.276 [restartedMain] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
|
||||
15:48:58.492 [restartedMain] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
|
||||
15:48:58.493 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
|
||||
15:48:58.494 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
|
||||
15:48:58.527 [restartedMain] INFO c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
|
||||
15:48:59.065 [restartedMain] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
|
||||
15:49:04.143 [restartedMain] INFO c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功
|
||||
15:49:04.361 [restartedMain] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
|
||||
15:49:06.338 [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@753fe8a7[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
|
||||
15:49:06.338 [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@23e8cb8a[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
|
||||
15:49:06.484 [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
|
||||
15:49:07.506 [restartedMain] INFO c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
|
||||
15:49:07.506 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
|
||||
15:49:07.507 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
|
||||
15:49:07.513 [restartedMain] INFO c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
|
||||
15:49:07.516 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
|
||||
15:49:07.516 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
|
||||
15:49:07.846 [restartedMain] INFO c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 5b4008e1-5a8c-4dfb-bf36-74e3282e629e
|
||||
15:49:07.850 [restartedMain] INFO c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->5b4008e1-5a8c-4dfb-bf36-74e3282e629e
|
||||
15:49:07.850 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5b4008e1-5a8c-4dfb-bf36-74e3282e629e] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
|
||||
15:49:07.851 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5b4008e1-5a8c-4dfb-bf36-74e3282e629e] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
|
||||
15:49:07.852 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5b4008e1-5a8c-4dfb-bf36-74e3282e629e] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
|
||||
15:49:07.853 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5b4008e1-5a8c-4dfb-bf36-74e3282e629e] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848}
|
||||
15:49:07.853 [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}
|
||||
15:49:08.226 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5b4008e1-5a8c-4dfb-bf36-74e3282e629e] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1725176946580_12.2.0.3_62851
|
||||
15:49:08.226 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5b4008e1-5a8c-4dfb-bf36-74e3282e629e] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
|
||||
15:49:08.226 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5b4008e1-5a8c-4dfb-bf36-74e3282e629e] Notify connected event to listeners.
|
||||
15:49:08.226 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [5b4008e1-5a8c-4dfb-bf36-74e3282e629e] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$647/0x0000023951510440
|
||||
15:49:08.226 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.client.naming - [onConnected,90] - Grpc connection connect
|
||||
15:49:08.227 [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}}
|
||||
15:49:08.333 [restartedMain] INFO c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl-rule 192.168.170.140:13000 register finished
|
||||
15:49:09.444 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStarted,56] - Started EtlRuleApplication in 20.655 seconds (process running for 21.083)
|
||||
15:49:09.450 [restartedMain] INFO c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis
|
||||
15:49:09.451 [restartedMain] INFO c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true
|
||||
15:49:09.451 [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
|
||||
15:49:09.455 [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
|
||||
15:49:09.456 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule, group=DEFAULT_GROUP
|
||||
15:49:09.457 [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
|
||||
15:49:09.457 [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
|
||||
15:49:09.457 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP
|
||||
15:49:09.457 [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
|
||||
15:49:09.457 [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
|
||||
15:49:09.457 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP
|
||||
15:49:09.838 [RMI TCP Connection(2)-192.168.170.140] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
|
||||
15:49:31.917 [http-nio-13000-exec-1] INFO c.m.r.c.u.OssUtil - [<clinit>,45] - oss服务连接成功!
|
||||
15:49:32.360 [http-nio-13000-exec-1] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.java文件->ENGINE_phone_zzzzz_V9.java
|
||||
15:49:32.360 [http-nio-13000-exec-1] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.java文件->ENGINE_VALUE_VFD1000_V1.java
|
||||
15:49:32.361 [http-nio-13000-exec-1] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.java文件->ENGINE_VALUE_VFD1000_V2.java
|
||||
15:49:33.166 [http-nio-13000-exec-1] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.class文件->ENGINE_phone_zzzzz_V9.class
|
||||
15:49:33.166 [http-nio-13000-exec-1] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.class文件->ENGINE_VALUE_VFD1000_V1.class
|
||||
15:49:33.167 [http-nio-13000-exec-1] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.class文件->ENGINE_VALUE_VFD1000_V2.class
|
||||
15:49:33.169 [http-nio-13000-exec-1] INFO c.m.r.s.l.JavaBinaryClassLoader - [loadClassByNameAndLocation,52] - 成功加载规则引擎-> com.muyu.rule.server.basic.engine.value.ENGINE_phone_zzzzz_V9
|
||||
15:49:33.169 [http-nio-13000-exec-1] INFO c.m.r.s.l.JavaBinaryClassLoader - [loadClassByNameAndLocation,52] - 成功加载规则引擎-> com.muyu.rule.server.basic.engine.value.ENGINE_VALUE_VFD1000_V1
|
||||
15:49:33.170 [http-nio-13000-exec-1] INFO c.m.r.s.l.JavaBinaryClassLoader - [loadClassByNameAndLocation,52] - 成功加载规则引擎-> com.muyu.rule.server.basic.engine.value.ENGINE_VALUE_VFD1000_V2
|
||||
15:50:29.230 [http-nio-13000-exec-6] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.java文件->ENGINE_phone_zzzzz_V9.java
|
||||
15:50:29.230 [http-nio-13000-exec-6] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.java文件->ENGINE_VALUE_VFD1000_V1.java
|
||||
15:50:29.231 [http-nio-13000-exec-6] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.java文件->ENGINE_VALUE_VFD1000_V2.java
|
||||
15:50:29.299 [http-nio-13000-exec-6] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.class文件->ENGINE_phone_zzzzz_V9.class
|
||||
15:50:29.300 [http-nio-13000-exec-6] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.class文件->ENGINE_VALUE_VFD1000_V1.class
|
||||
15:50:29.300 [http-nio-13000-exec-6] INFO c.m.r.s.l.JavaBinaryClassLoader - [accept,79] - 扫描到.class文件->ENGINE_VALUE_VFD1000_V2.class
|
||||
15:53:12.230 [Thread-18] INFO c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
|
||||
15:53:12.293 [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]
|
||||
15:53:12.294 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
|
||||
15:53:12.294 [Thread-12] INFO c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
|
||||
15:53:12.294 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
|
||||
15:53:12.294 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
|
||||
15:53:12.294 [Thread-17] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
|
||||
15:53:12.301 [Thread-12] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
|
||||
15:53:12.302 [Thread-12] 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={}}
|
||||
15:53:12.358 [Thread-12] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
|
||||
15:53:12.359 [Thread-12] INFO c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
|
||||
15:53:12.359 [Thread-12] INFO c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for uuid->5b4008e1-5a8c-4dfb-bf36-74e3282e629e
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@5ea0fd93[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 81]
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@3b9b2a5[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
|
||||
15:53:12.360 [Thread-12] INFO c.a.n.c.r.client - [closeConnection,584] - Close current connection 1725176946580_12.2.0.3_62851
|
||||
15:53:12.363 [Thread-12] INFO c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@5dc244eb[Running, pool size = 4, active threads = 0, queued tasks = 0, completed tasks = 57]
|
||||
15:53:12.363 [Thread-12] INFO c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client for uuid ->5b4008e1-5a8c-4dfb-bf36-74e3282e629e
|
||||
15:53:12.363 [Thread-12] INFO c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
|
||||
15:53:12.363 [Thread-12] INFO c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
|
||||
15:53:12.363 [Thread-12] INFO c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
|
||||
15:53:12.366 [Thread-12] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
|
||||
15:53:12.367 [Thread-12] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
|
||||
15:53:12.383 [Thread-12] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
|
||||
15:53:12.384 [Thread-12] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
|
||||
15:53:12.384 [Thread-12] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
|
||||
15:53:12.384 [grpc-nio-worker-ELG-1-4] INFO c.a.n.s.i.g.i.AbstractClientStream - [inboundTrailersReceived,378] - Received trailers on closed stream:
|
||||
Metadata()
|
||||
{2}
|
||||
15:53:12.384 [Thread-12] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
|
||||
15:53:12.385 [Thread-12] INFO o.a.c.c.C.[.[.[/] - [log,173] - Destroying Spring FrameworkServlet 'dispatcherServlet'
|
||||
15:53:15.087 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
|
||||
15:53:15.572 [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
|
||||
15:53:15.719 [restartedMain] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
|
||||
15:53:15.719 [restartedMain] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
|
||||
15:53:15.743 [restartedMain] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
|
||||
15:53:16.201 [com.alibaba.nacos.client.Worker.7] INFO c.a.n.c.a.r.i.CredentialWatcher - [loadCredentialFromEnv,189] - null No credential found
|
||||
15:53:18.041 [restartedMain] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-2,master} inited
|
||||
15:53:18.041 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
|
||||
15:53:18.041 [restartedMain] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
|
||||
15:53:18.047 [restartedMain] INFO c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
|
||||
15:53:18.355 [restartedMain] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
|
||||
15:53:21.482 [restartedMain] INFO c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功
|
||||
15:53:21.550 [restartedMain] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
|
||||
15:53:23.289 [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@69b979f2[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
|
||||
15:53:23.290 [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@79fcb5dd[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
|
||||
15:53:23.305 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
|
||||
15:53:23.305 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
|
||||
15:53:23.305 [Thread-34] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
|
||||
15:53:23.352 [Thread-35] 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
|
||||
15:53:23.599 [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]
|
||||
15:53:23.600 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
|
||||
15:53:24.425 [restartedMain] INFO c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
|
||||
15:53:24.425 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
|
||||
15:53:24.425 [restartedMain] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
|
||||
15:53:24.425 [restartedMain] INFO c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
|
||||
15:53:24.427 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
|
||||
15:53:24.427 [restartedMain] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
|
||||
15:53:24.581 [restartedMain] INFO c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 7dd13332-6fc3-4676-8c1a-76cde973795d
|
||||
15:53:24.582 [restartedMain] INFO c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->7dd13332-6fc3-4676-8c1a-76cde973795d
|
||||
15:53:24.582 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7dd13332-6fc3-4676-8c1a-76cde973795d] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
|
||||
15:53:24.582 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7dd13332-6fc3-4676-8c1a-76cde973795d] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
|
||||
15:53:24.583 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7dd13332-6fc3-4676-8c1a-76cde973795d] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
|
||||
15:53:24.583 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7dd13332-6fc3-4676-8c1a-76cde973795d] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848}
|
||||
15:53:24.583 [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}
|
||||
15:53:24.762 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7dd13332-6fc3-4676-8c1a-76cde973795d] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1725177203236_12.2.0.3_63966
|
||||
15:53:24.762 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7dd13332-6fc3-4676-8c1a-76cde973795d] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
|
||||
15:53:24.762 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7dd13332-6fc3-4676-8c1a-76cde973795d] Notify connected event to listeners.
|
||||
15:53:24.762 [restartedMain] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7dd13332-6fc3-4676-8c1a-76cde973795d] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$647/0x0000023951510440
|
||||
15:53:24.762 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.client.naming - [onConnected,90] - Grpc connection connect
|
||||
15:53:24.762 [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}}
|
||||
15:53:24.810 [restartedMain] INFO c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl-rule 192.168.170.140:13000 register finished
|
||||
15:53:25.956 [restartedMain] INFO c.m.r.s.EtlRuleApplication - [logStarted,56] - Started EtlRuleApplication in 13.495 seconds (process running for 277.596)
|
||||
15:53:25.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, group=DEFAULT_GROUP, cnt=2
|
||||
15:53:25.958 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule, group=DEFAULT_GROUP
|
||||
15:53:25.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-dev.yml, group=DEFAULT_GROUP, cnt=2
|
||||
15:53:25.958 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule-dev.yml, group=DEFAULT_GROUP
|
||||
15:53:25.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=2
|
||||
15:53:25.958 [restartedMain] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-rule.yml, group=DEFAULT_GROUP
|
||||
|
|
Loading…
Reference in New Issue