HikariCP连接池监控

参考文档:https://github.com/brettwooldridge/HikariCP/wiki/MBean-(JMX)-Monitoring-and-Management

1、作用

可以用来监控Hikari连接池的空闲连接数 ，活动连接，总连接数，等待连接的线程数

2、注意

这些值（空闲连接数 ，活动连接，总连接数，等待连接的线程数）是非常短暂的。由于每个统计数据都是时间敏感的，并且是独立收集的，所以在短时间内可能无法“累计”。不要基于这些值进行任何编程决策，它们仅用于监视。

3、代码实现

前提条件连接池初始化的时候设置hikariDataSource.setRegisterMbeans(true);
代码相关

            hikariDataSource.setDriverClassName("com.mysql.jdbc.Driver");
            hikariDataSource.setJdbcUrl("jdbc:mysql://localhost:3306/ceshi?autoReconnect=true&useUnicode=true&createDatabaseIfNotExist=true&characterEncoding=utf8&useSSL=true&serverTimezone=UTC");
            hikariDataSource.setUsername("root");
            hikariDataSource.setPassword("root");
            //最小空闲连接数量
            hikariDataSource.setMinimumIdle(5);
            //连接池最大连接数，默认是10
            hikariDataSource.setMaximumPoolSize(5);
            hikariDataSource.setPoolName("ceshi");
            hikariDataSource.setMaxLifetime(6000);
            hikariDataSource.setLoginTimeout(5);

            hikariDataSource.setRegisterMbeans(true);
            MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
            ObjectName poolName = new ObjectName("com.zaxxer.hikari:type=Pool (ceshi)");
            poolProxy = JMX.newMXBeanProxy(mBeanServer, poolName, HikariPoolMXBean.class);
            Connection connection = hikariDataSource.getConnection();
            connection.close();

这里注意需要添加下面几行代码，如果不添加在监控扫描的时候报错javax.management.InstanceNotFoundException: com.zaxxer.hikari:type=Pool (ceshi)

Connection connection = hikariDataSource.getConnection();
connection.close();

设置监控程序去监控，代码相关

  @Scheduled(fixedRate = 5000)
    public void HikariMonitor() {
        if(poolProxy == null) {
            System.out.println("Hikari not initialized,please wait...");
        }else {
            System.out.println("HikariPoolState = "
                    + "Active=[" + String.valueOf(poolProxy.getActiveConnections() + "] "
                    + "Idle=[" + String.valueOf(poolProxy.getIdleConnections() + "] "
                    + "Wait=["+poolProxy.getThreadsAwaitingConnection()+"] "
                    + "Total=["+poolProxy.getTotalConnections()+"]")));
        }
    }