美文网首页框架原理SpringJava
SpringBoot使用Sharding-JDBC读写分离

SpringBoot使用Sharding-JDBC读写分离

作者: 月亮老师_61ce | 来源:发表于2019-02-13 21:39 被阅读121次

    摘要: 本文介绍SpringBoot使用当当Sharding-JDBC进行读写分离。 1.有关Sharding-JDBC 本文还是基于当当网Sharding-Jdbc的依赖,与上一篇使用Sharding-Jdbc进行分库分表依赖一致,并且本文大致内容与上一篇文章相似,建议先查看我的另一篇在查看这篇会简单许多,传送门《SpringBoot使用Sharding-JDBC分库分表》。

    本文介绍SpringBoot使用当当Sharding-JDBC进行读写分离。

    1.有关Sharding-JDBC

    本文还是基于当当网Sharding-Jdbc的依赖,与上一篇使用Sharding-Jdbc进行分库分表依赖一致,并且本文大致内容与上一篇文章相似,建议先查看我的另一篇在查看这篇会简单许多,传送门《SpringBoot使用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

    相关文章

      网友评论

        本文标题:SpringBoot使用Sharding-JDBC读写分离

        本文链接:https://www.haomeiwen.com/subject/mukjeqtx.html