| | |
| | | package com.genersoft.iot.vmp.conf; |
| | | |
| | | import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.query.cmd.AlarmQueryMessageHandler; |
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
| | | import com.genersoft.iot.vmp.utils.SystemInfoUtils; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | |
| | | @Component |
| | | public class SystemInfoTimerTask { |
| | | |
| | | private Logger logger = LoggerFactory.getLogger(SystemInfoTimerTask.class); |
| | | |
| | | @Autowired |
| | | private IRedisCatchStorage redisCatchStorage; |
| | | |
| | | @Scheduled(fixedRate = 1000) //每1秒执行一次 |
| | | @Scheduled(fixedRate = 2000) //每1秒执行一次 |
| | | public void execute(){ |
| | | try { |
| | | double cpuInfo = SystemInfoUtils.getCpuInfo(); |
| | | redisCatchStorage.addCpuInfo(cpuInfo); |
| | | double memInfo = SystemInfoUtils.getMemInfo(); |
| | | redisCatchStorage.addMemInfo(memInfo); |
| | | Map<String, String> networkInterfaces = SystemInfoUtils.getNetworkInterfaces(); |
| | | Map<String, Double> networkInterfaces = SystemInfoUtils.getNetworkInterfaces(); |
| | | redisCatchStorage.addNetInfo(networkInterfaces); |
| | | List<Map<String, Object>> diskInfo =SystemInfoUtils.getDiskInfo(); |
| | | redisCatchStorage.addDiskInfo(diskInfo); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | logger.error("[获取系统信息失败] {}", e.getMessage()); |
| | | } |
| | | |
| | | } |