redis-monitor-master.zip

/** * */ package com.opensource.nredis.proxy.monitor.api; import java.lang.management.ClassLoadingMXBean; import java.lang.management.MemoryMXBean; import java.lang.management.ThreadMXBean; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Properties; import java.util.concurrent.ConcurrentHashMap; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.ResponseBody; import com.github.abel533.echarts.Grid; import com.github.abel533.echarts.Option; import com.github.abel533.echarts.axis.AxisLabel; import com.github.abel533.echarts.axis.CategoryAxis; import com.github.abel533.echarts.axis.ValueAxis; import com.github.abel533.echarts.code.AxisType; import com.github.abel533.echarts.code.SeriesType; import com.github.abel533.echarts.code.Trigger; import com.github.abel533.echarts.series.Line; import com.opensource.nredis.proxy.monitor.api.utils.ConfigUtils; import com.opensource.nredis.proxy.monitor.date.utils.DateBase; import com.opensource.nredis.proxy.monitor.enums.TomcatStatusEnums; import com.opensource.nredis.proxy.monitor.jvm.tools.CPUBean; import com.opensource.nredis.proxy.monitor.jvm.tools.HeapMemroryGarbage; import com.opensource.nredis.proxy.monitor.jvm.tools.MemrorySpaceBean; import com.opensource.nredis.proxy.monitor.jvm.tools.MonitorJVM; import com.opensource.nredis.proxy.monitor.jvm.tools.QuartzRuntimeBean; import com.opensource.nredis.proxy.monitor.jvm.tools.TomcatThreadBean; import com.opensource.nredis.proxy.monitor.model.SystemApplication; import com.opensource.nredis.proxy.monitor.model.SystemComponent; import com.opensource.nredis.proxy.monitor.platform.DataGridObject; import com.opensource.nredis.proxy.monitor.platform.EChartsObject; import com.opensource.nredis.proxy.monitor.platform.NormalAreaStyle; import com.opensource.nredis.proxy.monitor.platform.ResponseObject; import com.opensource.nredis.proxy.monitor.platform.RestStatus; import com.opensource.nredis.proxy.monitor.service.ISystemApplicationService; import com.opensource.nredis.proxy.monitor.service.ISystemComponentService; import com.opensource.nredis.proxy.monitor.string.utils.StringUtil; /** * @author liubing * 系统首页监控图 */ @Controller public class SystemIndexController { private Logger logger = Logger.getLogger(SystemIndexController.class); @Autowired private ISystemApplicationService systemApplicationService; @Autowired private ISystemComponentService systemComponentService; private static Integer tomcatFlag=1; private static Integer quartzFlag=2; //--------------------------------tomcat thread-------------- private List<String> threadTime=new ArrayList<String>(); private Map<Integer,List<Long>> tomcatCurrentThreadCountMap=new ConcurrentHashMap<Integer, List<Long>>(); private Map<Integer,List<Long>> tomcatCurrentThreadsBusyMap=new ConcurrentHashMap<Integer, List<Long>>(); private Map<Integer,List<Long>> tomcatMaxThreadMap=new ConcurrentHashMap<Integer, List<Long>>(); //------------------------------jvm thread--------------------- private Map<Integer,List<Integer>> jvmThreadThreadCountsMap=new ConcurrentHashMap<Integer, List<Integer>>(); private Map<Integer,List<Integer>> jvmThreadDeadThreadCountsMap=new ConcurrentHashMap<Integer, List<Integer>>(); //----------------------------jvm classLoader-------------------- private Map<Integer,List<Integer>> jvmClassLoaderLoadedClassCountMap=new ConcurrentHashMap<Integer, List<Integer>>(); //------------------------------cpu ----------------------------------- private Map<Integer,List<Double>> CPUCountMap=new ConcurrentHashMap<Integer, List<Double>>(); //------------------------------jvm heap ----------------------------------- private Map<Integer,List<Double>>jvmHeapCountMap=new ConcurrentHashMap<Integer, List<Double>>(); //-------------------------------jvm各个区域使用率--------------------------------------- private Map<Integer,List<Double>> jvmEdenCountMap=new ConcurrentHashMap<Integer, List<Double>>(); private Map<Integer,List<Double>> jvmSurvivorCountMap=new ConcurrentHashMap<Integer, List<Double>>(); private Map<Integer,List<Double>>jvmOldCountMap=new ConcurrentHashMap<Integer, List<Double>>(); private Map<Integer,List<Double>> jvmPermCountMap=new ConcurrentHashMap<Integer, List<Double>>(); @RequestMapping(value = "/{id}/searchSystemComponentObject", method = RequestMethod.GET) @ResponseBody public ResponseObject searchSystemComponentObject(@PathVariable Integer id)throws Exception{ ResponseObject responseObject=new ResponseObject(); Map<String, Integer> result=new HashMap<String, Integer>(); List<SystemComponent> systemComponents=systemComponentService.getListByApplicationId(id); if(systemComponents!=null&&systemComponents.size()>0){ for(SystemComponent systemComponent:systemComponents){ if(StringUtil.isNotEmpty(systemComponent.getComponentValue())&&Integer.parseInt(systemComponent.getComponentValue())==quartzFlag){ result.put("quartz", 1);//有 } if(StringUtil.isNotEmpty(systemComponent.getComponentValue())&&Integer.parseInt(systemComponent.getComponentValue())==tomcatFlag){ result.put("tomcat", 1);//有 } } }else{ result.put("quartz", 0);//无 result.put("tomcat", 0);//无 } responseObject.setData(result); responseObject.setStatus(RestStatus.SERVER_ERROR.code); responseObject.setMessage(RestStatus.SERVER_ERROR.message); return responseObject; } /** * 统一时间点 * 查询监控报表数据 * @return * @throws Exception */ @RequestMapping(value = "/{id}/searchEChartsObject", method = RequestMethod.GET) @ResponseBody public EChartsObject searchEChartsObject(@PathVariable Integer id)throws Exception{ SystemApplication systemApplication=systemApplicationService.getEntityById(id); Integer tomcat=0,quartz=0;//默认无关联组件 List<SystemComponent> systemComponents=systemComponentService.getListByApplicationId(id); if(systemComponents!=null&&systemComponents.size()>0){ for(SystemComponent systemComponent:systemComponents){ if(StringUtil.isNotEmpty(systemComponent.getComponentValue())&&Integer.parseInt(systemComponent.getComponentValue())==quartzFlag){ quartz=1;//有关联控件 } if(StringUtil.isNotEmpty(systemComponent.getComponentValue())&&Integer.parseInt(systemComponent.getComponentValue())==tomcatFlag){ tomcat=1;//有关联控件 } } } return getSelfCPUUsed(systemApplication,tomcat,quartz); } /** * 获取cpu使用消息 * @param systemApplication * @param tomcatFlag 1:成功,2:失败 * @param quartzFlag 1：成功,2:失败 * @return * @throws Exception */ private EChartsObject getSelfCPUUsed(SystemApplication systemApplication,Integer tomcatFlag,Integer quartzFlag)throws Exception{ EChartsObject chartsObject=new EChartsObject(); Long start = System.currentTimeMillis(); MonitorJVM monitorJVM=new MonitorJVM(systemApplication.getJmxHost(), systemApplication.getJmxPort(), systemApplication.getJmxUserName(), systemApplication.getJmxPassWord()); CPUBean cPUBean=monitorJVM.getProcessCpuTime(); try { if(quartzFlag!=null&&quartzFlag==1){ chartsObject.setQuartzRuntimeDataGridObject(searchQuartzRuntimeBeans(systemApplication,monitorJVM)); } if(tomcatFlag!=null&&tomcatFlag==1){ chartsObject.setTomcatThreadOption(searchSelfTomcatThread(systemApplication,monitorJVM)); } chartsObject.setHeapMemroryGarbageObject(searchHeapMemroryGarbage(systemApplication,monitorJVM)); chartsObject.setJvmInfoOption(searchSelfJVMInfo(systemApplication,monitorJVM)); chartsObject.setJ