springbootmysql主从复制_SpringBoot+MyBatis+MySQL读写
分离
1. 引⾔
读写分离要做的事情就是对于⼀条SQL该选择哪个数据库去执⾏，⾄于谁来做选择数据库这件事⼉，⽆⾮两个，要么中间件帮我们做，要么程序⾃⼰做。因此，⼀般来讲，读写分离有两种实现⽅式。第⼀种是依靠中间件(⽐如：MyCat)，也就是说应⽤程序连接到中间件，中间件帮我们做SQL分离；第⼆种是应⽤程序⾃⼰去做分离。这⾥我们选择程序⾃⼰来做，主要是利⽤Spring提供的路由数据源，以及AOP
然⽽，应⽤程序层⾯去做读写分离最⼤的弱点(不⾜之处)在于⽆法动态增加数据库节点，因为数据源配置都是写在配置中的，新增数据库意味着新加⼀个数据源，必然改配置，并重启应⽤。当然，好处就是相对简单。
2. AbstractRoutingDataSource
基于特定的查key路由到特定的数据源。它内部维护了⼀组⽬标数据源，并且做了路由key与⽬标数据源之间的映射，提供基于key查数据源的⽅法。
3. 实践
3.1. maven依赖
4.0.0
ample
cjs-datasource-demo
0.0.1-SNAPSHOT
jar
cjs-datasource-demo
org.springframework.boot
spring-boot-starter-parent
2.0.5.RELEASE
UTF-8
UTF-8
1.8
org.springframework.boot
spring-boot-starter-aop
org.springframework.boot
spring-boot-starter-jdbc
org.springframework.boot
spring-boot-starter-web
mybatis-spring-boot-starter
1.3.2
org.apachemons
commons-lang3
3.8
mysql
mysql-connector-java
runtime
org.springframework.boot
spring-boot-starter-test
test
org.springframework.boot
spring-boot-maven-plugin
3.2. 数据源配置
spring:
datasource:
master:
jdbc-url: jdbc:mysql://192.168.102.31:3306/test
username: root
password: 123456
driver-class-name: sql.jdbc.Driver
slave1:
jdbc-url: jdbc:mysql://192.168.102.56:3306/test
username: pig # 只读账户
password: 123456
driver-class-name: sql.jdbc.Driver
slave2:
jdbc-url: jdbc:mysql://192.168.102.36:3306/test
username: pig # 只读账户
password: 123456
driver-class-name: sql.jdbc.Driver
多数据源配置
fig;ample.bean.MyRoutingDataSource;ums.DBTypeEnum 关于数据源配置，参考SpringBoot官⽅⽂档第79章《Data Access》
* 79. Data Access
* 79.1 Configure a Custom DataSource
* 79.2 Configure Two DataSources*/@Configurationpublic classDataSourceConfig {
@Bean
@ConfigurationProperties("spring.datasource.master")publicDataSource masterDataSource()
{ate().build();
}
@Bean
@ConfigurationProperties("spring.datasource.slave1")publicDataSource slave1DataSource()
{ate().build();
}
@Bean
@ConfigurationProperties("spring.datasource.slave2")publicDataSource slave2DataSource()
{ate().build();
}
@Beanpublic DataSource myRoutingDataSource(@Qualifier("masterDataSource") DataSource masterDataSource,
@Qualifier("slave1DataSource") DataSource slave1DataSource,
@Qualifier("slave2DataSource") DataSource slave2DataSource) {
Map targetDataSources = new HashMap<>();
targetDataSources.put(DBTypeEnum.MASTER, masterDataSource);
targetDataSources.put(DBTypeEnum.SLAVE1, slave1DataSource);
targetDataSources.put(DBTypeEnum.SLAVE2, slave2DataSource);
MyRoutingDataSource myRoutingDataSource= newMyRoutingDataSource();
myRoutingDataSource.setDefaultTargetDataSource(masterDataSource);
myRoutingDataSource.setTargetDataSources(targetDataSources);returnmyRoutingDataSource;
}
}
这⾥，我们配置了4个数据源，1个master，2两个slave，1个路由数据源。前3个数据源都是为了⽣成第4个数据源，⽽且后续我们只⽤这
最后⼀个路由数据源。
MyBatis配置
fig;importorg.apache.ibatis.session.batis.spring.SqlSessionFactor
@EnableTransactionManagement
@Configurationpublic classMyBatisConfig {
@Resource(name= "myRoutingDataSource")privateDataSource myRoutingDataSource;
@Beanpublic SqlSessionFactory sqlSessionFactory() throwsException {
SqlSessionFactoryBean sqlSessionFactoryBean= newSqlSessionFactoryBean();
sqlSessionFactoryBean.setDataSource(myRoutingDataSource);
sqlSessionFactoryBean.setMapperLocations(new
PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml"));Object();
}
@BeanpublicPlatformTransactionManager platformTransactionManager() {return
newDataSourceTransactionManager(myRoutingDataSource);
}
}
由于Spring容器中现在有4个数据源，所以我们需要为事务管理器和MyBatis⼿动指定⼀个明确的数据源。
3.3. 设置路由key / 查数据源
⽬标数据源就是那前3个这个我们是知道的，但是使⽤的时候是如果查数据源的呢？
⾸先，我们定义⼀个枚举来代表这三个数据源
ums;public enumDBTypeEnum {
MASTER, SLAVE1, SLAVE2;
}
接下来，通过ThreadLocal将数据源设置到每个线程上下⽂中
ample.bean;ums.DBTypeEnum;urrent.atomic.AtomicInteger;pub classDBContextHolder {private static final ThreadLocal contextHolder = new ThreadLocal<>();private static final
AtomicInteger counter = new AtomicInteger(-1);public static voidset(DBTypeEnum dbType) {
contextHolder.set(dbType);
}public staticDBTypeEnum get() {();
}public static voidmaster() {
set(DBTypeEnum.MASTER);
System.out.println("切换到master");
}public static voidslave() {//轮询
int index = AndIncrement() % 2;if (() > 9999) {
counter.set(-1);
}if (index == 0) {
set(DBTypeEnum.SLAVE1);
System.out.println("切换到slave1");
}else{
set(DBTypeEnum.SLAVE2);
springboot aopSystem.out.println("切换到slave2");
}
}
}
获取路由key
ample.bean;importorg.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;importorg.sprin class MyRoutingDataSource extendsAbstractRoutingDataSource {
@Nullable
@OverrideprotectedObject determineCurrentLookupKey() {();
}
}
设置路由key
默认情况下，所有的查询都⾛从库，插⼊/修改/删除⾛主库。我们通过⽅法名来区分操作类型(CRUD)
ample.aop;ample.bean.DBContextHolder;importorg.apachemons.lang3.StringUtils;impo
@Aspect
@Componentpublic classDataSourceAop {
@Pointcut("!@annotation(ample.annotation.Master) " +
"&& (execution(* ample.service..*.select*(..)) " +
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论