SpringBoot集成ShardingJDBC实现MySQL读写分离

朱雀 2023-10-11 18:29 130阅读 0赞

再具体的实战之前，我们需要做一些准备工作：

*  1.Mysql的主从配置
    
     *  主库：负责写
     *  从库：负责读
 *  2.SpringBoot集成ShardingSphere

## 1.准备工作 ##

### 1.1.mysql设置主从数据库的同步 ###

我之前写过一篇文章，里面很详细的从原理到具体如何搭建，请大家移步至此：[点击此处访问][Link 1]

我创建了两个mysql服务：

*  3307：主库
 *  3308：从库

![在这里插入图片描述][6f0b8a4b98b3431ca5a11d5bf6ecd2b5.png_pic_center]

同时在主库里创建数据库：qw(名字自己随便取)，同时新增表：user  
![在这里插入图片描述][4d086a40f15b4fb2ba962baa34e9ba61.png_pic_center]

### 1.2 集成mybatis-plus ###

[点击此处查看][Link 2]

如果你已经完成了数据库的主从配置，那接下来我们就具体的开始看看读写分离是怎么实现的。

## 2.读写分离实战 ##

ShardingSphere是一套开源的分布式数据库中间件解决方案组成的生态圈，由于ShardingSphere是比较常用的分库分表工具，里面涉及到的东西也比较多，包含分库分表的策略，分片键的设置等等，所以我单独出了一篇文章，建议大家跟着操作一下：[点击此处查看][Link 3]

### 2.1 添加依赖 ###

<dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
            </dependency>
            
            <dependency>
                <groupId>cn.hutool</groupId>
                <artifactId>hutool-all</artifactId>
                <version>5.7.10</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>1.2.69</version>
            </dependency>
            
            <dependency>
                <groupId>org.apache.shardingsphere</groupId>
                <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
                <version>4.1.0</version>
            </dependency>

### 2.2 在application.yml中添加配置 ###

spring:
      shardingsphere:
        datasource:
          names:
            master,slave
          # 主数据源
          master:
            type: com.zaxxer.hikari.HikariDataSource
            driver-class-name: com.mysql.cj.jdbc.Driver
            username: root
            password: root
            jdbc-url: jdbc:mysql://192.168.1.2:3307/qw?autoReconnect=true&useUnicode=true&characterEncoding=utf-8&&zeroDateTimeBehavior=CONVERT_TO_NULL&&serverTimezone=GMT%2B8
          # 从数据源
          slave:
            type: com.zaxxer.hikari.HikariDataSource
            driver-class-name: com.mysql.cj.jdbc.Driver
            username: root
            password: root
            jdbc-url: jdbc:mysql://192.168.1.2:3308/qw?autoReconnect=true&useUnicode=true&characterEncoding=utf-8&&zeroDateTimeBehavior=CONVERT_TO_NULL&&serverTimezone=GMT%2B8
        masterslave:
          # 读写分离配置，设置负载均衡的模式为轮询
          load-balance-algorithm-type: round_robin
          # 最终的数据源名称
          name: dataSource
          # 主库数据源名称
          master-data-source-name: master
          # 从库数据源名称列表，多个逗号分隔
          slave-data-source-names: slave
        props:
          sql:
            show: true #开启SQL显示，默认false
      # 覆盖注册bean，后面创建数据源会覆盖前面创建的数据源
      main:
        allow-bean-definition-overriding: true

### 2.3 编写sql语句测试 ###

public interface TbUserMapper extends BaseMapper<TbUser> {
        
        @Select("select * from tb_user")
        List<TbUser> getAll();
    
        @Insert("INSERT INTO tb_user(user_name) VALUES(#{userName})")
        int insert(@Param("userName") String userName);
    
    }

@RestController
    public class TbUserController {
        
        @Autowired
        TbUserMapper tbUserMapper;
    
        @GetMapping("getAllUser")
        public Object getAllUser() {
        
            return tbUserMapper.getAll();
        }
    
        @GetMapping("addUser")
        public Object addUser() {
        
            return tbUserMapper.insert(Math.random() + "");
        }
    }

访问：http://localhost:8080/addUser  
![在这里插入图片描述][df9e9a11a0fc4a63845a49cc8854d7e0.png_pic_center]

访问：http://localhost:8080/getAllUser  
![在这里插入图片描述][499be59ed34546cdacd58733f46cfa9a.png_pic_center]

可以看出：插入数据执行的是主库，而查询执行的则是从库

[Link 1]: https://blog.csdn.net/zhiyikeji/article/details/121970369
[6f0b8a4b98b3431ca5a11d5bf6ecd2b5.png_pic_center]: https://img-blog.csdnimg.cn/6f0b8a4b98b3431ca5a11d5bf6ecd2b5.png#pic_center
[4d086a40f15b4fb2ba962baa34e9ba61.png_pic_center]: https://img-blog.csdnimg.cn/4d086a40f15b4fb2ba962baa34e9ba61.png#pic_center
[Link 2]: https://blog.csdn.net/zhiyikeji/article/details/116258935
[Link 3]: https://blog.csdn.net/zhiyikeji/article/details/125353932
[df9e9a11a0fc4a63845a49cc8854d7e0.png_pic_center]: https://img-blog.csdnimg.cn/df9e9a11a0fc4a63845a49cc8854d7e0.png#pic_center
[499be59ed34546cdacd58733f46cfa9a.png_pic_center]: https://img-blog.csdnimg.cn/499be59ed34546cdacd58733f46cfa9a.png#pic_center