java使用spring实现读写分离的示例代码

Sure! 首先，我们来了解一下读写分离。

读写分离，顾名思义，就是将数据库中的读写操作分离开来。通俗点讲，就是在读多写少的场景下，通过将读操作分别发送到不同的数据库实例上，减轻数据库读请求的压力，提高系统处理能力。

接下来，我们一起来看看 Java 如何使用 Spring 实现读写分离。

前置条件

在开始编写示例之前，需要确保你已经搭建好了如下环境：

1. Java JDK 1.8 及以上版本。
2. Spring Framework 5.2.5 及以上版本。
3. Maven 3.3.9 及以上版本。
4. MySQL 数据库。

此外，此文档中会使用到以下几个概念：

1. master 数据库：负责写操作的数据库，同时也兼顾读操作。
2. slave 数据库：负责读操作的数据库。

导入相关依赖

为了正常执行此示例，需要在 pom.xml 文件中添加以下依赖：

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

<dependency>
   <groupId>mysql</groupId>
   <artifactId>mysql-connector-java</artifactId>
   <version>${mysql.version}</version>
</dependency>

<dependency>
   <groupId>io.shardingjdbc</groupId>
   <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
   <version>${sharding-jdbc.version}</version>
</dependency>

不同版本的 Sharding-Jdbc 可能会对应不同的版本号，这里以 4.1.1 为例进行说明。同时，如果使用的是 Spring Boot，不需要进行 Sharding-Jdbc 额外的配置。

编写 Sharding-Jdbc 配置

Spring 集成 Sharding-Jdbc 之后，需要在项目的 application.yml 中进行配置。

spring:
  shardingsphere:
    datasource:
      names: master,slave0,slave1
      master:
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://localhost:3306/master?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
        username: root
        password: root
      slave0:
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://localhost:3307/slave0?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
        username: root
        password: root
      slave1:
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://localhost:3308/slave1?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
        username: root
        password: root
    masterslave:
      name: ms
      master-data-source-name: master
      slave-data-source-names: slave0,slave1

配置文件中，masterslave 部分是本示例实现读写分离的重点。其中，

• ms 为主从数据源的名称，你可以自定义。这里设置为 ms。
• master-data-source-name 是 master 数据库的数据源名称。
• slave-data-source-names 是两个 slave 数据库的数据源名称。

需要注意的是，masterslave 之后，还需要设置好对应的 Sharding-Jdbc 数据源类型和规则。

  type: org.apache.shardingsphere.api.config.masterslave.MasterSlaveRuleConfiguration
  masterDataSourceName: master
  slaveDataSourceNames:
    - slave0
    - slave1
  loadBalanceAlgorithmType: round_robin

在此示例中，我们将 master 数据源和 slave 数据源设置成了读写分离的数据源类型，同时使用了基于轮询（round_robin）的负载均衡策略。

编写实例代码

在配置文件中编写好 Sharding-Jdbc 所需要的配置内容之后，就可以在 Java 代码中使用了。下面是几个使用读写分离技术的示例：

示例 1：使用 JdbcTemplate 进行 CURD

@Repository
public class UserRepository {
    private final JdbcTemplate jdbcTemplate;

    @Autowired
    public UserRepository(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public List<User> findAll() {
        String sql = "select * from user";
        return jdbcTemplate.query(sql, new Object[]{}, new BeanPropertyRowMapper<>(User.class));
    }

    public User findByUserName(String userName) {
        String sql = "select * from user where user_name = ?";
        return jdbcTemplate.queryForObject(sql, new Object[]{userName}, new BeanPropertyRowMapper<>(User.class));
    }

    public int add(User user) {
        String sql = "INSERT INTO user(user_name, pass_word, salt) VALUES(?, ?, ?)";
        return jdbcTemplate.update(sql, user.getUserName(), user.getPassWord(), user.getSalt());
    }
}

上述代码中，我们使用了 JdbcTemplate 框架，实现了对数据库的 CURD 操作。由于我们在配置文件中已经开启了读写分离，因此在进行查询操作时，本类中所有的 select 语句将会被路由到 slave 数据库进行操作，而因此在添加用户信息等写操作时，则自动路由到 master 数据库中进行操作。

示例 2：使用 Jpa 进行 CURD

@Repository
public interface UserRepository extends JpaRepository<User, Long> {

}

由于我们已经在配置文件中开启了读写分离和路由规则，因此在使用 Jpa 时也无需对此进行明确的指定，直接进行操作即可。

结束语

至此，我们将 Java 使用 Spring 实现读写分离的过程和相关示例进行了详细的说明。在编写实际项目时，你可以将示例作为参考，按照实际情况进行代码的编写和优化。