2. 连接池水位概念

连接池水位是衡量数据库连接池资源使用饱和程度的核心抽象概念。它借鉴了水库水位管理的思路：连接池中的连接如同水库中的水，应用程序从池中“取水”（获取连接）执行数据库操作，操作完成后再“还水”（归还连接）。当“取水”速度持续大于“还水”速度时，水位就会上升，最终可能导致系统故障。

2.1 正常水位与异常水位的定义

2.2 水位监控三大核心指标

要准确判断连接池水位，需要实时监控以下三个指标。这三个指标共同构成了水位诊断的“三驾马车”。

1. 活跃连接数（Active Connections）
   当前正在执行数据库操作、尚未归还到池中的连接数量。这是最直接的水位指示器。
   正常范围： 池容量的 30%~70%。
   异常阈值： 持续超过池容量的 85%。
2. 空闲连接数（Idle Connections）
   已创建但未被使用的连接数量，存放在池中等待分配。空闲连接是系统的缓冲能力。
   正常范围： 至少保持池容量的 10%~20%。
   异常阈值： 空闲连接数降为 0 且持续不恢复。
3. 等待队列长度（Pending Queue Size）
   请求获取连接但所有连接均被占用时，进入阻塞等待队列的线程数量。
   正常范围： 0。
   异常阈值： 大于 0 且持续增长。

2.3 连接池水位变化示意图

下图展示了连接池从正常水位逐步攀升至异常水位的完整过程，以及各阶段监控指标的变化特征。

2.4 水位异常的根本原因分类

连接池水位异常通常由以下三类原因引发，理解这些原因有助于快速定位故障根因。

2.5 水位监控指标采集示例

以下代码展示了如何通过 HikariCP 的 JMX 接口采集水位指标，用于实时告警和故障定位。

// 通过 HikariPoolMXBean 采集连接池水位指标
import com.zaxxer.hikari.HikariPoolMXBean;
import javax.management.*;

public class ConnectionPoolWaterLevelMonitor {
    
    public static PoolMetrics collectMetrics(MBeanServerConnection mbsc, String poolName) throws Exception {
        ObjectName poolNameObj = new ObjectName("com.zaxxer.hikari:type=Pool (" + poolName + ")");
        HikariPoolMXBean poolProxy = JMX.newMXBeanProxy(mbsc, poolNameObj, HikariPoolMXBean.class);
        
        PoolMetrics metrics = new PoolMetrics();
        metrics.activeConnections = poolProxy.getActiveConnections();
        metrics.idleConnections = poolProxy.getIdleConnections();
        metrics.pendingThreads = poolProxy.getPendingThreads();
        metrics.totalConnections = poolProxy.getTotalConnections();
        
        // 计算水位百分比
        metrics.waterLevelPercent = (double) metrics.activeConnections / metrics.totalConnections * 100;
        
        // 水位状态判定
        if (metrics.waterLevelPercent > 85) {
            metrics.status = "CRITICAL";
        } else if (metrics.waterLevelPercent > 70) {
            metrics.status = "WARNING";
        } else {
            metrics.status = "NORMAL";
        }
        
        return metrics;
    }
    
    static class PoolMetrics {
        int activeConnections;
        int idleConnections;
        int pendingThreads;
        int totalConnections;
        double waterLevelPercent;
        String status;
    }
}