1.原理实现介绍

本质来说使用连接池是为了节省创建、关闭数据库连接的资源消耗，从而提升访问的性能。底层还是JDBC的调用，jdbc访问多主mysql有提供loadbalace的形式：

  1. jdbc:mysql:loadbalance://[host1][:port],[host2][:port][,[host3][:port]]...[/[database]] »
  2. [?propertyName1=propertyValue1[&propertyName2=propertyValue2]...]

通过上面这种JDBC形式，即可访问多主mysql，但是实际成果中，如果不做任何参数设置，检测失效mysql连接时间非常长，从而降低了数据库访问时间，特加上了以下参数作为性能调优：

  1. roundRobinLoadBalance=true&failOverReadOnly=false&tcpRcvBuf=1024000&loadBalanceStrategy=bestResponseTime&loadBalanceBlacklistTimeout=300000&loadBalancePingTimeout=1000&selfDestructOnPingMaxOperations=200&queryTimeoutKillsConnection=true&loadBalanceValidateConnectionOnSwapServer=true&connectTimeout=1000

JDBC参数详解：

参数名 默认值 设置值 含义
roundRobinLoadBalance false true 采用权重轮循均衡算法
failOverReadOnly true false 自动重连成功后,连接不设为为只读
tcpRcvBuf 0 1024000 TCP接收缓冲区增大到1MB
loadBalanceStrategy random bestResponseTime 默认为“random”即随机路由请求，“bestResponseTime”策略负载均衡将请求路由到对上一个事务具有最佳响应时间的主机。
loadBalanceBlacklistTimeout 0 300000 如果某个节点请求时返回SQLException，那么此host将会被添加到黑名单中，在此后的timeout时间内下一次选择时将不会再被选中。
loadBalancePingTimeout 0 1000 负责均衡响应ping的超时时间
selfDestructOnPingMaxOperations 0 200 连接ping不通被关闭时报告阈值
queryTimeoutKillsConnection false true 查询超时关闭连接
loadBalanceValidateConnectionOnSwapServer false true 当在提交/回滚时交换到新的物理连接时，负载平衡连接显式检查连接处于活动状态
connectTimeout 0 1000 连接超时时间

