当前位置: 首页 > news >正文

聊聊druid连接池的监控

本文主要研究一下druid连接池的监控

init

com/alibaba/druid/pool/DruidDataSource.java

public void init() throws SQLException {//......registerMbean();//......
}

DruidDataSource的init方法会执行registerMbean

registerMbean

com/alibaba/druid/pool/DruidDataSource.java

    public void registerMbean() {if (!mbeanRegistered) {AccessController.doPrivileged(new PrivilegedAction<Object>() {@Overridepublic Object run() {ObjectName objectName = DruidDataSourceStatManager.addDataSource(DruidDataSource.this,DruidDataSource.this.name);DruidDataSource.this.setObjectName(objectName);DruidDataSource.this.mbeanRegistered = true;return null;}});}}

registerMbean会执行DruidDataSourceStatManager.addDataSource(DruidDataSource.this, DruidDataSource.this.name)

DruidDataSourceStatManager

com/alibaba/druid/stat/DruidDataSourceStatManager.java

    public static synchronized ObjectName addDataSource(Object dataSource, String name) {final Map<Object, ObjectName> instances = getInstances();MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();synchronized (instances) {if (instances.size() == 0) {try {ObjectName objectName = new ObjectName(MBEAN_NAME);if (!mbeanServer.isRegistered(objectName)) {mbeanServer.registerMBean(instance, objectName);}} catch (JMException ex) {LOG.error("register mbean error", ex);}DruidStatService.registerMBean();}}ObjectName objectName = null;if (name != null) {try {objectName = new ObjectName("com.alibaba.druid:type=DruidDataSource,id=" + name);mbeanServer.registerMBean(dataSource, objectName);} catch (Throwable ex) {LOG.error("register mbean error", ex);objectName = null;}}if (objectName == null) {try {int id = System.identityHashCode(dataSource);objectName = new ObjectName("com.alibaba.druid:type=DruidDataSource,id=" + id);mbeanServer.registerMBean(dataSource, objectName);} catch (Throwable ex) {LOG.error("register mbean error", ex);objectName = null;}}instances.put(dataSource, objectName);return objectName;}

DruidDataSourceStatManager的addDataSource方法通过mbeanServer.registerMBean(dataSource, objectName)将DruidDataSource注册到mbeanServer中,而DruidDataSource则实现了DruidDataSourceMBean接口

DruidDataSourceMBean

public interface DruidDataSourceMBean extends DruidAbstractDataSourceMBean {long getResetCount();boolean isEnable();String getUrl();void shrink();int removeAbandoned();String dump();int getWaitThreadCount();int getLockQueueLength();long getNotEmptyWaitCount();int getNotEmptyWaitThreadCount();long getNotEmptySignalCount();long getNotEmptyWaitMillis();long getNotEmptyWaitNanos();void resetStat();boolean isResetStatEnable();void setResetStatEnable(boolean resetStatEnable);String getVersion();void setPoolPreparedStatements(boolean poolPreparedStatements);int getActivePeak();int getPoolingPeak();Date getActivePeakTime();Date getPoolingPeakTime();long getErrorCount();ObjectName getObjectName();void clearStatementCache() throws SQLException;long getDiscardCount();void setStatLoggerClassName(String className);long getTimeBetweenLogStatsMillis();void setTimeBetweenLogStatsMillis(long timeBetweenLogStatsMillis);void setConnectionProperties(String connectionProperties);int fill() throws SQLException;int fill(int toCount) throws SQLException;boolean isUseGlobalDataSourceStat();
}

DruidDataSourceMBean按jmx规范命名以MBean结尾,它定义了一系列的getter和操作方法,它还继承了DruidAbstractDataSourceMBean

DruidAbstractDataSourceMBean

com/alibaba/druid/pool/DruidAbstractDataSourceMBean.java

