Sharding-Jdbc实现读写分离

上一篇 <<<MyCat的分片查询原理
下一篇 >>>Sharding-Jdbc的分片算法及分表分库

1.Sharding-Jdbc(Shardingsphere)介绍

2.Sharding-Jdbc读写分离原理

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区别