日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
SpringBoot讀寫分離組件開發(fā)詳解

環(huán)境：springboot2.2.6RELEASE

創(chuàng)新互聯(lián)是專業(yè)的老城網(wǎng)站建設公司，老城接單;提供成都網(wǎng)站設計、網(wǎng)站制作,網(wǎng)頁設計,網(wǎng)站設計,建網(wǎng)站,PHP網(wǎng)站建設等專業(yè)做網(wǎng)站服務;采用PHP框架,可快速的進行老城網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團隊,希望更多企業(yè)前來合作!

實現(xiàn)目標：一寫多讀，讀可以任意配置多個，默認都是從寫庫中進行操作，只有符合條件的方法(指定的目標方法或者標有指定注解的方法才會從讀庫中操作)。獨立打成一個jar包放入本地倉庫。

實現(xiàn)原理：通過aop。

1.pom.xml配置文件

 
 
 
 
    
  
  
  
  
  1.  
    2. 
  
  
  
  
  2.             org.springframework.boot 
    3. 
  
  
  
  
  3.             spring-boot-starter 
    4. 
  
  
  
  
  4.  
    5. 
  
  
  
  
  5.  
    6. 
  
  
  
  
  6.             org.springframework.boot 
    7. 
  
  
  
  
  7.             spring-boot-starter-data-jpa 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9.  
    10. 
  
  
  
  
  10.             org.springframework.boot 
    11. 
  
  
  
  
  11.             spring-boot-configuration-processor 
    12. 
  
  
  
  
  12.             true 
    13. 
  
  
  
  
  13.  
    14.

 2.application.yml配置文件

 
 
 
 
    
  
  
  
  
  1. pack: 
    2. 
  
  
  
  
  2.   datasource: 
    3. 
  
  
  
  
  3.     pointcut: execution(public * net.greatsoft.service.base.*.*(..)) || execution(public * net.greatsoft.service.xxx.*.*(..)) 
    4. 
  
  
  
  
  4.     master: 
    5. 
  
  
  
  
  5.       driverClassName: oracle.jdbc.driver.OracleDriver 
    6. 
  
  
  
  
  6.       jdbcUrl: jdbc:oracle:thin:@10.100.102.113:1521/orcl 
    7. 
  
  
  
  
  7.       username: test 
    8. 
  
  
  
  
  8.       password: test 
    9. 
  
  
  
  
  9.       minimumIdle: 10 
    10. 
  
  
  
  
  10.       maximumPoolSize: 200 
    11. 
  
  
  
  
  11.       autoCommit: true 
    12. 
  
  
  
  
  12.       idleTimeout: 30000 
    13. 
  
  
  
  
  13.       poolName: MbookHikariCP 
    14. 
  
  
  
  
  14.       maxLifetime: 1800000 
    15. 
  
  
  
  
  15.       connectionTimeout: 30000 
    16. 
  
  
  
  
  16.       connectionTestQuery: SELECT 1 FROM DUAL   
    17. 
  
  
  
  
  17.     slaves: 
    18. 
  
  
  
  
  18.       - driverClassName: oracle.jdbc.driver.OracleDriver 
    19. 
  
  
  
  
  19.         jdbcUrl: jdbc:oracle:thin:@10.100.102.113:1521/orcl 
    20. 
  
  
  
  
  20.         username: dc 
    21. 
  
  
  
  
  21.         password: dc 
    22. 
  
  
  
  
  22.         minimumIdle: 10 
    23. 
  
  
  
  
  23.         maximumPoolSize: 200 
    24. 
  
  
  
  
  24.         autoCommit: true 
    25. 
  
  
  
  
  25.         idleTimeout: 30000 
    26. 
  
  
  
  
  26.         poolName: MbookHikariCP 
    27. 
  
  
  
  
  27.         maxLifetime: 1800000 
    28. 
  
  
  
  
  28.         connectionTimeout: 30000 
    29. 
  
  
  
  
  29.         connectionTestQuery: SELECT 1 FROM DUAL 
    30. 
  
  
  
  
  30.       - driverClassName: oracle.jdbc.driver.OracleDriver 
    31. 
  
  
  
  
  31.         jdbcUrl: jdbc:oracle:thin:@10.100.102.113:1521/orcl 
    32. 
  
  
  
  
  32.         username: empi 
    33. 
  
  
  
  
  33.         password: empi 
    34. 
  
  
  
  
  34.         minimumIdle: 10 
    35. 
  
  
  
  
  35.         maximumPoolSize: 200 
    36. 
  
  
  
  
  36.         autoCommit: true 
    37. 
  
  
  
  
  37.         idleTimeout: 30000 
    38. 
  
  
  
  
  38.         poolName: MbookHikariCP 
    39. 
  
  
  
  
  39.         maxLifetime: 1800000 
    40. 
  
  
  
  
  40.         connectionTimeout: 30000 
    41. 
  
  
  
  
  41.         connectionTestQuery: SELECT 1 FROM DUAL 
    42.

 pointcut：定義切點，那些方法是需要攔截(從讀庫中操作)。

