数据库系列课程(04)-SpringBoot整合MySQL读写分离

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: 数据库系列课程(04)-SpringBoot整合MySQL读写分离

1.引言

代码已上传到Github,有兴趣的同学可以下载来看看:https://github.com/ylw-github/SpringBoot-MyCat-Demo

在前面几个章节,我们了解到了MySQL数据库的主从复制、使用MyCat实现读写分离:

回到代码的层面,本文主要开始讲解SpringBoot如何实现读写分离。

SpringBoot项目整合动态数据源(读写分离)思路:

  1. 配置多个数据源,根据业务需求访问不同的数据,指定对应的策略:增加,删除,修改操作访问对应数据,查询访问对应数据,不同数据库做好的数据一致性的处理。由于此方法相对易懂,简单,不做过多介绍。
  2. 动态切换数据源,根据配置的文件,业务动态切换访问的数据库:此方案通过Spring的AOP,AspactJ来实现动态织入,通过编程继承实现Spring中的AbstractRoutingDataSource,来实现数据库访问的动态切换,不仅可以方便扩展,不影响现有程序,而且对于此功能的增删也比较容易。
  3. 通过mycat来实现读写分离:使用mycat提供的读写分离功能,mycat连接多个数据库,数据源只需要连接mycat,对于开发人员而言他还是连接了一个数据库(实际是mysql的mycat中间件),而且也不需要根据不同业务来选择不同的库,这样就不会有多余的代码产生

2.SpringBoot整合MySQL读写分离

在Spring 2.0.1中引入了AbstractRoutingDataSource, 该类充当了DataSource的路由中介, 能有在运行时, 根据某种key值来动态切换到真正的DataSource上。

  1. 项目中需要集成多个数据源分别为读和写的数据源,绑定不同的key。
  2. 采用AOP技术进行拦截业务逻辑层方法,判断方法的前缀是否需要写或者读的操作。
  3. 如果方法的前缀是写的操作的时候,直接切换为写的数据源,反之切换为读的数据源。
  4. 也可以自己定义注解进行封装

2.1 集成步骤

1.新建maven项目SpringBoot-MyCat-Demo:

2.添加maven依赖:

<parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>2.0.4.RELEASE</version>
  <relativePath /> <!-- lookup parent from repository -->
</parent>
<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</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>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>
  <dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.0.23</version>
  </dependency>
</dependencies>
<build>
  <plugins>
    <plugin>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-maven-plugin</artifactId>
    </plugin>
  </plugins>
</build>

3.application.yml

spring:
  datasource:
    ###可读数据源
    select:
      jdbc-url: jdbc:mysql://192.168.162.131:8066/mycat_testdb
      driver-class-name: com.mysql.jdbc.Driver
      username: user
      password: user
    ####可写数据源
    update:
      jdbc-url: jdbc:mysql://192.168.162.131:8066/mycat_testdb
      driver-class-name: com.mysql.jdbc.Driver
      username: root
      password: 123456
    type: com.alibaba.druid.pool.DruidDataSource

4.DataSourceContextHolder

@Component
@Lazy(false)
public class DataSourceContextHolder {
  // 采用ThreadLocal 保存本地多数据源
  private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();
  // 设置数据源类型
  public static void setDbType(String dbType) {
    contextHolder.set(dbType);
  }
  public static String getDbType() {
    return contextHolder.get();
  }
  public static void clearDbType() {
    contextHolder.remove();
  }
}

5.DataSourceConfig

@Configuration
public class DataSourceConfig {
  // 创建可读数据源
  @Bean(name = "selectDataSource")
  @ConfigurationProperties(prefix = "spring.datasource.select") // application.properteis中对应属性的前缀
  public DataSource dataSource1() {
    return DataSourceBuilder.create().build();
  }
  // 创建可写数据源
  @Bean(name = "updateDataSource")
  @ConfigurationProperties(prefix = "spring.datasource.update") // application.properteis中对应属性的前缀
  public DataSource dataSource2() {
    return DataSourceBuilder.create().build();
  }
}

6.DynamicDataSource(在Spring 2.0.1中引入了AbstractRoutingDataSource, 该类充当了DataSource的路由中介, 能有在运行时, 根据某种key值来动态切换到真正的DataSource上。)

@Component
@Primary
public class DynamicDataSource extends AbstractRoutingDataSource {
  @Autowired
  @Qualifier("selectDataSource")
  private DataSource selectDataSource;
  @Autowired
  @Qualifier("updateDataSource")
  private DataSource updateDataSource;
  /**
   * 这个是主要的方法,返回的是生效的数据源名称
   */
  @Override
  protected Object determineCurrentLookupKey() {
    System.out.println("DataSourceContextHolder:::" + DataSourceContextHolder.getDbType());
    return DataSourceContextHolder.getDbType();
  }
  /**
   * 配置数据源信息
   */
  @Override
  public void afterPropertiesSet() {
    Map<Object, Object> map = new HashMap<>();
    map.put("selectDataSource", selectDataSource);
    map.put("updateDataSource", updateDataSource);
    setTargetDataSources(map);
    setDefaultTargetDataSource(updateDataSource);
    super.afterPropertiesSet();
  }
}

7.SwitchDataSourceAOP(通过AOP来选择数据源)

