ShardingSphere读写分离

读写分离是为了确保数据库产品的稳定性，很多数据库拥有双机热备功能。

原理：让主数据库（master）处理事务性增、改、删操作，而从数据库（slave）处理select查询操作。

注意：

• Sharding-JDBC 通过 sql 语句语义分析，实现读写分离过程，不会做数据同步。
• 数据同步需要数据库搭建主从集群架构，来做数据之间的主从同步。

关于数据库的主从集群架构自行搭建，下面从 Sharding-JDBC 的应用层来做数据的读写分离。

一、读写分离

1、application.properties 配置文件

在 application.properties 配置文件中进行

# 配置真实数据源
spring.shardingsphere.datasource.names=db1,db2
# 配置第1个数据源
spring.shardingsphere.datasource.db1.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.db1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.db1.url=jdbc:mysql://localhost:3306/sharding_db1?useUnicode=true&characterEncoding=utf8&useSSL=true&serverTimezone=GMT
spring.shardingsphere.datasource.db1.username=root
spring.shardingsphere.datasource.db1.password=123456
# 配置第2个数据源
spring.shardingsphere.datasource.db2.type=com.alibaba.druid.pool.DruidDataSource
spring.shardingsphere.datasource.db2.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.db2.url=jdbc:mysql://localhost:3306/sharding_db2?useUnicode=true&characterEncoding=utf8&useSSL=true&serverTimezone=GMT
spring.shardingsphere.datasource.db2.username=root
spring.shardingsphere.datasource.db2.password=123456

##配置主从逻辑数据源，读写分离规则， db1主库，db2从库
spring.shardingsphere.sharding.master-slave-rules.ds0.master-data-source-name=db1
spring.shardingsphere.sharding.master-slave-rules.ds0.slave-data-source-names[0]=db2
#基于读写分离的表分片
spring.shardingsphere.sharding.tables.course.actual-data-nodes=ds0.course_$->{1..2}

# 指定表的主键生成策略
spring.shardingsphere.sharding.tables.course.key-generator.column=id
spring.shardingsphere.sharding.tables.course.key-generator.type=SNOWFLAKE
spring.shardingsphere.sharding.tables.course.key-generator.props.worker.id=1
#表策略
spring.shardingsphere.sharding.tables.course.table-strategy.inline.sharding-column=id
spring.shardingsphere.sharding.tables.course.table-strategy.inline.algorithm-expression=course_$->{id%2+1}

# 打开shardingsphere的sql日志输出。
spring.shardingsphere.props.sql.show=true

# 一个实体类对应两张表，覆盖
spring.main.allow-bean-definition-overriding=true
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

2、测试

1）保存

   @Test
    public void testSave() throws InterruptedException {
        for (int i = 0; i < 4; i++) {
            Course course = new Course();
            course.setGmtCreate(new Date());
            course.setName("java");
            course.setUserId(1001L + i);
            course.setStatus("1");

            TimeUnit.MILLISECONDS.sleep(50);
            int count = courseMapper.insert(course);
            System.out.println("id ->" + course.getId());
        }

    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

从日志中看到，保存操作的数据库都是主库（db1）。

2）查询

    @Test
    public void testIN() {
        QueryWrapper<Course> wrapper = new QueryWrapper<Course>();
        wrapper.in("id",1515577381737865217L, 1515492164109004802L, 1515576508269936641L);
        List<Course> courses = courseMapper.selectList(wrapper);
        System.out.println(courses.size());
        courses.forEach(course -> System.out.println(course));
    }
1
2
3
4
5
6
7
8

从日志中看到，查询操作的数据库都是从库（db2）。

因为 id=1515577381737865217记录在主库（db1）中。数据还没有同步到从库（db2），所以查不到。

– 求知若饥，虚心若愚。