Druid 监控机制深度解析

🎯 Druid 的三大核心价值

• 性能监控：实时采集 SQL 执行耗时、连接池状态等关键指标
• 安全防护：内置 SQL 防火墙，阻止 SQL 注入和危险操作
• 故障诊断：提供连接泄漏检测、慢 SQL 追踪等诊断能力

⚙️ Filter 链工作原理

Druid 的监控能力源于其 Filter 链设计模式。每个 Filter 负责特定的监控职责：

• StatFilter：统计 SQL 执行次数、耗时、影响行数等核心指标
• WallFilter：SQL 防火墙，拦截危险 SQL（DROP、TRUNCATE 等）
• Log4j2Filter：将慢 SQL 和异常记录到日志系统
• ConfigFilter：支持数据库密码加密

执行流程：SQL 请求 → Filter1 → Filter2 → ... → 实际执行 → Filter2 返回 → Filter1 返回 → 应用

// DruidConfig.java - Druid 配置类
@Configuration
public class DruidConfig {
    
    @Bean
    @ConfigurationProperties("spring.datasource.druid")
    public DataSource druidDataSource() {
        return new DruidDataSource();
    }
    
    // 配置 Druid 监控的 Servlet
    @Bean
    public ServletRegistrationBean<StatViewServlet> statViewServlet() {
        ServletRegistrationBean<StatViewServlet> bean = 
            new ServletRegistrationBean<>(
                new StatViewServlet(), "/druid/*"
            );
        
        // 设置登录账号密码
        bean.addInitParameter("loginUsername", "admin");
        bean.addInitParameter("loginPassword", "admin123");
        
        // IP 白名单（为空表示允许所有）
        bean.addInitParameter("allow", "127.0.0.1,192.168.1.*");
        
        return bean;
    }
    
    // 配置 Web 监控 Filter
    @Bean
    public FilterRegistrationBean<WebStatFilter> webStatFilter() {
        FilterRegistrationBean<WebStatFilter> bean = 
            new FilterRegistrationBean<>(
                new WebStatFilter()
            );
        
        bean.addUrlPatterns("/*");
        bean.addInitParameter("exclusions", 
            "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
        
        return bean;
    }
}

• WaitThreadCount > 5 持续 1 分钟 → 触发连接池告警
• MaxTimespan > 5000ms → 触发慢 SQL 告警
• ActiveCount / maxActive > 0.9 → 触发连接池即将耗尽告警

⚡ 连接池核心参数调优

# 计算公式：
maxActive = max(并发请求数 * 单个请求平均数据库操作数, 20)
# 例如：并发 100 QPS，每个请求 2 次 DB 查询，平均响应时间 50ms
maxActive = 100 * 2 * 0.05 = 10 （建议留 30% 余量，设为 15）

initialSize: 5   # 应用启动时创建 5 个连接，避免冷启动延迟
minIdle: 5        # 保持至少 5 个空闲连接，应对突发流量
maxActive: 20     # 最大 20 个连接
# 建议：minIdle = initialSize，且为 maxActive 的 20%-50%

maxWait: 3000  # 单位：毫秒，超过 3 秒抛出 GetConnectionTimeoutException
# Web 应用建议 3-5 秒，微服务建议 1-2 秒
# 过长会导致级联超时，影响用户体验

testWhileIdle: true              # 空闲时检测连接是否有效
testOnBorrow: false              # 借用连接时不检测（避免性能损耗）
testOnReturn: false              # 归还时不检测
validationQuery: "SELECT 1"     # MySQL 检测 SQL
timeBetweenEvictionRunsMillis: 60000  # 每 60 秒检测一次
minEvictableIdleTimeMillis: 300000    # 连接空闲 5 分钟后回收
removeAbandoned: true           # 开启连接泄漏检测
removeAbandonedTimeout: 180       # 连接被占用超过 3 分钟强制回收

• 低并发场景：initialSize=3, minIdle=3, maxActive=10
• 中等并发：initialSize=5, minIdle=5, maxActive=20
• 高并发场景：initialSize=10, minIdle=10, maxActive=50
• 微服务架构：单实例 maxActive 不超过 30，通过水平扩展提升并发能力

💡 常见问题与解决方案