博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
JXM 监控tomcat 7(含代码
阅读量:6853 次
发布时间:2019-06-26

本文共 5833 字,大约阅读时间需要 19 分钟。

1.在tomcat的server.xml中加入:
<Listener className="org.apache.catalina.mbeans.JmxRemoteLifecycleListener" rmiRegistryPortPlatform="10001" rmiServerPortPlatform="10002" />
 
2. 将jdk目录/jre/lib/management下的jmxremote.access、jmxremote.password两个文件放到 CATALINA_HOME/conf目录里面,如果没有jmxremote.password,则从JAVA_HOME/jre/lib /management/jmxremote.password.template拷贝出一个名为jmxremote.password的新文件, 修改文件内容:
jmxremote.password 文件末尾:
admin bibo
jmxremote.access 文件末尾:
admin read
#(这里只要有read权限就够了,不需要readwrite)
 
ps:帐号是admin,密码是bibo
 
3.将catalina-jmx-remote.jar加入tomcat目录/lib下
4.修改tomcat  /bin/catalina.bat
在rem ----- Execute The Requested Command 下加入
windows下:
set JAVA_OPTS= -Dcom.sun.management.jmxremote.password.file=../conf/jmxremote.password -Dcom.sun.management.jmxremote.access.file=../conf/jmxremote.access -Dcom.sun.management.jmxremote.ssl=false
linux下:
CATALINA_OPTS="
-Djava.rmi.server.hostname=192.168.2.201 -Dcom.sun.management.jmxremote
-Dcom.sun.management.jmxremote.ssl=false
-Dcom.sun.management.jmxremote.authenticate=true
-Dcom.sun.management.jmxremote.password.file=../conf/jmxremote.password
-Dcom.sun.management.jmxremote.access.file=../conf/jmxremote.access"
注意如果要从其他机器通过jconsole连接的话,就一定要有
-Djava.rmi.server.hostname=192.168.2.201,否则会连接不上
参考:
 
附件:
https://app.yinxiang.com/shard/s41/res/a2fc563b-0be3-4b43-abc9-6b54061c672e/catalina-jmx-remote.jar
 
代码:
import java.io.File;import java.io.FileOutputStream;import java.io.IOException;import java.text.SimpleDateFormat;import java.util.Date;import java.util.HashMap;import java.util.Map;import javax.management.MBeanServerConnection;import javax.management.ObjectName;import javax.management.remote.JMXConnector;import javax.management.remote.JMXConnectorFactory;import javax.management.remote.JMXServiceURL;public class TomcatMonitor {	public static String host="127.0.0.1";	public static String port="10001";	public static String user="monitor";	public static String pwd="adchina";	public static String connector="\"http-bio-8080\"";	public static String basepath="/monitordata";	public static void main(String[] args) throws IOException{		Parser(args);		String jmxUrl="service:jmx:rmi:///jndi/rmi://"+host+":"+port+"/jmxrmi";		int jvm_memory_free=0;		int jvm_memory_max=0;		int jvm_memory_total=0;				int connector_max_time=0;		int connector_error_count=0;		int connector_bytes_sent=0;		int connector_processing_time=0;		int connector_request_count=0;		int connector_bytes_received=0;				int connector_current_thread_count=0;		int connector_min_spare_threads=0;		int connector_max_threads=0;		int connector_max_spare_threads=0;		int connector_current_threads_busy=0;		JMXConnector jmxConnector =null;		try {			JMXServiceURL serviceURL=new JMXServiceURL(jmxUrl);			Map
map=new HashMap
(); String[] credentials = new String[] { user, pwd }; map.put("jmx.remote.credentials", credentials); jmxConnector = JMXConnectorFactory.connect(serviceURL, map); MBeanServerConnection mbsc = jmxConnector.getMBeanServerConnection(); ObjectName threadObjName = new ObjectName("Catalina:type=ThreadPool,name="+connector+""); connector_current_thread_count=Integer.parseInt(mbsc.getAttribute(threadObjName, "currentThreadCount").toString()); connector_min_spare_threads=Integer.parseInt(mbsc.getAttribute(threadObjName, "minSpareThreads").toString()); connector_max_threads=Integer.parseInt(mbsc.getAttribute(threadObjName, "maxThreads").toString()); //if(mbsc.getAttribute(threadObjName, "maxSpareThreads")!=null) // connector_max_spare_threads=Integer.parseInt(mbsc.getAttribute(threadObjName, "maxSpareThreads").toString()); connector_current_threads_busy=Integer.parseInt(mbsc.getAttribute(threadObjName, "currentThreadsBusy").toString()); ObjectName requestObjectName=new ObjectName("Catalina:type=RequestProcessor,worker=\"http-bio-8080\",name=HttpRequest1"); connector_max_time=Integer.parseInt(mbsc.getAttribute(requestObjectName, "maxTime").toString()); connector_error_count=Integer.parseInt(mbsc.getAttribute(requestObjectName, "errorCount").toString()); connector_bytes_sent=Integer.parseInt(mbsc.getAttribute(requestObjectName, "bytesSent").toString()); connector_processing_time=Integer.parseInt(mbsc.getAttribute(requestObjectName, "processingTime").toString()); connector_request_count=Integer.parseInt(mbsc.getAttribute(requestObjectName, "requestCount").toString()); connector_bytes_received=Integer.parseInt(mbsc.getAttribute(requestObjectName, "bytesReceived").toString()); String output_str="jvm_memory_free:"+jvm_memory_free+" jvm_memory_max:"+jvm_memory_max+" jvm_memory_total:"+jvm_memory_total+ " connector_max_time:"+connector_max_time+" connector_error_count:"+connector_error_count+" connector_bytes_sent:"+connector_bytes_sent+" connector_bytes_received:"+connector_bytes_received+ " connector_processing_time:"+connector_processing_time+" connector_request_count:"+connector_request_count+" connector_current_thread_count:"+connector_current_thread_count+ " connector_min_spare_threads:"+connector_min_spare_threads+" connector_max_threads:"+connector_max_threads+" connector_max_spare_threads:"+connector_max_spare_threads+ " connector_current_threads_busy:"+connector_current_threads_busy; saveDataToFile(output_str); } catch (Exception e) { errorLog(e.getMessage()); } finally { if(connector!=null) { try { jmxConnector.close(); } catch (IOException e) { e.printStackTrace(); } } } } public static void Parser(String[] args) { Map
opt=new HashMap
(); for(int i=0;i

 

转载于:https://www.cnblogs.com/biboxie/p/4233371.html

你可能感兴趣的文章
LightKV-高性能key-value存储组件
查看>>
小程序
查看>>
ES6变量的解构赋值
查看>>
ansible自动化运维详细教程及playbook详解
查看>>
快速解决Dev c++无法调试
查看>>
自学算法笔记
查看>>
python通过luhn算法实现的信用卡卡号验证源码
查看>>
小米手机5X获得Root权限的方法
查看>>
中国联通把百度指向了127.0.0.1?
查看>>
Java程序员这样优化简历,一投制胜!
查看>>
runtime(消息转发)
查看>>
设计模式——建造者模式
查看>>
Async & generator & Promise
查看>>
解决vagrant ssh登录时permission deny的问题
查看>>
Dapper,大规模分布式系统的跟踪系统
查看>>
Spring源码之XMLBeanFactory
查看>>
PopupWindow 点击外部区域无法关闭的问题
查看>>
jQuery 遍历
查看>>
开源的丰富的flutter Icons库
查看>>
内存管理Release和Retain实现原理
查看>>