欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springboot 動態(tài)數(shù)據源的實現(xiàn)方法(Mybatis+Druid)

 更新時間:2019年01月23日 10:13:02   作者:時光沉舊了少年  
這篇文章主要介紹了springboot 動態(tài)數(shù)據源的實現(xiàn)方法(Mybatis+Druid),小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧

Spring多數(shù)據源實現(xiàn)的方式大概有2中,一種是新建多個MapperScan掃描不同包,另外一種則是通過繼承AbstractRoutingDataSource實現(xiàn)動態(tài)路由。今天作者主要基于后者做的實現(xiàn),且方式1的實現(xiàn)比較簡單這里不做過多探討。

實現(xiàn)方式

方式1的實現(xiàn)(核心代碼):

@Configuration
@MapperScan(basePackages = "com.goofly.test1", sqlSessionTemplateRef = "test1SqlSessionTemplate")
public class DataSource1Config1 {

  @Bean(name = "dataSource1")
  @ConfigurationProperties(prefix = "spring.datasource.test1")
  @Primary
  public DataSource testDataSource() {
    return DataSourceBuilder.create().build();
  }
  // .....略

}

@Configuration
@MapperScan(basePackages = "com.goofly.test2", sqlSessionTemplateRef = "test1SqlSessionTemplate")
public class DataSourceConfig2 {

  @Bean(name = "dataSource2")
  @ConfigurationProperties(prefix = "spring.datasource.test2")
  @Primary
  public DataSource testDataSource() {
    return DataSourceBuilder.create().build();
  }
  // .....略

}

方式2的實現(xiàn)(核心代碼):

public class DynamicRoutingDataSource extends AbstractRoutingDataSource {
  private static final Logger log = Logger.getLogger(DynamicRoutingDataSource.class);
  
  @Override
  protected Object determineCurrentLookupKey() {
    //從ThreadLocal中取值
    return DynamicDataSourceContextHolder.get();
  }
}

第1種方式雖然實現(xiàn)比較加單,劣勢就是不同數(shù)據源的mapper文件不能在同一包名,就顯得不太靈活了。所以為了更加靈活的作為一個組件的存在,作者采用的第二種方式實現(xiàn)。

設計思路

  1. 當請求經過被注解修飾的類后,此時會進入到切面邏輯中。
  2. 切面邏輯會獲取注解中設置的key值,然后將該值存入到ThreadLocal中
  3. 執(zhí)行完切面邏輯后,會執(zhí)行AbstractRoutingDataSource.determineCurrentLookupKey()方法,然后從ThreadLocal中獲取之前設置的key值,然后將該值返回。
  4. 由于AbstractRoutingDataSource的targetDataSources是一個map,保存了數(shù)據源key和數(shù)據源的對應關系,所以能夠順利的找到該對應的數(shù)據源。

源碼解讀

org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource,如下:

public abstract class AbstractRoutingDataSource extends AbstractDataSource implements InitializingBean {
  
  private Map<Object, Object> targetDataSources;
  private Object defaultTargetDataSource;
  private boolean lenientFallback = true;
  private DataSourceLookup dataSourceLookup = new JndiDataSourceLookup();
  private Map<Object, DataSource> resolvedDataSources;
  private DataSource resolvedDefaultDataSource;
  
    protected DataSource determineTargetDataSource() {
    Assert.notNull(this.resolvedDataSources, "DataSource router not initialized");
    Object lookupKey = determineCurrentLookupKey();
    DataSource dataSource = this.resolvedDataSources.get(lookupKey);
    if (dataSource == null && (this.lenientFallback || lookupKey == null)) {
      dataSource = this.resolvedDefaultDataSource;
    }
    if (dataSource == null) {
      throw new IllegalStateException("Cannot determine target DataSource for lookup key [" + lookupKey + "]");
    }
    return dataSource;
  }

  /**
   * Determine the current lookup key. This will typically be
   * implemented to check a thread-bound transaction context.
   * <p>Allows for arbitrary keys. The returned key needs
   * to match the stored lookup key type, as resolved by the
   * {@link #resolveSpecifiedLookupKey} method.
   */
  protected abstract Object determineCurrentLookupKey();
  
