上一篇 <<<MyCat的分片查询原理
下一篇 >>>Sharding-Jdbc的分片算法及分表分库
1.Sharding-Jdbc(Shardingsphere)介绍
Sharding-Jdbc是当当网旗下的，在3.0后改名为Shardingsphere,它由Sharding-JDBC、Sharding-Proxy和Sharding-Sidecar这3款相互独立的产品组成。
他们均提供标准化的数据分片、分布式事务和数据库治理功能，可适用于如Java同构、异构语言、容器、云原生等各种多样化的应用场景。
Sharding-Jdbc官方网址: http://shardingsphere.io/index_zh.html
改名新闻: https://www.oschina.net/news/95889/sharding-jdbc-change-to-sphere
2.Sharding-Jdbc读写分离原理
a、需要在配置文件配置读写分离数据源，jdbc链接全部交给Sharding-JDBC
tips：Sharding-Jdbc只是实现连接主或者从数据源，不会实现主从复制功能，需要自己配置数据库自带主从复制方式。
b、Sharding-JDBC会自动判断是DML还是DQL，对针对不同的类型请求到不同的数据库
DML:数据操作语言，主要有1) 插入：INSERT 2) 更新：UPDATE 3) 删除：DELETE
DQL:数据查询语言，主要是SELECT
3.SpringBoot整合Sharding-Jdbc实现读写分离核心代码
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.0-beta</version>
</dependency>
<dependency>
<groupId>io.shardingjdbc</groupId>
<artifactId>sharding-jdbc-core</artifactId>
<version>2.0.3</version>
</dependency>
#shardingjdbc配置
sharding:
jdbc:
data-sources:
###配置第一个从数据库,如果有多个的话，则ds_slave_1这样排下去
ds_slave_0:
password: root
jdbc-url: jdbc:mysql://10.211.55.27:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=true
driver-class-name: com.mysql.jdbc.Driver
username: root
###主数据库配置
ds_master:
password: root
jdbc-url: jdbc:mysql://10.211.55.26:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=true
driver-class-name: com.mysql.jdbc.Driver
username: root
###配置读写分离
master-slave-rule:
###配置从库选择策略，提供轮询与随机，这里选择用轮询，如果有多个从数据库的话会生效
load-balance-algorithm-type: round_robin
####指定从数据库，如果有多个的话以英文逗号隔开
slave-data-source-names: ds_slave_0
#shardingjdbc的名称命名
name: ds_ms
####指定主数据库
master-data-source-name: ds_master
/**
* 配置多数据源
*/
@Data
@ConfigurationProperties(prefix = "sharding.jdbc")
public class ShardingMasterSlaveConfig {
// 存放本地多个数据源
private Map<String, HikariDataSource> dataSources = new HashMap<>();
private MasterSlaveRuleConfiguration masterSlaveRule;
}
@Configuration
@EnableConfigurationProperties(ShardingMasterSlaveConfig.class)
@Slf4j
// 读取ds_master主数据源和读写分离配置
@ConditionalOnProperty({ "sharding.jdbc.data-sources.ds_master.jdbc-url",
"sharding.jdbc.master-slave-rule.master-data-source-name" })
public class ShardingDataSourceConfig {
@Autowired
private ShardingMasterSlaveConfig shardingMasterSlaveConfig;
@Bean
public DataSource masterSlaveDataSource() throws SQLException {
final Map<String, DataSource> dataSourceMap = new HashMap<>();
dataSourceMap.putAll(shardingMasterSlaveConfig.getDataSources());
final Map<String, Object> newHashMap = Maps.newHashMap();
// 创建 MasterSlave数据源
DataSource dataSource = MasterSlaveDataSourceFactory.createDataSource(dataSourceMap,
shardingMasterSlaveConfig.getMasterSlaveRule(), newHashMap);
log.info("masterSlaveDataSource config complete");
return dataSource;
}
}
推荐阅读：
<<<MySQL自带主从复制原理
<<<MyCat实现读写分离与动态数据源切换
<<<分表分库与分区的区别及拆分策略
<<<MyCat的分片查询原理
<<<Sharding-Jdbc的分片算法及分表分库
<<<Sharding-Jdbc与MyCat区别
