可观测性-Metrics-数据库连接池HikariCP监控

文章目录

• • 非SpringBoot环境
  • • 添加依赖
    • 示例
    • 指标详解
  • Spring Boot环境
  • • 手动
    • 自动
  • 关于Sql日志记录和慢日志

非SpringBoot环境

HikariCP其内部提供了setMetricReGIStry()方法，让我们可以注入MetricRegistry来实现对连接池指标的收集。这样我们可以较为方便的监控连接池的运行状态。

添加依赖

    <dependency>      <groupId>com.zaxxergroupId>      <artifactId>HikariCPartifactId>      <version>4.0.3version>    dependency>    <dependency>       <groupId>MysqlgroupId>       <artifactId>mysql-connector-javaartifactId>    dependency>    <dependency>      <groupId>io.micrometergroupId>      <artifactId>micrometer-coreartifactId>      <version>1.9.4version>    dependency>

示例

// hikari配置       HikariConfig hikariConfig = new HikariConfig();        hikariConfig.setJdbcUrl("jdbc:mysql://localhost:3306/laker?serverTimezone=GMT%2B8&characterEncoding=utf8&useSSL=false");        hikariConfig.setUsername("root");        hikariConfig.setPassWord("123456");        hikariConfig.setDriverClassName("com.mysql.jdbc.Driver");        hikariConfig.setAutoCommit(true);        hikariConfig.setPoolName("laker_poolName");        hikariConfig.setMaximumPoolSize(10);        hikariConfig.setMinimumIdle(3);        // 创建HikariDataSource        HikariDataSource dataSource = new HikariDataSource(hikariConfig);        // 设置metric注册器 每10秒打印一次        LoggingMeterRegistry loggingMeterRegistry = new LoggingMeterRegistry(new LoggingRegistryConfig() {            @Override            public String get(String key) {                return null;            }            @Override            public Duration step() {                return Duration.ofSeconds(10);            }        }, Clock.SYSTEM);        dataSource.setMetricRegistry(loggingMeterRegistry);        // 测试 持有3秒连接后才释放        Connection connection = dataSource.getConnection();        TimeUnit.SECONDS.sleep(3);        connection.close();

结果：

hikaricp.connections{pool=laker_poolName} value=4hikaricp.connections.active{pool=laker_poolName} value=1hikaricp.connections.idle{pool=laker_poolName} value=3hikaricp.connections.max{pool=laker_poolName} value=10hikaricp.connections.min{pool=laker_poolName} value=3hikaricp.connections.pending{pool=laker_poolName} value=0hikaricp.connections.acquire{pool=laker_poolName} throughput=0.1/s mean=0.0000581s max=0.0000581shikaricp.connections.creation{pool=laker_poolName} throughput=0.3/s mean=0.006666666s max=0.007shikaricp.connections.usage{pool=laker_poolName} throughput=0.1/s mean=3.017s max=3.017s

指标详解

对应的指标在com.zaxxer.hikari.metrics.PoolStats中。

Spring Boot环境

手动

还是添加上面的依赖组件。

@Configurationpublic class DatasourceConfiguration {    @Bean    public DataSource primaryDataSource(MetricRegistry metricRegistry) {HikariConfig hikariConfig = new HikariConfig();        hikariConfig.setJdbcUrl("jdbc:mysql://localhost:3306/laker?serverTimezone=GMT%2B8&characterEncoding=utf8&useSSL=false");        hikariConfig.setUsername("root");        hikariConfig.setPassword("123456");        hikariConfig.setDriverClassName("com.mysql.jdbc.Driver");        hikariConfig.setAutoCommit(true);        hikariConfig.setPoolName("laker_poolName");        hikariConfig.setMaximumPoolSize(10);        hikariConfig.setMinimumIdle(3);        // 创建HikariDataSource        HikariDataSource dataSource = new HikariDataSource(hikariConfig);        dataSource.setMetricRegistry(loggingMeterRegistry);        return dataSource;    }}

自动

只需要添加如下依赖，内部会自动加上HikariCP和micrometer-core依赖，并自动配置注册器。

  <dependency>     <groupId>org.springframework.bootgroupId>     <artifactId>spring-boot-starter-actuatorartifactId>  dependency>

原理，我们可以看这个类DataSourcePoolMetricsAutoConfiguration.java

关于Sql日志记录和慢日志

可以看这个Issue:https://github.com/brettwooldridge/HikariCP/issues/57

作者是不愿意在连接池层去做这种监控的事情的，应为会大大降低其性能。

注意：

• Sql记录功能会导致性能下降，所以建议仅能用于开发、测试环境。

• 慢日志可以考虑通过事件类型，发送事件用于告警，关联更多的上下文，在ORM层去做，例如在mybatis的拦截器做。

来源地址：https://blog.csdn.net/abu935009066/article/details/127155653