  //........略

targetDataSources是一個map結構,保存了key與數(shù)據源的對應關系;

dataSourceLookup是一個DataSourceLookup類型,默認實現(xiàn)是JndiDataSourceLookup。點開該類源碼會發(fā)現(xiàn),它實現(xiàn)了通過key獲取DataSource的邏輯。當然,這里可以通過setDataSourceLookup()來改變其屬性,因為關于此處有一個坑,后面會講到。

public class JndiDataSourceLookup extends JndiLocatorSupport implements DataSourceLookup {

  public JndiDataSourceLookup() {
    setResourceRef(true);
  }

  @Override
  public DataSource getDataSource(String dataSourceName) throws DataSourceLookupFailureException {
    try {
      return lookup(dataSourceName, DataSource.class);
    }
    catch (NamingException ex) {
      throw new DataSourceLookupFailureException(
          "Failed to look up JNDI DataSource with name '" + dataSourceName + "'", ex);
    }
  }

}

組件使用

多數(shù)據源

# db1
spring.datasource.master.url = jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false
spring.datasource.master.username = root
spring.datasource.master.password = 123456
spring.datasource.master.driverClassName = com.mysql.jdbc.Driver
spring.datasource.master.validationQuery = true
spring.datasource.master.testOnBorrow = true
## db2
spring.datasource.slave.url = jdbc:mysql://127.0.0.1:3306/test1?useUnicode=true&characterEncoding=utf8&useSSL=false
spring.datasource.slave.username = root
spring.datasource.slave.password = 123456
spring.datasource.slave.driverClassName = com.mysql.jdbc.Driver
spring.datasource.slave.validationQuery = true
spring.datasource.slave.testOnBorrow = true

#主數(shù)據源名稱
spring.maindb=master
#mapperper包路徑
mapper.basePackages =com.btps.xli.multidb.demo.mapper

單數(shù)據源

為了讓使用者能夠用最小的改動實現(xiàn)最好的效果,作者對單數(shù)據源的多種配置做了兼容。

示例配置1(配置數(shù)據源名稱):

spring.datasource.master.url = jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false
spring.datasource.master.username = root
spring.datasource.master.password = 123456
spring.datasource.master.driverClassName = com.mysql.jdbc.Driver
spring.datasource.master.validationQuery = true
spring.datasource.master.testOnBorrow = true

# mapper包路徑
mapper.basePackages = com.goofly.xli.multidb.demo.mapper
# 主數(shù)據源名稱
spring.maindb=master

示例配置2(不配置數(shù)據源名稱):

spring.datasource.url = jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false
spring.datasource.username = root
spring.datasource.password = 123456
spring.datasource.driverClassName = com.mysql.jdbc.Driver
spring.datasource.validationQuery = true
spring.datasource.testOnBorrow = true

# mapper包路徑
mapper.basePackages = com.goofly.xli.multidb.demo.mapper

踩坑之路

多數(shù)據源的循環(huán)依賴

Description:

The dependencies of some of the beans in the application context form a cycle:

  happinessController (field private com.db.service.HappinessService com.db.controller.HappinessController.happinessService)
   ↓
  happinessServiceImpl (field private com.db.mapper.MasterDao com.db.service.HappinessServiceImpl.masterDao)
   ↓
  masterDao defined in file [E:\GitRepository\framework-gray\test-db\target\classes\com\db\mapper\MasterDao.class]
   ↓
  sqlSessionFactory defined in class path resource [com/goofly/xli/datasource/core/DynamicDataSourceConfiguration.class]
┌─────┐
| dynamicDataSource defined in class path resource [com/goofly/xli/datasource/core/DynamicDataSourceConfiguration.class]
↑   ↓
| firstDataSource defined in class path resource [com/goofly/xli/datasource/core/DynamicDataSourceConfiguration.class]
↑   ↓
| dataSourceInitializer

解決方案:

在Spring boot啟動的時候排除DataSourceAutoConfiguration即可。如下:

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

但是作者在創(chuàng)建多數(shù)據源的時候由于并未創(chuàng)建多個DataSource的Bean,而是只創(chuàng)建了一個即需要做動態(tài)數(shù)據源的那個Bean。 其他的DataSource則直接創(chuàng)建實例然后存放在Map里面,然后再設置到DynamicRoutingDataSource#setTargetDataSources即可。

因此這種方式也不會出現(xiàn)循環(huán)依賴的問題!

動態(tài)刷新數(shù)據源

筆者在設計之初是想構建一個動態(tài)刷新數(shù)據源的方案,所以利用了SpringCloud的@RefreshScope去標注數(shù)據源,然后利用RefreshScope#refresh實現(xiàn)刷新。但是在實驗的時候發(fā)現(xiàn)由Druid創(chuàng)建的數(shù)據源會因此而關閉,由Spring的DataSourceBuilder創(chuàng)建的數(shù)據源則不會發(fā)生任何變化。
​ 最后關于此也沒能找到解決方案。同時思考,如果只能的可以實現(xiàn)動態(tài)刷新的話,那么數(shù)據源的原有連接會因為刷新而中斷嗎還是會有其他處理?

多數(shù)據源事務

有這么一種特殊情況,一個事務中調用了兩個不同數(shù)據源,這個時候動態(tài)切換數(shù)據源會因此而失效。

翻閱了很多文章,大概找了2中解決方案,一種是Atomikos進行事務管理,但是貌似性能并不是很理想。

另外一種則是通過優(yōu)先級控制,切面的的優(yōu)先級必須要大于數(shù)據源的優(yōu)先級,用注解@Order控制。

此處留一個坑!

git代碼地址

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。

相關文章

