0
  • 聊天消息
  • 系统消息
  • 评论与回复
登录后你可以
  • 下载海量资料
  • 学习在线课程
  • 观看技术视频
  • 写文章/发帖/加入社区
会员中心
创作中心

完善资料让更多小伙伴认识你,还能领取20积分哦,立即完善>

3天内不再提示

读写分离的两种实现方式

Android编程精选 来源:博客园 作者:狂乱的贵公子 2021-09-29 14:51 次阅读

1. 引言

读写分离要做的事情就是对于一条SQL该选择哪个数据库去执行,至于谁来做选择数据库这件事儿,无非两个,要么中间件帮我们做,要么程序自己做。因此,一般来讲,读写分离有两种实现方式。

第一种是依靠中间件(比如:MyCat),也就是说应用程序连接到中间件,中间件帮我们做SQL分离;第二种是应用程序自己去做分离。这里我们选择程序自己来做,主要是利用Spring提供的路由数据源,以及AOP。然而,应用程序层面去做读写分离最大的弱点(不足之处)在于无法动态增加数据库节点,因为数据源配置都是写在配置中的,新增数据库意味着新加一个数据源,必然改配置,并重启应用。当然,好处就是相对简单。

2. AbstractRoutingDataSource

基于特定的查找key路由到特定的数据源。它内部维护了一组目标数据源,并且做了路由key与目标数据源之间的映射,提供基于key查找数据源的方法。

3. 实践

关于配置请参考《MySQL主从复制配置》

地址:www.cnblogs.com/cjsblog/p/9706370.html

3.1. maven依赖

《?xml version=“1.0” encoding=“UTF-8”?》 《project xmlns=“http://maven.apache.org/POM/4.0.0” xmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance” xsi:schemaLocation=“http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd”》 《modelVersion》4.0.0《/modelVersion》

《groupId》com.cjs.example《/groupId》 《artifactId》cjs-datasource-demo《/artifactId》 《version》0.0.1-SNAPSHOT《/version》 《packaging》jar《/packaging》 《name》cjs-datasource-demo《/name》 《description》《/description》 《parent》 《groupId》org.springframework.boot《/groupId》 《artifactId》spring-boot-starter-parent

《/artifactId》 《version》2.0.5.RELEASE《/version》 《relativePath/》 《!-- lookup parent from repository --》 《/parent》 《properties》 《project.build.sourceEncoding》UTF-8《/project.build.sourceEncoding》 《project.reporting.outputEncoding》

UTF-8

《/project.reporting.outputEncoding》 《java.version》1.8《/java.version》 《/properties》 《dependencies》 《dependency》 《groupId》org.springframework.boot《/groupId》 《artifactId》spring-boot-starter-aop《/artifactId》 《/dependency》

《dependency》 《groupId》org.springframework.boot《/groupId》 《artifactId》spring-boot-starter-jdbc《/artifactId》 《/dependency》 《dependency》 《groupId》org.springframework.boot《/groupId》 《artifactId》spring-boot-starter-web《/artifactId》

《/dependency》 《dependency》 《groupId》org.mybatis.spring.boot《/groupId》 《artifactId》mybatis-spring-boot-starter《/artifactId》 《version》

1.3.2《/version》 《/dependency》 《dependency》 《groupId》org.apache.commons《/groupId》 《artifactId》commons-lang3《/artifactId》 《version》3.8《/version》 《/dependency》 《dependency》

《groupId》mysql《/groupId》 《artifactId》mysql-connector-java《/artifactId》 《scope》runtime《/scope》 《/dependency》 《dependency》 《groupId》org.springframework.boot《/groupId》 《artifactId》spring-boot-starter-test《/artifactId》 《scope》test《/scope》 《/dependency》 《/dependencies》 《build》 《plugins》 《plugin》 《groupId》org.springframework.boot《/groupId》 《artifactId》spring-boot-maven-plugin《/artifactId》 《/plugin》 《

!--《plugin》 《groupId》org.mybatis.generator《/groupId》 《artifactId》mybatis-generator-maven-plugin《/artifactId》 《version》1.3.5《/version》 《dependencies》 《dependency》 《groupId》mysql《/groupId》 《artifactId》mysql-connector-java《/artifactId》 《version》

5.1.46《/version》 《/dependency》 《/dependencies》 《configuration》 《configurationFile》