master：寫庫配置。

slaves：讀庫配置(List集合)。

3.屬性配置類

 
 
 
 
    
  
  
  
  
  1. @Component 
    2. 
  
  
  
  
  2. @ConfigurationProperties(prefix = "pack.datasource") 
    3. 
  
  
  
  
  3. public class RWDataSourceProperties { 
    4. 
  
  
  
  
  4.      
    5. 
  
  
  
  
  5.     private String pointcut ; 
    6. 
  
  
  
  
  6.     private HikariConfig master ; 
    7. 
  
  
  
  
  7.     private List slaves = new ArrayList<>(); 
    8. 
  
  
  
  
  8.      
    9. 
  
  
  
  
  9. } 
    10.

 4.讀寫配置類

 
 
 
 
    
  
  
  
  
  1. public class RWConfig  { 
    2. 
  
  
  
  
  2.      
    3. 
  
  
  
  
  3.     private static Logger logger = LoggerFactory.getLogger(RWConfig.class) ; 
    4. 
  
  
  
  
  4.  
    5. 
  
  
  
  
  5.     @Bean 
    6. 
  
  
  
  
  6.     public HikariDataSource masterDataSource(RWDataSourceProperties rwDataSourceProperties) { 
    7. 
  
  
  
  
  7.         return new HikariDataSource(rwDataSourceProperties.getMaster()) ; 
    8. 
  
  
  
  
  8.     } 
    9. 
  
  
  
  
  9.      
    10. 
  
  
  
  
  10.     @Bean 
    11. 
  
  
  
  
  11.     public List slaveDataSources(RWDataSourceProperties rwDataSourceProperties) { 
    12. 
  
  
  
  
  12.         List lists = new ArrayList<>() ; 
    13. 
  
  
  
  
  13.         for(HikariConfig config : rwDataSourceProperties.getSlaves()) { 
    14. 
  
  
  
  
  14.             lists.add(new HikariDataSource(config)) ; 
    15. 
  
  
  
  
  15.         } 
    16. 
  
  
  
  
  16.         return lists ; 
    17. 
  
  
  
  
  17.     } 
    18. 
  
  
  
  
  18.      
    19. 
  
  
  
  
  19.     @Bean 
    20. 
  
  
  
  
  20.   @Primary 
    21. 
  
  
  
  
  21.     @DependsOn({"masterDataSource", "slaveDataSources"}) 
    22. 
  
  
  
  
  22.     public AbstractRoutingDataSource routingDataSource(@Qualifier("masterDataSource")DataSource masterDataSource, 
    23. 
  
  
  
  
  23.             @Qualifier("slaveDataSources")List slaveDataSources) { 
    24. 
  
  
  
  
  24.         BaseRoutingDataSource ds = new BaseRoutingDataSource() ; 
    25. 
  
  
  
  
  25.         Map targetDataSources = new HashMap<>(2) ; 
    26. 
  
  
  
  
  26.         targetDataSources.put("master", masterDataSource) ; 
    27. 
  
  
  
  
  27.         for (int i = 0; i < slaveDataSources.size(); i++) { 
    28. 
  
  
  
  
  28.             targetDataSources.put("slave-" + i, slaveDataSources.get(i)) ; 
    29. 
  
  
  
  
  29.         } 
    30. 
  
  
  
  
  30.         ds.setDefaultTargetDataSource(masterDataSource) ; 
    31. 
  
  
  
  
  31.         ds.setTargetDataSources(targetDataSources) ; 
    32. 
  
  
  
  
  32.         return ds ; 
    33. 
  
  
  
  
  33.     } 
    34. 
  
  
  
  
  34.      
    35. 
  
  
  
  
  35. } 
    36.

 5.數(shù)據(jù)源路由

 
 
 
 
    
  
  
  
  
  1. public class BaseRoutingDataSource extends AbstractRoutingDataSource { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.     @Resource 
    4. 
  
  
  
  
  4.     private DataSourceHolder holder; 
    5. 
  
  
  
  
  5.      
    6. 
  
  
  
  
  6.     @Override 
    7. 
  
  
  
  
  7.     protected Object determineCurrentLookupKey() { 
    8. 
  
  
  
  
  8.         return holder.get() ; 
    9. 
  
  
  
  
  9.     } 
    10. 
  
  
  
  
  10.      
    11. 
  
  
  
  
  11. } 
    12. 
 
 
 
 

 
 
 
 
    
  
  
  
  
  1. public class DataSourceHolder { 
    2. 
  
  
  
  
  2.      
    3. 
  
  
  
  
  3.     private ThreadLocal context = new ThreadLocal() { 
    4. 
  
  
  
  
  4.         @Override 
    5. 
  
  
  
  
  5.         protected Integer initialValue() { 
    6. 
  
  
  
  
  6.             return 0 ; 
    7. 
  
  
  
  
  7.         } 
    8. 
  
  
  
  
  8.     }; 
    9. 
  
  
  
  
  9.      
    10. 
  
  
  
  
  10.     @Resource 
    11. 
  
  
  
  
  11.     private BaseSlaveLoad slaveLoad ; 
    12. 
  
  
  
  
  12.      
    13. 
  
  
  
  
  13.     public String get() { 
    14. 
  
  
  
  
  14.         Integer type = context.get() ; 
    15. 
  
  
  
  
  15.         return type == null || type == 0 ? "master" : "slave-" + slaveLoad.load() ; 
    16. 
  
  
  
  
  16.     } 
    17. 
  
  
  
  
  17.      
    18. 
  
  
  
  
  18.     public void set(Integer type) { 
    19. 
  
  
  
  
  19.         context.set(type) ; 
    20. 
  
  
  
  
  20.     } 
    21. 
  
  
  
  
  21.      
    22. 
  
  
  
  
  22. } 
    23.

 通過aop動態(tài)設置context的內(nèi)容值，0為從寫庫中操作，其它的都在讀庫中操作。

