看看写写，记录所学，权当笔记の

(转过来，源地址：)

最近心血来潮，想是否可以通过增加一个tomcat的扩展，来持续收集tomcat服务器本身的性能信息，如线程池的各项数据，请求数等等，，这样可以配合业务方面的监控，可以更方便的分析调整tomcat配置，以提供更好的服务。

这样也不需要每次通过连接jmx去观察数据，而且idc环境要开启jmx，还得涉及各种安全问题…….

Tomcat manager中StatusManagerServlet就是通过JMX提供了Tomcat服务的当前状态信息。我也会“抄袭”这里的代码来收集服务器数据。

要想定时的收集Tomcat的数据，需要在tomcat启动过程中，启一个定时任务去不停的收集服务信息，之后根据自己的需要，看是通过写日志方式保存，还是上报，抑或其它方式。

要做到不侵入tomcat本身源码，可以选择通过Listener的方式，实现一个自定义Listener，监听服务启动事件，启动数据采集任务，定时收集数据，如：

public class ServerInfoMonitorLifecycleListener implementsLifecycleListener {private ServerInfoCollection collect = new ServerInfoCollection();@Overridepublic void lifecycleEvent(LifecycleEvent event ) {Lifecycle lifecycle = event .getLifecycle();if (Lifecycle.AFTER_START_EVENT .equals(event .getType())&& lifecycle instanceof Server) {collect.startMonitor();}if (Lifecycle.BEFORE_STOP_EVENT .equals(event .getType())&& lifecycle instanceof Server) {collect.stopMonitor();}}}

这里监控的是Server的启动事件，需要注意，如果你想监控其它container，如host，context等，则配置listener的时候需要放到对应的container，大多数情况下，我们还是习惯配置在Server这一级别，确实在Server这一级别是最方便的。Tomcat本身的个别listener，想监听host，context等的事件是通过监听到Server事件的时候依次对server下面的host，context等添加listener。

有了定时收集tomcat数据的定时任务，下面就是数据的收集了。

首先得先获取需要的Mbean，如：

// Retrieve the MBean servermBeanServer = Registry.getRegistry( null , null ).getMBeanServer();try {// Query Thread PoolsthreadPools .clear();String onStr = "*:type=ThreadPool,*" ;ObjectName objectName = new ObjectName(onStr );Set set = mBeanServer .queryMBeans( objectName, null );Iterator iterator = set .iterator();while (iterator .hasNext()) {ObjectInstance oi = iterator.next();threadPools .addElement(oi .getObjectName());}// Query Global Request ProcessorsglobalRequestProcessors .clear();onStr = "*:type=GlobalRequestProcessor,*" ;objectName = new ObjectName( onStr);set = mBeanServer .queryMBeans(objectName , null );iterator = set.iterator();while (iterator .hasNext()) {ObjectInstance oi = iterator.next();globalRequestProcessors .addElement(oi .getObjectName());}} catch (Exception e ) {log.error( "init failed." , e );}通过Mbean获取tomcat性能数据：

Enumeration enumeration = threadPools .elements();while (enumeration .hasMoreElements()) {ObjectName objectName = enumeration .nextElement();String name = objectName .getKeyProperty("name" );ServerInfo serverInfo = new ServerInfo();serverInfo .setMaxThreads((Integer) mBeanServer .getAttribute(objectName , "maxThreads" ));serverInfo .setCurrentThreadCount((Integer) mBeanServer.getAttribute( objectName ,"currentThreadCount" ));serverInfo .setCurrentThreadsBusy((Integer) mBeanServer.getAttribute( objectName ,"currentThreadsBusy" ));try {Object value = mBeanServer .getAttribute(objectName ,"keepAliveCount" );serverInfo .setKeepAliveCount((Integer) value );} catch (Exception e ) {// Ignore}ObjectName grpName = null ;Enumeration reqEnumer =globalRequestProcessors.elements();while (reqEnumer .hasMoreElements()) {ObjectName reqObjName = reqEnumer .nextElement();if (name .equals(reqObjName .getKeyProperty( "name"))) {grpName = reqObjName ;}}if (grpName == null) {return ;}serverInfo .setMaxTime((Long) mBeanServer .getAttribute(grpName ,"maxTime" ));serverInfo .setProcessingTime((Long) mBeanServer .getAttribute(grpName, "processingTime" ));serverInfo .setRequestCount((Integer) mBeanServer .getAttribute(grpName, "requestCount" ));serverInfo .setErrorCount((Integer) mBeanServer .getAttribute(grpName, "errorCount" ));serverInfo .setBytesReceived((Long) mBeanServer .getAttribute(grpName, "bytesReceived" ));serverInfo .setBytesSent((Long) mBeanServer .getAttribute(grpName, "bytesSent" ));store.storeInfo( serverInfo );}在server.xml配置好自定义的listener，启动tomcat，便可以看到收集到的数据，如（这里为了测试，收集到的数据直接写日志）：

ServerInfo:maxThreads:200,currentThreadCount:16,busyThreadCount:6,keepAliveCount:0,maxTime:6166,requestCount:57,errorCount:0,processTime:10380,bytesRec:0,bytesSend:238874

当然，还有很多其它的信息可以收集，看具体需要。

另外，还可以借助Value链条，编写自己的Value来上报请求处理时间，异常情况等等。

基础的代码可在github上看看：https://github.com/jjmatrix/tomcat-extension

相关文章：

你感兴趣的文章：

标签云：