| | |
| | | @Autowired |
| | | private SnmpInfoService snmpInfoService; |
| | | @Autowired |
| | | private OspfInfoService ospfInfoService; |
| | | @Autowired |
| | | private CommonConfig commonConfig; |
| | | @Autowired |
| | | private MailConfig mailConfig; |
| | | @Autowired |
| | | private ServletContext servletContext; |
| | | |
| | | /** |
| | | * 30秒后执行,每1分钟检测一次 |
| | | * 检测ospf状态 |
| | | */ |
| | | @Scheduled(initialDelay = 30000L, fixedRate = 2 * 60 * 1000) |
| | | public void ospfDownCheckTask() { |
| | | logger.info("ospf链路检测任务开始------------" + DateUtil.getDateTimeString(new Date())); |
| | | ospfInfoService.getDetailedOspfNeighborInfo(); |
| | | logger.info("ospf链路检测任务结束------------" + DateUtil.getDateTimeString(new Date())); |
| | | } |
| | | |
| | | /** |
| | | * 5秒后执行,之后每24小时刷新一次 |
| | |
| | | * 20秒后执行,之后每6分钟刷新一次 |
| | | * 初始化一些任务 |
| | | */ |
| | | @Scheduled(initialDelay = 20000L, fixedRate = 6 * 60 * 1000) |
| | | //@Scheduled(initialDelay = 20000L, fixedRate = 6 * 60 * 1000) |
| | | public void initTask() { |
| | | logger.info("initTask------------" + DateUtil.getDateTimeString(new Date())); |
| | | try { |
| | |
| | | * 15秒后执行,之后每小时刷新一次 |
| | | * 获取所有磁盘总容量之和,缓存起来 |
| | | */ |
| | | @Scheduled(initialDelay = 15000L, fixedRate = 60 * 60 * 1000) |
| | | //@Scheduled(initialDelay = 15000L, fixedRate = 60 * 60 * 1000) |
| | | public void sumDiskSizeCacheTask() { |
| | | logger.info("sumDiskSizeCacheTask------------" + DateUtil.getDateTimeString(new Date())); |
| | | try { |
| | |
| | | * 150秒后执行,之后每隔15分钟执行, 单位:ms。 |
| | | * snmp设备监测 |
| | | */ |
| | | @Scheduled(initialDelay = 150000L, fixedRateString = "${base.snmpTimes}" + "000") |
| | | //@Scheduled(initialDelay = 150000L, fixedRateString = "${base.snmpTimes}" + "000") |
| | | public void snmpInfoTask() { |
| | | if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) { |
| | | logger.info("slave节点不执行snmp设备监测任务"); |
| | |
| | | * 60秒后执行,之后每隔10分钟执行, 单位:ms。 |
| | | * 检测服务接口 |
| | | */ |
| | | @Scheduled(initialDelay = 60000L, fixedRateString = "${base.heathTimes}" + "000") |
| | | //@Scheduled(initialDelay = 60000L, fixedRateString = "${base.heathTimes}" + "000") |
| | | public void heathMonitorTask() { |
| | | if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) { |
| | | logger.info("slave节点不执行检测服务接口任务"); |
| | |
| | | * 90秒后执行,之后每隔15分钟执行, 单位:ms。 |
| | | * 检测数通PING设备 |
| | | */ |
| | | @Scheduled(initialDelay = 90000L, fixedRateString = "${base.dceTimes}" + "000") |
| | | //@Scheduled(initialDelay = 90000L, fixedRateString = "${base.dceTimes}" + "000") |
| | | public void dceInfoTask() { |
| | | if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) { |
| | | logger.info("slave节点不执行检测数通设备PING任务"); |
| | |
| | | * 120秒后执行,之后每隔120分钟执行, 单位:ms。 |
| | | * 数据表监控 |
| | | */ |
| | | @Scheduled(initialDelay = 120000L, fixedRateString = "${base.dbTableTimes}" + "000") |
| | | //@Scheduled(initialDelay = 120000L, fixedRateString = "${base.dbTableTimes}" + "000") |
| | | public void tableCountTask() { |
| | | if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) { |
| | | logger.info("slave节点不执行数据表监控任务"); |
| | |
| | | * 300秒后执行,每6分钟检测一次 |
| | | * 检测主机是否已经下线,检测进程、端口、docker、文件防篡改是否恢复 |
| | | */ |
| | | @Scheduled(initialDelay = 300000L, fixedRate = 5 * 60 * 1000) |
| | | //@Scheduled(initialDelay = 300000L, fixedRate = 5 * 60 * 1000) |
| | | public void hostDownCheckTask() { |
| | | if (!StaticKeys.NODE_MASTER.equals(commonConfig.getNodeType())) { |
| | | logger.info("slave节点不执行检测主机/进程/docker/端口是否恢复任务"); |