BaseSlaveLoad類為到底從那個讀庫中選取的一個算法類，默認實現(xiàn)使用的是輪詢算法。

 
 
 
 
    
  
  
  
  
  1. public interface BaseSlaveLoad { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.     int load() ; 
    4. 
  
  
  
  
  4.      
    5. 
  
  
  
  
  5. } 
    6. 
 
 
 
 

 
 
 
 
    
  
  
  
  
  1. public abstract class AbstractSlaveLoad implements BaseSlaveLoad { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.     @Resource 
    4. 
  
  
  
  
  4.     protected List slaveDataSources ; 
    5. 
  
  
  
  
  5.      
    6. 
  
  
  
  
  6. } 
    7.

 這里定義一個抽象類注入了讀庫列表，所有的實現(xiàn)類從該類中繼承即可。

 
 
 
 
    
  
  
  
  
  1. public class PollingLoad extends AbstractSlaveLoad { 
    2. 
  
  
  
  
  2.      
    3. 
  
  
  
  
  3.     private int index = 0 ; 
    4. 
  
  
  
  
  4.     private int size = 1 ; 
    5. 
  
  
  
  
  5.      
    6. 
  
  
  
  
  6.     @PostConstruct 
    7. 
  
  
  
  
  7.     public void init() { 
    8. 
  
  
  
  
  8.         size = slaveDataSources.size() ; 
    9. 
  
  
  
  
  9.     } 
    10. 
  
  
  
  
  10.      
    11. 
  
  
  
  
  11.     @Override 
    12. 
  
  
  
  
  12.     public int load() { 
    13. 
  
  
  
  
  13.         int n = index ; 
    14. 
  
  
  
  
  14.         synchronized (this) { 
    15. 
  
  
  
  
  15.             index = (++index) % size ; 
    16. 
  
  
  
  
  16.         } 
    17. 
  
  
  
  
  17.         return n ; 
    18. 
  
  
  
  
  18.     } 
    19. 
  
  
  
  
  19.      
    20. 
  
  
  
  
  20. } 
    21.

 配置成Bean

 
 
 
 
    
  
  
  
  
  1. @Bean 
    2. 
  
  
  
  
  2.     @ConditionalOnMissingBean 
    3. 
  
  
  
  
  3.     public BaseSlaveLoad slaveLoad() { 
    4. 
  
  
  
  
  4.         return new PollingLoad() ; 
    5. 
  
  
  
  
  5.     } 
    6. 
  
  
  
  
  6.      
    7. 
  
  
  
  
  7.     @Bean 
    8. 
  
  
  
  
  8.     public DataSourceHolder dataSourceHolder() { 
    9. 
  
  
  
  
  9.         return new DataSourceHolder() ; 
    10. 
  
  
  
  
  10.     } 
    11.

 6.數(shù)據(jù)源AOP

 
 
 
 
    
  
  
  
  
  1. public class DataSourceAspect implements MethodInterceptor { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.     private DataSourceHolder holder ; 
    4. 
  
  
  
  
  4.      
    5. 
  
  
  
  
  5.     public DataSourceAspect(DataSourceHolder holder) { 
    6. 
  
  
  
  
  6.         this.holder = holder ; 
    7. 
  
  
  
  
  7.     } 
    8. 
  
  
  
  
  8.      
    9. 
  
  
  
  
  9.     @Override 
    10. 
  
  
  
  
  10.     public Object invoke(MethodInvocation invocation) throws Throwable { 
    11. 
  
  
  
  
  11.         Method method = invocation.getMethod() ; 
    12. 
  
  
  
  
  12.         String methodName = method.getName() ; 
    13. 
  
  
  
  
  13.         SlaveDB slaveDB = method.getAnnotation(SlaveDB.class) ; 
    14. 
  
  
  
  
  14.         if (slaveDB == null) { 
    15. 
  
  
  
  
  15.             slaveDB = method.getDeclaringClass().getAnnotation(SlaveDB.class) ; 
    16. 
  
  
  
  
  16.         } 
    17. 
  
  
  
  
  17.         if (methodName.startsWith("find")  
    18. 
  
  
  
  
  18.                 || methodName.startsWith("get") 
    19. 
  
  
  
  
  19.                 || methodName.startsWith("query") 
    20. 
  
  
  
  
  20.                 || methodName.startsWith("select") 
    21. 
  
  
  
  
  21.                 || methodName.startsWith("list") 
    22. 
  
  
  
  
  22.                 || slaveDB != null) { 
    23. 
  
  
  
  
  23.             holder.set(1) ; 
    24. 
  
  
  
  
  24.         } else { 
    25. 
  
  
  
  
  25.             holder.set(0) ; 
    26. 
  
  
  
  
  26.         } 
    27. 
  
  
  
  
  27.         return invocation.proceed(); 
    28. 
  
  
  
  
  28.     } 
    29. 
  
  
  
  
  29.  
    30. 
  
  
  
  
  30. } 
    31.

 應該切點需要動態(tài)配置，所以這里采用spring aop的方式來配置

 
 
 
 
    
  
  
  
  
  1. @Bean 
    2. 
  
  
  
  
  2.     public AspectJExpressionPointcutAdvisor logAdvisor(RWDataSourceProperties props, DataSourceHolder holder) { 
    3. 
  
  
  
  
  3.         AspectJExpressionPointcutAdvisor advisor = new AspectJExpressionPointcutAdvisor() ; 
    4. 
  
  
  
  
  4.         logger.info("執(zhí)行表達式：{}", props.getPointcut()) ; 
    5. 
  
  
  
  
  5.         advisor.setExpression(props.getPointcut()) ; 
    6. 
  
  
  
  
  6.         advisor.setAdvice(new DataSourceAspect(holder)) ; 
    7. 
  
  
  
  
  7.         return advisor ; 
    8. 
  
  
  
  
  8.     } 
    9.

 7.Enable開啟功能

 
 
 
 
    
  
  
  
  
  1. public class RWImportSelector implements ImportSelector { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.     @Override 
    4. 
  
  
  
  
  4.     public String[] selectImports(AnnotationMetadata importingClassMetadata) { 
    5. 
  
  
  
  
  5.         return new String[] {RWConfig.class.getName()} ; 
    6. 
  
  
  
  
  6.     } 
    7. 
  
  
  
  
  7.  
    8. 
  
  
  
  
  8. } 
    9.

 這里的RWConfig為我們上面的配置類

 
 
 
 
    
  
  
  
  
  1. @Retention(RetentionPolicy.RUNTIME) 
    2. 
  
  
  
  
  2. @Target(ElementType.TYPE) 
    3. 
  
  
  
  
  3. @Documented 
    4. 
  
  
  
  
  4. @Import({RWImportSelector.class}) 
    5. 
  
  
  
  
  5. public @interface EnableRW { 
    6. 
  
  
  
  
  6. } 
    7. 
 
 
 
 

 
 
 
 
    
  
  
  
  
  1. @Documented 
    2. 
  
  
  
  
  2. @Retention(RUNTIME) 
    3. 
  
  
  
  
  3. @Target({ TYPE, METHOD }) 
    4. 
  
  
  
  
  4. public @interface SlaveDB { 
    5. 
  
  
  
  
  5. } 
    6.

 有@SlaveDB的注解方法會類都會從讀庫中操作。

