Springboot自定义数据源DruidDataSource

news/2024/10/6 4:31:04/文章来源:https://www.cnblogs.com/fswhq/p/18061062

1、Druid简介
Java程序很大一部分要操作数据库，为了提高性能操作数据库的时候，又不得不使用数据库连接池。
Druid 是阿里巴巴开源平台上一个数据库连接池实现，结合了 C3P0、DBCP 等 DB 池的优点，同时加入了日志监控。
Druid 可以很好的监控 DB 池连接和 SQL 的执行情况，天生就是针对监控而生的 DB 连接池。
Druid已经在阿里巴巴部署了超过600个应用，经过一年多生产环境大规模部署的严苛考验。
Spring Boot 2.0 以上默认使用 Hikari 数据源，可以说 Hikari 与 Driud 都是当前 Java Web 上最优秀的数据源，我们来重点介绍 Spring Boot 如何集成 Druid 数据源，如何实现数据库监控。

Github地址：https://github.com/alibaba/druid/

com.alibaba.druid.pool.DruidDataSource 基本配置参数如下：

 

2、配置数据源
1、添加上 Druid 数据源依赖。

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.21</version>
</dependency>


2、切换数据源；之前已经说过 Spring Boot 2.0 以上默认使用 com.zaxxer.hikari.HikariDataSource 数据源，但可以 通过 spring.datasource.type 指定数据源。

 

