数据库数据源监控的类型有哪些

本篇文章为大家展示了数据库数据源监控的类型有哪些，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

1.Druid监控

问题：
众所周知，alibaba druid提供了比较完善的数据库监控，但是也是有比较明显的劣势（比如：数据源的连接数等在监控页面只能看到那瞬间的值等），不能持久化监控以及和公司内部监控告警集成
解决：
通过内部druid监控方法

private class DruidStatsThread extends Thread {    public DruidStatsThread(String name) {        super(name);        this.setDaemon(true);    }    @Override    public void run() {        long initialDelay = metricDruidProperties.getInitialDelay() * 1000;        if (initialDelay > 0) {            MwThreadUtil.sleep(initialDelay);        }        while (!this.isInterrupted()) {            try {                try {                    Set druidDataSources =                            DruidDataSourceStatManager.getDruidDataSourceInstances();                    Optional.ofNullable(druidDataSources).ifPresent(val -> val.forEach(druidDataSource -> {                        DruidDataSourceStatValue statValue = druidDataSource.getStatValueAndReset();                        long maxWaitMillis = druidDataSource.getMaxWait();//最大等待时间                        long waitThreadCount = statValue.getWaitThreadCount();//当前等待获取连接的线程数                        long notEmptyWaitMillis = statValue.getNotEmptyWaitMillis();//获取连接时累计等待多长时间                        long notEmptyWaitCount = statValue.getNotEmptyWaitCount();//获取连接时累计等待多少次'                        int maxActive = druidDataSource.getMaxActive();//最大活跃数                        int poolingCount = statValue.getPoolingCount();//当前连接池数                        int poolingPeak = statValue.getPoolingPeak();//连接池峰值                        int activeCount = statValue.getActiveCount();//当前活跃连接数                        int activePeak = statValue.getActivePeak();//活跃数峰值                        if (Objects.nonNull(statsDClient)) {                            URI jdbcUri = parseJdbcUrl(druidDataSource.getUrl());                            Optional.ofNullable(jdbcUri).ifPresent(val2 -> {                                String host = StringUtils.replaceChars(val2.getHost(), '.', '_');                                String prefix = METRIC_DRUID_PREFIX + host + '.' + val2.getPort() + '.';                                statsDClient.recordExecutionTime(prefix + "maxWaitMillis", maxWaitMillis);                                statsDClient.recordExecutionTime(prefix + "waitThreadCount", waitThreadCount);                                statsDClient.recordExecutionTime(prefix + "notEmptyWaitMillis", notEmptyWaitMillis);                                statsDClient.recordExecutionTime(prefix + "notEmptyWaitCount", notEmptyWaitCount);                                statsDClient.recordExecutionTime(prefix + "maxActive", maxActive);                                statsDClient.recordExecutionTime(prefix + "poolingCount", poolingCount);                                statsDClient.recordExecutionTime(prefix + "poolingPeak", poolingPeak);                                statsDClient.recordExecutionTime(prefix + "activeCount", activeCount);                                statsDClient.recordExecutionTime(prefix + "activePeak", activePeak);                            });                        } else {                            druidDataSource.logStats();                        }                    }));                } catch (Exception e) {                    logger.error("druid stats exception", e);                }                TimeUnit.SECONDS.sleep(metricDruidProperties.getStatsInterval());            } catch (InterruptedException e) {                Thread.currentThread().interrupt();                logger.info("metric druid interrupt exit...");            } catch (Exception e) {                logger.error("metric druid exception...", e);            }        }    }}private URI parseJdbcUrl(String url) {    if (StringUtils.isBlank(url) || !StringUtils.startsWith(url, "jdbc:")) {        return null;    }    String cleanURI = url.substring(5);    return URI.create(cleanURI);}

2.Hikari监控

问题：
针对Hikari数据源，没有统一的监控处理，但是，提供了JMX入口，同理，持久化在监控服务上
解决：

private class HikariStatsThread extends Thread {    public HikariStatsThread(String name) {        super(name);        this.setDaemon(true);    }    @Override    public void run() {        long initialDelay = metricHikariProperties.getInitialDelay() * 1000;        if (initialDelay > 0) {            MwThreadUtil.sleep(initialDelay);        }        while (!this.isInterrupted()) {            try {                Optional.ofNullable(hikariDataSources).ifPresent(val -> val.forEach(hikariDataSource -> {                    URI jdbcUri = parseJdbcUrl(hikariDataSource.getJdbcUrl());                    Optional.ofNullable(jdbcUri).ifPresent(val2 -> {                        String host = StringUtils.replaceChars(val2.getHost(), '.', '_');                        String prefix = METRIC_HIKARI_PREFIX + host + '.' + val2.getPort() + '.';                        PoolStatBean poolStatBean = PoolStatBean.builder().build();                        HikariPoolMXBean hikariPoolMXBean = hikariDataSource.getHikariPoolMXBean();                        Optional.ofNullable(hikariPoolMXBean).ifPresent(val3 -> {                            int activeConnections = val3.getActiveConnections();                            int idleConnections = val3.getIdleConnections();                            int totalConnections = val3.getTotalConnections();                            int threadsAwaitingConnection = val3.getThreadsAwaitingConnection();                            poolStatBean.setActiveConnections(activeConnections);                            poolStatBean.setIdleConnections(idleConnections);                            poolStatBean.setTotalConnections(totalConnections);                            poolStatBean.setThreadsAwaitingConnection(threadsAwaitingConnection);                        });                        HikariConfigMXBean hikariConfigMXBean = hikariDataSource.getHikariConfigMXBean();                        Optional.ofNullable(hikariConfigMXBean).ifPresent(val3 -> {                            int maximumPoolSize = val3.getMaximumPoolSize();                            int minimumIdle = val3.getMinimumIdle();                            poolStatBean.setMaximumPoolSize(maximumPoolSize);                            poolStatBean.setMinimumIdle(minimumIdle);                        });                        statsPool(prefix, poolStatBean);                    });                }));                TimeUnit.SECONDS.sleep(metricHikariProperties.getStatsInterval());            } catch (InterruptedException e) {                Thread.currentThread().interrupt();                logger.info("metric hikari interrupt exit...");            } catch (Exception e) {                logger.error("metric hikari exception...", e);            }        }    }}private void statsPool(String prefix, PoolStatBean poolStatBean) {    if (Objects.nonNull(statsDClient)) {        statsDClient.recordExecutionTime(prefix + "activeConnections", poolStatBean.getActiveConnections());        statsDClient.recordExecutionTime(prefix + "idleConnections", poolStatBean.getIdleConnections());        statsDClient.recordExecutionTime(prefix + "totalConnections", poolStatBean.getTotalConnections());        statsDClient.recordExecutionTime(prefix + "threadsAwaitingConnection",                poolStatBean.getThreadsAwaitingConnection());        statsDClient.recordExecutionTime(prefix + "maximumPoolSize", poolStatBean.getMaximumPoolSize());        statsDClient.recordExecutionTime(prefix + "minimumIdle", poolStatBean.getMinimumIdle());        return;    }    StringBuilder sBuilder = new StringBuilder(16);    sBuilder.append(prefix + "activeConnections => [" + poolStatBean.getActiveConnections() + "],");    sBuilder.append(prefix + "idleConnections => [" + poolStatBean.getIdleConnections() + "],");    sBuilder.append(prefix + "totalConnections => [" + poolStatBean.getTotalConnections() + "],");    sBuilder.append(prefix + "threadsAwaitingConnection => [" + poolStatBean.getThreadsAwaitingConnection() + "],");    sBuilder.append(prefix + "maximumPoolSize => [" + poolStatBean.getMaximumPoolSize() + "],");    sBuilder.append(prefix + "minimumIdle => [" + poolStatBean.getMinimumIdle() + "]");    logger.info(sBuilder.toString());}private URI parseJdbcUrl(String url) {    if (StringUtils.isBlank(url) || !StringUtils.startsWith(url, "jdbc:")) {        return null;    }    String cleanURI = url.substring(5);    return URI.create(cleanURI);}@Data@Builderprivate static class PoolStatBean {    private int activeConnections;    private int idleConnections;    private int totalConnections;    private int threadsAwaitingConnection;    private int maximumPoolSize;    private int minimumIdle;}

注：以上只是提供一种解决方案

上述内容就是数据库数据源监控的类型有哪些，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注行业资讯频道。