分库分表(3) ---SpringBoot + ShardingSphere 实现读写分离

分库分表(3)---ShardingSphere实现读写分离

有关ShardingSphere概念前面写了两篇博客:

1、分库分表(1) --- 理论

2、 分库分表(2) --- ShardingSphere(理论)

下面就这个项目做个团体简单介绍，并在文章最下方附上项目Github地址。

一、项目概述

1、技能架构

项目总体技能选型

1. <code>SpringBoot2.0.6 + shardingsphere4.0.0-RC1 + Maven3.5.4 + MySQL + lombok(插件)</code>

复制代码

2、项目阐明

场景 如果实际项目中Mysql是 Master-Slave (主从)摆设的，那么数据生存到Master库，Master库数据同步数据到Slave库，数据读取到Slave库，

如许可以减缓数据库的压力。

3、数据库设计

我们这个项目中Mysql服务器并没有实现主从摆设,而是同一个服务器创建两个库，一个当做Master库，一个当做Slave库。所以这里是不能实现的功能就是Master库

新增数据自动同步到Slave库。如许也更有利于我们测试看结果。

Master库

Slave库

从两幅图中可以看出，我这里在同一个服务器建两个数据库来模仿主从数据库。为了方便看测试结果，这里主从数据库中的数据是不一样的。

二、焦点代码

阐明 完整的代码会放到GitHub上，这里只放一些焦点代码。

1、pom.xml

1. <code> <properties>
2. <java.version>1.8</java.version>
3. <mybatis-spring-boot>2.0.1</mybatis-spring-boot>
4. <druid>1.1.16</druid>
5. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
6. </properties>
8. <dependencies>
9. <dependency>
10. <groupId>org.springframework.boot</groupId>
11. <artifactId>spring-boot-starter-web</artifactId>
12. </dependency>
13. <dependency>
14. <groupId>org.mybatis.spring.boot</groupId>
15. <artifactId>mybatis-spring-boot-starter</artifactId>
16. <version>${mybatis-spring-boot}</version>
17. </dependency>
18. <!--mybatis驱动-->
19. <dependency>
20. <groupId>mysql</groupId>
21. <artifactId>mysql-connector-java</artifactId>
22. </dependency>
23. <!--druid数据源-->
24. <dependency>
25. <groupId>com.alibaba</groupId>
26. <artifactId>druid-spring-boot-starter</artifactId>
27. <version>${druid}</version>
28. </dependency>
29. <!--shardingsphere最新版本-->
30. <dependency>
31. <groupId>org.apache.shardingsphere</groupId>
32. <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
33. <version>4.0.0-RC1</version>
34. </dependency>
35. <!--lombok实体工具-->
36. <dependency>
37. <groupId>org.projectlombok</groupId>
38. <artifactId>lombok</artifactId>
39. </dependency>
40. </dependencies></code>

复制代码

2、application.properties

1. <code>server.port=8088
2. #指定mybatis信息
3. mybatis.config-location=classpath:mybatis-config.xml
5. spring.shardingsphere.datasource.names=master,slave0
6. # 数据源 主库
7. spring.shardingsphere.datasource.master.type=com.alibaba.druid.pool.DruidDataSource
8. spring.shardingsphere.datasource.master.driver-class-name=com.mysql.jdbc.Driver
9. spring.shardingsphere.datasource.master.url=jdbc:mysql://localhost:3306/master?characterEncoding=utf-8
10. spring.shardingsphere.datasource.master.username=root
11. spring.shardingsphere.datasource.master.password=123456
12. # 数据源 从库
13. spring.shardingsphere.datasource.slave0.type=com.alibaba.druid.pool.DruidDataSource
14. spring.shardingsphere.datasource.slave0.driver-class-name=com.mysql.jdbc.Driver
15. spring.shardingsphere.datasource.slave0.url=jdbc:mysql://localhost:3306/slave?characterEncoding=utf-8
16. spring.shardingsphere.datasource.slave0.username=root
17. spring.shardingsphere.datasource.slave0.password=123456
19. # 读写分离
20. spring.shardingsphere.masterslave.load-balance-algorithm-type=round_robin
21. spring.shardingsphere.masterslave.name=ms
22. spring.shardingsphere.masterslave.master-data-source-name=master
23. spring.shardingsphere.masterslave.slave-data-source-names=slave0
24. #打印sql
25. spring.shardingsphere.props.sql.show=true
26. </code>

复制代码

Sharding-JDBC可以通过Java，YAML，Spring定名空间和Spring Boot Starter四种方式设置，开发者可根据场景选择适合的设置方式。详细可以看官网。

3、UserController

1. <code>@RestController
2. public class UserController {
4. @Autowired
5. private UserService userService;
6. /**
7. * @Description: 生存用户
8. */
9. @PostMapping("save-user")
10. public Object saveUser() {
11. return userService.saveOne(new User("小小", "女", 3));
12. }
13. /**
14. * @Description: 获取用户列表
15. */
16. @GetMapping("list-user")
17. public Object listUser() {
18. return userService.list();
19. }
20. }</code>

复制代码

三、测试验证

1、读数据

我们可以发现读取的数据是Slave库的数据。我们再来看控制台打印的SQL。可以看到读操作是Slave库。

2、写数据

哀求

1. <code>localhost:8088/save-user?name=小小&sex=女&age=3</code>

复制代码

查看Mater数据库

发现Master数据库已经多了一条数据了，再看控制台打印的SQL。

这个时间如果去看Slave库的话这条新增的数据是没有的，由于没有同步已往。

Github地址：https://github.com/yudiandemingzi/spring-boot-sharding-sphere

参考

1、ShardingSphere中文文档

2、ShardingSphere官网

3、Shardingsphere Github库

1. <code> 我信赖，无论今后的门路多么崎岖，只要捉住本日，迟早会在奋斗中尝到人生的甘甜。捉住人生中的一分一秒，胜过虚度中的一月一年！(18）</code>

复制代码

来源：https://www.cnblogs.com/qdhxhz/p/11656205.html