JAVA JMX协议监控

  JMX协议监控,可通过JMX协议远程监控,实时监控线上jvm情况,并通过平台管理界面进行

展示,可以通过监控实时获得线上服务器运行情况。

  可以监控内存、实时线程、共享内存等各种信息。

  获取实时线程信息并显示:

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 "终止";
    }
}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏码匠的流水账

关于ribbonClient配置的一个坑

不知道从哪个版本起,给ribbon配置物理的server list起,单纯配置xxx.ribbon.listOfServers不起效果了,于是就开启了埋坑之旅。

722
来自专栏何俊林

Android Multimedia框架总结(十八)Camera2框架从Java层到C++层类关系

好,正文开始,Camera2框架,是对Camera更灵活,在很多命名上,Google都用Camera2,如Camera2Client,说明,这是一次大的改动。否...

2356
来自专栏吴伟祥

Spring4 @Configuration源码

542
来自专栏你不就像风一样

SpringBoot整合Mybatis使用注解或XML的方式开发

[User{id=1, name='name', age=18}, User{id=2, name='name2', age=19}, User{id=3, n...

572
来自专栏移动端周边技术扩展

iOS打开系统功能对应的URL

1583
来自专栏Android 研究

Android系统启动——6 SystemServer启动

SystemServer是Android系统的核心之一,大部分Android提供的服务都运行在这个进程里,SystemServer中运行的服务总共有60多种。为...

1362
来自专栏码匠的流水账

聊聊pg jdbc的queryTimeout及next方法

本文主要介绍一下pg jdbc statement的queryTimeout及resultSet的next方法

971
来自专栏程序员的酒和故事

Go实战--golang中使用RethinkDB(gorethink/gorethink.v3)

生命不止,继续go go go !!! 关于golang中操作数据库,曾经介绍了不少: Go实战–go语言操作sqlite数据库(The way to go) ...

4288
来自专栏炉边夜话

很幽默的讲解六种Socket I/O模型

信息来源:幻影论坛     作  者: flyinwuhan (制怒·三思而后行)

881
来自专栏一个会写诗的程序员的博客

《Springboot极简教程》 第11章 Springboot集成mongodb开发小结

本章我们通过SpringBoot集成mongodb,Java,Kotlin开发一个极简社区文章博客系统。

774

扫码关注云+社区