# 数据源配置
spring:
datasource:
type: com.alibaba.druid.pool.DruidDataSource
driverClassName: com.kingbase8.Driver
# 数据源
druid:
url: jdbc:kingbase8:localhost:54321/SAMPLES?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=utf-8
username: SYSTEM
password: SYSTEM
# 初始连接数
initialSize: 5
# 最小连接池数量
minIdle: 10
# 最大连接池数量
maxActive: 20
# 配置获取连接等待超时的时间
maxWait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
timeBetweenEvictionRunsMillis: 60000
# 配置一个连接在池中最小生存的时间，单位是毫秒
minEvictableIdleTimeMillis: 300000
# 配置一个连接在池中最大生存的时间，单位是毫秒
maxEvictableIdleTimeMillis: 900000
# 配置检测连接是否有效
#mysql使用：SELECT 1 FROM DUAL
validationQuery: SELECT 1
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
webStatFilter:
enabled: true
statViewServlet:
enabled: true
# 设置白名单，不填则允许所有访问
allow:
url-pattern: /druid/*
# 控制台管理用户名和密码
login-username: admin
login-password: admin
filter:
stat:
enabled: true
# 慢SQL记录
log-slow-sql: true
slow-sql-millis: 1000
merge-sql: true
wall:
config:
multi-statement-allow: true


3、数据源切换之后，在测试类中注入 DataSource，然后获取到它，输出一看便知是否成功切换；

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringBootLoggingApplicationTests {

//记录器
Logger LOGGER = LoggerFactory.getLogger(getClass());


@Autowired
private DataSource dataSource;

@Test
public void contextLoads2() throws SQLException {
//看一下默认数据源
LOGGER.info("dataSource class:{}", dataSource.getClass());
//dataSource class:class com.zaxxer.hikari.HikariDataSource
//获得连接
Connection connection = dataSource.getConnection();
LOGGER.info("connection:{}", connection);
// connection:HikariProxyConnection@1332121385 wrapping com.mysql.jdbc.JDBC4Connection@716e431d
//关闭连接
connection.close();
}

}


4、切换成功！既然切换成功，就可以设置数据源连接初始化大小、最大连接数、等待时间、最小连接数 等设置项；可以查看源码

spring:
datasource:
username: root
password: 123456
#?serverTimezone=UTC解决时区的报错
url: jdbc:mysql://localhost:3306/springboot?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8
driver-class-name: com.mysql.cj.jdbc.Driver
type: com.alibaba.druid.pool.DruidDataSource

#Spring Boot 默认是不注入这些属性值的，需要自己绑定
#druid 数据源专有配置
initialSize: 5
minIdle: 5
maxActive: 20
maxWait: 60000
timeBetweenEvictionRunsMillis: 60000
minEvictableIdleTimeMillis: 300000
validationQuery: SELECT 1 FROM DUAL
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
poolPreparedStatements: true

#配置监控统计拦截的filters，stat:监控统计、log4j：日志记录、wall：防御sql注入
#如果运行时报错 java.lang.ClassNotFoundException: org.apache.log4j.Priority
#则导入 log4j 依赖即可，Maven 地址：https://mvnrepository.com/artifact/log4j/log4j
filters: stat,wall,log4j
maxPoolPreparedStatementPerConnectionSize: 20
useGlobalDataSourceStat: true
connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500
5、导入Log4j 的依赖

如果运行时报错 java.lang.ClassNotFoundException: org.apache.log4j.Priority
则导入 log4j 依赖即可，Maven 地址：https://mvnrepository.com/artifact/log4j/log4j
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
6、使用springboot自动为DruidDataSource 绑定配置文件中的参数时，只会获取到连接数据库的四个参数，其他参数springboot不会绑定

#数据库连接配置
spring:
datasource:
username: root
password: 12345678
url: jdbc:mysql://localhost:3306/mybatis?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8
driver-class-name: com.mysql.jdbc.Driver
type: com.alibaba.druid.pool.DruidDataSource

#Spring Boot 默认是不注入这些属性值的，需要自己绑定
#druid 数据源专有配置
initialSize: 5
minIdle: 5
maxActive: 20
maxWait: 60000
timeBetweenEvictionRunsMillis: 60000
minEvictableIdleTimeMillis: 300000
validationQuery: SELECT 1 FROM DUAL
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
poolPreparedStatements: true

#配置监控统计拦截的filters，stat:监控统计、log4j：日志记录、wall：防御sql注入
#如果允许时报错 java.lang.ClassNotFoundException: org.apache.log4j.Priority
#则导入 log4j 依赖即可，Maven 地址：https://mvnrepository.com/artifact/log4j/log4j
filters: stat,wall,log4j
maxPoolPreparedStatementPerConnectionSize: 20
useGlobalDataSourceStat: true
connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500
7、测试

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringBootLoggingApplicationTests {

//记录器
Logger LOGGER = LoggerFactory.getLogger(getClass());
@Autowired
private DataSource dataSource;

@Test
public void contextLoads2() throws SQLException {
//看一下默认数据源
LOGGER.info("dataSource class:{}", dataSource.getClass());
//dataSource class:class com.zaxxer.hikari.HikariDataSource
//获得连接
Connection connection = dataSource.getConnection();
LOGGER.info("connection:{}", connection);
// connection:HikariProxyConnection@1332121385 wrapping com.mysql.jdbc.JDBC4Connection@716e431d
DruidDataSource druidDataSource = (DruidDataSource)dataSource;
LOGGER.info("getUrl:{}", druidDataSource.getUrl());
LOGGER.info("getPassword:{}", druidDataSource.getPassword());
LOGGER.info("getMaxWait:{}", druidDataSource.getMaxWait());

connection.close();
}

}
结果：

getUrl:jdbc:mysql://localhost:3306/mybatis?
getPassword:12345678
getMaxWait:-1
可以看出，Url和password 获取成功。maxWait获取失败，得到默认值。

8、程序员自己为 DruidDataSource 绑定全局配置文件中的参数，再添加到容器中，而不再使用 Spring Boot 的自动生成了；我们需要 自己添加 DruidDataSource 组件到容器中，并绑定属性；

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;

@Configuration
public class DruidConfig {

/*
将自定义的 Druid数据源添加到容器中，不再让 Spring Boot 自动创建
绑定全局配置文件中的 druid 数据源属性到 com.alibaba.druid.pool.DruidDataSource从而让它们生效
@ConfigurationProperties(prefix = "spring.datasource")：作用就是将 全局配置文件中
前缀为 spring.datasource的属性值注入到 com.alibaba.druid.pool.DruidDataSource 的同名参数中
*/
@ConfigurationProperties(prefix = "spring.datasource")
@Bean
public DataSource druidDataSource() {
return new DruidDataSource();
}

}
9、去测试类中测试一下；看是否成功

@SpringBootTest
class SpringbootDataJdbcApplicationTests {

//DI注入数据源
@Autowired
DataSource dataSource;

@Test
public void contextLoads() throws SQLException {
//看一下默认数据源
System.out.println(dataSource.getClass());
//获得连接
Connection connection = dataSource.getConnection();
System.out.println(connection);

DruidDataSource druidDataSource = (DruidDataSource) dataSource;
System.out.println("druidDataSource 数据源最大连接数：" + druidDataSource.getMaxActive());
System.out.println("druidDataSource 数据源初始化连接数：" + druidDataSource.getInitialSize());

//关闭连接
connection.close();
}
}
输出结果 ：可见配置参数已经生效！

 