${basedir}/src/main/resources/myBatisGeneratorConfig.xml《/configurationFile》 《overwrite》true《/overwrite》 《/configuration》 《executions》 《execution》 《id》Generate MyBatis Artifacts《/id》 《goals》 《goal》generate《/goal》 《/goals》 《/execution》 《/executions》 《/plugin》--》 《/plugins》 《/build》 《/project》

3.2. 数据源配置application.yml

spring: datasource: master: jdbc-url: jdbc:mysql://192.168.102.31:3306/test username: root password: 123456 driver-class-name: com.mysql.jdbc.Driver slave1: jdbc-url: jdbc:mysql://192.168.102.56:3306/test username:

pig # 只读账户 password: 123456 driver-class-name: com.mysql.jdbc.Driver slave2: jdbc-url: jdbc:mysql://192.168.102.36:3306/test username: pig # 只读账户 password: 123456 driver-class-name: com.mysql.jdbc.Driver多数据源配置

/** * 关于数据源配置,参考SpringBoot官方文档第79章《Data Access》

* 79. Data Access * 79.1 Configure a Custom DataSource * 79.2 Configure Two DataSources */ @Configuration public class DataSourceConfig

{ @Bean @ConfigurationProperties(“spring.datasource.master”) public DataSource masterDataSource()

{ return DataSourceBuilder.create().build(); } @Bean @ConfigurationProperties

(“spring.datasource.slave1”) public DataSource slave1DataSource() { return DataSourceBuilder.create().build(); } @Bean @ConfigurationProperties

(“spring.datasource.slave2”) public DataSource slave2DataSource() { return DataSourceBuilder.create().build(); } @Bean public DataSource myRoutingDataSource(@Qualifier

(“masterDataSource”) DataSource masterDataSource, @Qualifier(“slave1DataSource”) DataSource slave1DataSource, @Qualifier(“slave2DataSource”) DataSource slave2DataSource) { Map《Object, Object》 targetDataSources = new HashMap《》(); targetDataSources.put

(DBTypeEnum.MASTER, masterDataSource); targetDataSources.put(DBTypeEnum.SLAVE1, slave1DataSource); targetDataSources.put

(DBTypeEnum.SLAVE2, slave2DataSource); MyRoutingDataSource myRoutingDataSource = new MyRoutingDataSource(); myRoutingDataSource.setDefaultTargetDataSource(masterDataSource); myRoutingDataSource.setTargetDataSources(targetDataSources);

return myRoutingDataSource; } }这里,我们配置了4个数据源,1个master,2两个slave,1个路由数据源。前3个数据源都是为了生成第4个数据源,而且后续我们只用这最后一个路由数据源。MyBatis配置

