您现在的位置是:首页 >技术交流 >HikariCP配置MetricRegistry监控网站首页技术交流

HikariCP配置MetricRegistry监控

北纬39°的风 2023-07-13 08:00:02
简介HikariCP配置MetricRegistry监控

最近有个项目新上线服务为springboot+HikariCP,每到月底业务集中,服务报错数据库连接超时,修改连接数,空闲释放时间等参数无效,为排查问题增加HikariCP监控。

1.pom引入

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-actuator</artifactId>
</dependency>
<dependency>
    <groupId>io.dropwizard.metrics</groupId>
    <artifactId>metrics-core</artifactId>
</dependency>

2.增加监控配置类

import com.codahale.metrics.MetricRegistry;
import com.codahale.metrics.Slf4jReporter;
import com.zaxxer.hikari.HikariDataSource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.StringUtils;

import java.util.concurrent.TimeUnit;

@Configuration
public class DatasourceConfiguration {
    private final static Logger LOGGER = LoggerFactory.getLogger(DatasourceConfiguration.class);
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.hikari")
    HikariDataSource dataSource(DataSourceProperties properties) {
        HikariDataSource dataSource = properties.initializeDataSourceBuilder()
                .type(HikariDataSource.class)
                .build();
        if (StringUtils.hasText(properties.getName())) {
            dataSource.setPoolName(properties.getName());
        }
        dataSource.setMetricRegistry(initMetricRegistry(dataSource.getPoolName()));
        return dataSource;
    }

    /**
     * 配置指标监控
     * @param poolName
     * @return
     */
    public MetricRegistry initMetricRegistry(String poolName) {
        MetricRegistry metricRegistry = new MetricRegistry();
        Slf4jReporter reporter = Slf4jReporter.forRegistry(metricRegistry)
                .outputTo(LOGGER)
                .convertRatesTo(TimeUnit.SECONDS)
                .convertDurationsTo(TimeUnit.MILLISECONDS)
                .build();
        reporter.start(30, TimeUnit.SECONDS);//30秒打印一次
        return metricRegistry;
    }

3.基本打印指标说明

hikaricp.connections    当前总连接数,包括空闲的连接和使用中的连接。(4 = 3 + 1)对应上面日志;
Connections = activeConnection + idleConnections,会随着连接使用情况变化。
hikaricp.connections.active    正在使用中活跃连接数 (1),会随着连接使用情况变化。
hikaricp.connections.idle    空闲连接数 (3) ,会随着连接使用情况变化。
hikaricp.connections.max    最大连接数 (10),初始配置。
hikaricp.connections.min    最小连接数 (3),初始配置。
hikaricp.connections.pending    正在等待连接的线程数量(0)。重点:一般来说,这里应该都是0,如果存在这个数据并且时间较长要触发告警,视情况加大最大连接数。
hikaricp.connections.acquire    获取每个连接需要时间,单位为ns。
hikaricp.connections.creation    连接创建时间,单位为ms。
hikaricp.connections.timeout    创建连接超时次数。
hikaricp.connections.usage    连接从池中取出到返回的时间,单位为ms。即连接被业务占用时间(3.017s)。重点:这个时间长的话,
可能是慢SQL或者长事务导致连接被占用问题。

风语者!平时喜欢研究各种技术,目前在从事后端开发工作,热爱生活、热爱工作。