3、配置Druid数据源监控
Druid 数据源具有监控的功能，并提供了一个 web 界面方便用户查看，类似安装 路由器 时，人家也提供了一个默认的 web 页面。

1、需要设置 Druid 的后台管理页面，比如 登录账号、密码 等；配置后台管理；

@Configuration
public class DruidConfig {

@ConfigurationProperties("spring.datasource")
@Bean
public DataSource druidDataSource(){
return new DruidDataSource();
}

//下面的1和2是配置Druid的监控
//1、配置一个管理后台的Servlet
配置 Druid 监控管理后台的Servlet；
//内置 Servlet 容器时没有web.xml文件，所以使用 Spring Boot 的注册 Servlet 方式
@Bean
public ServletRegistrationBean statViewServlet() {
ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");

// 这些参数可以在 com.alibaba.druid.support.http.StatViewServlet
// 的父类 com.alibaba.druid.support.http.ResourceServlet 中找到
Map<String, String> initParams = new HashMap<>();
initParams.put("loginUsername", "admin"); //后台管理界面的登录账号
initParams.put("loginPassword", "123456"); //后台管理界面的登录密码

//后台允许谁可以访问
//initParams.put("allow", "localhost")：表示只有本机可以访问
//initParams.put("allow", "")：为空或者为null时，表示允许所有访问
initParams.put("allow", "");
//deny：Druid 后台拒绝谁访问
//initParams.put("kuangshen", "192.168.1.20");表示禁止此ip访问

//设置初始化参数
bean.setInitParameters(initParams);
return bean;
}

}
配置完毕后，我们可以选择访问 ：http://localhost:8888/druid/login.html

 

进入之后

 

配置 Druid web 监控 filter 过滤器


//配置 Druid 监控 之 web 监控的 filter
//WebStatFilter：用于配置Web和Druid数据源之间的管理关联监控统计
@Bean
public FilterRegistrationBean webStatFilter() {
FilterRegistrationBean bean = new FilterRegistrationBean();
bean.setFilter(new WebStatFilter());

//exclusions：设置哪些请求进行过滤排除掉，从而不进行统计
Map<String, String> initParams = new HashMap<>();
initParams.put("exclusions", "*.js,*.css,/druid/*,/jdbc/*");
bean.setInitParameters(initParams);

//"/*" 表示过滤所有请求
bean.setUrlPatterns(Arrays.asList("/*"));
return bean;
}
平时在工作中，按需求进行配置即可，主要用作监控！
————————————————

版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。

原文链接：https://blog.csdn.net/mingyuli/article/details/123039145

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/738864.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

泛娱乐出海新风口，视频云技术需要怎样的融合创新？

泛娱乐出海新风口，视频云技术需要怎样的融合创新？

泛娱乐的音视频技术随着出海在演进，交互和内容的技术是内核，也在融合。 泛娱乐的音视频技术随着出海在演进，交互和内容的技术是内核，也在融合。 面向出海，虽然娱乐社交这个行业由来已久，但近几年的商业模式发生了巨大变化，比如行业刚兴起时，大家要先把DAU做大之后再…
阅读更多...
米尔瑞米派集聚5种操作系统，兼顾学习开发和项目产品需要的派

米尔瑞米派集聚5种操作系统，兼顾学习开发和项目产品需要的派

米尔电子发布的瑞萨第一款MPU生态板卡-瑞米派（Remi Pi），采用瑞萨RZ/G2L双核A55芯片，接口丰富，全面兼容树莓派的扩展模块。瑞米派支持五种系统，兼顾学习开发和项目产品需要。软件提供五种软件系统分别为：基于Yocto构建的两种系统，一种是支持通用功能的精简型系统，另一种…
阅读更多...
echarts中Label标签与数据项颜色设置为同一种颜色

echarts中Label标签与数据项颜色设置为同一种颜色

echarts5中默认标签颜色不会跟数据项颜色保持一致，而是全都是黑色。想要实现label颜色和它的数据项颜色一致，需要手动继承颜色，设置label{ color: inherit}即可解决label标签颜色与数据项颜色一致。 https://echarts.apache.org/examples/zh/editor.html?c=pie-simple 注意…
阅读更多...
GaussDB AI新特性：gs_index_advise推荐索引

