整合Druid

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/

引入Druid依赖

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

再application.yaml配置文件中,将数据源改为Druid

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: root
    url: jdbc:mysql://localhost:3306/mybatis?useSSL=true&useUnicode=true&characterEncoding=utf-8
    //将数据源改为Druid
    type: com.alibaba.druid.pool.DruidDataSource

测试(终端输出)

class com.alibaba.druid.pool.DruidDataSource

application.yaml配置文件配置

 #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

这里需要导入log4j依赖

<dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.12</version>
        </dependency>

我们配置了配置文件中的参数,但还没有为DruidDateSource绑定全局配置文件,所有我们接下来就将DruidDateSource与配置文件连接起来

在src文件下新建一个config文件夹,新建一个类DruidConfig

@Configuration
public class DruidConfig {
    /*将数据源的参数与配置文件的参数绑定起来*/
    @ConfigurationProperties(prefix = "spring.datasource")
    @Bean
    public DataSource duridDateSource(){
        return new DruidDataSource();
    }

我们还可以注册Servlet,虽然SpringBoot把Servlet集成了,但在SpringBoot我们还是可以去注册Servlet的

接下来我们注册一个Servlet,是数据库监听后台的界面,我们需要简单的配置一个URl,和一些必须的配置(用户名,密码,允许访问的权限),就可以了

@Bean
    public ServletRegistrationBean ServletBean(){


        ServletRegistrationBean<StatViewServlet> ServletBean = new ServletRegistrationBean<>(new StatViewServlet(), "/Druid/*");

        Map<String, String> initParameters = new HashMap<>();
        initParameters.put("loginUsername","admin");//后台管理界面的登入账号(这个key是固定的)
        initParameters.put("loginPassword","123");//后台管理界面的登入密码(这个key是固定的)

        //后台允许谁可以访问
        initParameters.put("allow","");//值为空的时候,全部计算机可以访问
        //initParams.put("allow", "localhost"):表示只有本机可以访问

        //设置初始化参数
        ServletBean.setInitParameters(initParameters);
        return ServletBean;
    }

当然我们也可以注册Filter(过滤器)

    @Bean
    public FilterRegistrationBean WebStatFilter(){
        FilterRegistrationBean filterBean = new FilterRegistrationBean();
        filterBean.setFilter(new WebStatFilter());
        Map<String, String> initParameters = new HashMap<>();
        //exclusions:设置那些请求经行过滤,而又不进行统计
        initParameters.put("exclusions","*.js,*.css,/druid/*,/jdbc/*");
        filterBean.setInitParameters(initParameters);
        //"/*"表示过滤所有请求
        filterBean.setUrlPatterns(Arrays.asList("/*"));
        return filterBean;
    }

简而言之,durid数据源,处理sql语句,速度快,并且还有监控功能

上一篇:Elasticsearch(3)--- Docker容器中运行ES、Kibana、Cerebro


下一篇:SpringBoot+kafka+ES实现信息数据同步管理(一)