public interface DruidAbstractDataSourceMBean {int getLoginTimeout();String getDbType();String getName();int getInitialSize();String getUsername();String getUrl();String getDriverClassName();long getConnectCount();long getCloseCount();long getConnectErrorCount();int getPoolingCount();long getRecycleCount();int getActiveCount();long getCreateCount();long getDestroyCount();long getCreateTimespanMillis();long getCommitCount();long getRollbackCount();long getStartTransactionCount();int getQueryTimeout();int getTransactionQueryTimeout();String getValidationQuery();int getValidationQueryTimeout();int getMaxWaitThreadCount();long getTimeBetweenEvictionRunsMillis();long getMinEvictableIdleTimeMillis();boolean isRemoveAbandoned();long getRemoveAbandonedTimeoutMillis();List<String> getActiveConnectionStackTrace();List<String> getFilterClassNames();boolean isTestOnBorrow();void setTestOnBorrow(boolean testOnBorrow);boolean isTestOnReturn();boolean isTestWhileIdle();void setTestWhileIdle(boolean testWhileIdle);boolean isDefaultAutoCommit();Boolean getDefaultReadOnly();Integer getDefaultTransactionIsolation();String getDefaultCatalog();boolean isPoolPreparedStatements();boolean isSharePreparedStatements();long getMaxWait();int getMinIdle();int getMaxIdle();long getCreateErrorCount();int getMaxActive();void setMaxActive(int maxActive);long getTimeBetweenConnectErrorMillis();int getMaxOpenPreparedStatements();long getRemoveAbandonedCount();boolean isLogAbandoned();void setLogAbandoned(boolean logAbandoned);long getDupCloseCount();boolean isBreakAfterAcquireFailure();int getConnectionErrorRetryAttempts();int getMaxPoolPreparedStatementPerConnectionSize();void setMaxPoolPreparedStatementPerConnectionSize(int maxPoolPreparedStatementPerConnectionSize);String getProperties();int getRawDriverMinorVersion();int getRawDriverMajorVersion();Date getCreatedTime();String getValidConnectionCheckerClassName();long[] getTransactionHistogramValues();void setTransactionThresholdMillis(long transactionThresholdMillis);long getTransactionThresholdMillis();long getPreparedStatementCount();long getClosedPreparedStatementCount();long getCachedPreparedStatementCount();long getCachedPreparedStatementDeleteCount();long getCachedPreparedStatementAccessCount();long getCachedPreparedStatementMissCount();long getCachedPreparedStatementHitCount();boolean isUseOracleImplicitCache();void setUseOracleImplicitCache(boolean useOracleImplicitCache);int getDriverMajorVersion();int getDriverMinorVersion();String getExceptionSorterClassName();
}

DruidAbstractDataSourceMBean定义了暴露给jmx的一系列方法

getStatDataForMBean

