這篇文章記錄一下如何在spring boot中監控tomcat,druid連線池狀態，之前我寫過一篇文章介紹過類似的，具體背景和監控資料的收集部分這裡就不贅述，可以參考在SPRING BOOT應用監控執行緒池的狀態

背景

隨著流量的增大，我們急需監控各個微服務部署的tomcat和資料庫連線池狀態，以此來了解線上連線池配置是否滿足要求，不存在效能上的問題。

資料收集

JMX

再介紹怎麼監控連線池狀態之前，先來了解一下JMX, JMX在Java程式語言中定義了應用程式以及網路管理和監控的體系結構、設計模式、應用程式介面以及服務。通常使用JMX來監控系統的執行狀態或管理系統的某些方面，比如清空快取、重新載入配置檔案等。

tomcat和druid在啟動後都會在JMX中註冊自己的Mbean, 其中Mbean有關於連線池狀態的屬性，因此只需要定時讀取Mbean中的這部分屬性就能做到對執行緒池的監控。

怎麼試著檢視JMX呢？最簡單的辦法就是通過jvisualvm，開啟已經啟動的spring boot專案，當然前提是要在jvisualvm中提前安裝好mbeans的外掛，之後我們能發現有一個Mbeans標籤，點選它就能看到所有註冊到JMX的Mbean， 其中就有Tomcat和Druid的Mbean，順著它們的樹狀結構檢視它們支援的所有屬性值，這些屬性值就是正在執行的spring boot程式的當前狀態，挑出我們最關心的屬性繼續往下看。

還是和之前一樣利用spring boot actuator, 它能和statsd整合，並定時將/metrics中的監控資料傳送出去，因此我們只需要實現PublicMetrics介面，而在metrics方法中讀取tomcat和druid的Mbean資料，具體可以參考下面的程式碼：

監控Tomcat連線池

@Component
public class TomcatPublishMetrics implements PublicMetrics {

    public static final Logger LOG = LoggerFactory.getLogger(TomcatPublishMetrics.class);

    @Autowired
    private MBeanServer mbeanServer;

    @Override
    public Collection<Metric<?>> metrics() {
        try {
            Set<ObjectName> objectNames = mbeanServer.queryNames(new ObjectName("Tomcat:type=ThreadPool,*"), null);
            Collection<Metric<?>> result = new ArrayList<>();
            if (objectNames != null && objectNames.size() == 1) {
                for (ObjectName objectName : objectNames) {
                    int maxThreads = (Integer) mbeanServer.getAttribute(objectName, "maxThreads");
                    int currentThreadCount = (Integer) mbeanServer.getAttribute(objectName, "currentThreadCount");
                    int currentThreadsBusy = (Integer) mbeanServer.getAttribute(objectName, "currentThreadsBusy");
                    long connectionCount = (Long) mbeanServer.getAttribute(objectName, "connectionCount");
                    int maxConnections = (Integer) mbeanServer.getAttribute(objectName, "maxConnections");
                    result.add(new Metric<Number>("tomcat.thread.busy", currentThreadsBusy, new Date()));
                    result.add(new Metric<Number>("tomcat.thread.max", maxThreads, new Date()));
                    result.add(new Metric<Number>("tomcat.thread.current", currentThreadCount, new Date()));
                    result.add(new Metric<Number>("tomcat.thread.connectionCount", connectionCount, new Date()));
                    result.add(new Metric<Number>("tomcat.thread.maxConnections", maxConnections, new Date()));
                }
            } else {
                LOG.warn("Tomcat thread pool monitor failed");
            }
            return result;
        } catch (Exception e) {
            LOG.error("Tomcat thread pool monitor exception", e);
        }
        return Collections.emptyList();
    }
}

監控Druid連線池

@Component
public class DruidPoolPublishMetrics implements PublicMetrics {

    public static final Logger LOG = LoggerFactory.getLogger(DruidPoolPublishMetrics.class);

    @Autowired
    private MBeanServer mbeanServer;

    @Override
    public Collection<Metric<?>> metrics() {
        try {
            Set<ObjectName> objectNames = mbeanServer.queryNames(new ObjectName("com.alibaba.druid.pool:type=DruidDataSource,*"), null);
            Collection<Metric<?>> result = new ArrayList<>();
            if (objectNames != null && objectNames.size() == 1) {
                for (ObjectName objectName : objectNames) {
                    long errorCount = (Long) mbeanServer.getAttribute(objectName, "ErrorCount");
                    int waitThreadCount = (Integer) mbeanServer.getAttribute(objectName, "WaitThreadCount");
                    long resetCount = (Long) mbeanServer.getAttribute(objectName, "ResetCount");
                    int activeCount = (Integer) mbeanServer.getAttribute(objectName, "ActiveCount");
                    long rollbackCount = (Long) mbeanServer.getAttribute(objectName, "RollbackCount");
                    int maxActive = (Integer) mbeanServer.getAttribute(objectName, "MaxActive");
                    result.add(new Metric<Number>("druid.pool.errorCount", errorCount, new Date()));
                    result.add(new Metric<Number>("druid.pool.waitThreadCount", waitThreadCount, new Date()));
                    result.add(new Metric<Number>("druid.pool.resetCount", resetCount, new Date()));
                    result.add(new Metric<Number>("druid.pool.activeCount", activeCount, new Date()));
                    result.add(new Metric<Number>("druid.pool.rollbackCount", rollbackCount, new Date()));
                    result.add(new Metric<Number>("druid.pool.maxActive", maxActive, new Date()));
                }
            } else {
                LOG.warn("DruidPool monitor failed");
            }
            return result;
        } catch (Exception e) {
            LOG.error("DruidPool monitor exception", e);
        }
        return Collections.emptyList();
    }
}

總結

這篇文章介紹了通過讀取JMX中相應的Mbean的資料進行收集並監控，如果其他的監控指標註冊在JMX中，例如對redis的連線池，也可以採用類似的方法收集。

歡迎關注我的個人的部落格www.zhijianliu.cn, 虛心求教，有錯誤還請指正輕拍，謝謝