hanbo-starter是一个springbootStarter，适用于mysql5.7 的群组复制（单主模式）
基于connector/J的mysqlx、replication等协议实现的客户端自动选主以及负载均衡
因为没有发布到中央库，需要手动打包上传到自己的私服
cd proDir && mvn clean install
<dependency>
<groupId>com.lmx</groupId>
<artifactId>hanbo-starter</artifactId>
<version>0.0.2-snapshot</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.11</version>
</dependency>
application.properties
#单主模式配置
cj.replicationUrl=jdbc:mysql:replication://address=(type=master)(host=192.168.32.128)(port=24802),address=(type=slave)(host=192.168.32.128)(port=24801),address=(type=slave)(host=192.168.32.128)(port=24803)/test?useSSL=false&autoReconnect=true
cj.userName=root
cj.passWord=root
cj.driverClass=com.mysql.cj.jdbc.Driver
cj.maxWait=10000
cj.maxConn=64
#故障转移配置,优先级按照出现在list的顺序
cj.failoverUrl=jdbc:mysql://192.168.32.128:24801,192.168.32.128:24802,192.168.32.128:24803/test?characterEncoding=UTF-8&useSSL=false
结合事务注解@Transactional来享受上述特性
/**
* readonly=true，走从库连接 ，如果强行执行写操作会抛出异常
*/
@Transactional(readOnly = true)
@Cacheable(cacheManager = "redisCacheManager", cacheNames = "app:user", key = "#id")
public User getUser(long id) {
return userRep.findOne(id);
}
/**
* readonly=false，走主库连接
* @param id
* @return
*/
@Transactional
@CacheEvict(cacheManager = "redisCacheManager", cacheNames = "app:user", key = "#id")
public User getTXUser(long id) {
User user = userRep.findOne(id);
user.setC2(UUID.randomUUID().toString().substring(0, 10));
userRep.save(user);
User user1 = new User();
user1.setC2(UUID.randomUUID().toString().substring(0, 10));
user1.setC3(Math.random() * 10000 "");
user1.setC4(new Date());
userRep.save(user1);
return userRep.findOne(id);
});
}