com/alibaba/druid/pool/DruidDataSource.java

    public Map<String, Object> getStatDataForMBean() {try {Map<String, Object> map = new HashMap<String, Object>();// 0 - 4map.put("Name", this.getName());map.put("URL", this.getUrl());map.put("CreateCount", this.getCreateCount());map.put("DestroyCount", this.getDestroyCount());map.put("ConnectCount", this.getConnectCount());// 5 - 9map.put("CloseCount", this.getCloseCount());map.put("ActiveCount", this.getActiveCount());map.put("PoolingCount", this.getPoolingCount());map.put("LockQueueLength", this.getLockQueueLength());map.put("WaitThreadCount", this.getNotEmptyWaitThreadCount());// 10 - 14map.put("InitialSize", this.getInitialSize());map.put("MaxActive", this.getMaxActive());map.put("MinIdle", this.getMinIdle());map.put("PoolPreparedStatements", this.isPoolPreparedStatements());map.put("TestOnBorrow", this.isTestOnBorrow());// 15 - 19map.put("TestOnReturn", this.isTestOnReturn());map.put("MinEvictableIdleTimeMillis", this.minEvictableIdleTimeMillis);map.put("ConnectErrorCount", this.getConnectErrorCount());map.put("CreateTimespanMillis", this.getCreateTimespanMillis());map.put("DbType", this.dbTypeName);// 20 - 24map.put("ValidationQuery", this.getValidationQuery());map.put("ValidationQueryTimeout", this.getValidationQueryTimeout());map.put("DriverClassName", this.getDriverClassName());map.put("Username", this.getUsername());map.put("RemoveAbandonedCount", this.getRemoveAbandonedCount());// 25 - 29map.put("NotEmptyWaitCount", this.getNotEmptyWaitCount());map.put("NotEmptyWaitNanos", this.getNotEmptyWaitNanos());map.put("ErrorCount", this.getErrorCount());map.put("ReusePreparedStatementCount", this.getCachedPreparedStatementHitCount());map.put("StartTransactionCount", this.getStartTransactionCount());// 30 - 34map.put("CommitCount", this.getCommitCount());map.put("RollbackCount", this.getRollbackCount());map.put("LastError", JMXUtils.getErrorCompositeData(this.getLastError()));map.put("LastCreateError", JMXUtils.getErrorCompositeData(this.getLastCreateError()));map.put("PreparedStatementCacheDeleteCount", this.getCachedPreparedStatementDeleteCount());// 35 - 39map.put("PreparedStatementCacheAccessCount", this.getCachedPreparedStatementAccessCount());map.put("PreparedStatementCacheMissCount", this.getCachedPreparedStatementMissCount());map.put("PreparedStatementCacheHitCount", this.getCachedPreparedStatementHitCount());map.put("PreparedStatementCacheCurrentCount", this.getCachedPreparedStatementCount());map.put("Version", this.getVersion());// 40 -map.put("LastErrorTime", this.getLastErrorTime());map.put("LastCreateErrorTime", this.getLastCreateErrorTime());map.put("CreateErrorCount", this.getCreateErrorCount());map.put("DiscardCount", this.getDiscardCount());map.put("ExecuteQueryCount", this.getExecuteQueryCount());map.put("ExecuteUpdateCount", this.getExecuteUpdateCount());return map;} catch (JMException ex) {throw new IllegalStateException("getStatData error", ex);}}

DruidDataSource的getStatDataForMBean定义了给jmx的所有监控项

DruidDataSourceUtils

com/alibaba/druid/util/DruidDataSourceUtils.java

    public static Map<String, Object> getStatDataForMBean(Object druidDataSource) {if (druidDataSource.getClass() == DruidDataSource.class) {return ((DruidDataSource) druidDataSource).getStatDataForMBean();}try {Method method = druidDataSource.getClass().getMethod("getStatDataForMBean");Object obj = method.invoke(druidDataSource);return (Map<String, Object>) obj;} catch (Exception e) {LOG.error("getStatDataForMBean error", e);return null;}}

DruidDataSourceUtils提供了静态方法用于获取监控项

小结

DruidDataSource的init方法会执行registerMbean,把自身注册到mbeanServer,它实现了DruidDataSourceMBean接口;而DruidDataSourceUtils提供了静态方法用于获取监控项,它使用的是DruidDataSource的getStatDataForMBean方法(貌似没直接给到jmx),可以利用该方法把指标暴露给micrometer,之后就可以利用micrometer的集成能力输出到各个监控平台。

相关文章:

聊聊druid连接池的监控

序 本文主要研究一下druid连接池的监控 init com/alibaba/druid/pool/DruidDataSource.java public void init() throws SQLException {//......registerMbean();//...... }DruidDataSource的init方法会执行registerMbean registerMbean com/alibaba/druid/pool/DruidData…...

CentOS 7 安装 Docker 的详细步骤

文章目录 Docker简介1.更新2.安装必要的软件包3.添加Docker仓库4.安装5.安装后的一些常规设置及常用的命令5.1 启动 Docker5.2 Docker 在系统启动时自动运行5.3 运行一个 Hello World 镜像5.4 查看docker运行状态5.5 docker ps5.6 查看docker版本 6.安装种常见的错误错误1:yum-…...

竞赛 基于深度学习的动物识别 - 卷积神经网络 机器视觉 图像识别

文章目录 0 前言1 背景2 算法原理2.1 动物识别方法概况2.2 常用的网络模型2.2.1 B-CNN2.2.2 SSD 3 SSD动物目标检测流程4 实现效果5 部分相关代码5.1 数据预处理5.2 构建卷积神经网络5.3 tensorflow计算图可视化5.4 网络模型训练5.5 对猫狗图像进行2分类 6 最后 0 前言 &#…...

数据结构之【泛型】

泛型&#xff1a;定义阶段不明确具体类型&#xff0c;产生对象时明确具体类型。 //Object是Java中的最高参数统一化&#xff0c;能够接受所有的引用类型&#xff1b; //有了包装类的自动拆装箱之后&#xff0c;Object还能够接收基本类型数值&#xff08;自动装箱&#xff09; …...

华为ac无线侧命令行配置思路和步骤

无线侧配置思路&#xff1a; Ap和ac在同一个广播域内&#xff0c;不用配置 option 43 source 源ip回包哪个模式都得配置 Cli配置业务模版流程&#xff1a; 1、 AC控制器上全局配置capwap回包接口地址 1、配置ssid&#xff1a;wifi名称 2、配置安全模版&#xff1a;用户连接密码…...

十六)Stable Diffusion教程:出图流程化

今天说一个流程化出图的案例&#xff0c;适用很多方面。 1、得到线稿&#xff0c;自己画或者图生图加线稿lora出线稿&#xff1b;如果想sd出图调整参数不那么频繁细致&#xff0c;则线稿的素描关系、层次、精深要表现出来&#xff0c;表现清楚。 2、文生图&#xff0c;seed随机…...

SpringBoot全局异常处理源码

SpringBoot全局异常处理源码 一、SpringMVC执行流程二、SpringBoot源码跟踪三、自定义优雅的全局异常处理脚手架starter自定义异常国际化引入封装基础异常封装基础异常扫描器&#xff0c;并注册到ExceptionHandler中项目分享以及改进点 一、SpringMVC执行流程 今天这里叙述的全…...

设计模式——7. 装饰者模式

1. 说明 装饰者模式(Decorator Pattern)是一种结构型设计模式,它允许你在不改变对象接口的前提下,动态地将新行为附加到对象上。这种模式是通过创建一个包装(或装饰)对象,将要被装饰的对象包裹起来,从而实现对原有对象功能的增强和扩展。 装饰者模式的主要特点包括:…...

安卓玩机-----反编译apk 修改apk 去广告 去弹窗等操作中的一些常识

安卓机型app的编译与反编译 apk文件的简单说明与解析 -安卓修改apk apk的组成和编译 一 电脑端几种反编译apk工具操作步骤解析 前面几个博文有说明关于反编译apk和apk架构等有些常识.今天对以上做个补充。初学者记住一点。对于一个apk文件使用压缩软件7zip打开可以查看到文件…...

Hoeffing不等式

在李航老师的统计学习方法&#xff08;第一版中&#xff09; H o e f f i n g 不等式 Hoeffing不等式 Hoeffing不等式是这样子给出的 设 X 1 , X 2 , . . . , X N X_1,X_2,...,X_N X1​,X2​,...,XN​是独立随机变量&#xff0c;且 X i ∈ [ a i , b i ] , i 1 , 2 , . . . ,…...

ffmpeg解复用指定pid转推udp

命令 ffmpeg -re -i udp://224.2.2.2:4003?fifo_size1024000 -map #5001 -acodec copy -flush_packets 1 -f mpegts udp://192.168.2.62:5161 ffmpeg -re -i udp://224.2.2.2:4003?fifo_size1024000 -map #5001 -acodec copy -flush_packets 1 -f mpegts udp://192.16…...

Vue组件通信方式

1.props通信 1.1在 Vue 2 中使用 props 通信 注意:props传递的数据是只读的,子组件修改,不会影响父组件 1.1.1.定义 props 在子组件中使用 props 选项来定义要接收的属性 // 子组件 <script> export default {props: {message: String} } </script>1.1.2.传递…...

redis-设置从节点

节点结构 节点配置文件 主节点 不变 6380节点 port 6380 slaveof 127.0.0.1 63796381节点 port 6381 slaveof 127.0.0.1 6380启动 指定配置文件的方式启动 D:\jiqun\redis\Redis-6380>redis-server.exe redis.windows.conf启动时&#xff0c;会触发同步数据命令 主节点…...

k8s-实战——基于nfs实现动态存储

部署nfs服务 基于Centos7.9版本创建动态存储注意k8s版本应低于v1.24版本高k8s版本ServiceAccount需要手动创建secrets并关联相关sa部署流程 创建NFS共享服务、采用单独的节点用于nfs服务独占安装nfs-utils和rpcbindnfs客户端和服务端都安装nfs-utils包通过部署化脚本安装k8s集群…...

【广州华锐互动】鱼类授精繁殖VR虚拟仿真实训系统

随着科技的不断发展&#xff0c;虚拟现实技术在各个领域的应用越来越广泛。在养殖业中&#xff0c;VR技术可以帮助养殖户进行家鱼授精实操演练&#xff0c;提高养殖效率和繁殖成功率。本文将介绍利用VR开展家鱼授精实操演练的方法和应用。 首先&#xff0c;我们需要了解家鱼授精…...

RocketMQ Promethus Exporter

介绍​ Rocketmq-exporter 是用于监控 RocketMQ broker 端和客户端所有相关指标的系统&#xff0c;通过 mqAdmin 从 broker 端获取指标值后封装成 87 个 cache。 警告 过去版本曾是 87 个 concurrentHashMap&#xff0c;由于 Map 不会删除过期指标&#xff0c;所以一旦有 la…...

Kafka收发消息核心参数详解

文章目录 1、从基础的客户端说起1.1、消息发送者主流程1.2、消息消费者主流程 2、从客户端属性来梳理客户端工作机制2.1、消费者分组消费机制 1、从基础的客户端说起 Kafka提供了非常简单的客户端API。只需要引入一个Maven依赖即可&#xff1a; <dependency><groupId…...

Springboot中Aop的使用

Springboot中使用拦截器、过滤器、监听器-CSDN博客 相比较于拦截器&#xff0c;Spring 的aop则功能更强大&#xff0c;封装的更细致&#xff0c;需要单独引用 jar包。 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-b…...

创建vue3项目、链式调用、setup函数、ref函数、reactive函数、计算和监听属性、vue3的生命周期、torefs的使用、vue3的setup写法

1 创建vue3项目 # 两种方式- vue-cli&#xff1a;vue脚手架---》创建vue项目---》构建vue项目--》工具链跟之前一样- vite &#xff1a;https://cn.vitejs.dev/-npm create vuelatest // 或者-npm create vitelatest一路选择即可# 运行vue3项目-vue-cli跟之前一样-vite 创建的…...

搭建好自己的PyPi服务器后怎么使用

当您成功搭建好自己的 PyPI 服务器后&#xff0c;您可以使用以下步骤来发布和使用您的包&#xff1a; 打包您的代码&#xff1a; 首先&#xff0c;将您的 Python 项目打包成一个发布包。确保您已经在项目根目录下创建了 setup.py 文件&#xff0c;并按照正确的格式填写了项目信…...

挑战杯推荐项目

“人工智能”创意赛 - 智能艺术创作助手&#xff1a;借助大模型技术&#xff0c;开发能根据用户输入的主题、风格等要求&#xff0c;生成绘画、音乐、文学作品等多种形式艺术创作灵感或初稿的应用&#xff0c;帮助艺术家和创意爱好者激发创意、提高创作效率。 ​ - 个性化梦境…...

利用ngx_stream_return_module构建简易 TCP/UDP 响应网关

一、模块概述 ngx_stream_return_module 提供了一个极简的指令&#xff1a; return <value>;在收到客户端连接后&#xff0c;立即将 <value> 写回并关闭连接。<value> 支持内嵌文本和内置变量&#xff08;如 $time_iso8601、$remote_addr 等&#xff09;&a…...

工业安全零事故的智能守护者:一体化AI智能安防平台

前言&#xff1a; 通过AI视觉技术&#xff0c;为船厂提供全面的安全监控解决方案&#xff0c;涵盖交通违规检测、起重机轨道安全、非法入侵检测、盗窃防范、安全规范执行监控等多个方面&#xff0c;能够实现对应负责人反馈机制&#xff0c;并最终实现数据的统计报表。提升船厂…...

渗透实战PortSwigger靶场-XSS Lab 14:大多数标签和属性被阻止

<script>标签被拦截 我们需要把全部可用的 tag 和 event 进行暴力破解 XSS cheat sheet&#xff1a; https://portswigger.net/web-security/cross-site-scripting/cheat-sheet 通过爆破发现body可以用 再把全部 events 放进去爆破 这些 event 全部可用 <body onres…...

1688商品列表API与其他数据源的对接思路

将1688商品列表API与其他数据源对接时&#xff0c;需结合业务场景设计数据流转链路&#xff0c;重点关注数据格式兼容性、接口调用频率控制及数据一致性维护。以下是具体对接思路及关键技术点&#xff1a; 一、核心对接场景与目标 商品数据同步 场景&#xff1a;将1688商品信息…...

什么?连接服务器也能可视化显示界面?:基于X11 Forwarding + CentOS + MobaXterm实战指南

文章目录 什么是X11?环境准备实战步骤1️⃣ 服务器端配置(CentOS)2️⃣ 客户端配置(MobaXterm)3️⃣ 验证X11 Forwarding4️⃣ 运行自定义GUI程序(Python示例)5️⃣ 成功效果![在这里插入图片描述](https://i-blog.csdnimg.cn/direct/55aefaea8a9f477e86d065227851fe3d.pn…...

算法笔记2

1.字符串拼接最好用StringBuilder&#xff0c;不用String 2.创建List<>类型的数组并创建内存 List arr[] new ArrayList[26]; Arrays.setAll(arr, i -> new ArrayList<>()); 3.去掉首尾空格...

【笔记】WSL 中 Rust 安装与测试完整记录

#工作记录 WSL 中 Rust 安装与测试完整记录 1. 运行环境 系统&#xff1a;Ubuntu 24.04 LTS (WSL2)架构&#xff1a;x86_64 (GNU/Linux)Rust 版本&#xff1a;rustc 1.87.0 (2025-05-09)Cargo 版本&#xff1a;cargo 1.87.0 (2025-05-06) 2. 安装 Rust 2.1 使用 Rust 官方安…...

基于Java+VUE+MariaDB实现(Web)仿小米商城

仿小米商城 环境安装 nodejs maven JDK11 运行 mvn clean install -DskipTestscd adminmvn spring-boot:runcd ../webmvn spring-boot:runcd ../xiaomi-store-admin-vuenpm installnpm run servecd ../xiaomi-store-vuenpm installnpm run serve 注意&#xff1a;运行前…...

人工智能--安全大模型训练计划:基于Fine-tuning + LLM Agent

安全大模型训练计划&#xff1a;基于Fine-tuning LLM Agent 1. 构建高质量安全数据集 目标&#xff1a;为安全大模型创建高质量、去偏、符合伦理的训练数据集&#xff0c;涵盖安全相关任务&#xff08;如有害内容检测、隐私保护、道德推理等&#xff09;。 1.1 数据收集 描…...