读写分离

概念

为了缓解数据库压力，将写入和读取操作分离为不同数据源，写库称为主库，读库称为从库，一主库可配置多从库。

支持项

  • 提供了一主多从的读写分离配置，可独立使用，也可配合分库分表使用。
  • 同一线程且同一数据库连接内，如有写入操作，以后的读操作均从主库读取，用于保证数据一致性。
  • Spring命名空间。
  • 基于Hint的强制主库路由。

不支持范围

  • 主库和从库的数据同步。
  • 主库和从库的数据同步延迟导致的数据不一致。
  • 主库双写或多写。

代码开发示例

  1. // 构建读写分离数据源, 读写分离数据源实现了DataSource接口, 可直接当做数据源处理. masterDataSource0, slaveDataSource00, slaveDataSource01等为使用DBCP等连接池配置的真实数据源
  2. Map<String, DataSource> slaveDataSourceMap0 = new HashMap<>();
  3. slaveDataSourceMap0.put("slaveDataSource00", slaveDataSource00);
  4. slaveDataSourceMap0.put("slaveDataSource01", slaveDataSource01);
  5. // 可选择主从库负载均衡策略, 默认是ROUND_ROBIN, 还有RANDOM可以选择, 或者自定义负载策略
  6. DataSource masterSlaveDs0 = MasterSlaveDataSourceFactory.createDataSource("ms_0", "masterDataSource0", masterDataSource0, slaveDataSourceMap0, MasterSlaveLoadBalanceStrategyType.ROUND_ROBIN);
  8. Map<String, DataSource> slaveDataSourceMap1 = new HashMap<>();
  9. slaveDataSourceMap1.put("slaveDataSource10", slaveDataSource10);
  10. slaveDataSourceMap1.put("slaveDataSource11", slaveDataSource11);
  11. DataSource masterSlaveDs1 = MasterSlaveDataSourceFactory.createDataSource("ms_1", "masterDataSource1", masterDataSource1, slaveDataSourceMap1, MasterSlaveLoadBalanceStrategyType.ROUND_ROBIN);
  13. // 构建分库分表数据源
  14. Map<String, DataSource> dataSourceMap = new HashMap<>();
  15. dataSourceMap.put("ms_0", masterSlaveDs0);
  16. dataSourceMap.put("ms_1", masterSlaveDs1);
  18. // 通过ShardingDataSourceFactory继续创建ShardingDataSource

Spring命名空间配置示例

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  4.     xmlns:context="http://www.springframework.org/schema/context"
  5.     xmlns:rdb="http://www.dangdang.com/schema/ddframe/rdb" 
  6.     xsi:schemaLocation="http://www.springframework.org/schema/beans 
  7.                         http://www.springframework.org/schema/beans/spring-beans.xsd
  8.                         http://www.springframework.org/schema/context 
  9.                         http://www.springframework.org/schema/context/spring-context.xsd 
  10.                         http://www.dangdang.com/schema/ddframe/rdb 
  11.                         http://www.dangdang.com/schema/ddframe/rdb/rdb.xsd 
  12.                         ">
  13.     <!-- 配置真实数据源 -->
  14.     <bean id="dbtbl_0_master" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  15.         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  16.         <property name="url" value="jdbc:mysql://localhost:3306/dbtbl_0_master"/>
  17.         <property name="username" value="root"/>
  18.         <property name="password" value=""/>
  19.     </bean>
  21.     <bean id="dbtbl_0_slave_0" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  22.         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  23.         <property name="url" value="jdbc:mysql://localhost:3306/dbtbl_0_slave_0"/>
  24.         <property name="username" value="root"/>
  25.         <property name="password" value=""/>
  26.     </bean>
  28.     <bean id="dbtbl_0_slave_1" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  29.         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  30.         <property name="url" value="jdbc:mysql://localhost:3306/dbtbl_0_slave_1"/>
  31.         <property name="username" value="root"/>
  32.         <property name="password" value=""/>
  33.     </bean>
  35.     <bean id="dbtbl_1_master" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  36.         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  37.         <property name="url" value="jdbc:mysql://localhost:3306/dbtbl_1_master"/>
  38.         <property name="username" value="root"/>
  39.         <property name="password" value=""/>
  40.     </bean>
  42.     <bean id="dbtbl_1_slave_0" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  43.         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  44.         <property name="url" value="jdbc:mysql://localhost:3306/dbtbl_1_slave_0"/>
  45.         <property name="username" value="root"/>
  46.         <property name="password" value=""/>
  47.     </bean>
  49.     <bean id="dbtbl_1_slave_1" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  50.         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  51.         <property name="url" value="jdbc:mysql://localhost:3306/dbtbl_1_slave_1"/>
  52.         <property name="username" value="root"/>
  53.         <property name="password" value=""/>
  54.     </bean>
  56.     <!-- 定义读写分离数据源, 读写分离数据源实现了DataSource接口, 可直接当做数据源处理 -->
  57.     <rdb:master-slave-data-source id="dbtbl_0" master-data-source-ref="dbtbl_0_master" slave-data-sources-ref="dbtbl_0_slave_0, dbtbl_0_slave_1" strategy-type="ROUND_ROBIN" />
  58.     <rdb:master-slave-data-source id="dbtbl_1" master-data-source-ref="dbtbl_1_master" slave-data-sources-ref="dbtbl_1_slave_0, dbtbl_1_slave_1" strategy-type="ROUND_ROBIN" />
  60.     <!-- 通过rdb:strategy和rdb:data-source继续构建分片数据源 -->
  61.     <rdb:strategy id="databaseStrategy" sharding-columns="user_id" algorithm-expression="dbtbl_${user_id.longValue() % 2}"/>
  62.     <rdb:strategy id="orderTableStrategy" sharding-columns="order_id" algorithm-expression="t_order_${order_id.longValue() % 4}"/>
  64.     <rdb:data-source id="shardingDataSource">
  65.         <rdb:sharding-rule data-sources="dbtbl_0, dbtbl_1">
  66.             <rdb:table-rules>
  67.                 <rdb:table-rule logic-table="t_order" actual-tables="t_order_${0..3}" database-strategy="databaseStrategy" table-strategy="orderTableStrategy"/>
  68.             </rdb:table-rules>
  69.         </rdb:sharding-rule>
  70.     </rdb:data-source>
  71. </beans>

使用Hint强制路由主库示例

  1. HintManager hintManager = HintManager.getInstance();
  2. hintManager.setMasterRouteOnly();
  3. // 继续JDBC操作