到此讀寫分離組件開發(fā)完成。

8.打包安裝到本地倉庫

 
 
 
 
    
  
  
  
  
  1. mvn install -Dmaven.test.skip=true 
    2.

9.新建base-web項目

引入依賴

 
 
 
 
    
  
  
  
  
  1.  
    2. 
  
  
  
  
  2.             com.pack 
    3. 
  
  
  
  
  3.             xg-component-rw 
    4. 
  
  
  
  
  4.             1.0.0 
    5. 
  
  
  
  
  5.  
    6.

 啟動類添加注解開啟讀寫分離功能

 
 
 
 
    
  
  
  
  
  1. @SpringBootApplication 
    2. 
  
  
  
  
  2. @EnableRW 
    3. 
  
  
  
  
  3. public class BaseWebApplication { 
    4. 
  
  
  
  
  4.  
    5. 
  
  
  
  
  5.     public static void main(String[] args) { 
    6. 
  
  
  
  
  6.         SpringApplication.run(BaseWebApplication.class, args); 
    7. 
  
  
  
  
  7.     } 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9. } 
    10.

 測試：

第一次查詢：

第二次查詢：

為了區(qū)別兩個從庫設置不同的數(shù)據(jù)

這里是寫庫

完畢?。?！


網(wǎng)站欄目：SpringBoot讀寫分離組件開發(fā)詳解
當前地址：http://www.5511xx.com/article/cohhjjo.html