JAVA JMX协议监控

import javax.management.MBeanServerConnection;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
import java.io.IOException;
import java.lang.management.ManagementFactory;
import java.lang.management.ThreadInfo;
import java.lang.management.ThreadMXBean;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

 /**
 * Created by liubaofeng on 2017/3/10.
 * 根据jmx配置
 * 将线程信息返回
 */
public class JvmRuntimeServiceImpl implements JvmRuntimeService {
    protected static final Logger logger = LoggerFactory.getLogger("file_logger");
    private Map<String,MBeanServerConnection> map = new HashMap<>();
    

        @Override
    public List<JvmRuntimeModel> threadRuntime(String url)  {
        if(logger.isDebugEnabled())
            logger.debug("url:"+url);
        String jmxURL = "service:jmx:rmi:///jndi/rmi://"+url+"/jmxrmi";
        List<JvmRuntimeModel> resultList = null;
        if(!map.containsKey(jmxURL)) {
            MBeanServerConnection mBeanServerConnection = null;
            try {
                mBeanServerConnection = connection(jmxURL);
            } catch (IOException e) {
                if (logger.isErrorEnabled())
                    logger.error(e.getMessage(), e);
            }
            map.put(jmxURL,mBeanServerConnection);
            try {
                ThreadInfo[] threadInfos = thread(mBeanServerConnection);
                resultList = getJvmRuntimeModelList(threadInfos);
            } catch (IOException e) {
                if (logger.isErrorEnabled())
                    logger.error(e.getMessage(), e);
            }
        }else{
            MBeanServerConnection mBeanServerConnection = map.get(jmxURL);
            try {
                ThreadInfo[] threadInfos = thread(mBeanServerConnection);
                resultList = getJvmRuntimeModelList(threadInfos);
            } catch (IOException e) {
                if (logger.isErrorEnabled())
                    logger.error(e.getMessage(), e);
            }
        }
        return resultList;
    }
    

        /**
     * 建立jmx连接
     * @param jmxURL
     * @return
     * @throws IOException
     */
    private MBeanServerConnection connection(String jmxURL)throws IOException{
        JMXServiceURL serviceURL = new JMXServiceURL(jmxURL);
        JMXConnector connector = JMXConnectorFactory.connect(serviceURL, null);
        MBeanServerConnection mBeanServerConnection = connector.getMBeanServerConnection();
        return mBeanServerConnection;
    }
            

    /**
     * 取threadinfo信息.
     * @param mBeanServerConnection
     * @throws IOException
     */
    private ThreadInfo[] thread(MBeanServerConnection mBeanServerConnection) throws IOException {
        ThreadMXBean threadMXBean = ManagementFactory
                .newPlatformMXBeanProxy(mBeanServerConnection,
                        ManagementFactory.THREAD_MXBEAN_NAME,
                        ThreadMXBean.class);
        long[] ids = threadMXBean.getAllThreadIds();
        ThreadInfo[] threadInfos = threadMXBean.getThreadInfo(ids);
        return threadInfos;
    }
            

                /**
     * 取jvm运行时信息.
     * @param threadInfos
     * @return
     */
    private List<JvmRuntimeModel> getJvmRuntimeModelList(ThreadInfo[] threadInfos){
        if(threadInfos!=null)
            return null;
        
        List<JvmRuntimeModel> list = new ArrayList<JvmRuntimeModel>(threadInfos.length);
        for(int i=0;i<threadInfos.length;i++){
            ThreadInfo threadInfo = threadInfos[i];
            String threadName = threadInfo.getThreadName();
            Thread.State threadState = threadInfo.getThreadState();
            JvmRuntimeModel jvmRuntimeModel = new JvmRuntimeModel();
            jvmRuntimeModel.id = i;
            jvmRuntimeModel.name = threadName;
            jvmRuntimeModel.state = getState(threadState);
            list.add(jvmRuntimeModel);
        }
    

            return list;
    }
    

        /**
     * 获得状态.
     * @param state
     * @return
     */
    private String getState(Thread.State state){
        if(state.equals(Thread.State.NEW))
            return "新建";
        else if(state.equals(Thread.State.RUNNABLE))
            return "执行中";
        else if(state.equals(Thread.State.BLOCKED))
            return "阻塞";
        else if(state.equals(Thread.State.WAITING))
            return "等待";
        else if(state.equals(Thread.State.TIMED_WAITING))
            return "定时等待";
        else
            return "终止";
    }
}