如何通过ShardingJDBC进行读写分离

news2025/3/12 12:32:56

背景信息：
1. 面对日益增加的系统访问量，数据库的吞吐量面临着巨大瓶颈。对于同一时刻有大量并发读操作和较少写操作类型的应用系统来说，将数据库拆分为主库和从库。其中主库负责处理事务性的增删改操作，从库负责处理查询操作，这样就能够有效的避免因数据更新导致的行锁，进而使得整个系统的查询性能得到极大的改善。
2. 那么我们在项目中，可以使用ShardingJDBC框架，通过Java代码来完成读写分离，这样就可以在执行select的时候查询从库，在执行insert、update、delete的时候，操作主库了。
ShardingJDBC的介绍
1. Sharding-JDBC定位为轻量级Java框架，在Java的JDBC层提供的额外服务。它使用客户端直连数据库，以jar包形式提供服务，无需额外部署和依赖，可理解为增强版的JDBC驱动，完全兼容JDBC和各种ORM框架。
  1. 适用于任何基于 JDBC 的 ORM 框架，如：JPA, Hibernate, Mybatis, Spring JDBC Template 或直接使用 JDBC
  2. 支持任何第三方的数据库连接池，如：DBCP, C3P0, BoneCP, HikariCP 等
  3. 支持任意实现 JDBC 规范的数据库，目前支持 MySQL，PostgreSQL，Oracle，SQLServer 以及任何可使用 JDBC 访问的数据库
2. 通过使用Sharding-JDBC可以在程序中轻松的实现数据库读写分离
环境准备
1. 部署主从复制的两台MySQL服务器
2. 并将MySQL服务正常启动
3. 在MySQL数据库中的主库中正常创建自己需要的数据库以及相关的数据库表，从库会自动同步相应的数据，所以不用操作从库

java项目使用Sharding-JDBC进行读写分离配置

在maven项目的pom.xml文件中增加Sharding-JDBC的maven坐标

<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
    <version>4.1.1</version>
</dependency>

在spring boot项目的application.yml中增加数据源的配置信息

spring:
#  datasource:
#    druid:
#      driver-class-name: com.mysql.cj.jdbc.Driver
#      url: jdbc:mysql://localhost:3333/study-pro?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
#      username: root
#      password: 123456

  shardingsphere:
    datasource:
      # 数据源的名称，可以随意定义，但是需要和下面所设定的配置一致
      names:
        master,slave
      # 主数据源
      master:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://192.168.xxx.xxx:3306/study-pro?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
        username: root
        password: 123456
      # 从数据源
      slave:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://192.168.xxx.xxx:3306/study-pro?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
        username: root
        password: 123456
    # 读写分离配置
    masterslave:
      # 负载均衡算法名称：轮询。如果有多个从库时的负载均衡策略。round_robin(轮询)和random(随机)
      load-balance-algorithm-type: round_robin
      # 最终的数据源名称
      name: shardingDataSource
      # 主库数据源名称
      master-data-source-name: master
      # 从库数据源名称列表，多个逗号分隔
      slave-data-source-names: slave
    props:
      sql:
        # 开启SQL显示，默认false
        show: true
  main:
    # 如果当前项目中存在同名的bean,后定义的bean会覆盖先定义的。因为一个同名的 dataSource 的bean在com.alibaba.druid.spring.boot.autoconfigure包下的DruidDataSourceAutoConfigure类加载时已经声明了，所以我们需要用到的是 ShardingJDBC包下的dataSource，所以我们需要配置上述属性，让后加载的覆盖先加载的
    allow-bean-definition-overriding: true

注意
1. 在application.yml文件中添加spring.main.allow-bean-definition-overriding=true的配置，这是为了如果当前项目中存在同名的bean,后定义的bean会覆盖先定义的
2. 若在sharding-jdbc、mybatis、druid中使用时，请选择下列jar包得搭配方式，不然将会导致sqlSessionFactory不能正常初始化，无法正常启动服务，可选择下列搭配方式
  1. sharding-jdbc4.0.0-RC1应搭配 mybatis、druid-spring-boot-starter使用
  2. sharding-jdbc4.0.0-RC2以上版本应搭配 mybatis、com.alibaba.druid（非spring boot版本）使用

功能测试
1. 在增删查改的逻辑下若控制台打印相应的sharding-jdbc的SQL日志，并且功能正常使用，则证明已经成功搭建好读写分离
官方参考文档
1. 概览 :: ShardingSphere (apache.org)
2. shardingsphere/examples at master · apache/shardingsphere (github.com)