ShardingSphere实战（4）- 广播表和默认数据源

news2025/1/11 14:22:31

上篇博客，我们讲了 ShardingSphere实战（3）- 快速实现分库分表，这篇博客，我们解决分库分表以后遗留的两个小问题。

一、广播表

1. 广播表介绍

广播表（Broadcast Table）是一种特殊的表类型，常见于分布式数据库系统中，如在Apache ShardingSphere等数据库中间件中被广泛应用。广播表的设计目的是为了处理那些数据量相对较小，但需要频繁参与跨分片查询或关联操作的表。

广播表的特点：
- 数据冗余：广播表在每一个数据分片（或数据库节点）中都有一个完整的副本，这意味着数据在每个节点上都是完全相同的。
- 读取优化：由于每个节点都有完整数据，对于涉及广播表的查询可以直接在本地节点完成，无需进行跨节点通信，从而提高查询效率。
- 更新控制：由于广播表的数据在所有节点上都需要保持一致，因此对广播表的更新操作需要被严格控制，以避免数据不一致的问题。
使用场景：
- 配置表：存储系统配置信息，如枚举值、状态码等，这类数据通常变化不大，但需要在查询时快速访问。
- 字典表：存储一些固定的对照关系，如地区代码与名称的对照表。
- 关联表：当一个表需要与多个分片的主表进行关联查询时，可以考虑使用广播表来减少跨分片的JOIN操作。

2. 广播表配置

基于上篇博客配置的前提下（上篇博客的最后放上了完整的配置，需要的可以去看看，这里就不重复写上去了），加上广播表的配置：

# 配置广播表
spring.shardingsphere.sharding.broadcast-tables=t_config

在这里插入图片描述

3. 测试

/**
     * 广播表测试-保存
     */
    @GetMapping("/test5")
    public String test5(@RequestParam("count") Integer count) {

        Date now = new Date();
        for (int i = 0; i < count; i++) {
            ConfigDO configDO = new ConfigDO();
            configDO.setId(this.getId());
            configDO.setRemark("remark" + i);
            configDO.setCreateTime(now);
            configDO.setLastModifyTime(now);
            configMapper.insertSelective(configDO);
        }
        return "success";
    }

运行结果：
在这里插入图片描述
ds-0.t_config 和 ds-1.t_config 表保存了相同的数据。

二、默认数据源

1. 为什么需要默认数据源

t_order 的数据量特比大，所以我们 分库分表
t_order_item 和 t_order 是关联关系，所以我们设置为 绑定表
t_config 数据量小，但是需要频繁参与跨分片查询或关联操作，所以我们设置为 广播表
但是有些表，它就是一张普通的表，不具备上面所说的属性，就希望像普通项目一样，正常增删改查，这时候指定默认数据源就派上用场了

2. 指定默认数据源配置

假如有部分表不需要分片配置，可以这样配置：
# 不需要分片的表配置
spring.shardingsphere.sharding.tables.t_user.actual-data-nodes=ds-0.t_user
spring.shardingsphere.sharding.tables.t_account.actual-data-nodes=ds-1.t_account
这样就可以指定 t_user 表路由到 ds-0 库中， t_account 表路由到 ds-1 库中。

如果其它未设置分片规则的表，都希望进入某一个默认库中，可以这样配置：
# 默认数据源配置
spring.shardingsphere.sharding.default-data-source-name=ds-0

三、完整配置

老规矩，下面是本篇博客关于ShardingSphere的完整配置：

# sharding-jdbc 水平分表策略
# 给数据源起别名，这里名称需要和下面的一致
spring.shardingsphere.datasource.names=ds-0,ds-1

# 配置数据源
spring.shardingsphere.datasource.ds-0.type=com.zaxxer.hikari.HikariDataSource
spring.shardingsphere.datasource.ds-0.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.ds-0.jdbc-url=jdbc:mysql://xxx:3316/ds-0?serverTimezone=UTC&useSSL=false
spring.shardingsphere.datasource.ds-0.username=xxx
spring.shardingsphere.datasource.ds-0.password=xxx
spring.shardingsphere.datasource.ds-1.type=com.zaxxer.hikari.HikariDataSource
spring.shardingsphere.datasource.ds-1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.shardingsphere.datasource.ds-1.jdbc-url=jdbc:mysql://xxx:3316/ds-1?serverTimezone=UTC&useSSL=false
spring.shardingsphere.datasource.ds-1.username=xxx
spring.shardingsphere.datasource.ds-1.password=xxx

####################### 配置分片表t_order #######################
# 指定真实数据节点
spring.shardingsphere.sharding.tables.t_order.actual-data-nodes=ds-$->{0..1}.t_order_$->{0..2}

### 分库策略
# 分库分片健
spring.shardingsphere.sharding.tables.t_order.database-strategy.inline.sharding-column=order_id
# 分库分片算法
spring.shardingsphere.sharding.tables.t_order.database-strategy.inline.algorithm-expression=ds-$->{order_id % 2}

### 分表策略
# 分表分片健
spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.sharding-column=order_id
# 分表算法
spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.algorithm-expression=t_order_$->{order_id % 3}


####################### 配置分片表t_order_item #######################
# 指定真实数据节点
spring.shardingsphere.sharding.tables.t_order_item.actual-data-nodes=ds-$->{0..1}.t_order_item_$->{0..2}

### 分库策略
# 分库分片健
spring.shardingsphere.sharding.tables.t_order_item.database-strategy.inline.sharding-column=order_id
# 分库分片算法
spring.shardingsphere.sharding.tables.t_order_item.database-strategy.inline.algorithm-expression=ds-$->{order_id % 2}

### 分表策略
# 分表分片健
spring.shardingsphere.sharding.tables.t_order_item.table-strategy.inline.sharding-column=order_id
# 分表算法
spring.shardingsphere.sharding.tables.t_order_item.table-strategy.inline.algorithm-expression=t_order_item_$->{order_id % 3}


# 绑定表关系
spring.shardingsphere.sharding.binding-tables=t_order,t_order_item
# 配置广播表
spring.shardingsphere.sharding.broadcast-tables=t_config

# 不需要分片的表配置
spring.shardingsphere.sharding.tables.t_user.actual-data-nodes=ds-0.t_user

# 默认数据源配置
spring.shardingsphere.sharding.default-data-source-name=ds-0

# 是否开启 SQL解析日志
spring.shardingsphere.props.sql.show=true

mybatis.mapper-locations=classpath:sqlmapper/*.xml