快捷導(dǎo)航

淺談利用Spring的AbstractRoutingDataSource解決多數(shù)據(jù)源的問(wèn)題

更新時(shí)間：2017年08月11日 08:51:16 作者：Hing Kwan

本篇文章主要介紹了淺談利用Spring的AbstractRoutingDataSource解決多數(shù)據(jù)源的問(wèn)題，具有一定的參考價(jià)值，有需要的可以了解一下

在互聯(lián)網(wǎng)的服務(wù)端開(kāi)發(fā)的時(shí)候，我們很經(jīng)常要在一個(gè)項(xiàng)目中去調(diào)用不同的數(shù)據(jù)庫(kù)。在這種情況下，必然要涉及到多數(shù)據(jù)源問(wèn)題。那么，我們?cè)撊绾谓鉀Q多數(shù)據(jù)源問(wèn)題呢？有沒(méi)有一種方法來(lái)動(dòng)態(tài)切換數(shù)據(jù)源呢？

答案是有的。萬(wàn)能的Spring已經(jīng)給了我們解決方案——利用AbstractRoutingDataSource。在 AbstractRoutingDataSource 類(lèi)中，發(fā)現(xiàn) getConnection() 方法，從名字上可以知道它是獲得connection連接的。跟蹤 getConnection() 方法， determineTargetDataSource() 就這么進(jìn)入我們的視線(xiàn)，繼續(xù)下去，我們發(fā)現(xiàn)了重點(diǎn)—— determineCurrentLookupKey() 。 determineCurrentLookupKey 方法是一個(gè)抽象方法，它的返回值就是我們要用到的數(shù)據(jù)源dataSource的key，然后根據(jù)這個(gè)key從 resolvedDataSources 這個(gè)map中取出dataSource，如果找不到就使用默認(rèn)的dataSource。

知道了這些，我們就來(lái)用代碼實(shí)現(xiàn)吧！以下的代碼是基于Spring Boot，所以需要建立一個(gè)Spring Boot項(xiàng)目，然后引入spring-boot-starter-jdbc。項(xiàng)目中又有用到AOP，肯定的，我們必須引入spring-boot-starter-aop。

接下來(lái)，我們需要建一個(gè)DynamicDataSource。

public class DynamicDataSourceextends AbstractRoutingDataSource{

  @Override
  protectedObjectdetermineCurrentLookupKey(){
    String dataSourceName = DynamicDataSourceContextHolder.getDataSourceName();
    return dataSourceName;
  }
}

DynamicDataSource 繼承了抽象類(lèi) AbstractRoutingDataSource ，實(shí)現(xiàn)了 determineCurrentLookupKey() 。在 DynamicDataSourceContextHolder 中，我們使用ThreadLocal維護(hù) dataSouceName 這個(gè)變量。這樣，每一個(gè)線(xiàn)程都可以獨(dú)立改變自己的副本，而不會(huì)影響其他線(xiàn)程所對(duì)應(yīng)的副本。

/**
 * 動(dòng)態(tài)數(shù)據(jù)源上下文
 */
public class DynamicDataSourceContextHolder{

  private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();
  public static List<String> dataSourceNames = new ArrayList<>();

  public static void setDataSourceName(String name){
    contextHolder.set(name);
  }

  public staticStringgetDataSourceName(){
    return contextHolder.get();
  }

  public static void clearDataSourceName(){
    contextHolder.remove();
  }

  public static boolean containsDataSource(String dataSourceName){
    return dataSourceNames.contains(dataSourceName);
  }

}

OK，我們已經(jīng)有了動(dòng)態(tài)數(shù)據(jù)源DynamicDataSource，也有了DynamicDataSourceContextHolder，我們?cè)趺词褂媚?？讓我們看?DataSourceConfig 。

@Configuration
public class DataSourceConfig{

  @Bean(name = "primaryDataSource")
  @ConfigurationProperties(prefix = "spring.datasource.primary")
  @Primary
  publicDataSourceprimaryDataSource(){
    return DataSourceBuilder.create().build();
  }

  @Bean(name = "secondaryDataSource")
  @ConfigurationProperties(prefix = "spring.datasource.secondary")
  publicDataSourcesecondaryDataSource(){
    return DataSourceBuilder.create().build();
  }

  @Autowired
  @Qualifier("primaryDataSource")
  private DataSource primaryDataSource;

  @Autowired
  @Qualifier("secondaryDataSource")
  private DataSource secondaryDataSource;

