当前位置: 首页 > 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;并按照正确的格式填写了项目信…...

【Python】 -- 趣味代码 - 小恐龙游戏

文章目录 文章目录 00 小恐龙游戏程序设计框架代码结构和功能游戏流程总结01 小恐龙游戏程序设计02 百度网盘地址00 小恐龙游戏程序设计框架 这段代码是一个基于 Pygame 的简易跑酷游戏的完整实现,玩家控制一个角色(龙)躲避障碍物(仙人掌和乌鸦)。以下是代码的详细介绍:…...

Flask RESTful 示例

目录 1. 环境准备2. 安装依赖3. 修改main.py4. 运行应用5. API使用示例获取所有任务获取单个任务创建新任务更新任务删除任务 中文乱码问题&#xff1a; 下面创建一个简单的Flask RESTful API示例。首先&#xff0c;我们需要创建环境&#xff0c;安装必要的依赖&#xff0c;然后…...

AI Agent与Agentic AI:原理、应用、挑战与未来展望

文章目录 一、引言二、AI Agent与Agentic AI的兴起2.1 技术契机与生态成熟2.2 Agent的定义与特征2.3 Agent的发展历程 三、AI Agent的核心技术栈解密3.1 感知模块代码示例&#xff1a;使用Python和OpenCV进行图像识别 3.2 认知与决策模块代码示例&#xff1a;使用OpenAI GPT-3进…...

聊聊 Pulsar:Producer 源码解析

一、前言 Apache Pulsar 是一个企业级的开源分布式消息传递平台&#xff0c;以其高性能、可扩展性和存储计算分离架构在消息队列和流处理领域独树一帜。在 Pulsar 的核心架构中&#xff0c;Producer&#xff08;生产者&#xff09; 是连接客户端应用与消息队列的第一步。生产者…...

cf2117E

原题链接&#xff1a;https://codeforces.com/contest/2117/problem/E 题目背景&#xff1a; 给定两个数组a,b&#xff0c;可以执行多次以下操作&#xff1a;选择 i (1 < i < n - 1)&#xff0c;并设置 或&#xff0c;也可以在执行上述操作前执行一次删除任意 和 。求…...

C++.OpenGL (10/64)基础光照(Basic Lighting)

基础光照(Basic Lighting) 冯氏光照模型(Phong Lighting Model) #mermaid-svg-GLdskXwWINxNGHso {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-GLdskXwWINxNGHso .error-icon{fill:#552222;}#mermaid-svg-GLd…...

QT: `long long` 类型转换为 `QString` 2025.6.5

在 Qt 中&#xff0c;将 long long 类型转换为 QString 可以通过以下两种常用方法实现&#xff1a; 方法 1&#xff1a;使用 QString::number() 直接调用 QString 的静态方法 number()&#xff0c;将数值转换为字符串&#xff1a; long long value 1234567890123456789LL; …...

【HarmonyOS 5 开发速记】如何获取用户信息(头像/昵称/手机号)

1.获取 authorizationCode&#xff1a; 2.利用 authorizationCode 获取 accessToken&#xff1a;文档中心 3.获取手机&#xff1a;文档中心 4.获取昵称头像&#xff1a;文档中心 首先创建 request 若要获取手机号&#xff0c;scope必填 phone&#xff0c;permissions 必填 …...

python执行测试用例,allure报乱码且未成功生成报告

allure执行测试用例时显示乱码&#xff1a;‘allure’ &#xfffd;&#xfffd;&#xfffd;&#xfffd;&#xfffd;ڲ&#xfffd;&#xfffd;&#xfffd;&#xfffd;ⲿ&#xfffd;&#xfffd;&#xfffd;Ҳ&#xfffd;&#xfffd;&#xfffd;ǿ&#xfffd;&am…...

Java求职者面试指南:Spring、Spring Boot、MyBatis框架与计算机基础问题解析

Java求职者面试指南&#xff1a;Spring、Spring Boot、MyBatis框架与计算机基础问题解析 一、第一轮提问&#xff08;基础概念问题&#xff09; 1. 请解释Spring框架的核心容器是什么&#xff1f;它在Spring中起到什么作用&#xff1f; Spring框架的核心容器是IoC容器&#…...