ShardingSphere应用专题--4.1.1版本--Sharding-JDBC读写分离+分库分表（七）

妖狐艹你老母 2022-11-14 13:16 258阅读 0赞

### 前言： ###

1.基础的环境介绍请移步[ShardingSphere应用专题–4.1.1版本–sharding jdbc环境搭建（四）][ShardingSphere_4.1.1_sharding jdbc]  
你可以同时打开两个页面，避免因查找原始配置上下翻动。

2.ShardingSphere[官方文档][Link 1]更新不及时，很容易踩坑。贴出的4.x版本文档实际是4.0.1版本的，如果你准备使用该版本可以参考官方文档。本文使用的是此时最新的正式版本4.1.1版本，配置与官方文档配置不同。事实上，源码中有非常详细的版本配置文档，本文也是参考4.1.1 tag的源码配置。

3.ShardingSphere各版本差异很大，甚至核心依赖的包名都不一样，使用时，一定要确认使用哪个版本，目前调研的结果：3.x、4.0.1、4.1.1、5.0.0-alpha都存在很大的配置差异

4.底层的逻辑在[ShardingSphere应用专题–4.1.1版本–Sharding-JDBC分库分表（六）][ShardingSphere_4.1.1_Sharding-JDBC]已经说得很清楚，**本文主要是介绍应用级别的配置**

### 读写分离+分库分表代码实现 ###

#### （1）数据库sql及pom文件 ####

参考ShardingSphere应用专题–4.1.1版本–Sharding-JDBC分库分表（六）的[数据库sql][sql]及[pom文件][pom]

#### （2）添加读写分离+分库分表环境配置application-sharding-sub-db-tb-rw.properties ####

#打印sql
    spring.shardingsphere.props.sql.show=true
    #设置单次请求可适用的最大线程数，以决定是线程限制还是内存限制。增大该参数可提高数据库元数据加载速度（默认为1）
    spring.shardingsphere.props.max.connections.size.per.query=3
    
    spring.shardingsphere.datasource.names=master0,slave0,master1,slave1
    
    spring.shardingsphere.datasource.master0.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.shardingsphere.datasource.master0.type=com.zaxxer.hikari.HikariDataSource
    spring.shardingsphere.datasource.master0.jdbc-url=jdbc:mysql://localhost:4406/mydb0?characterEncoding=utf-8
    spring.shardingsphere.datasource.master0.username=root
    spring.shardingsphere.datasource.master0.password=111
    
    spring.shardingsphere.datasource.slave0.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.shardingsphere.datasource.slave0.type=com.zaxxer.hikari.HikariDataSource
    spring.shardingsphere.datasource.slave0.jdbc-url=jdbc:mysql://localhost:5506/mydb0?characterEncoding=utf-8
    spring.shardingsphere.datasource.slave0.username=root
    spring.shardingsphere.datasource.slave0.password=111
    
    spring.shardingsphere.datasource.master1.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.shardingsphere.datasource.master1.type=com.zaxxer.hikari.HikariDataSource
    spring.shardingsphere.datasource.master1.jdbc-url=jdbc:mysql://localhost:4406/mydb1?characterEncoding=utf-8
    spring.shardingsphere.datasource.master1.username=root
    spring.shardingsphere.datasource.master1.password=111
    
    spring.shardingsphere.datasource.slave1.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.shardingsphere.datasource.slave1.type=com.zaxxer.hikari.HikariDataSource
    spring.shardingsphere.datasource.slave1.jdbc-url=jdbc:mysql://localhost:5506/mydb1?characterEncoding=utf-8
    spring.shardingsphere.datasource.slave1.username=root
    spring.shardingsphere.datasource.slave1.password=111
    
    #配置没有设置分片规则的表（必须设置，否则没有配置分片规则的表将随机到同的库中，由于表缺失造成错误）
    spring.shardingsphere.sharding.broadcast-tables=bill_item
    
    #设置默认分库策略（大批量的表使用同一套分库策略的时候使用，比如使用id，这里只是作为一种配置情况展示）
    spring.shardingsphere.sharding.default-database-strategy.inline.sharding-column=bill_amount
    spring.shardingsphere.sharding.default-database-strategy.inline.algorithm-expression=master$->{ bill_amount % 2}
    #根据id分表
    spring.shardingsphere.sharding.tables.bill.actual-data-nodes=master$->{ 0..1}.bill_$->{ 0..1}
    spring.shardingsphere.sharding.tables.bill.table-strategy.inline.sharding-column=id
    spring.shardingsphere.sharding.tables.bill.table-strategy.inline.algorithm-expression=bill_$->{ id % 2}
    
    spring.shardingsphere.sharding.tables.bill.key-generator.column=id
    spring.shardingsphere.sharding.tables.bill.key-generator.type=SNOWFLAKE
    spring.shardingsphere.sharding.tables.bill.key-generator.props.worker.id=123
    
    #指定master0为主库，slave0为它的从库
    spring.shardingsphere.sharding.master-slave-rules.master0.master-data-source-name=master0
    spring.shardingsphere.sharding.master-slave-rules.master0.slave-data-source-names=slave0
    #指定master1为主库，slave1为它的从库
    spring.shardingsphere.sharding.master-slave-rules.master1.master-data-source-name=master1
    spring.shardingsphere.sharding.master-slave-rules.master1.slave-data-source-names=slave1