GaussDB AI新特性：gs_index_advise推荐索引

GaussDB的AI新特性，可以把SQL文本嵌套在函数中，数据库会返回一个创建合适索引的列gs_index_advise(text) 描述：针对单条查询语句推荐索引。 参数： SQL语句字符串 返回值类型： record 一、通常的SQL优化会通过参数调优的方式进行调整，例如如下参数set enable_fast_query_s…
阅读更多...
Packing Python to exe（打包Python成EXE文件）

Packing Python to exe（打包Python成EXE文件）

Python文件要执行需要Python环境，如果package成EXE文件则可以随意放在任意主机上去执行。package步骤如下： 1. 安装pythoninstaller （pip install pyinstaller） 2.安装auto-py-to-exe(有UI界面，很方便使用)（pip install auto-py-to-exe） 3.然后直接运行命令auto-py-to-e…
阅读更多...
Sqlalchemy 连接SQL Server 登录失败

Sqlalchemy 连接SQL Server 登录失败

实验系统环境 Windows平台 Sqlalchemy 2.0.23 Python 3.10 SQL Server 2012 aioodbc 0.5.0 问题详情 sqlalchemy.exc.InterfaceError: (pyodbc.InterfaceError) (28000, [28000] [Microsoft][ODBC Driver 17 for SQL Server][SQL Server]登录失败。该登录名来自不受信任的域，不…
阅读更多...
电脑使用什么远程控制软件？推荐使用安全软件ToDesk

电脑使用什么远程控制软件？推荐使用安全软件ToDesk

当你面临紧急工作需求，但却和办公电脑相隔千里时，远程控制电脑就派上了用场！ 初次使用远程控制软件的人，可能会担心使用时会不会存在信息被盗取，使用过后会不会发生被陌生人悄悄远控的情况 小社长向大家安利一个超好用的远程控制软件ToDesk！电脑远程控制高清不卡顿，传输…
阅读更多...
便宜SSL证书申请Lets Encrypt泛域名SSL证书

便宜SSL证书申请Lets Encrypt泛域名SSL证书

随着互联网的飞速发展，网络安全问题愈发凸显其重要性。而HTTPS协议作为保障网站数据传输安全的重要手段，已经得到了广泛的应用。 申请Lets Encrypt便宜泛域名SSL证书步骤1. 登录来此加密网站，输入域名，可以勾选泛域名和包含根域。2. 选择加密方式，一般选择默认就可以了，也…
阅读更多...
ToDesk云电脑实测！轻松应对游戏电竞、AIGC创作、设计建模等场景

ToDesk云电脑实测！轻松应对游戏电竞、AIGC创作、设计建模等场景

万物智联时代，现代社会对数字计算的需求呈指数级增长。当算力成为推动技术创新和应用发展的重要引擎，云电脑产业正在悄然占据国内算力应用的市场，成为新时代的数字经济发展方向。1云电脑，顾名思义，是一台随时运行在云上的“电脑”，操作系统、存储、运算都能在云端上进行，…
阅读更多...
ToDesk智能无损画质是什么功能？如何使用1

ToDesk智能无损画质是什么功能？如何使用1

能跨设备跨系统远程控制设备的ToDesk相信大家都有用过，它不仅有流畅的远控体验，而且开发了许多实用的插件功能。 比如能直接从硬盘高速传资料的文件传输功能，官方实测能达到12m/s，还有能远程开关机，太方便远程办公完需要关电脑的打工人了。最近小社长还发现ToDesk远程控制…
阅读更多...
Mingw GCC 编译OpenCV报错: Project files may be invalid

Mingw GCC 编译OpenCV报错: Project files may be invalid

这是一个通用报错弹窗:具体要看下边输出窗口:CMake Error: CMake was unable to find a build program corresponding to "MinGW Makefiles". CMAKE_MAKE_PROGRAM is not set. You probably need to select a different build tool. CMake Error: CMAKE_CXX_COMPIL…
阅读更多...
linux部署Hugegraph

linux部署Hugegraph

HugeGraph是一款易用、高效、通用的开源图数据库系统（Graph Database）。 一、基本概述功能特性：HugeGraph实现了Apache TinkerPop3框架，并完全兼容Gremlin查询语言，具备完善的工具链组件，助力用户轻松构建基于图数据库之上的应用和产品。它支持百亿以上的顶点和边快速导入…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023