首页 > 其他分享 >Springboot自定义数据源DruidDataSource

Springboot自定义数据源DruidDataSource

时间：2024-07-05 17:30:37浏览次数：10  
标签：自定义 true 数据源 druid DruidDataSource com log4j

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

标签：自定义,true,数据源,druid,DruidDataSource,com,log4j
From： https://www.cnblogs.com/fswhq/p/18061062

相关文章

  • SpringDataJPA配置多套数据源
    场景在使用SpringDataJPA的服务中,需要同时连接自己的数据库进行增删改查,也需要连接一个外部提供的数据库查询数据.因此需要维护两套数据库配置.实现思路首先使用JPA一般都需要domain实体和repository.规划为:主数据库的实体都放到统一包domain下,repository放reposi......
  • WPF自定义控件与样式-自定义按钮（Button）
    一、前言程序界面上的按钮多种多样，常用的就这几种：普通按钮、图标按钮、文字按钮、图片文字混合按钮。本文章记录了不同样式类型的按钮实现方法。二、固定样式的按钮固定样式的按钮一般在临时使用时或程序的样式比较固定时才会使用，按钮整体样式不需要做大的改动。2.1普通按钮-......
  • Laravel 宏指令（Macro）动态添加自定义方法到Laravel的核心组件中
    Laravel宏指令（Macro）在Laravel中，宏指令（Macro）是一种灵活的方式，允许您动态添加自定义方法到Laravel的核心组件中，如模型、查询构建器、集合等，以便在不改变核心代码的情况下扩展框架的功能。通过宏指令，您可以向Laravel内置的类添加自定义方法，实现更高级的功能和逻辑。福利彩......
  • ubuntu 自定义开机画面
    1. 修改UEFI固件图片2. 修改GRUB背景图片3. 修改Plymouth启动画面 1. 固件和启动过程UEFI固件加载图片：在系统启动时，UEFI固件首先加载，并显示制造商的Logo（如“LEGION”），这在启动过程中称为“splashscreen”。这张图片是嵌入在UEFI固件中的，用户通常无法直接修改或访问......
  • vue2和vue3自定义指令实现只读模式，禁止用户编辑
    解决代码表单组件大量disable的麻烦，实现只读。只需要在需要的地方加上v-read-only即可达到只读效果，快捷方便。实现思路父元素下添加一个遮罩层元素遮罩层元素的显示隐藏由参数决定要想简单快捷的实现，最好用的就是写一个遮罩层，通过遮罩来隔绝用户的操作。原始代码如下：<temp......
  • 微信小程序-自定义组件数据监听器observers
    一.监测自定义组件data值定义data值，在.js文件里面定义data值data:{num:10,count:100,obj:{name:'tom',age:10},arr:[1,2,3]}只有在data值进行改变后才会触发到数据监听的回调函数，如果数据没有改变回调函数不会被触发ob......
  • python logging 自定义备份的日志文件命名
    importtimeimportloggingfromlogging.handlersimportTimedRotatingFileHandlerdeflog_file_namer(log_file_name):log_file_name_split=log_file_name.split('.')log_suffix=log_file_name_split.pop(1)log_file_name_split.append(l......
  • python教程：自定义函数
    1.多态我们可以看到，Python不用考虑输入的数据类型，而是将其交给具体的代码去判断执行，同样的一个函数（比如这边的相加函数my_sum()），可以同时应用在整型、列表、字符串等等的操作中。在编程语言中，我们把这种行为称为多态。这也是Python和其他语言，比如Java、C等很大的一个不同点......
  • uniapp 开发微信小程序自定义与胶囊平行的导航栏
    1、page.json中使用custom自定义导航栏{ "path":"pages/partners/index", "style":{ "navigationBarTitleText":"", "navigationStyle":"custom"//自定义导航栏样式 } },2、vue文件：<template> ......
  • 在Linux中，自定义解析域名的时候，可以编辑哪个⽂件？是否可以⼀个ip对应多个域名？是否⼀个
    在Linux系统中，如果你想要自定义域名解析，通常有以下几种方法：编辑/etc/hosts文件：hosts文件是一个本地DNS解析文件，它允许你将域名映射到IP地址。你可以编辑这个文件来自定义域名解析。例如：192.168.1.10example.comwww.example.com在这个例子中，192.168.1.10是IP地址，exampl......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99