关于读写分离的配置说明参阅：[ShardingSphere应用专题–4.1.1版本–Sharding-JDBC读写分离（五）][ShardingSphere_4.1.1_Sharding-JDBC 1]  
关于分库分表的配置说明参阅：[ShardingSphere应用专题–4.1.1版本–Sharding-JDBC分库分表（六）][ShardingSphere_4.1.1_Sharding-JDBC]

具体的测试就不贴图了，基本上就是在分库分表的基础上，增加了读写分类的策略。

### 读写分离+分库分表详细示例 ###

spring.shardingsphere.datasource.names= #数据源名称，多数据源以逗号分隔
    
    spring.shardingsphere.datasource.<data-source-name>.type= #数据库连接池类名称
    spring.shardingsphere.datasource.<data-source-name>.driver-class-name= #数据库驱动类名
    spring.shardingsphere.datasource.<data-source-name>.url= #数据库url连接
    spring.shardingsphere.datasource.<data-source-name>.username= #数据库用户名
    spring.shardingsphere.datasource.<data-source-name>.password= #数据库密码
    spring.shardingsphere.datasource.<data-source-name>.xxx= #数据库连接池的其它属性
    
    spring.shardingsphere.sharding.tables.<logic-table-name>.actual-data-nodes= #由数据源名 + 表名组成，以小数点分隔。多个表以逗号分隔，支持inline表达式。缺省表示使用已知数据源与逻辑表名称生成数据节点，用于广播表（即每个库中都需要一个同样的表用于关联查询，多为字典表）或只分库不分表且所有库的表结构完全一致的情况
    
    #分库策略，缺省表示使用默认分库策略，以下的分片策略只能选其一
    
    #用于单分片键的标准分片场景
    spring.shardingsphere.sharding.tables.<logic-table-name>.database-strategy.standard.sharding-column= #分片列名称
    spring.shardingsphere.sharding.tables.<logic-table-name>.database-strategy.standard.precise-algorithm-class-name= #精确分片算法类名称，用于=和IN。该类需实现PreciseShardingAlgorithm接口并提供无参数的构造器
    spring.shardingsphere.sharding.tables.<logic-table-name>.database-strategy.standard.range-algorithm-class-name= #范围分片算法类名称，用于BETWEEN，可选。该类需实现RangeShardingAlgorithm接口并提供无参数的构造器
    
    #用于多分片键的复合分片场景
    spring.shardingsphere.sharding.tables.<logic-table-name>.database-strategy.complex.sharding-columns= #分片列名称，多个列以逗号分隔
    spring.shardingsphere.sharding.tables.<logic-table-name>.database-strategy.complex.algorithm-class-name= #复合分片算法类名称。该类需实现ComplexKeysShardingAlgorithm接口并提供无参数的构造器
    
    #行表达式分片策略
    spring.shardingsphere.sharding.tables.<logic-table-name>.database-strategy.inline.sharding-column= #分片列名称
    spring.shardingsphere.sharding.tables.<logic-table-name>.database-strategy.inline.algorithm-expression= #分片算法行表达式，需符合groovy语法
    
    #Hint分片策略
    spring.shardingsphere.sharding.tables.<logic-table-name>.database-strategy.hint.algorithm-class-name= #Hint分片算法类名称。该类需实现HintShardingAlgorithm接口并提供无参数的构造器
    
    #分表策略，同分库策略
    spring.shardingsphere.sharding.tables.<logic-table-name>.table-strategy.xxx= #省略
    
    spring.shardingsphere.sharding.tables.<logic-table-name>.key-generator.column= #自增列名称，缺省表示不使用自增主键生成器
    spring.shardingsphere.sharding.tables.<logic-table-name>.key-generator.type= #自增列值生成器类型，缺省表示使用默认自增列值生成器。可使用用户自定义的列值生成器或选择内置类型：SNOWFLAKE/UUID
    spring.shardingsphere.sharding.tables.<logic-table-name>.key-generator.props.<property-name>= #属性配置, 注意：使用SNOWFLAKE算法，需要配置worker.id与max.tolerate.time.difference.milliseconds属性。若使用此算法生成值作分片值，建议配置max.vibration.offset属性
    
    spring.shardingsphere.sharding.binding-tables[0]= #绑定表规则列表
    spring.shardingsphere.sharding.binding-tables[1]= #绑定表规则列表
    spring.shardingsphere.sharding.binding-tables[x]= #绑定表规则列表
    
    spring.shardingsphere.sharding.broadcast-tables[0]= #广播表规则列表
    spring.shardingsphere.sharding.broadcast-tables[1]= #广播表规则列表
    spring.shardingsphere.sharding.broadcast-tables[x]= #广播表规则列表
    
    spring.shardingsphere.sharding.default-data-source-name= #未配置分片规则的表将通过默认数据源定位
    spring.shardingsphere.sharding.default-database-strategy.xxx= #默认数据库分片策略，同分库策略
    spring.shardingsphere.sharding.default-table-strategy.xxx= #默认表分片策略，同分表策略
    spring.shardingsphere.sharding.default-key-generator.type= #默认自增列值生成器类型，缺省将使用org.apache.shardingsphere.core.keygen.generator.impl.SnowflakeKeyGenerator。可使用用户自定义的列值生成器或选择内置类型：SNOWFLAKE/UUID
    spring.shardingsphere.sharding.default-key-generator.props.<property-name>= #自增列值生成器属性配置, 比如SNOWFLAKE算法的worker.id与max.tolerate.time.difference.milliseconds
    
    spring.shardingsphere.sharding.master-slave-rules.<master-slave-data-source-name>.master-data-source-name= #详见读写分离部分
    spring.shardingsphere.sharding.master-slave-rules.<master-slave-data-source-name>.slave-data-source-names[0]= #详见读写分离部分
    spring.shardingsphere.sharding.master-slave-rules.<master-slave-data-source-name>.slave-data-source-names[1]= #详见读写分离部分
    spring.shardingsphere.sharding.master-slave-rules.<master-slave-data-source-name>.slave-data-source-names[x]= #详见读写分离部分
    spring.shardingsphere.sharding.master-slave-rules.<master-slave-data-source-name>.load-balance-algorithm-class-name= #详见读写分离部分
    spring.shardingsphere.sharding.master-slave-rules.<master-slave-data-source-name>.load-balance-algorithm-type= #详见读写分离部分
    
    spring.shardingsphere.props.sql.show= #是否开启SQL显示，默认值: false
    spring.shardingsphere.props.executor.size= #工作线程数量，默认值: CPU核数

[ShardingSphere_4.1.1_sharding jdbc]: https://blog.csdn.net/qq_31457665/article/details/114991734
[Link 1]: https://shardingsphere.apache.org/document/legacy/4.x/document/cn/overview/
[ShardingSphere_4.1.1_Sharding-JDBC]: https://blog.csdn.net/qq_31457665/article/details/115219306
[sql]: https://blog.csdn.net/qq_31457665/article/details/115219306#config1
[pom]: https://blog.csdn.net/qq_31457665/article/details/115219306#config2
[ShardingSphere_4.1.1_Sharding-JDBC 1]: https://blog.csdn.net/qq_31457665/article/details/115217056