zoukankan      html  css  js  c++  java
  • spring boot + mybatis + druid

    因为在用到spring boot + mybatis的项目时候,经常发生访问接口卡,服务器项目用了几天就很卡的甚至不能访问的情况,而我们的项目和数据库都是好了,考虑到可能是数据库连接的问题,所以我打算引入其他的数据池,引入数据池的时候找来找去,比较了当前两个最火的数据池,druid和HikariCP,比来比去选了阿里的druid,虽然spring boot默认不支持druid,而是支持HikariCP,而且HikariCP的性能更好,但是阿里功能多,界面友好方便,性价比更高

    实际配置:

    1.首先现在下载一个最新的spring boot项目,我这里用的是spring boot 1.5.4,然后在pom.xml中加入依赖

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

    <dependency>
      <groupId>org.mybatis.spring.boot</groupId>
      <artifactId>mybatis-spring-boot-starter</artifactId>
      <version>1.3.0</version>
    </dependency>

    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>6.0.6</version>
    </dependency>

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
      <version>1.5.4.RELEASE</version>
    </dependency>

    2.在application.yml中加入mybatis的配置,mysql配置

    # mybatis配置
    mybatis:
      mapper-locations: classpath*:/mapper/*Mapper.xml

    #mysql配置

    spring:
      datasource:
        url: jdbc:mysql://localhost/test?useSSL=false&serverTimezone=UTC
        username: root
        password:
        driver-class-name: com.mysql.cj.jdbc.Driver

    这样mybatis和mysql就配置好了

    3.然后我们引入阿里的druid,这个东西不但可以配置还有监控界面,阿里还是挺良心的

    spring:
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        # 下面为连接池的补充设置,应用到上面所有数据源中
        # 初始化大小,最小,最大
        initialSize: 1
        minIdle: 3
        maxActive: 20
        # 配置获取连接等待超时的时间
        maxWait: 60000
        # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
        timeBetweenEvictionRunsMillis: 60000
        # 配置一个连接在池中最小生存的时间,单位是毫秒
        minEvictableIdleTimeMillis: 30000
        validationQuery: select 'x'
        testWhileIdle: true
        testOnBorrow: false
        testOnReturn: false
        # 打开PSCache,并且指定每个连接上PSCache的大小
        poolPreparedStatements: true
        maxPoolPreparedStatementPerConnectionSize: 20
        # 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙
        filters: stat,wall,slf4j
        # 通过connectProperties属性来打开mergeSql功能;慢SQL记录
        connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
        # 合并多个DruidDataSource的监控数据
        useGlobalDataSourceStat: true

    因为spring boot默认不支持druid,而且我们要配置阿里的监控界面,所以我们需要写一个配置文件

    package com.xiabin.TestDruid.druid;

    import com.alibaba.druid.pool.DruidDataSource;
    import com.alibaba.druid.support.http.StatViewServlet;
    import com.alibaba.druid.support.http.WebStatFilter;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    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;
    import org.springframework.context.annotation.Primary;

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

    /**
    * Created by xiabin on 2017/6/18.
    */
    @Configuration
    public class DruidConfiguration {

      private static final Logger logger = LoggerFactory.getLogger(DruidConfiguration.class);

      private static final String DB_PREFIX = "spring.datasource";

      @Bean
      public ServletRegistrationBean druidServlet() {
        logger.info("init Druid Servlet Configuration ");
        ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
        // IP白名单
        servletRegistrationBean.addInitParameter("allow", "192.168.2.25,127.0.0.1");
        // IP黑名单(共同存在时,deny优先于allow)
        servletRegistrationBean.addInitParameter("deny", "192.168.1.100");
        //控制台管理用户
        servletRegistrationBean.addInitParameter("loginUsername", "admin");
        servletRegistrationBean.addInitParameter("loginPassword", "9527");
        //是否能够重置数据 禁用HTML页面上的“Reset All”功能
        servletRegistrationBean.addInitParameter("resetEnable", "false");
        return servletRegistrationBean;
    }

      @Bean
      public FilterRegistrationBean filterRegistrationBean() {
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());
        filterRegistrationBean.addUrlPatterns("/*");
        filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
        return filterRegistrationBean;
      }

    //解决 spring.datasource.filters=stat,wall,log4j 无法正常注册进去
    @ConfigurationProperties(prefix = DB_PREFIX)
    class IDataSourceProperties {
      private String url;
      private String username;
      private String password;
      private String driverClassName;
      private int initialSize;
      private int minIdle;
      private int maxActive;
      private int maxWait;
      private int timeBetweenEvictionRunsMillis;
      private int minEvictableIdleTimeMillis;
      private String validationQuery;
      private boolean testWhileIdle;
      private boolean testOnBorrow;
      private boolean testOnReturn;
      private boolean poolPreparedStatements;
      private int maxPoolPreparedStatementPerConnectionSize;
      private String filters;
      private String connectionProperties;

      @Bean //声明其为Bean实例
      @Primary //在同样的DataSource中,首先使用被标注的DataSource
      public DataSource dataSource() {
        DruidDataSource datasource = new DruidDataSource();
        datasource.setUrl(url);
        datasource.setUsername(username);
        datasource.setPassword(password);
        datasource.setDriverClassName(driverClassName);

        //configuration
        datasource.setInitialSize(initialSize);
        datasource.setMinIdle(minIdle);
        datasource.setMaxActive(maxActive);
        datasource.setMaxWait(maxWait);
        datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
        datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
        datasource.setValidationQuery(validationQuery);
        datasource.setTestWhileIdle(testWhileIdle);
        datasource.setTestOnBorrow(testOnBorrow);
        datasource.setTestOnReturn(testOnReturn);
        datasource.setPoolPreparedStatements(poolPreparedStatements);
        datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
        try {
          datasource.setFilters(filters);
        } catch (SQLException e) {
        System.err.println("druid configuration initialization filter: " + e);
        }
        datasource.setConnectionProperties(connectionProperties);
        return datasource;
    }

      public String getUrl() {
        return url;
      }

      public void setUrl(String url) {
        this.url = url;
      }

      public String getUsername() {
        return username;
      }

      public void setUsername(String username) {
        this.username = username;
      }

      public String getPassword() {
        return password;
      }

      public void setPassword(String password) {
        this.password = password;
      }

      public String getDriverClassName() {
        return driverClassName;
      }

      public void setDriverClassName(String driverClassName) {
        this.driverClassName = driverClassName;
      }

      public int getInitialSize() {
        return initialSize;
      }

      public void setInitialSize(int initialSize) {
        this.initialSize = initialSize;
      }

      public int getMinIdle() {
        return minIdle;
      }

      public void setMinIdle(int minIdle) {
        this.minIdle = minIdle;
      }

      public int getMaxActive() {
        return maxActive;
      }

      public void setMaxActive(int maxActive) {
        this.maxActive = maxActive;
      }

      public int getMaxWait() {
        return maxWait;
      }

      public void setMaxWait(int maxWait) {
        this.maxWait = maxWait;
      }

      public int getTimeBetweenEvictionRunsMillis() {
        return timeBetweenEvictionRunsMillis;
      }

      public void setTimeBetweenEvictionRunsMillis(int timeBetweenEvictionRunsMillis) {
        this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;
      }

      public int getMinEvictableIdleTimeMillis() {
        return minEvictableIdleTimeMillis;
      }

      public void setMinEvictableIdleTimeMillis(int minEvictableIdleTimeMillis) {
        this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;
      }

      public String getValidationQuery() {
        return validationQuery;
      }

      public void setValidationQuery(String validationQuery) {
        this.validationQuery = validationQuery;
      }

      public boolean isTestWhileIdle() {
        return testWhileIdle;
      }

      public void setTestWhileIdle(boolean testWhileIdle) {
        this.testWhileIdle = testWhileIdle;
      }

      public boolean isTestOnBorrow() {
        return testOnBorrow;
      }

      public void setTestOnBorrow(boolean testOnBorrow) {
        this.testOnBorrow = testOnBorrow;
      }

      public boolean isTestOnReturn() {
        return testOnReturn;
      }

      public void setTestOnReturn(boolean testOnReturn) {
        this.testOnReturn = testOnReturn;
      }

      public boolean isPoolPreparedStatements() {
        return poolPreparedStatements;
      }

      public void setPoolPreparedStatements(boolean poolPreparedStatements) {
        this.poolPreparedStatements = poolPreparedStatements;
      }

      public int getMaxPoolPreparedStatementPerConnectionSize() {
        return maxPoolPreparedStatementPerConnectionSize;
      }

      public void setMaxPoolPreparedStatementPerConnectionSize(int maxPoolPreparedStatementPerConnectionSize) {
        this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize;
      }

      public String getFilters() {
        return filters;
      }

      public void setFilters(String filters) {
        this.filters = filters;
      }

      public String getConnectionProperties() {
        return connectionProperties;
      }

      public void setConnectionProperties(String connectionProperties) {
        this.connectionProperties = connectionProperties;
      }
      }

    }

    4.然后我们启动项目,访问localhost:8080/druid,输入admin ,9527(配置文件里面写的用户名和密码),就可以看得到我们的监控界面了

    github源码地址:https://github.com/waterlufei/spring-boot,下面的TestDruid项目

  • 相关阅读:
    Java 给Word指定字符串添加批注
    Java 打印Word文档
    Java 在PDF中添加页面跳转按钮
    C# 添加、修改、删除Excel图表数据标签
    C# 添加、读取、删除Excel文档属性
    Java 操作Word表格——创建嵌套表格、添加/复制表格行或列、设置表格是否禁止跨页断行
    【Luogu5348】密码解锁(莫比乌斯反演,数论)
    AtCoder Grand Contest 015
    AtCoder Grand Contest 014
    Codeforces Round #556 (Div. 1)
  • 原文地址:https://www.cnblogs.com/waterlufei/p/7056420.html
Copyright © 2011-2022 走看看