2.项目配置

  • 引入druid相关的maven依赖

    1. <dependency>
    2. <groupId>log4j2</groupId>
    3. <artifactId>log4j2</artifactId>
    4. <version>1.2.17</version>
    5. </dependency>
    6. <!-- 阿里系的Druid依赖包 -->
    7. <dependency>
    8. <groupId>com.alibaba</groupId>
    9. <artifactId>druid</artifactId>
    10. <version>1.0.20</version>
    11. </dependency>

  • 在application.properties/application.yml中添加druid配置文件

    1. spring:
    2. thymeleaf:
    3.   mode: html5
    4.   encoding: utf-8
    5.   suffix: .html
    6.   cache: false
    7.   # 驱动配置信息
    8. datasource:
    9.   type: com.alibaba.druid.pool.DruidDataSource
    10.   url: jdbc:mysql:loadbalance://192.168.1.105:3306,192.168.1.107:3306,ip3:3307/test?roundRobinLoadBalance=true&failOverReadOnly=false&tcpRcvBuf=1024000&loadBalanceStrategy=bestResponseTime&loadBalanceBlacklistTimeout=300000&loadBalancePingTimeout=1000&selfDestructOnPingMaxOperations=200&queryTimeoutKillsConnection=true&loadBalanceValidateConnectionOnSwapServer=true&connectTimeout=1000
    11.   username: root
    12.   password: unew2&2014
    13.   driverClassName: com.mysql.jdbc.Driver
    14.   # 连接池的配置信息
    15.   # 初始化大小，最小，最大
    17.   initialSize: 5
    18.   minIdle: 5
    19.   maxActive: 20
    20.   # 配置获取连接等待超时的时间
    21.   maxWait: 60000
    22.   # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
    23.   timeBetweenEvictionRunsMillis: 60000
    24.   # 配置一个连接在池中最小生存的时间，单位是毫秒
    25.   minEvictableIdleTimeMillis: 300000
    26.   validationQuery: SELECT 1 FROM DUAL
    27.   testWhileIdle: true
    28.   testOnBorrow: false
    29.   testOnReturn: false
    30. # 打开PSCache，并且指定每个连接上PSCache的大小
    31.   poolPreparedStatements: true
    32.   maxPoolPreparedStatementPerConnectionSize: 20
    33. # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
    34.   filters: stat,wall,log4j2
    35. # 通过connectProperties属性来打开mergeSql功能；慢SQL记录
    36. #     connectionProperties: druid.stat.mergeSql: true
    37.   druid.stat.slowSqlMillis: 5000
    38. logging:
    39. config: classpath:log4j2/log4j2.xml

  • 添加druidConfig.java作为配置生效文件,并添加druid监控页面 ```java package com.example.demo.configuration;

import com.alibaba.druid.pool.DruidDataSource; import com.alibaba.druid.support.http.StatViewServlet; import com.alibaba.druid.support.http.WebStatFilter; 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 javax.sql.DataSource; import java.util.Arrays; import java.util.HashMap; import java.util.Map; @Configuration public class DruidConfig {

  1. // 将所有前缀为spring.datasource下的配置项都加载到DataSource中
  2. @ConfigurationProperties(prefix = "spring.datasource")
  3. @Bean
  4. public DataSource druidDataSource() {
  5.     return new DruidDataSource();
  6. }
  8. //配置Druid的监控
  9. //1、配置一个管理后台的Servlet
  10. @Bean
  11. public ServletRegistrationBean statViewServlet(){
  12.     ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
  13.     Map<String,String> initParams = new HashMap<>();
  14.     initParams.put("loginUsername","admin");
  15.     initParams.put("loginPassword","123456");
  16.     initParams.put("allow","");//默认就是允许所有访问
  17.     initParams.put("deny","192.168.15.21");
  18.     bean.setInitParameters(initParams);
  19.     return bean;
  20. }
  22. //2、配置一个web监控的filter
  23. @Bean
  24. public FilterRegistrationBean webStatFilter(){
  25.     FilterRegistrationBean bean = new FilterRegistrationBean();
  26.     bean.setFilter(new WebStatFilter());
  27.     Map<String,String> initParams = new HashMap<>();
  28.     initParams.put("exclusions","*.js,*.css,/druid/*");
  29.     bean.setInitParameters(initParams);
  30.     bean.setUrlPatterns(Arrays.asList("/*"));
  31.     return  bean;
  32. }

}

  1. 此刻mybatis集成druid已经完成了，可以正常使用druid作为数据连接池去连接数据了。<br />访问http://localhost:8080/druid/login.html 可以查看druid监控页面。<br />参考资料：[https://dev.mysql.com/doc/connector-j/5.1/en/connector-j-reference-configuration-properties.html](https://dev.mysql.com/doc/connector-j/5.1/en/connector-j-reference-configuration-properties.html)<br />[https://dev.mysql.com/doc/connector-j/5.1/en/connector-j-usagenotes-j2ee-concepts-managing-load-balanced-connections.html](https://dev.mysql.com/doc/connector-j/5.1/en/connector-j-usagenotes-j2ee-concepts-managing-load-balanced-connections.html)
  3. 以上转自：[https://blog.csdn.net/weixin_30344795/article/details/97160475](https://blog.csdn.net/weixin_30344795/article/details/97160475)<br />已做部分修改适应自己项目。
  6. 下面是自己的<br />![image.png](https://cdn.nlark.com/yuque/0/2021/png/12678011/1616822404750-897a3b67-d87d-4c29-9cad-2a1d96dda9ef.png#align=left&display=inline&height=189&margin=%5Bobject%20Object%5D&name=image.png&originHeight=189&originWidth=295&size=162402&status=done&style=none&width=295)
  8. <a name="9Yat4"></a>
  9. ### 3.使用实例
  11. <a name="8VrFA"></a>
  12. #### 配置文件
  13. ```yaml
  14. spring:
  15.   thymeleaf:
  16.     encoding: utf-8
  17.     suffix: .html
  18.     cache: false
  19.     # 驱动配置信息
  20.   datasource:
  21.     type: com.alibaba.druid.pool.DruidDataSource
  22.     url: jdbc:mysql:loadbalance://192.168.1.105:3306,192.168.1.107:3306/test?roundRobinLoadBalance=true&failOverReadOnly=false&tcpRcvBuf=1024000&loadBalanceStrategy=bestResponseTime&loadBalanceBlacklistTimeout=300000&loadBalancePingTimeout=1000&selfDestructOnPingMaxOperations=200&queryTimeoutKillsConnection=true&loadBalanceValidateConnectionOnSwapServer=true&connectTimeout=1000&characterEncoding=UTF-8
  23.     username: root
  24.     password: 123456
  25.     driverClassName: com.mysql.jdbc.Driver
  26.     # 连接池的配置信息
  27.     # 初始化大小，最小，最大
  29.     initialSize: 5
  30.     minIdle: 5
  31.     maxActive: 20
  32.     # 配置获取连接等待超时的时间
  33.     maxWait: 60000
  34.     # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
  35.     timeBetweenEvictionRunsMillis: 60000
  36.     # 配置一个连接在池中最小生存的时间，单位是毫秒
  37.     minEvictableIdleTimeMillis: 300000
  38.     validationQuery: SELECT 1 FROM DUAL
  39.     testWhileIdle: true
  40.     testOnBorrow: false
  41.     testOnReturn: false
  42. # 打开PSCache，并且指定每个连接上PSCache的大小
  43.     poolPreparedStatements: true
  44.     maxPoolPreparedStatementPerConnectionSize: 20
  45. # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
  46.     filters: stat,wall,log4j2
  47. # 通过connectProperties属性来打开mergeSql功能；慢SQL记录
  48. #     connectionProperties: druid.stat.mergeSql: true
  49.     druid.stat.slowSqlMillis: 5000
  50. mybatis:
  51.   mapper-locations: classpath:mapper/*.xml  #注意：一定要对应mapper映射xml文件的所在路径
  52.   configuration:
  53.     #org.apache.ibatis.logging.stdout.StdOutImpl 控制台打印sql语句方便调试sql语句执行错误
  54.     #org.apache.ibatis.logging.log4j2.Log4j2Impl:这个不在控制台打印查询结果,但是在log4j中打印
  55.     log-impl: org.apache.ibatis.logging.log4j2.Log4j2Impl
  56.     mapUnderscoreToCamelCase: true # 开启驼峰命名转换法
  58. logging:
  59.   config: classpath:log4j2/log4j2.xml
  60.   level:
  61.     com.example.demo.model: DEBUG