From 97b935e6f42e3ca1ee787e17bafc28204c6bc7fe Mon Sep 17 00:00:00 2001 From: qiminbao Date: Thu, 4 Sep 2025 18:15:29 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=BD=91=E5=8D=A1=E3=80=81?= =?UTF-8?q?=E4=BA=A4=E6=8D=A2=E6=9C=BA=E9=87=87=E9=9B=86=E5=BB=B6=E8=BF=9F?= =?UTF-8?q?=E6=97=B6=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../scheduler/service/AppInitializer.java | 56 +++++++++---------- 1 file changed, 28 insertions(+), 28 deletions(-) diff --git a/src/main/java/com/tongran/agentserver/scheduler/service/AppInitializer.java b/src/main/java/com/tongran/agentserver/scheduler/service/AppInitializer.java index c15482a..8cf12e2 100644 --- a/src/main/java/com/tongran/agentserver/scheduler/service/AppInitializer.java +++ b/src/main/java/com/tongran/agentserver/scheduler/service/AppInitializer.java @@ -33,30 +33,30 @@ public class AppInitializer implements CommandLineRunner { dynamicTaskService.scheduleTask("heartbeat", businessTasks::heartbeatTask, 5000, 30000); -// // 每300秒执行CPU信息采集任务 -// AssertLog.info("初始化启动CPU信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 25000, 300000); -// dynamicTaskService.scheduleTask("cpu", -// businessTasks::cpuTask, 25000, 300000); // 25秒后开始,每300秒执行 -// -// // 每300秒执行磁盘信息采集任务 -// AssertLog.info("初始化启动磁盘信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 35000, 300000); -// dynamicTaskService.scheduleTask("disk", -// businessTasks::diskTask, 35000, 300000); // 35秒后开始,每300秒执行 -// -// // 每300秒执行系统信息采集任务 -// AssertLog.info("初始化启动系统信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 40000, 300000); -// dynamicTaskService.scheduleTask("system", -// businessTasks::systemTask, 40000, 300000); // 40秒后开始,每300秒执行 -// -// // 每300秒执行容器信息采集任务 -// AssertLog.info("初始化启动容器信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 45000, 300000); -// dynamicTaskService.scheduleTask("docker", -// businessTasks::dockerTask, 45000, 300000); // 45秒后开始,每300秒执行 -// -// // 每300秒执行内存信息采集任务 -// AssertLog.info("初始化启动内存信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 55000, 300000); -// dynamicTaskService.scheduleTask("memory", -// businessTasks::memoryTask, 55000, 300000); // 55秒后开始,每300秒执行 + // 每300秒执行CPU信息采集任务 + AssertLog.info("初始化启动CPU信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 25000, 300000); + dynamicTaskService.scheduleTask("cpu", + businessTasks::cpuTask, 25000, 300000); // 25秒后开始,每300秒执行 + + // 每300秒执行磁盘信息采集任务 + AssertLog.info("初始化启动磁盘信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 35000, 300000); + dynamicTaskService.scheduleTask("disk", + businessTasks::diskTask, 35000, 300000); // 35秒后开始,每300秒执行 + + // 每300秒执行系统信息采集任务 + AssertLog.info("初始化启动系统信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 40000, 300000); + dynamicTaskService.scheduleTask("system", + businessTasks::systemTask, 40000, 300000); // 40秒后开始,每300秒执行 + + // 每300秒执行容器信息采集任务 + AssertLog.info("初始化启动容器信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 45000, 300000); + dynamicTaskService.scheduleTask("docker", + businessTasks::dockerTask, 45000, 300000); // 45秒后开始,每300秒执行 + + // 每300秒执行内存信息采集任务 + AssertLog.info("初始化启动内存信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 55000, 300000); + dynamicTaskService.scheduleTask("memory", + businessTasks::memoryTask, 55000, 300000); // 55秒后开始,每300秒执行 //获取当前时间距离下一个“分钟为 0 或 5”的时间点还差多少毫秒 @@ -66,10 +66,10 @@ public class AppInitializer implements CommandLineRunner { dynamicTaskService.scheduleTask("net", businessTasks::netTask, millis, 300000); // 65秒后开始,每300秒执行 -// // 每300秒执行挂载信息采集任务 -// AssertLog.info("初始化启动挂载信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 75000, 300000); -// dynamicTaskService.scheduleTask("point", -// businessTasks::pointTask, 75000, 300000); // 75秒后开始,每300秒执行 + // 每300秒执行挂载信息采集任务 + AssertLog.info("初始化启动挂载信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", 75000, 300000); + dynamicTaskService.scheduleTask("point", + businessTasks::pointTask, 75000, 300000); // 75秒后开始,每300秒执行 // 每300秒执行交换机信息采集任务 AssertLog.info("初始化启动交换机信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", millis, 300000);