  @Bean
  publicDynamicDataSourcedataSource(){

    Map<Object, Object> targetDataSources = new HashMap<>();
    targetDataSources.put("primaryDataSource", primaryDataSource);
    targetDataSources.put("secondaryDataSource", secondaryDataSource);

    DynamicDataSourceContextHolder.dataSourceNames.add("primaryDataSource");
    DynamicDataSourceContextHolder.dataSourceNames.add("secondaryDataSource");

    DynamicDataSource dataSource = new DynamicDataSource();
    //設(shè)置數(shù)據(jù)源映射
    dataSource.setTargetDataSources(targetDataSources);
    //設(shè)置默認(rèn)數(shù)據(jù)源，當(dāng)無(wú)法映射到數(shù)據(jù)源時(shí)會(huì)使用默認(rèn)數(shù)據(jù)源
    dataSource.setDefaultTargetDataSource(primaryDataSource);
    dataSource.afterPropertiesSet();

    return dataSource;
  }

}

當(dāng)然，上面的 DataSourceConfig 還得搭配 application.properties 配置文件。

#
spring.datasource.primary.jdbcUrl=jdbc:mysql://localhost/test1?useSSL=false
spring.datasource.primary.username=root
spring.datasource.primary.password=root
spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driver
#
spring.datasource.secondary.jdbcUrl=jdbc:mysql://localhost/test2?useSSL=false
spring.datasource.secondary.username=root
spring.datasource.secondary.password=root
spring.datasource.secondary.driver-class-name=com.mysql.jdbc.Driver

到現(xiàn)在為止，我們已經(jīng)配置了動(dòng)態(tài)的數(shù)據(jù)源，將我們的多個(gè)數(shù)據(jù)源設(shè)置給了DynamicDataSource。這樣，我們就可以在Service或者是Dao中使用 DynamicDataSourceContextHolder.setDataSourceName("primaryDataSource") 方法來(lái)動(dòng)態(tài)切換數(shù)據(jù)源了。但是，這樣的寫(xiě)法會(huì)不會(huì)感到很不爽呢？其實(shí)，我們可以在方法上使用注解來(lái)切換數(shù)據(jù)源。

自定義一個(gè)注解TargetDataSource：

/**
 * 在方法上使用，用于指定使用哪個(gè)數(shù)據(jù)源
 */
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface TargetDataSource {

  Stringvalue();

}

這樣，我們就可以在Service上如以下使用：

@TargetDataSource(value = "primaryDataSource")
publicList<Customer>findAll(){
  //TODO
  return null;
}

@TargetDataSource(value = "secondaryDataSource")
public void addCustomer(String name, String email){

}

很明顯的，到目前為止還不能完成我們的切換需求。我們還需要一段代碼，來(lái)實(shí)現(xiàn)動(dòng)態(tài)調(diào)用 DynamicDataSourceContextHolder.setDataSourceName("xxx") ，比較好的實(shí)現(xiàn)就是AOP啦。

@Aspect
@Component
@Order(-1)// 保證該AOP在@Transactional之前執(zhí)行
public class DynamicDataSourceChangeAspect{

  private static final Logger logger = LoggerFactory.getLogger(DynamicDataSourceChangeAspect.class);

  @Before("@annotation(targetDataSource)")
  public void changeDataSource(JoinPoint joinPoint, TargetDataSource targetDataSource){
    String dsName = targetDataSource.value();
    if (!DynamicDataSourceContextHolder.containsDataSource(dsName)) {
      System.err.println("數(shù)據(jù)源[{}]不存在，使用默認(rèn)數(shù)據(jù)源 > {}" + targetDataSource.value() + joinPoint.getSignature());
    } else {
      DynamicDataSourceContextHolder.setDataSourceName(targetDataSource.value()); //設(shè)置到動(dòng)態(tài)數(shù)據(jù)源上下文中
    }
  }

  @After("@annotation(targetDataSource)")
  public void restoreDataSource(JoinPoint point, TargetDataSource targetDataSource){
    //方法執(zhí)行完畢之后，銷(xiāo)毀當(dāng)前數(shù)據(jù)源信息，進(jìn)行垃圾回收。
    DynamicDataSourceContextHolder.clearDataSourceName();
  }
}

到現(xiàn)在為止，我們就實(shí)現(xiàn)了動(dòng)態(tài)切換數(shù)據(jù)源了。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: