SpringBoot使用Sharding-JDBC读写分离

329 阅读3分钟

1.有关Sharding-JDBC

本文还是基于当当网Sharding-Jdbc的依赖

这里需要特殊介绍的是,使用Sharding-JDBC进行读写分离的时候,只允许设置一个主库,从库的话可以设置多个,访问策略的话从源码上看只有两种轮询(ROUND_ROBIN)和随机(RANDOM)。

源码代码如下:

2.本文场景

由于本地环境并没有使用Mysql主从复制,只是创建了三个库,其中database0作为主库,database1和database2作为从库。主库进行增删改操作,从库进行查询操作,如下图为本文数据库的三个表。

如上图分别是三个数据库中的user表,其中master-user为database0数据库中的user表,salve-user1为database1中的user表,salve-user2为database2中的user表。

3.代码实现

本文使用SpringBoot2.0.3,SpringData-JPA,Druid连接池,和当当的sharding-jdbc。

3.1 建表SQL

创建表和数据库的SQL如下所示,这里默认在从库内分别插入了一条数据,name值分别存放dalaoyang1和dalaoyang2便于区分。

3.2 依赖文件

新建项目,依赖文件还是当当的sharding-jdbc-core依赖和druid连接池,完整pom文件代码如下所示。


3.3 配置信息

在配置信息中配置了三个数据库的信息和JPA的简单配置。

3.4 启动类

上一篇文章说到在启动类加入了@EnableAutoConfiguration去除数据库自动配置,当时也没太注意,其实可以直接在@SpringBootApplication注解上去除数据库自动配置,剩下的和上一篇一样,使用@EnableTransactionManagement开启事务,使用@EnableConfigurationProperties注解加入配置实体,启动类完整代码如下所示。

3.5 实体类和数据库操作层

User实体类。

UserRepository类。

3.6 数据库参数类

数据库配置类,Database0Config。

数据库配置类,Database1Config。

数据库配置类,Database2Config。


3.7 读写分离配置

创建一个DataSourceConfig类来设置读写分离,这里其实也与分库分表类似,也可以在分库分表的基础上进行读写分离,需要创建一个Map集合来接收从库。在创建数据源时需要传入五个参数,分别是:

•name:数据源名称

•masterDataSourceName:主库数据源名称

•masterDataSource:主数据源

•slaveDataSourceMap:从数据源集合

•strategyType:访问策略 当然,也可以使用其他方法创建数据源,本文代码如下:

3.8 Controller Controller

做为测试类,创建两个方法,save方法和getAll方法,其中:

•save方法用于测试主库的插入和修改

•getAll方法用于测试读数据 UserController类如下所示。

4.测试

4.1 测试主库

使用postman访问http://localhost:8080/save,控制台如图所示。

再次访问,如图。

主键冲突了,其实这是由于插入的时候使用的database0,但是查询使用的是database1和database2,但是我在从库内并没有ID是100的数据,所以JPA判定我为插入,但是数据库内缺有这样的数据。 我们接下来测试一下查询。访问http://localhost:8080/getAll

再次访问,如图。

证明从库的读取是正常的,接下来修改从库的ID为100。然后访问http://localhost:8080/save,查看控制台如图。

因为存在了ID为100的数据,所以SQL为修改语句。

5.源码

源码地址:https://gitee.com/dalaoyang/springboot_learn/tree/master/springboot2_shardingjdbc_dxfl