@SpringBootApplication@EnableAutoConfiguration(exclude={DataSourceAutoConfiguration.class})public class Application {  public static void main(String[] args) {   SpringApplication.run(Application.class, args);  } }

@Bean(initMethod="init", destroyMethod="close", name="dataSource0")@ConfigurationProperties(prefix = "spring.datasource")public DataSource dataSource0(){  return new DruidDataSource();}@Bean(initMethod="init", destroyMethod="close", name="dataSource1")@ConfigurationProperties(prefix = "spring.datasource2")public DataSource dataSource1(){  return new DruidDataSource();}

@Beanpublic DataSourceRule dataSourceRule(@Qualifier("dataSource0") DataSource dataSource0,     @Qualifier("dataSource1") DataSource dataSource1){  Map<String, DataSource> dataSourceMap = new HashMap<>();  dataSourceMap.put("dataSource0", dataSource0);  dataSourceMap.put("dataSource1", dataSource1);  return new DataSourceRule(dataSourceMap, "dataSource0");}

@Beanpublic ShardingRule shardingRule(DataSourceRule dataSourceRule){  //表策略  TableRule orderTableRule = TableRule.builder("t_order")      .actualTables(Arrays.asList("t_order_0", "t_order_1"))      .tableShardingStrategy(new TableShardingStrategy("order_id", new ModuloTableShardingAlgorithm()))      .dataSourceRule(dataSourceRule)      .build();  TableRule orderItemTableRule = TableRule.builder("t_order_item")      .actualTables(Arrays.asList("t_order_item_0", "t_order_item_1"))      .tableShardingStrategy(new TableShardingStrategy("order_id", new ModuloTableShardingAlgorithm()))      .dataSourceRule(dataSourceRule)      .build();  //綁定表策略，在查詢時(shí)會(huì)使用主表策略計(jì)算路由的數(shù)據(jù)源，因此需要約定綁定表策略的表的規(guī)則需要一致，可以一定程度提高效率  List<BindingTableRule> bindingTableRules = new ArrayList<BindingTableRule>();  bindingTableRules.add(new BindingTableRule(Arrays.asList(orderTableRule, orderItemTableRule)));  return ShardingRule.builder()      .dataSourceRule(dataSourceRule)      .tableRules(Arrays.asList(orderTableRule, orderItemTableRule))      .bindingTableRules(bindingTableRules)      .databaseShardingStrategy(new DatabaseShardingStrategy("user_id", new ModuloDatabaseShardingAlgorithm()))      .tableShardingStrategy(new TableShardingStrategy("order_id", new ModuloTableShardingAlgorithm()))      .build();}

@Bean("dataSource")public DataSource shardingDataSource(ShardingRule shardingRule){  return ShardingDataSourceFactory.createDataSource(shardingRule);}

//需要手動(dòng)聲明配置事務(wù)@Beanpublic DataSourceTransactionManager transactitonManager(@Qualifier("dataSource") DataSource dataSource){  return new DataSourceTransactionManager(dataSource);}

import java.util.Collection;import java.util.LinkedHashSet;import com.dangdang.ddframe.rdb.sharding.api.ShardingValue;import com.dangdang.ddframe.rdb.sharding.api.strategy.database.SingleKeyDatabaseShardingAlgorithm;import com.google.common.collect.Range;/** * Created by fuwei.deng on 2017年5月11日. */public class ModuloDatabaseShardingAlgorithm implements SingleKeyDatabaseShardingAlgorithm<Long> {  @Override  public String doEqualSharding(Collection<String> databaseNames, ShardingValue<Long> shardingValue) {   for (String each : databaseNames) {      if (each.endsWith(shardingValue.getValue() % 2 + "")) {        return each;      }    }    throw new IllegalArgumentException();  }    @Override  public Collection<String> doInSharding(Collection<String> databaseNames, ShardingValue<Long> shardingValue) {   Collection<String> result = new LinkedHashSet<>(databaseNames.size());    for (Long value : shardingValue.getValues()) {      for (String tableName : databaseNames) {        if (tableName.endsWith(value % 2 + "")) {          result.add(tableName);        }      }    }    return result;  }    @Override  public Collection<String> doBetweenSharding(Collection<String> databaseNames, ShardingValue<Long> shardingValue) {   Collection<String> result = new LinkedHashSet<>(databaseNames.size());    Range<Long> range = (Range<Long>) shardingValue.getValueRange();    for (Long i = range.lowerEndpoint(); i <= range.upperEndpoint(); i++) {      for (String each : databaseNames) {        if (each.endsWith(i % 2 + "")) {          result.add(each);        }      }    }    return result;  }}

import java.util.Collection;import java.util.LinkedHashSet;import com.dangdang.ddframe.rdb.sharding.api.ShardingValue;import com.dangdang.ddframe.rdb.sharding.api.strategy.table.SingleKeyTableShardingAlgorithm;import com.google.common.collect.Range;/** * Created by fuwei.deng on 2017年5月11日. */public class ModuloTableShardingAlgorithm implements SingleKeyTableShardingAlgorithm<Long> {  @Override  public String doEqualSharding(Collection<String> tableNames, ShardingValue<Long> shardingValue) {   for (String each : tableNames) {      if (each.endsWith(shardingValue.getValue() % 2 + "")) {        return each;      }    }    throw new IllegalArgumentException();  }    @Override  public Collection<String> doInSharding(Collection<String> tableNames, ShardingValue<Long> shardingValue) {   Collection<String> result = new LinkedHashSet<>(tableNames.size());    for (Long value : shardingValue.getValues()) {      for (String tableName : tableNames) {        if (tableName.endsWith(value % 2 + "")) {          result.add(tableName);        }      }    }    return result;  }    @Override  public Collection<String> doBetweenSharding(Collection<String> tableNames, ShardingValue<Long> shardingValue) {   Collection<String> result = new LinkedHashSet<>(tableNames.size());    Range<Long> range = (Range<Long>) shardingValue.getValueRange();    for (Long i = range.lowerEndpoint(); i <= range.upperEndpoint(); i++) {      for (String each : tableNames) {        if (each.endsWith(i % 2 + "")) {          result.add(each);        }      }    }    return result;  }}

// 構(gòu)建讀寫分離數(shù)據(jù)源, 讀寫分離數(shù)據(jù)源實(shí)現(xiàn)了DataSource接口, 可直接當(dāng)做數(shù)據(jù)源處理. // masterDataSource0, slaveDataSource00, slaveDataSource01等為使用DBCP等連接池配置的真實(shí)數(shù)據(jù)源DataSource masterSlaveDs0 = MasterSlaveDataSourceFactory.createDataSource("ms_0",           masterDataSource0, slaveDataSource00, slaveDataSource01);DataSource masterSlaveDs1 = MasterSlaveDataSourceFactory.createDataSource("ms_1",           masterDataSource1, slaveDataSource11, slaveDataSource11);// 構(gòu)建分庫(kù)分表數(shù)據(jù)源Map<String, DataSource> dataSourceMap = new HashMap<>(2);dataSourceMap.put("ms_0", masterSlaveDs0);dataSourceMap.put("ms_1", masterSlaveDs1);// 通過ShardingDataSourceFactory繼續(xù)創(chuàng)建ShardingDataSource

HintManager hintManager = HintManager.getInstance();hintManager.setMasterRouteOnly();// 繼續(xù)JDBC操作

HintManager hintManager = HintManager.getInstance();hintManager.addDatabaseShardingValue("t_order", "user_id", 1L);hintManager.addTableShardingValue("t_order", "order_id", order.getOrderId());hintManager.addDatabaseShardingValue("t_order_item", "user_id", 1L);hintManager.addTableShardingValue("t_order_item", "order_id", order.getOrderId());