Java案例如何实现读写分离？

wen java案例 2026-06-07 80

Java案例如何实现读写分离？从原理到实战的全解析

目录导读

什么是读写分离？为什么需要它？
读写分离的核心实现机制
基于Spring Boot + MyBatis + ShardingSphere的实战案例
代码实现：动态数据源与读写路由
常见问题与解决方案（Q&A）
性能测试与优化建议
从案例到生产环境的注意事项

什么是读写分离？为什么需要它？

读写分离 是数据库架构中的一种常见优化策略，它将数据库的读操作（SELECT）和写操作（INSERT、UPDATE、DELETE）分发到不同的数据库实例上，典型架构中，主库（Master）处理写请求，从库（Slave）处理读请求，数据通过主从复制保持同步。

Java案例如何实现读写分离？

核心价值：

减轻主库压力：读操作分散到多个从库，避免单点瓶颈。
提升查询性能：从库可水平扩展，应对高并发读场景（如电商大促、内容阅读）。
高可用保障：主库故障时，从库可快速切换为新的主库。

读写分离的核心实现机制

实现读写分离通常需要解决两个问题：

数据源动态路由：根据SQL类型（读/写）自动选择对应的数据源。
主从数据一致性：通过MySQL主从复制（binlog同步）保证数据最终一致。

常见实现方式：

中间件层：如ShardingSphere、MyCat、Atlas，透明代理SQL。
应用层：使用AbstractRoutingDataSource（Spring）或AOP切面动态切换。

基于Spring Boot + MyBatis + ShardingSphere的实战案例

环境准备

JDK 1.8+
MySQL 8.0（主库+从库，通过docker-compose搭建）
Spring Boot 2.7.x
ShardingSphere-JDBC 5.3.x

项目依赖（pom.xml）

<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>shardingsphere-jdbc-core-spring-boot-starter</artifactId>
    <version>5.3.2</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
</dependency>

配置文件（application.yml）

spring:
  shardingsphere:
    datasource:
      names: master,slave0
      master:
        type: com.zaxxer.hikari.HikariDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://192.168.1.10:3306/db_user?useSSL=false
        username: root
        password: master_pwd
      slave0:
        type: com.zaxxer.hikari.HikariDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://192.168.1.11:3306/db_user?useSSL=false
        username: root
        password: slave_pwd
    rules:
      readwrite-splitting:
        data-sources:
          # 逻辑数据源名称（在代码中注入使用）
          ds_user:
            type: Static
            props:
              write-data-source-name: master
              read-data-source-names: slave0
            # 负载均衡算法（可选：ROUND_ROBIN / RANDOM）
            load-balancer-name: round_robin
        load-balancers:
          round_robin:
            type: ROUND_ROBIN
    props:
      sql-show: true  # 开启SQL日志，便于调试

关键说明：

上述配置定义了一个逻辑数据源ds_user，写操作自动路由到master，读操作路由到slave0。
若有多从库,可在read-data-source-names中以逗号分隔，并配置负载均衡算法。

实体类与Mapper（略）

// 普通POJO，如User.java
// Mapper接口继承BaseMapper（MyBatis-Plus）或使用@Select等

验证结果

启动项目后,调用查询接口（如GET /user/list），日志会显示：

Logic SQL: SELECT * FROM user
Actual SQL: master ::: SELECT * FROM user  (写？读？)

若为读操作,实际路由应为slave0，且通过ShardingSphere代理自动修改为从库执行。

代码实现：动态数据源与读写路由（不使用中间件）

若项目不希望引入额外中间件,可通过Spring的AbstractRoutingDataSource实现：

步骤1：定义动态数据源类

public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDatabaseType(); // 从ThreadLocal获取
    }
}

步骤2：AOP切面实现自动切换

@Aspect
@Component
@Order(1)
public class DataSourceAspect {
    @Around("@annotation(readOnly)") // 自定义注解@ReadOnly
    public Object around(ProceedingJoinPoint joinPoint, ReadOnly readOnly) throws Throwable {
        DataSourceContextHolder.setDatabaseType(DatabaseType.SLAVE);
        try {
            return joinPoint.proceed();
        } finally {
            DataSourceContextHolder.clear();
        }
    }
}