Alibaba Druid

为什么选择 Druid？

Druid 是阿里巴巴开源的数据库连接池，专为监控而生。它不仅提供高性能的连接池功能，还集成了 SQL 监控、黑名单拦截、Web 应用防火墙（WallFilter）等企业级功能，在阿里内部经过大规模生产环境验证。

Druid 架构概览

Druid 通过 Filter 链机制实现了对 JDBC 层的全面拦截与增强，所有 SQL 操作都会经过 Filter 处理。

1. 添加 Maven 依赖

在 pom.xml 中添加 Druid 依赖。推荐使用 druid-spring-boot-starter 简化 Spring Boot 集成。

<!-- 方式一：原生 Druid（适用于非 Spring Boot 项目） -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.23</version>
</dependency>

<!-- 方式二：Spring Boot Starter（推荐） -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.2.23</version>
</dependency>

<!-- MySQL 驱动 -->
<dependency>
    <groupId>com.mysql</groupId>
    <artifactId>mysql-connector-j</artifactId>
    <version>8.3.0</version>
</dependency>Copy

2. 基础代码示例 (纯 JDBC)

不使用 Spring 框架时，通过代码直接创建和配置 Druid 数据源。

import com.alibaba.druid.pool.DruidDataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class DruidDemo {
    private static DruidDataSource dataSource;

    static {
        dataSource = new DruidDataSource();
        // 基础配置
        dataSource.setUrl("jdbc:mysql://localhost:3306/test_db?useSSL=false&serverTimezone=Asia/Shanghai");
        dataSource.setUsername("root");
        dataSource.setPassword("password");
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        // 连接池配置
        dataSource.setInitialSize(5);
        dataSource.setMinIdle(5);
        dataSource.setMaxActive(20);
        dataSource.setMaxWait(60000);
        // 连接保活
        dataSource.setValidationQuery("SELECT 1");
        dataSource.setTestWhileIdle(true);
        dataSource.setTimeBetweenEvictionRunsMillis(60000);
        dataSource.setMinEvictableIdleTimeMillis(300000);
    }

    public static void main(String[] args) {
        try (Connection conn = dataSource.getConnection();
             PreparedStatement stmt = conn.prepareStatement("SELECT 1")) {
            ResultSet rs = stmt.executeQuery();
            while (rs.next()) {
                System.out.println("Result: " + rs.getInt(1));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // 应用关闭时调用
    public static void shutdown() {
        if (dataSource != null) {
            dataSource.close();
        }
    }
}Copy

关键参数解析

合理的配置能显著提升系统稳定性与性能。以下是生产环境推荐配置说明。

Spring Boot 配置文件示例 (application.yml)

spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/mydb?useSSL=false&serverTimezone=Asia/Shanghai
    username: root
    password: ${DB_PASSWORD:secret}
    druid:
      # 连接池核心配置
      initial-size: 5
      min-idle: 5
      max-active: 20
      max-wait: 60000
      # 连接保活与回收
      validation-query: SELECT 1
      test-while-idle: true
      test-on-borrow: false
      test-on-return: false
      time-between-eviction-runs-millis: 60000
      min-evictable-idle-time-millis: 300000
      # 监控与拦截
      filters: stat,wall,slf4j
      # 连接泄漏检测（开发环境推荐开启）
      remove-abandoned: true
      remove-abandoned-timeout: 1800
      log-abandoned: true
      # 监控页面配置
      stat-view-servlet:
        enabled: true
        url-pattern: /druid/*
        login-username: admin
        login-password: admin
        reset-enable: false
      # Web 关联监控
      web-stat-filter:
        enabled: true
        url-pattern: /*
        exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"Copy

连接状态流转

理解连接的生命周期有助于排查"连接泄漏"或"连接超时"等问题。连接在池中经历创建、空闲、使用、回收四个阶段。

内置监控页面

Druid 内置了一个功能强大的 Web 监控页面，可以实时查看 SQL 执行情况、连接池状态、慢查询统计等。这是 Druid 区别于其他连接池的核心优势。

传统 Web 项目配置 (web.xml)

在非 Spring Boot 项目中，需要在 web.xml 中手动配置 Servlet 和 Filter：

<!-- 1. 监控页面 Servlet -->
<servlet>
    <servlet-name>DruidStatView</servlet-name>
    <servlet-class>com.alibaba.druid.support.http.StatViewServlet</servlet-class>
    <init-param>
        <param-name>resetEnable</param-name>
        <param-value>false</param-value>
    </init-param>
    <init-param>
        <param-name>loginUsername</param-name>
        <param-value>admin</param-value>
    </init-param>
    <init-param>
        <param-name>loginPassword</param-name>
        <param-value>admin</param-value>
    </init-param>
</servlet>
<servlet-mapping>
    <servlet-name>DruidStatView</servlet-name>
    <url-pattern>/druid/*</url-pattern>
</servlet-mapping>

<!-- 2. Web 关联监控 Filter -->
<filter>
    <filter-name>DruidWebStatFilter</filter-name>
    <filter-class>com.alibaba.druid.support.http.WebStatFilter</filter-class>
    <init-param>
        <param-name>exclusions</param-name>
        <param-value>*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*</param-value>
    </init-param>
</filter>
<filter-mapping>
    <filter-name>DruidWebStatFilter</filter-name>
    <url-pattern>/*</url-pattern>
</filter-mapping>Copy

Spring Boot 注解配置方式

使用 druid-spring-boot-starter 时，可通过 Java Config 方式注册监控：

import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class DruidMonitorConfig {
    @Bean
    public ServletRegistrationBean<StatViewServlet> statViewServlet() {
        ServletRegistrationBean<StatViewServlet> bean =
            new ServletRegistrationBean<>(new StatViewServlet(), "/druid/*");
        bean.addInitParameter("loginUsername", "admin");
        bean.addInitParameter("loginPassword", "securePassword");
        bean.addInitParameter("resetEnable", "false");
        return bean;
    }

    @Bean
    public FilterRegistrationBean<WebStatFilter> webStatFilter() {
        FilterRegistrationBean<WebStatFilter> bean =
            new FilterRegistrationBean<>(new WebStatFilter());
        bean.setUrlPatterns(java.util.Collections.singletonList("/*"));
        bean.addInitParameter("exclusions", "*.js,*.css,*.ico,/druid/*");
        return bean;
    }
}Copy

SQL 防火墙

Druid 内置的 WallFilter 基于语义分析实现 SQL 防火墙功能，能有效防御 SQL 注入攻击，并可禁止危险的 SQL 操作（如 DROP TABLE、TRUNCATE 等）。

Java 代码配置

import com.alibaba.druid.wall.WallConfig;
import com.alibaba.druid.wall.WallFilter;
import java.util.Arrays;

// 自定义 WallFilter 配置
WallFilter wallFilter = new WallFilter();
WallConfig wallConfig = new WallConfig();
wallConfig.setDeleteAllow(false);         // 禁止 DELETE
wallConfig.setDropTableAllow(false);      // 禁止 DROP TABLE
wallConfig.setTruncateAllow(false);       // 禁止 TRUNCATE
wallConfig.setAlterTableAllow(false);     // 禁止 ALTER TABLE
wallConfig.setMultiStatementAllow(false); // 禁止多语句执行
wallFilter.setConfig(wallConfig);
wallFilter.setDbType("mysql");

DruidDataSource dataSource = new DruidDataSource();
dataSource.setProxyFilters(Arrays.asList(wallFilter));Copy

Spring Boot YAML 配置

spring:
  datasource:
    druid:
      filters: stat,wall,slf4j
      filter:
        wall:
          enabled: true
          db-type: mysql
          config:
            delete-allow: false
            drop-table-allow: false
            truncate-allow: false
            alter-table-allow: false
            multi-statement-allow: falseCopy

连接池大小计算

连接池大小并非越大越好。业界常用经验公式（引自 HikariCP 文档）：

池大小 = (CPU 核心数 * 2) + 有效磁盘数

示例：4 核 CPU + 1 块 SSD
推荐池大小 = (4 * 2) + 1 = 9（可适当上调至 10-15）Copy

关键监控指标

慢 SQL 检测与连接泄漏排查

spring:
  datasource:
    druid:
      filter:
        stat:
          enabled: true
          slow-sql-millis: 3000    # 超过 3 秒视为慢 SQL
          log-slow-sql: true       # 记录慢 SQL 日志
          merge-sql: true          # 合并相同结构的 SQL 统计
      # 连接泄漏检测
      remove-abandoned: true
      remove-abandoned-timeout: 1800   # 30 分钟未归还则强制回收
      log-abandoned: true              # 记录泄漏连接的堆栈信息Copy