  • 利用Spring Social輕松搞定微信授權登錄的方法示例

    利用Spring Social輕松搞定微信授權登錄的方法示例

    這篇文章主要介紹了利用Spring Social輕松搞定微信授權登錄的方法示例,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-12-12
  • SpringBoot 內嵌 camunda的配置方法

    SpringBoot 內嵌 camunda的配置方法

    Camunda是一個基于Java的框架,支持用于工作流和流程自動化的BPMN、用于案例管理的CMMN和用于業(yè)務決策管理的DMN,這篇文章主要介紹了SpringBoot 內嵌 camunda,需要的朋友可以參考下
    2024-06-06
  • Java深入淺出講解多線程的概念到使用

    Java深入淺出講解多線程的概念到使用

    哈哈!經過一個階段的學習,Java基礎知識學習終于到多線程了!Java多線程以及后面互斥鎖的概念都是Java基礎學習的難點,所以我做了一個總結,希望對大家也有幫助
    2022-05-05
  • 一文徹底弄懂Java中MultipartFile接口和File類

    一文徹底弄懂Java中MultipartFile接口和File類

    MultipartFile是一個接口,我們可以理解為是Spring?給我們綁定的一個在使用文件上傳等時簡便實現(xiàn)的口子,這篇文章主要給大家介紹了關于如何通過一文徹底弄懂Java中MultipartFile接口和File類的相關資料,需要的朋友可以參考下
    2023-11-11
  • spring 操作elasticsearch查詢使用方法

    spring 操作elasticsearch查詢使用方法

    本篇文章主要介紹了spring 操作elasticsearch使用方法,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-05-05
  • springboot?整合?SA-Token?使用詳解

    springboot?整合?SA-Token?使用詳解

    本文詳細介紹了SA-Token這款安全框架的使用,并結合實際操作演示了如何集成到springboot項目中,感興趣的朋友跟隨小編一起看看吧
    2024-08-08
  • spring security中的csrf防御原理(跨域請求偽造)

    spring security中的csrf防御原理(跨域請求偽造)

    這篇文章主要介紹了spring security中的csrf防御機制原理解析(跨域請求偽造),本文通過實例代碼詳解的非常詳細,具有一定的參考借鑒價值,需要的朋友可以參考下
    2019-12-12
  • springboot項目如何使用切面記錄用戶操作日志

    springboot項目如何使用切面記錄用戶操作日志

    這篇文章主要介紹了springboot項目如何使用切面記錄用戶操作日志,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-10-10
  • Spring @Async無法實現(xiàn)異步的解決方案

    Spring @Async無法實現(xiàn)異步的解決方案

    這篇文章主要介紹了Spring @Async無法實現(xiàn)異步的解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-10-10
  • Java接口默認方法帶來的問題分析【二義性問題】

    Java接口默認方法帶來的問題分析【二義性問題】

    這篇文章主要介紹了Java接口默認方法帶來的問題,結合實例形式分析了java接口帶來的二義性問題,需要的朋友可以參考下
    2019-08-08

最新評論