SpringBoot項目中使用Sharding-JDBC實現讀寫分離的詳細步驟

更新時間：2024年08月22日 11:04:34 作者：戰(zhàn)族狼魂

Sharding-JDBC是一個分布式數據庫中間件,它不僅支持數據分片,還可以輕松實現數據庫的讀寫分離,本文介紹如何在Spring Boot項目中集成Sharding-JDBC并實現讀寫分離的詳細步驟,需要的朋友可以參考下

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之后，開發(fā)者不需要做特別的操作，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方法中的查詢操作會根據配置路由到從庫。