spring boot、mybatis集成druid數據庫連接池，實現mysql cluster HA負載均衡訪問

1.原理實現介紹

本質來說使用連接池是為了節省創建、關閉數據庫連接的資源消耗，從而提升訪問的性能。底層還是JDBC的調用，jdbc訪問多主mysql有提供loadbalace的形式：

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

通過上面這種JDBC形式，即可訪問多主mysql，但是實際成果中，如果不做任何參數設置，檢測失效mysql連接時間非常長，從而降低了數據庫訪問時間，特加上了以下參數作為性能調優：

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依賴

  <dependency>
     <groupId>log4j</groupId>
     <artifactId>log4j</artifactId>
     <version>1.2.17</version>
   </dependency>
  
   <!-- 阿里系的Druid依賴包 -->
   <dependency>
     <groupId>com.alibaba</groupId>
     <artifactId>druid</artifactId>
     <version>1.0.20</version>
   </dependency>
  

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

# 驅動配置信息
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.url = jdbc:mysql:loadbalance://ip1:3307,ip2:3307,ip3:3307/test?roundRobinLoadBalance=true&failOverReadOnly=false&tcpRcvBuf=1024000&loadBalanceStrategy=bestResponseTime&loadBalanceBlacklistTimeout=300000&loadBalancePingTimeout=1000&selfDestructOnPingMaxOperations=200&queryTimeoutKillsConnection=true&loadBalanceValidateConnectionOnSwapServer=true&connectTimeout=1000
spring.datasource.username = root
spring.datasource.password = unew2&2014
spring.datasource.driverClassName = com.mysql.jdbc.Driver
# 連接池的配置信息
# 初始化大小，最小，最大
spring.datasource.initialSize=5
spring.datasource.minIdle=5
spring.datasource.maxActive=20
# 配置獲取連接等待超時的時間
spring.datasource.maxWait=60000
# 配置間隔多久才進行一次檢測，檢測需要關閉的空閑連接，單位是毫秒
spring.datasource.timeBetweenEvictionRunsMillis=60000
# 配置一個連接在池中最小生存的時間，單位是毫秒
spring.datasource.minEvictableIdleTimeMillis=300000
spring.datasource.validationQuery=SELECT 1 FROM DUAL
spring.datasource.testWhileIdle=true
spring.datasource.testOnBorrow=false
spring.datasource.testOnReturn=false
# 打開PSCache，並且指定每個連接上PSCache的大小
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
# 配置監控統計攔截的filters，去掉后監控界面sql無法統計，'wall'用於防火牆
spring.datasource.filters=stat,wall,log4j
# 通過connectProperties屬性來打開mergeSql功能；慢SQL記錄
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000

• 添加druidConfig.java作為配置生效文件,並添加druid監控頁面

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 {

    // 將所有前綴為spring.datasource下的配置項都加載到DataSource中
    @ConfigurationProperties(prefix = "spring.datasource")
    @Bean
    public DataSource druidDataSource() {
        return new DruidDataSource();
    }

    //配置Druid的監控
    //1、配置一個管理后台的Servlet
    @Bean
    public ServletRegistrationBean statViewServlet(){
        ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
        Map<String,String> initParams = new HashMap<>();
        initParams.put("loginUsername","admin");
        initParams.put("loginPassword","123456");
        initParams.put("allow","");//默認就是允許所有訪問
        initParams.put("deny","192.168.15.21");
        bean.setInitParameters(initParams);
        return bean;
    }

    //2、配置一個web監控的filter
    @Bean
    public FilterRegistrationBean webStatFilter(){
        FilterRegistrationBean bean = new FilterRegistrationBean();
        bean.setFilter(new WebStatFilter());
        Map<String,String> initParams = new HashMap<>();
        initParams.put("exclusions","*.js,*.css,/druid/*");
        bean.setInitParameters(initParams);
        bean.setUrlPatterns(Arrays.asList("/*"));
        return  bean;
    }
}

此刻mybatis集成druid已經完成了，可以正常使用druid作為數據連接池去連接數據了。
訪問http://localhost:8080/druid/login.html 可以查看druid監控頁面。

參考資料：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-usagenotes-j2ee-concepts-managing-load-balanced-connections.html