shardingjdbc实现读写分离

码酱 2021-02-12

1386

接上一篇mysql8.0主从配置，我们来看看mysql的读写分离。

一般读写分离，主库做增删改等操作，从库做查询操作。如果查询多的话，可以配置一主多从。SHARDINGJDBC最开始是由当当网开始的一个开源项目。由于反响好，直接进入apache的孵化项目，更名为 SHARDINGSPHERE。

github项目地址： https://github.com/apache/incubator-shardingsphere

一、准备工作

1，我们先在主库创建一个user表，插入一条记录

2，查询从库

3，为了方便操作，我们直接在客户端navicat上连接主从库

准备工作已经大致ok了...

进入正题

二、使用spring boot整合shardingjdbc

1，pom文件引入shardingjdbc的jar

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

2，配置application.yml文件

spring:
  shardingsphere:
    props:
      sql:
        show: true
    datasource:
      names: master,slave   #对应下面主从库
      master:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://192.168.1.12:3306/www?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai
        username: root
        password: 123456
      slave:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://192.168.1.8:3306/www?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai
        username: root
        password: 123456
    masterslave:
      load-balance-algorithm-type: round_robin  #负载 轮询，当你有多个从库或者主库时
      name: ms
      master-data-source-name: master           #设置主库
      slave-data-source-names: slave            #设置从库

很简单吧，就加了些配置信息，SHARDINGSPHERE会帮你自动切库，当你做增删改时，会直接操作主库，当你做查询操作时，会直接查询从库，这里数据库压力就可以平摊出来了而我们一般的系统都是增删改少，查询多，就可以多设置几个从库。

查询所有

@Component
@SpringBootTest(classes = App.class)
@RunWith(SpringRunner.class)
public class ShardingJdbcTest {
    @Autowired
    private InfoService infoService;
    @Test
    public void listInfo(){
        List<UserInfo> list = infoService.list();
        list.stream().forEach(r-> System.out.println(r.toString()));
    }
}

可以从日志看出，查询操作的是从库slave

插入一条数据

    @Test
    public void addOneInfo(){
        UserInfo userInfo = new UserInfo();
        userInfo.setName("diku");
        userInfo.setPassword("888888");
        userInfo.setAge(17);
        userInfo.setSex("1");
        infoService.save(userInfo);
    }

可以从日志看出，新增操作的是主库master

查询刚刚插入的数据

    @Test
    public void getOneInfoByName(){
        QueryWrapper<UserInfo> query = new QueryWrapper<>();
        query.eq("name","diku");
        UserInfo u = infoService.getOne(query);
        System.out.println(u);
    }

到这里，我们就基本实现了spring boot整合shardingjdbc的读写分离操作了。

数据库

文章转载自码酱，如果涉嫌侵权，请发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。

shardingjdbc实现读写分离

评论