spring-mvc-mongo-monitor

package com.test.task; import org.apache.log4j.Logger; import javax.management.AttributeList; import javax.management.MBeanServer; import javax.management.ObjectInstance; import javax.management.ObjectName; import java.lang.management.ManagementFactory; import java.util.Set; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; public class LogTask { private int initialDelay = 3; private int period = 3; private Logger logger = Logger.getLogger(LogTask.class); private MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer(); public void init() { logger.info("初始化mongo线程池监控日志"); ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3); scheduledThreadPool.scheduleAtFixedRate(new Runnable() { public void run() { try { Set<ObjectInstance> set = mbeanServer.queryMBeans(new ObjectName("org.mongodb.driver:type=ConnectionPool,*"), null); for (ObjectInstance oi : set) { String className = oi.getClassName(); if (className.contains("mongo")) { ObjectName objectName = oi.getObjectName(); logger.info(objectName); String[] attrs = new String[]{"CheckedOutCount", "Host", "Port", "MinSize", "MaxSize", "Size", "WaitQueueSize"}; for (String attr : attrs) { logger.info(attr + "==" + mbeanServer.getAttribute(objectName, attr)); } } } } catch (Exception e) { e.printStackTrace(); logger.error("执行日志打印失败", e); } } }, initialDelay, period, TimeUnit.SECONDS); } public int getInitialDelay() { return initialDelay; } public void setInitialDelay(int initialDelay) { this.initialDelay = initialDelay; } public int getPeriod() { return period; } public void setPeriod(int period) { this.period = period; } }