@Aspect
@Component
@Lazy(false)
@Order(0) // Order设定AOP执行顺序 使之在数据库事务上先执行
public class SwitchDataSourceAOP {
  // 这里切到你的方法目录
  @Before("execution(* com.ylw.springboot.mycat.service.*.*(..))")
  public void process(JoinPoint joinPoint) {
    String methodName = joinPoint.getSignature().getName();
    if (methodName.startsWith("get") || methodName.startsWith("count") || methodName.startsWith("find")
        || methodName.startsWith("list") || methodName.startsWith("select") || methodName.startsWith("check")) {
      // 读
      DataSourceContextHolder.setDbType("selectDataSource");
    } else {
      // 切换dataSource
      DataSourceContextHolder.setDbType("updateDataSource");
    }
  }
}

8.Controller层代码:

@RestController
public class UserController {
    @Autowired
    private UserService userService;
    @RequestMapping("/findUser")
    public List<UserEntity> findUser() {
        return userService.findUser();
    }
    @RequestMapping("/insertUser")
    public List<UserEntity> insertUser(String name, int age, String sex) {
        return userService.insertUser(UUID.randomUUID().toString(), name, age, sex);
    }
}

9.Service层代码:

@Service
public class UserService {
  @Autowired
  private UserMapper userMapper;
  public List<UserEntity> findUser() {
    return userMapper.findUser();
  }
  public List<UserEntity> insertUser(String uuid,String name,int age,String sex) {
    return userMapper.insertUser(uuid,name,age,sex);
  }
}

10.dao层代码:

public interface UserMapper {
  @Select("SELECT * FROM  t_user ")
  public List<UserEntity> findUser();
  @Select("insert into t_user values (#{uuid},#{name},#{age},#{sex}); ")
  public List<UserEntity> insertUser(@Param("uuid") String uuid,@Param("name") String name,@Param("age") int age,@Param("sex") String sex);
}

3.启动项目测试

1.启动项项目

2.查询用户,浏览器输入:http://localhost:8080/findUser,可以看出把所有的用户都查询出来了。

3.插入用户,浏览器输入:http://localhost:8080/insertUser?name=xiaohong&age=18&sex=1,再次查询,http://localhost:8080/findUser,可以看到新增的xiaohong用户添加成功。

本文完!

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
3天前
|
Java 数据库连接 测试技术
SpringBoot入门(4) - 添加内存数据库H2
SpringBoot入门(4) - 添加内存数据库H2
18 4
SpringBoot入门(4) - 添加内存数据库H2
|
5天前
|
Java 数据库连接 测试技术
SpringBoot入门(4) - 添加内存数据库H2
SpringBoot入门(4) - 添加内存数据库H2
15 2
SpringBoot入门(4) - 添加内存数据库H2
|
16天前
|
存储 关系型数据库 MySQL
Mysql(4)—数据库索引
数据库索引是用于提高数据检索效率的数据结构,类似于书籍中的索引。它允许用户快速找到数据,而无需扫描整个表。MySQL中的索引可以显著提升查询速度,使数据库操作更加高效。索引的发展经历了从无索引、简单索引到B-树、哈希索引、位图索引、全文索引等多个阶段。
50 3
Mysql(4)—数据库索引
|
1天前
|
关系型数据库 MySQL Linux
在 CentOS 7 中通过编译源码方式安装 MySQL 数据库的详细步骤,包括准备工作、下载源码、编译安装、配置 MySQL 服务、登录设置等。
本文介绍了在 CentOS 7 中通过编译源码方式安装 MySQL 数据库的详细步骤,包括准备工作、下载源码、编译安装、配置 MySQL 服务、登录设置等。同时,文章还对比了编译源码安装与使用 RPM 包安装的优缺点,帮助读者根据需求选择最合适的方法。通过具体案例,展示了编译源码安装的灵活性和定制性。
19 2
|
4天前
|
存储 关系型数据库 MySQL
MySQL vs. PostgreSQL:选择适合你的开源数据库
在众多开源数据库中,MySQL和PostgreSQL无疑是最受欢迎的两个。它们都有着强大的功能、广泛的社区支持和丰富的生态系统。然而,它们在设计理念、性能特点、功能特性等方面存在着显著的差异。本文将从这三个方面对MySQL和PostgreSQL进行比较,以帮助您选择更适合您需求的开源数据库。
20 4
|
7天前
|
SQL Java 数据库
Spring Boot与Flyway:数据库版本控制的自动化实践
【10月更文挑战第19天】 在软件开发中,数据库的版本控制是一个至关重要的环节,它确保了数据库结构的一致性和项目的顺利迭代。Spring Boot结合Flyway提供了一种自动化的数据库版本控制解决方案,极大地简化了数据库迁移管理。本文将详细介绍如何使用Spring Boot和Flyway实现数据库版本的自动化控制。
10 2
|
10天前
|
存储 关系型数据库 MySQL
如何在MySQL中创建数据库?
【10月更文挑战第16天】如何在MySQL中创建数据库?
|
14天前
|
SQL Oracle 关系型数据库
安装最新 MySQL 8.0 数据库(教学用)
安装最新 MySQL 8.0 数据库(教学用)
76 4
|
12天前
|
存储 SQL 关系型数据库
【入门级教程】MySQL:从零开始的数据库之旅
本教程面向零基础用户,采用通俗易懂的语言和丰富的示例,帮助你快速掌握MySQL的基础知识和操作技巧。内容涵盖SQL语言基础(SELECT、INSERT、UPDATE、DELETE等常用语句)、使用索引提高查询效率、存储过程等。适合学生、开发者及数据库爱好者。
27 0
【入门级教程】MySQL:从零开始的数据库之旅
|
15天前
|
存储 关系型数据库 MySQL
PACS系统 中 dicom 文件在mysql 8.0 数据库中的 存储和读取(pydicom 库使用)
PACS系统 中 dicom 文件在mysql 8.0 数据库中的 存储和读取(pydicom 库使用)
16 2