基于ShardingJDBC进行数据库读写分离

一、引入依赖

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

<dependency>
  	<groupId>org.apache.shardingsphere</groupId>
  	<artifactId>sharding-jdbc-spring-boot-starter</artifactId>
  	<version>4.0.0-RC1</version>
</dependency>
复制代码

二、增长读写分离的配置

项目bootstrap.yml增长读写分离的配置，如下是dev环境的配置：

spring:
 shardingsphere:
 datasource:
 names: master, slave
 master:
 type: com.zaxxer.hikari.HikariDataSource
 driver-class-name: com.mysql.cj.jdbc.Driver
 jdbc-url: jdbc:mysql://localhost:3306/testdb
 username: ''
 password: ''
 slave:
 type: com.zaxxer.hikari.HikariDataSource
 driver-class-name: com.mysql.cj.jdbc.Driver
 jdbc-url: jdbc:mysql://localhost:3306/testdb1
 username: ''
 password: ''
 masterslave:
 name: ms
 master-data-source-name: master
 slave-data-source-names: slave
复制代码

三、演示效果

3.一、新建测试表

dev环境实际关闭了主从同步，经过手动修改从库的数据来演示效果

CREATE TABLE `t1` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL DEFAULT 'testname',
  `age` int(10) unsigned NOT NULL DEFAULT '30',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- 主库插入的数据
INSERT INTO `testdb`.`t1`(`id`, `name`, `age`) VALUES (1, 'wangao', 10);

-- 从库插入的数据
INSERT INTO `testdb1`.`t1`(`id`, `name`, `age`) VALUES (1, 'wangao', 20);
复制代码

3.二、编写数据库访问接口

@Entity
@Table(name = "t1")
@Data
public class User {

    @Id
    @Column(name = "id")
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;
    
    @Column(name = "name")
    private String name;
    
    @Column(name = "age")
    private Integer age;
    
}
复制代码

public interface UserDao extends JpaRepository<User, Integer> {
    
}
复制代码

3.三、保存数据

@Test
public void base() {
  	User user = new User();
  	user.setName("wangao");
  	user.setAge(10);
  	user = userDao.save(user);
  	System.out.println(user);
}
复制代码

save方法能够正常返回带自增id的对象：

主库中有新插入的数据：

从库中没有数据（主从同步关闭）：

3.四、读取数据

读取id为1的数据，注意此时是从从库中获取，年龄为20

@Test
public void readSlave() {
 		User user = userDao.findById(1).get();
  	System.out.println(user);
}
复制代码

3.五、强制从主库读取

部分状况须要强制从主库进行读取。依旧读取id为1的数据，注意此时是从主库中获取，年龄为10：

@Test
public void readMaster() {
  	HintManager manager = HintManager.getInstance();
  	manager.setMasterRouteOnly();
  	User user = userDao.findById(1).get();
  	System.out.println(user);
  	//必定记得最后close
  	manager.close();
}
复制代码

3.六、特别注意

官方文档关于读写分离有这样一段话：

这里须要注意的是，默认配置spring.jpa.open-in-view=true，此时一个Restful请求对数据库的链接是同一个，若是存在写入操做，则后续读操做均从主库读取

@RestController
public class UserController {
    
    private final UserDao userDao;
    
    public UserController(UserDao userDao) {
        this.userDao = userDao;
    }
    
    @GetMapping("api/user/{id}")
    public User get(@PathVariable int id) {
      	//进行写入操做
        User user = new User();
        user.setName("奥利奥");
        user.setAge(30);
        user = userDao.save(user);
        System.out.println(user);
        //进行读取操做
        return userDao.findById(id).orElse(null);
    }
}
复制代码

若是将配置改为spring.jpa.open-in-view=false，此时每一个操做数据库的链接都会从链接池中获取，这样读取的操做会从从库读取：

四、参考

更多细节能够参考sharding-jdbc的官方网站获取信息：

shardingsphere.apache.org/document/cu…