@EnableTransactionManagement @Configuration public class MyBatisConfig { @Resource(name = “myRoutingDataSource”) private DataSource myRoutingDataSource;

@Bean public SqlSessionFactory sqlSessionFactory() throws Exception { SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();

sqlSessionFactoryBean.setDataSource(myRoutingDataSource); sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(“classpath:mapper/*.xml”));

return sqlSessionFactoryBean.getObject(); } @Bean public PlatformTransactionManager platformTransactionManager() { return new DataSourceTransactionManager(myRoutingDataSource);

} }由于 Spring 容器中现在有4个数据源,所以我们需要为事务管理器和MyBatis手动指定一个明确的数据源。3.3. 设置路由key / 查找数据源目标数据源就是那前3个这个我们是知道的,但是使用的时候是如果查找数据源的呢?首先,我们定义一个枚举来代表这三个数据源

package com.cjs.example.enums; public enum DBTypeEnum { MASTER, SLAVE1, SLAVE2; }接下来,通过ThreadLocal将数据源设置到每个线程上下文中

public class DBContextHolder { private static final ThreadLocal《DBTypeEnum》 contextHolder = new ThreadLocal《》();

private static final AtomicInteger counter = new AtomicInteger(-1); public static void set(DBTypeEnum dbType) { contextHolder.set(dbType); } public static DBTypeEnum get() { return contextHolder.get();

} public static void master() { set(DBTypeEnum.MASTER); System.out.println(“切换到master”);

} public static void slave() { // 轮询 int index = counter.getAndIncrement() % 2; if (counter.get() 》 9999) { counter.set(-1); } if (index == 0) { set(DBTypeEnum.SLAVE1); System.out.println(“切换到slave1”); }else { set(DBTypeEnum.SLAVE2);

System.out.println(“切换到slave2”); } } }获取路由key

package com.cjs.example.bean; import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource; import org.springframework.lang.Nullable; public class MyRoutingDataSource extends AbstractRoutingDataSource { @Nullable @Override protected Object determineCurrentLookupKey()

{ return DBContextHolder.get(); } }设置路由key默认情况下,所有的查询都走从库,插入/修改/删除走主库。我们通过方法名来区分操作类型(CRUD)

@Aspect @Component public class DataSourceAop { @Pointcut(“!@annotation(com.cjs.example.annotation.Master) ” + “&& (execution(* com.cjs.example.service..*.select*(。。)) ” + “|| execution(* com.cjs.example.service..*.get*(。。)))”)

public void readPointcut() { } @Pointcut(“@annotation(com.cjs.example.annotation.Master) ” + “|| execution(* com.cjs.example.service..*.insert*(。。)) ” + “|| execution(* com.cjs.example.service..*.add*(。。)) ” + “|| execution(* com.cjs.example.service..*.update*(。。))

” + “|| execution(* com.cjs.example.service..*.edit*(。。)) ” + “|| execution(* com.cjs.example.service..*.delete*(。。)) ” + “|| execution(* com.cjs.example.service..*.remove*(。。))”) public void writePointcut()

{ } @Before(“readPointcut()”) public void read() { DBContextHolder.slave(); } @Before(“writePointcut()”) public void write() { DBContextHolder.master(); } /** * 另一种写法:if.。.else.。。 判断哪些需要读从数据库,其余的走主数据库 */ // @Before

(“execution(* com.cjs.example.service.impl.*.*(。。))”) // public void before(JoinPoint jp) { // String methodName = jp.getSignature().getName();

// // if (StringUtils.startsWithAny(methodName, “get”, “select”, “find”)) { // DBContextHolder.slave();

// }else { // DBContextHolder.master(); // } // } }有一般情况就有特殊情况,特殊情况是某些情况下我们需要强制读主库,针对这种情况,我们定义一个主键,用该注解标注的就读主库

package com.cjs.example.annotation; public @interface Master { }例如,假设我们有一张表member

@Service public class MemberServiceImpl implements MemberService { @Autowired private MemberMapper memberMapper; @Transactional @Override public int insert(Member member) { return memberMapper.insert(member);

} @Master @Override public int save(Member member) { return memberMapper.insert(member);

} @Override public List《Member》 selectAll() { return memberMapper.selectByExample(new MemberExample()); } @Master @Override public String getToken(String appId) { // 有些读操作必须读主数据库 // 比如,获取微信access_token,因为高峰时期主从同步可能延迟 // 这种情况下就必须强制从主数据读 return null; } }4. 测试

@RunWith(SpringRunner.class) @SpringBootTest public class CjsDatasourceDemoApplicationTests { @Autowired private MemberService memberService; @Test public void testWrite() { Member member = new Member(); member.setName(“zhangsan”); memberService.insert(member);

} @Test public void testRead() { for (int i = 0; i 《 4; i++) { memberService.selectAll(); } } @Test public void testSave() { Member member = new Member(); member.setName(“wangwu”); memberService.save(member);

} @Test public void testReadFromMaster() { memberService.getToken(“1234”); } }查看控制台

责任编辑:haq

声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉
  • MySQL
    +关注

    关注

    1

    文章

    831

    浏览量

    26789
  • Sprint
    +关注

    关注

    0

    文章

    86

    浏览量

    15207

原文标题:Spring Boot + MyBatis + MySQL读写分离

文章出处:【微信号:AndroidPush,微信公众号:Android编程精选】欢迎添加关注!文章转载请注明出处。

收藏 人收藏

    相关推荐

    常见人体姿态评估显示方式两种方式

    人体姿态评估中有两种常见的显示方式,分别是火柴人效果与BodyPix效果。其中火柴人效果本质就是基于关键点的深度学习模型推理以后的显示效果;Bodypix本质就就是语义分割模型
    的头像 发表于 11-11 11:21 309次阅读
    常见人体姿态评估显示<b class='flag-5'>方式</b>的<b class='flag-5'>两种</b><b class='flag-5'>方式</b>

    配置MySQL主从复制和读写分离

    配置MySQL主从复制和读写分离
    的头像 发表于 10-23 11:44 559次阅读
    配置MySQL主从复制和<b class='flag-5'>读写</b><b class='flag-5'>分离</b>

    噪声传导的两种模式

    噪声传导有两种模式,一为差模传导,一为共模传导。
    的头像 发表于 10-15 11:33 411次阅读
    噪声传导的<b class='flag-5'>两种</b>模式

    什么是电流保护的接线方式?有哪两种接线方式?

    方式。下面将对这两种接线方式进行介绍。 一、完全星形接线方式 完全星形接线方式,也称为三相三继电器接线
    的头像 发表于 10-06 17:37 2099次阅读
    什么是电流保护的接线<b class='flag-5'>方式</b>?有哪<b class='flag-5'>两种</b>接线<b class='flag-5'>方式</b>?

    Linux应用层控制外设的两种不同的方式

    众所周知,linux下一切皆文件,那么应用层如何控制硬件层,同样是通过 文件I/O的方式实现的,那么应用层控制硬件层通常有两种方式
    的头像 发表于 10-05 19:03 774次阅读
    Linux应用层控制外设的<b class='flag-5'>两种</b>不同的<b class='flag-5'>方式</b>

    两种常见的硬件消抖实现方式

    由于机械按键在操作过程中会产生抖动现象,这种抖动信号如果不加以处理,就可能导致单片机等电子设备误判按键状态,从而引发错误操作。本文将详细介绍两种常见的硬件消抖实现方式:RS触发器和电容滤波。 RS
    的头像 发表于 09-25 16:54 1913次阅读
    <b class='flag-5'>两种</b>常见的硬件消抖<b class='flag-5'>实现</b><b class='flag-5'>方式</b>

    示波器两种衰减方式的区别是什么

    两种:内部衰减和外部衰减。 内部衰减 内部衰减是指示波器内部对输入信号进行衰减的方式。内部衰减器通常由电阻和电容组成,通过改变电阻和电容的参数,实现对输入信号的衰减。内部衰减器的优点如下: 1.1 精度高:内部衰减
    的头像 发表于 08-09 14:41 598次阅读

    接地保护分为哪两种方式

    接地保护是电气工程中非常重要的一安全措施,其目的是确保电气设备和系统在发生故障时能够安全地将电流导向地面,从而保护人身安全和设备安全。接地保护主要分为两种方式:工作接地和保护接地。以下是对这
    的头像 发表于 08-05 10:24 1394次阅读

    plc与传感器的两种连接方式

    在工业自动化领域,PLC(可编程逻辑控制器)与传感器的连接是实现自动化控制的关键环节。本文将详细介绍PLC与传感器的两种主要连接方式:模拟量连接和数字量连接。这两种连接
    的头像 发表于 07-25 09:36 1825次阅读

    wdm设备的两种传输方式

    系统中,有多种传输方式,其中最常见的两种是密集波分复用(DWDM)和粗波分复用(CWDM)。 1. 密集波分复用(DWDM) 1.1 DWDM技术原理 密集波分复用(Dense Wavelength Division Multiplexing,简称DWDM)是一
    的头像 发表于 07-18 09:45 571次阅读

    三相负载的连接方式有哪两种

    三相负载的连接方式主要有星形连接(Y连接)和三角形连接(Δ连接)两种。这两种连接方式在电气工程中非常常见,它们各自具有不同的特性和应用场景。下面将介绍这
    的头像 发表于 07-17 10:33 5539次阅读

    读写分离怎么保证数据同步

    读写分离是一常见的数据库架构设计,用于提高数据库的并发处理能力。在读写分离架构中,数据库的读操作和写操作被
    的头像 发表于 07-12 09:49 1164次阅读

    读写分离解决什么问题

    1.1 读写分离的定义 读写分离是一数据库架构设计策略,通过将数据库的读操作和写操作分离到不
    的头像 发表于 07-12 09:47 569次阅读

    控制器有哪两种实现方式?各有何优缺点?

    控制器是计算机系统中的一个关键组件,负责协调和管理计算机硬件和软件资源。在不同的应用场景和系统中,控制器的实现方式可能会有所不同。以下是两种常见的控制器实现
    的头像 发表于 06-30 10:33 1564次阅读

    PCBA加工中常见的两种焊接方式详解

    ,在PCBA行业中经常被使用。接下来深圳PCBA加工厂家为大家详细介绍PCBA加工手工焊接的两种方式,为您揭秘行业内的技术细节。 PCBA加工过程中常用焊接方式 第一
    的头像 发表于 06-14 09:18 664次阅读