Agent/agent-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改网卡、交换机采集延迟时间

Browse Source
This commit is contained in:
qiminbao
2025-09-04 18:14:46 +08:00
parent a4ef3a9870
commit 53de22eaf6
2 changed files with 41 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/tongran/agentserver/scheduler/service/AppInitializer.java
+34 -34
View File
@@ -33,48 +33,48 @@ 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”的时间点还差多少秒
long seconds = AgentUtil.secondsToNext5Minute() * 1000;
//获取当前时间距离下一个“分钟为 0 或 5”的时间点还差多少毫秒
long millis = AgentUtil.millisecondsToNext5Minute();
// 每300秒执行网络信息采集任务
AssertLog.info("初始化启动网络信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", seconds, 300000);
AssertLog.info("初始化启动网络信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", millis, 300000);
dynamicTaskService.scheduleTask("net",
businessTasks::netTask, seconds, 300000); // 65秒后开始，每300秒执行
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", seconds, 300000);
AssertLog.info("初始化启动交换机信息采集定时任务 - 延迟: {}ms, 间隔: {}ms", millis, 300000);
dynamicTaskService.scheduleTask("switchBoard",
businessTasks::switchBoardTask, seconds, 300000); // 85秒后开始，每300秒执行
businessTasks::switchBoardTask, millis, 300000); // 85秒后开始，每300秒执行
}
src/main/java/com/tongran/agentserver/utils/AgentUtil.java
+7 -7
View File
@@ -106,29 +106,29 @@ public class AgentUtil {
}
/**
* 获取当前时间距离下一个“分钟为 0 或 5”的时间点还差多少秒
* 获取当前时间距离下一个“分钟为 0 或 5”的时间点还差多少毫秒
* 例如：xx:00, xx:05, xx:10, ..., xx:55
*/
public static long secondsToNext5Minute() {
public static long millisecondsToNext5Minute() {
LocalDateTime now = LocalDateTime.now();
// 当前分钟
int minute = now.getMinute();
// 计算下一个 5 分钟整点（向上取整到 5 的倍数）
int nextMinute = ((minute / 5) + 1) * 5; // 例如：12 → 15, 17 → 20, 58 → 60
// 计算下一个 5 分钟整点（向上取整）
int nextMinute = ((minute / 5) + 1) * 5;
LocalDateTime nextTime;
if (nextMinute < 60) {
// 在当前小时内
nextTime = now.withMinute(nextMinute).withSecond(0).withNano(0);
} else {
// 跨小时，例如 10:58 → 11:00
// 跨小时，如 10:58 → 11:00
nextTime = now.plusHours(1).withMinute(0).withSecond(0).withNano(0);
}
// 计算相差的秒数
return ChronoUnit.SECONDS.between(now, nextTime);
// 计算相差的毫秒数
return ChronoUnit.MILLIS.between(now, nextTime);
}
}