springboot-整合Druid数据源


继续使用这篇博客中的项目:

1 配置Druid数据源

1.1 在pom.xml中引入Druid数据源依赖



    com.alibaba
    druid
    1.2.8

1.2 切换数据源

将springboot默认使用的数据源: com.zaxxer.hikari.HikariDataSource ,通过配置文件中 spring.datasource.type 重新指定其它数据源,这里我们指定Druid

application.yaml

spring:
  datasource:
    username: root
    password: 123456
    #假如时区报错了,就增加一个时区配置就OK了 serverTimezone=UTC
    url: jdbc:mysql://localhost:3306/mybatis?useSSL=false&useUnicode=true&characterEncoding=utf-8
    driver-class-name: com.mysql.cj.jdbc.Driver
    #切换数据源
    type: com.alibaba.druid.pool.DruidDataSource

1.3 编写测试文件

src/test/java/com/lv/Springboot04DataApplicationTests.java

package com.lv;

import com.alibaba.druid.pool.DruidDataSource;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;

@SpringBootTest
class Springboot04DataApplicationTests {

    @Autowired
    DataSource dataSource;

    @Test
    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();
    }
}

1.4 运行测试类,查看控制台

确认数据切换成功,接下来对Druid数据源进行初始化设置

1.5 Druid数据源初始化配置

application.yaml

spring:
  datasource:
    username: root
    password: 123456
    #假如时区报错了,就增加一个时区配置就OK了 serverTimezone=UTC
    url: jdbc:mysql://localhost:3306/mybatis?useSSL=false&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

1.6 在pom.xml导入log4j 的依赖



    log4j
    log4j
    1.2.17

1.7 编写log4j的配置文件

在resources下新建一个log4j.properties文件

log4j.properties

log4j.rootLogger=DEBUG, stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

1.8 编写DruidConfig

创建一个config包,并编写一个DruidConfig.java.目的是为 DruidDataSource 绑定全局配置文件中的参数,再添加到容器中,而不再使用spingboot的自动生成了.我们需要自己添加 DruidDataSource 组件到容器中,并绑定属性.

DruidConfig.java

package com.lv.config;

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 {
    @ConfigurationProperties(prefix = "spring.datasource")
    @Bean
    public DataSource druidDataSource(){
        return new DruidDataSource();
    }
}

1.9 运行测试类,查看控制台

配置发生了改变,说明我们的初始化配置生效了

2 配置 Druid 数据源监控

Druid数据源的强大之处就是它的监控功能并且它还提供了一个web界面方便用户查看,类似安装路由器时提供了一个默认的 web 页面

2.1 设置Druid的后台管理页面

在DruidConfig.java中添加如下方法

DruidConfig.java

//后台监控: web.xml,ServletRegistrationBean
//因为SpringBoot 内置了servlet容器,所以没有web.xml ,替代方法:ServletRegistrationBean
@Bean
public ServletRegistrationBean StatViewServlet(){
    ServletRegistrationBean bean = new ServletRegistrationBean<>(new StatViewServlet(),"/druid/*");
    //后台需要有人登录,账号密码配置
    HashMap initParameters = new HashMap<>();
    //增加配置
    initParameters.put("loginUsername","admin");//登录的账号Key 是固定的 loginUsername
    initParameters.put("loginPassword","123456");//登录的密码Key 是固定的 loginPassword
    //允许谁可以访问
    initParameters.put("allow","");
    //禁止谁访问 initParameters.put("deny","192.168.11.123");
    bean.setInitParameters(initParameters);//设置初始化参数
    return bean;
}

2.2 登录Druid后台管理页面

启动程序,访问http://localhost:8080/druid

页面会自动跳转到登录页面,输入之前设置好的账号密码,点击登录

成功进入监控后台,后台中有很多功能,就不演示了

2.3 配置监控过滤

在DruidConfig.java中添加如下方法即可

DruidConfig.java

//配置Druid监控web监控的filter,在工作中按需求进行配置即可,过滤掉不需要监控的数据
//WebStatFilter:用于配置Web和Druid数据源之间的管理关联监控统
@Bean
public FilterRegistrationBean webStatFilter(){
    FilterRegistrationBean bean = new FilterRegistrationBean();
    bean.setFilter(new WebStatFilter());
    HashMap initParameters = new HashMap<>();
    //exclusions:设置哪些请求进行过滤排除掉,从而不进行统计
    initParameters.put("exclusions",".js,*.css,/druid/*");
    bean.setInitParameters(initParameters);
    //"/*" 表示过滤所有请求
    bean.setUrlPatterns(Collections.singletonList("/*"));
    return bean;
}

相关