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);