SpringBoot项目中使用Sharding-JDBC实现读写分离的详细步骤_Java

1. 引入依赖

在spring boot项目的pom.xml文件中引入sharding-jdbc的依赖：

<dependency>
    <groupid>org.apache.shardingsphere</groupid>
    <artifactid>sharding-jdbc-spring-boot-starter</artifactid>
    <version>5.1.2</version> <!-- 选择合适的版本 -->
</dependency>

2. 配置数据源

sharding-jdbc支持通过yaml、properties、或者spring boot的application.yml/application.properties文件来配置数据源。这里以application.yml为例。

假设你有一个主库和两个从库，master是主库，slave0和slave1是从库。

spring:
  shardingsphere:
    datasource:
      names: master,slave0,slave1
      master:
        type: com.zaxxer.hikari.hikaridatasource
        driver-class-name: com.mysql.cj.jdbc.driver
        jdbc-url: jdbc:mysql://localhost:3306/master_db?servertimezone=utc&usessl=false
        username: root
        password: root
      slave0:
        type: com.zaxxer.hikari.hikaridatasource
        driver-class-name: com.mysql.cj.jdbc.driver
        jdbc-url: jdbc:mysql://localhost:3306/slave0_db?servertimezone=utc&usessl=false
        username: root
        password: root
      slave1:
        type: com.zaxxer.hikari.hikaridatasource
        driver-class-name: com.mysql.cj.jdbc.driver
        jdbc-url: jdbc:mysql://localhost:3306/slave1_db?servertimezone=utc&usessl=false
        username: root
        password: root
 
    rules:
      replica-query:
        data-sources:
          pr_ds:
            primary-data-source-name: master
            replica-data-source-names:
              - slave0
              - slave1
            load-balancer-name: round_robin  # 负载均衡策略
        load-balancers:
          round_robin:
            type: round_robin  # 轮询负载均衡策略

3. 配置sharding-jdbc相关参数

可以通过配置spring.shardingsphere前缀下的参数来定制sharding-jdbc的行为。常用的配置包括：

primary-data-source-name: 指定主数据库
replica-data-source-names: 指定从数据库
load-balancer-name: 选择负载均衡策略

4. 配置spring boot的事务管理

为了保证在读写分离的情况下事务的一致性，需要配置spring的事务管理器。sharding-jdbc内部已经封装好了事务管理，通常情况下不需要额外配置。

如果有特殊需求，可以自定义事务管理器。例如：

@configuration
public class transactionconfig {
 
    @bean
    public platformtransactionmanager transactionmanager(datasource datasource) {
        return new datasourcetransactionmanager(datasource);
    }
}

5. 使用sharding-jdbc进行数据库操作

使用sharding-jdbc之后，开发者不需要做特别的操作，sharding-jdbc会自动根据sql的类型（查询、插入、更新、删除）选择合适的数据库进行操作。例如：

@service
public class userservice {
 
    @autowired
    private usermapper usermapper;
 
    @transactional
    public void createuser(user user) {
        usermapper.insert(user);  // 插入操作会走主库
    }
 
    public user getuserbyid(long id) {
        return usermapper.selectbyid(id);  // 查询操作会走从库
    }
}

在上述代码中，createuser方法中的插入操作会自动路由到主库，而getuserbyid方法中的查询操作会根据配置路由到从库。