背景
偶然下和朋友聊到了mysql多节点集群架场景,对应我们各系代码如何去使用它,牵扯到mysql的驱动包中已经支持的策略。发现这块的概念有些模糊,索性就梳理了一番留着后用。重点是:replication\loadbalance,以mysql-connector-java:5.1.38为例展开。
官方java驱动文档:Multi-Host Connections
java connector
Mysql的multi-connection策略,官方叫server failover。replication和loadbalance协议都是建立在failover基础上演变而来对应mysql不同的部署架构:Cluster架构和Replication架构,这两个不再展开。
jdbc:mysql://[primary host][:port],[secondary host 1][:port][,[secondary host 2][:port]]...[/[database]]»
[?propertyName1=propertyValue1[&propertyName2=propertyValue2]...]
官方URL格式:primary host代表主库首选连接,secondary host代表从库,依次排列尝试连接同时支持很多配置属性(详细去看文档):
- failOverReadOnly
- secondsBeforeRetryMaster
- queriesBeforeRetryMaster
- retriesAllDown
- autoReconnect
- autoReconnectForPools
在驱动包中类NonRegisteringDriver.java定义了mysql支持的多种连接协议,可以看出有四种方式。mxj是指mysql会根据不同的系统平台切换不同的mysqld binary执行,支持macos、linux、window、Solaris等等,replicaiton和loadbalance后面会介绍。
private static final String REPLICATION_URL_PREFIX = "jdbc:mysql:replication://";
private static final String URL_PREFIX = "jdbc:mysql://";
private static final String MXJ_URL_PREFIX = "jdbc:mysql:mxj://";
public static final String LOADBALANCE_URL_PREFIX = "jdbc:mysql:loadbalance://";
我们根据Mysql支持的驱动类型也可以看出一共三个实现类,常规使用的com.mysql.jdbc.Driver,主从库模式下采用com.mysql.jdbc.ReplicationDriver,还有种为兼容 MM.MySQL实现的org.djt.mm.mysql.Driver。
触发的场景条件
当以下三个场景中会出发loadbalance策略执行:
- 一个事务提交或者回滚时;
- 以08开头的sql state 通信异常发生时;
- 自定义模式匹配条件时;一个SQLException匹配到mysql支持的loadBalanceSQLStateFailover,loadBalanceSQLExceptionSubclassFailover ,loadBalanceExceptionChecker 三个方案自定义的conditions时;
协议:replication
jdbc.diver= com.mysql.jdbc.ReplicationDriver
jdbc.url= jdbc:mysql:replication://127.0.0.1:3306,11.12.3.44:3306/mydb?autoReconnect=false
具体格式类似failover,比较大的变化是第一个host为master库是write/read模式,后面都是slave库是read模式,也是支持参数进行配置官网有详细介绍。