在Spring Boot + MyBatis项目中实现MySQL读写分离

简介: 在Spring Boot和MyBatis项目中实现MySQL读写分离,主要有两种思路:一种是在应用层通过代码和配置手动控制,另一种是借助中间件自动路由。

Spring BootMyBatis项目中实现MySQL读写分离,主要有两种思路:一种是在应用层通过代码和配置手动控制,另一种是借助中间件自动路由。

下面是几种主流的实现方案,并提供一个基于Spring抽象路由数据源的实战指南。

🎯 如何选择实现方案

你可以根据项目的复杂度、团队的技术栈和运维能力,参考下表进行选择:

对于大多数Java开发者来说,从应用层手动分离开始学习是最直观的路径。

🔧 核心实现:应用层手动分离

这种方法的核心是利用Spring的 AbstractRoutingDataSource 来动态决定使用哪个数据源。

主要步骤

1、配置多个数据源

在你的application.yml文件中,分别配置主库和从库的连接信息。

spring:
  datasource:
    master:
      driver-class-name: com.mysql.cj.jdbc.Driver
      url: jdbc:mysql://master-host:3306/db_name
      username: root
      password: master-pass
    slave:
      driver-class-name: com.mysql.cj.jdbc.Driver
      url: jdbc:mysql://slave-host:3306/db_name
      username: root
      password: slave-pass

2、创建数据源上下文持有者

使用ThreadLocal来安全地存储和获取当前线程需要使用的数据源键值。

public class DataSourceContextHolder {
    private static final ThreadLocal<String> CONTEXT_HOLDER = new ThreadLocal<>();
    
    public static void setDataSourceType(String dataSourceType) {
        CONTEXT_HOLDER.set(dataSourceType);
    }
    
    public static String getDataSourceType() {
        return CONTEXT_HOLDER.get();
    }
    
    public static void clearDataSourceType() {
        CONTEXT_HOLDER.remove();
    }
}

3、创建动态数据源类

继承AbstractRoutingDataSource并重写determineCurrentLookupKey方法,使其从上下文持有者中获取数据源键值。

public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDataSourceType();
    }
}

4、使用AOP自动切换数据源

通过切面,根据方法名或自定义注解自动设置数据源。

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Master {
}

5、处理特殊情况:强制读主库

在某些需要实时读取数据的场景(如刚写入后立刻查询),你可以使用自定义注解来强制方法走主库。

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Master {
}

然后在切面中增加对@Master注解的判断,优先使用主库。

⚠️ 实施中的关键问题与解决方案

主从延迟问题:这是读写分离架构中最常见的挑战。对于需要实时性保证的查询,可以使用上面提到的@Master注解强制走主库。

事务管理:为了确保数据一致性,在写操作(如@Transactional注解的方法)中,整个事务内的所有数据库操作都应使用主库。你可以在事务开始时就强制指定数据源为主库。

故障转移与监控:需要建立从库健康检查机制。当监测到从库延迟过大或宕机时,应能自动将读请求降级到主库,保证系统的可用性。

💎 总结

实现Spring Boot + MyBatis的读写分离,应用层手动方案适合快速上手和理解原理,而中间件方案则在动态扩展和运维管理上更有优势。

在学习或中小型项目中先从应用层方案入手,随着业务规模扩大,再平滑迁移到ProxySQL或ShardingSphere等更强大的中间件上。

在Spring Boot + MyBatis项目中实现MySQL读写分离.png

谢谢你看我的文章,既然看到这里了,如果觉得不错,随手点个赞、转发、在看三连吧,感谢感谢。那我们,下次再见。

您的一键三连,是我更新的最大动力,谢谢

山水有相逢,来日皆可期,谢谢阅读,我们再会

我手中的金箍棒,上能通天,下能探海

相关文章
|
SpringCloudAlibaba 负载均衡 Java
【一】SpringCloud Alibaba之Nacos整合篇(作为注册中心)
【一】SpringCloud Alibaba之Nacos整合篇(作为注册中心)
1162 1
【一】SpringCloud Alibaba之Nacos整合篇(作为注册中心)
|
6月前
|
存储 弹性计算 缓存
阿里云云服务器经济型、通用算力型和第九代热门实例解析:实例性能、适用场景与选购参考
在阿里云目前的活动中,可选的云服务器ECS实例规格主要有经济型e、通用算力型u1/u2i/u2a、九代c9i/g9i/r9i/c9a/g9a/r9a实例等。不同实例规格的所采用的架构、处理器不同,因此在计算、网络、存储等方面的性能也有所不同,从而在适用场景方面也有所差异。本文为大家解析这些实例各自的性能与适用场景,为企业及个人用户提供一份选择参考指南。
|
Java 关系型数据库 数据库连接
简单易懂的 MyBatis 分库分表方案
本文介绍了一种基于 MyBatis 框架的数据库分库分表方案——shardino。不同于复杂插件方式,该方案通过客户端代码包装实现简便易懂的操作,显式处理分库分表逻辑,确保开发者清晰了解数据分布。项目地址:[https://github.com/pyloque/shardino](https://github.com/pyloque/shardino)。方案中,帖子表按 userId 字段 hash 分为 64 张表,平均分配到多个主从库中,配置文件管理 MySQL 组对象,支持读写分离和权重随机选择从库。代码示例展示了如何计算 partition number 并进行具体操作。
598 22
简单易懂的 MyBatis 分库分表方案
|
存储 Java 数据库连接
Spring Boot 配置主从数据库实现读写分离
Spring Boot 配置主从数据库实现读写分离
2142 0
|
SQL Java 数据库连接
自定义HikariCP连接池
自定义HikariCP连接池
2382 0
|
JSON 关系型数据库 MySQL
mysqlx_max_connections
mysqlx_max_connections
1671 0
|
安全 Java 网络安全
SpringBoot 优雅停止服务的几种方法
SpringBoot 优雅停止服务的几种方法
1022 0
|
Java 数据库连接 数据库
Spring Boot整合MyBatis Plus集成多数据源轻松实现数据读写分离
Spring Boot整合MyBatis Plus集成多数据源轻松实现数据读写分离
1274 2
|
SQL 存储 算法
SpringBoot整合ShardingSphere实现分表分库&读写分离&读写分离+数据库分表
SpringBoot整合ShardingSphere实现分表分库&读写分离&读写分离+数据库分表
3623 0
SpringBoot整合ShardingSphere实现分表分库&读写分离&读写分离+数据库分表
|
XML Java 开发者
springboot 启动原理、启动过程、启动机制的介绍
【5月更文挑战第13天】Spring Boot 是一种基于 Java 的框架,用于创建独立的、生产级别的 Spring 应用程序。它的主要目标是简化 Spring 应用的初始搭建和开发过程,同时提供一系列大型项目常见的非功能性特征(如嵌入式服务器、安全性、度量、健康检查和外部化配置)。
2360 3