SpringBoot 如何使用 Druid 进行数据库连接池管理

使用 Druid 进行数据库连接池管理的 Spring Boot 应用

数据库连接池是任何Web应用程序的重要组成部分，它们有助于管理数据库连接的复用，提高性能和资源利用率。Druid是一个强大的数据库连接池，它具有监控、防SQL注入、快速、可扩展等特点。在本文中，我们将详细介绍如何在Spring Boot应用中使用Druid进行数据库连接池管理，并提供示例代码。

在这里插入图片描述

什么是 Druid？

Druid是阿里巴巴开源的数据库连接池实现，它提供了高性能、强壮、可扩展、可监控的数据库连接池。Druid不仅仅是一个连接池，它还提供了许多数据库监控和管理的功能，如实时监控、SQL防火墙、慢查询日志等。

Druid的一些主要特点包括：

高性能：Druid在连接池和监控方面做了大量优化，以确保最佳的性能。
安全性：Druid提供了SQL防火墙，可以检测和阻止恶意SQL注入攻击。
可扩展性：Druid允许您自定义扩展，以满足特定需求。
监控：Druid提供了丰富的监控数据，可以方便地集成到监控系统中。

创建 Spring Boot 项目

首先，确保您已经安装了Java开发环境和Maven。接下来，您可以使用Spring Initializer创建一个新的Spring Boot项目。在https://start.spring.io/上选择您的项目配置，然后生成项目并下载。

添加 Druid 依赖

在生成的项目中，您需要添加Druid的依赖。在pom.xml文件中，确保以下依赖项已经添加：

<dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.2.6</version>
</dependency>

这将包括Druid所需的所有依赖。

配置 Druid 数据源

接下来，您需要配置Druid数据源。在src/main/resources/application.properties文件中，添加以下配置：

spring.datasource.url=jdbc:mysql://localhost:3306/mydb
spring.datasource.username=root
spring.datasource.password=your_password
spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver# 配置 Druid 数据源
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.initialSize=5
spring.datasource.minIdle=5
spring.datasource.maxActive=20
spring.datasource.maxWait=60000
spring.datasource.timeBetweenEvictionRunsMillis=60000
spring.datasource.minEvictableIdleTimeMillis=300000
spring.datasource.validationQuery=SELECT 1 FROM DUAL
spring.datasource.testWhileIdle=true
spring.datasource.testOnBorrow=false
spring.datasource.testOnReturn=false
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.filters=stat,wall,log4j2
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000

在上述配置中，您需要根据实际情况修改spring.datasource.url、spring.datasource.username和spring.datasource.password等属性，以便连接到您的数据库。此外，您可以根据需求调整连接池的配置参数。

配置 Druid 监控

Druid提供了内置的监控功能，您可以使用它来监控数据库连接池的使用情况。要启用Druid监控，您需要添加一个Servlet和一个Filter。在src/main/java/com/example/demo包中创建一个名为DruidConfig的配置类：

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 DruidConfig {@Beanpublic ServletRegistrationBean<StatViewServlet> druidServlet() {ServletRegistrationBean<StatViewServlet> registrationBean = new ServletRegistrationBean<>(new StatViewServlet(), "/druid/*");// 设置登录用户名和密码registrationBean.addInitParameter("loginUsername", "admin");registrationBean.addInitParameter("loginPassword", "admin");return registrationBean;}@Beanpublic FilterRegistrationBean<WebStatFilter> filter() {FilterRegistrationBean<WebStatFilter> registrationBean = new FilterRegistrationBean<>(new WebStatFilter());// 设置过滤路径registrationBean.addUrlPatterns("/*");// 忽略的资源类型registrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");return registrationBean;}
}

在上述代码中，我们创建了一个DruidConfig配置类，使用ServletRegistrationBean注册了Druid的监控Servlet，以及使用FilterRegistrationBean注册了Druid的监控Filter。您可以根据需要调整登录用户名和密码，以及过滤路径和忽略的资源类型。

创建数据访问类

现在，您可以创建一个数据访问类来测试Druid数据源。在src/main/java/com/example/demo包中创建一个名为DemoDao的类：

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;import java.util.List;
import java.util.Map;@Repository
public class DemoDao {private final JdbcTemplate jdbcTemplate;public DemoDao(JdbcTemplate jdbcTemplate) {this.jdbcTemplate = jdbcTemplate;}public List<Map<String, Object>> queryData() {return jdbcTemplate.queryForList("SELECT * FROM my_table");}
}

在上述代码中，我们使用JdbcTemplate来执行SQL查询。

创建测试控制器

接下来，创建一个测试控制器来测试Druid数据源。在src/main/java/com/example/demo包中创建一个名为DemoController的类：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;
import java.util.Map;@RestController
public class DemoController {private final DemoDao demoDao;public DemoController(DemoDao demoDao) {this.demoDao = demoDao;}@GetMapping("/data")public List<Map<String, Object>> getData() {return demoDao.queryData();}
}