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

SpringBoot整合atomikos實現(xiàn)跨庫事務(wù)的詳細方案

 更新時間:2022年06月02日 11:57:10   作者:code2roc  
這篇文章主要介紹了SpringBoot整合atomikos實現(xiàn)跨庫事務(wù),業(yè)務(wù)主要涉及政府及企業(yè)且并發(fā)量不大,所以采用XA事務(wù),雖然性能有所損失,但是可以保證數(shù)據(jù)的強一致性,需要的朋友可以參考下

背景

框架之前完成了多數(shù)據(jù)源的動態(tài)切換及事務(wù)的處理,想更近一步提供一個簡單的跨庫事務(wù)處理功能,經(jīng)過網(wǎng)上的搜索調(diào)研,大致有XA事務(wù)/SEGA事務(wù)/TCC事務(wù)等方案,因為業(yè)務(wù)主要涉及政府及企業(yè)且并發(fā)量不大,所以采用XA事務(wù),雖然性能有所損失,但是可以保證數(shù)據(jù)的強一致性

方案設(shè)計

針對注冊的數(shù)據(jù)源拷貝一份用于XA事務(wù),使得本地事務(wù)和XA全局事務(wù)相互獨立可選擇的使用

Maven配置

引入atomikos第三方組件

 <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jta-atomikos</artifactId>
        </dependency>

注冊XA數(shù)據(jù)源

使用Druid連接池,需要使用DruidXADataSource數(shù)據(jù)源對象,再使用AtomikosDataSourceBean進行包裝

注冊數(shù)據(jù)源時針對同一個連接注冊兩份,一份正常數(shù)據(jù)源,一份用于XA事務(wù)的數(shù)據(jù)源,數(shù)據(jù)源標識區(qū)分并關(guān)聯(lián)

因為spring默認注冊了XA事務(wù)管理器后,所有事務(wù)操作不再走本地事務(wù),我們通過切換不同的數(shù)據(jù)源決定走本地事務(wù)還是XA事務(wù)

 //主數(shù)據(jù)源xa模式
    @Bean
    @Qualifier("masterXADataSource")
    public DataSource masterXADataSource() {
        DruidXADataSource datasource = new DruidXADataSource();
        if(driverClassName.equals("com.mysql.cj.jdbc.Driver")){
            if(!dbUrl.contains("useOldAliasMetadataBehavior")){
                dbUrl += "&useOldAliasMetadataBehavior=true";
            }
            if(!dbUrl.contains("useAffectedRows")){
                dbUrl += "&useAffectedRows=true";
            }
        }
        datasource.setUrl(this.dbUrl);
        datasource.setUsername(username);
        datasource.setPassword(password);
        datasource.setDriverClassName(driverClassName);
        //configuration
        datasource.setInitialSize(1);
        datasource.setMinIdle(3);
        datasource.setMaxActive(20);
        datasource.setMaxWait(60000);
        datasource.setTimeBetweenEvictionRunsMillis(60000);
        datasource.setMinEvictableIdleTimeMillis(60000);
        datasource.setValidationQuery("select 'x'");
        datasource.setTestWhileIdle(true);
        datasource.setTestOnBorrow(false);
        datasource.setTestOnReturn(false);
        datasource.setPoolPreparedStatements(true);
        datasource.setMaxPoolPreparedStatementPerConnectionSize(20);
        datasource.setLogAbandoned(false); //移除泄露連接發(fā)生是是否記錄日志
        try {
            datasource.setFilters("stat,slf4j");
        } catch (SQLException e) {
            logger.error("druid configuration initialization filter", e);
        }
        datasource.setConnectionProperties("druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000");//connectionProperties);

        AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean();
        atomikosDataSourceBean.setXaDataSourceClassName("com.alibaba.druid.pool.xa.DruidXADataSource");
        atomikosDataSourceBean.setUniqueResourceName("master-xa");
        atomikosDataSourceBean.setXaDataSource(datasource);
        atomikosDataSourceBean.setPoolSize(5);
        atomikosDataSourceBean.setMaxPoolSize(20);
        atomikosDataSourceBean.setTestQuery("select 1");
        return atomikosDataSourceBean;
    }

注冊XA事務(wù)管理器

使用spring內(nèi)置的JtaTransactionManager事務(wù)管理器對象,設(shè)置AllowCustomIsolationLevels為true,否則指定自定義事務(wù)隔離級別會報錯

    //xa模式全局事務(wù)管理器
    @Bean(name = "jtaTransactionManager")
    public PlatformTransactionManager transactionManager() throws Throwable {
        UserTransactionManager userTransactionManager = new UserTransactionManager();
        UserTransaction userTransaction = new UserTransactionImp();
        JtaTransactionManager jtaTransactionManager =  new JtaTransactionManager(userTransaction, userTransactionManager);
        jtaTransactionManager.setAllowCustomIsolationLevels(true);
        return jtaTransactionManager;
    }

定義XA事務(wù)切面

自定義注解@GlobalTransactional并定義對應(yīng)切面,使用指定注解時在ThreadLocal變量值進行標識,組合

@Transactional注解指定XA事務(wù)管理器,在切換數(shù)據(jù)原時判斷當前是否在XA事物中,從而切換不同的數(shù)據(jù)源

@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
@Transactional(rollbackFor = Exception.class,isolation = Isolation.READ_UNCOMMITTED,transactionManager = "jtaTransactionManager")
public @interface GlobalTransactional {
}
@Aspect
@Component
@Order(value = 99)
public class GlobalTransitionAspect {
    private static Logger logger = LoggerFactory.getLogger(GlobalTransitionAspect.class);
    @Autowired
    private DynamicDataSource dynamicDataSource;

    /**
     * 切面點 指定注解
     */
    @Pointcut("@annotation(com.code2roc.fastkernel.datasource.GlobalTransactional) " +
            "|| @within(com.code2roc.fastkernel.datasource.GlobalTransactional)")
    public void dataSourcePointCut() {

    }

    /**
     * 攔截方法指定為 dataSourcePointCut
     */
    @Around("dataSourcePointCut()")
    public Object around(ProceedingJoinPoint point) throws Throwable {
        MethodSignature signature = (MethodSignature) point.getSignature();
        Method method = signature.getMethod();
        GlobalTransactional methodAnnotation = method.getAnnotation(GlobalTransactional.class);
        if (methodAnnotation != null) {
            DataSourceContextHolder.tagGlobal();
            logger.info("標記全局事務(wù)");
        }
        try {
            return point.proceed();
        } finally {
            logger.info("清除全局事務(wù)");
            DataSourceContextHolder.clearGlobal();
        }
    }
}
public class DataSourceContextHolder {
    private static Logger log = LoggerFactory.getLogger(DataSourceContextHolder.class);
    // 對當前線程的操作-線程安全的
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();
    private static final ThreadLocal<String> contextGlobalHolder = new ThreadLocal<String>();

    // 調(diào)用此方法,切換數(shù)據(jù)源
    public static void setDataSource(String dataSource) {
        contextHolder.set(dataSource);
        log.debug("已切換到數(shù)據(jù)源:{}", dataSource);
    }

    // 獲取數(shù)據(jù)源
    public static String getDataSource() {
        String value = contextHolder.get();
        if (StringUtil.isEmpty(value)) {
            value = "master";
        }
        if (!StringUtil.isEmpty(getGlobal())) {
            value = value + "-xa";
        }
        return value;
    }

    // 刪除數(shù)據(jù)源
    public static void clearDataSource() {
        contextHolder.remove();
        log.debug("已切換到主數(shù)據(jù)源");
    }

    //====================全局事務(wù)標記================
    public static void tagGlobal() {
        contextGlobalHolder.set("1");
    }

    public static String getGlobal() {
        String value = contextGlobalHolder.get();
        return value;
    }

    public static void clearGlobal() {
        contextGlobalHolder.remove();
    }
    //===================================================
}

配置XA事務(wù)日志

通過在resource文件夾下創(chuàng)建transactions.properties文件可以指定XA事務(wù)日志的存儲路徑

com.atomikos.icatch.log_base_dir= tempfiles/transition/

到此這篇關(guān)于SpringBoot整合atomikos實現(xiàn)跨庫事務(wù)的文章就介紹到這了,更多相關(guān)SpringBoot整合atomikos內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • 關(guān)于@Valid注解大全以及用法規(guī)范

    關(guān)于@Valid注解大全以及用法規(guī)范

    這篇文章主要介紹了關(guān)于@Valid注解大全以及用法規(guī)范,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-01-01
  • 七個Spring核心模塊詳解

    七個Spring核心模塊詳解

    這篇文章主要為大家詳細介紹了七個Spring的核心模塊,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2018-03-03
  • java集合中的list詳解

    java集合中的list詳解

    這篇文章主要介紹了java集合中的list詳解,還是比較不錯的,這里分享給大家,需要的朋友可以參考下。
    2017-11-11
  • Java反射機制詳解

    Java反射機制詳解

    Java的反射機制是在運行狀態(tài)中,對于任何一個類,都可以知道這個類的所有屬性和方法,對于任何一個對象,都可以調(diào)用它所有的方法和屬性,修改部分類型信息。本文就來詳細講講Java反射機制的使用
    2022-07-07
  • Java編程Nashorn實例代碼

    Java編程Nashorn實例代碼

    這篇文章主要介紹了Java編程Nashorn實例代碼,小編覺得還是挺不錯的,具有一定借鑒價值,需要的朋友可以參考下
    2018-01-01
  • mybatis類型轉(zhuǎn)換器如何實現(xiàn)數(shù)據(jù)加解密

    mybatis類型轉(zhuǎn)換器如何實現(xiàn)數(shù)據(jù)加解密

    這篇文章主要介紹了mybatis類型轉(zhuǎn)換器如何實現(xiàn)數(shù)據(jù)加解密,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-09-09
  • Java中內(nèi)部類使用方法實戰(zhàn)案例分析

    Java中內(nèi)部類使用方法實戰(zhàn)案例分析

    這篇文章主要介紹了Java中內(nèi)部類使用方法,結(jié)合具體案例形式分析了Java內(nèi)部類原理、調(diào)用方法及相關(guān)使用注意事項,需要的朋友可以參考下
    2019-09-09
  • 基于Java編寫第一個區(qū)塊鏈項目

    基于Java編寫第一個區(qū)塊鏈項目

    區(qū)塊鏈是分布式數(shù)據(jù)存儲、點對點傳輸、共識機制、加密算法等計算機技術(shù)的新型應(yīng)用模式,下面這篇文章主要給大家介紹了基于Java實現(xiàn)區(qū)塊鏈的相關(guān)資料,需要的朋友可以參考下
    2021-08-08
  • SpringBoot如何進行對象復制的實踐

    SpringBoot如何進行對象復制的實踐

    本文主要介紹了SpringBoot 如何進行對象復制,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-09-09
  • springboot集成shiro遭遇自定義filter異常的解決

    springboot集成shiro遭遇自定義filter異常的解決

    這篇文章主要介紹了springboot集成shiro遭遇自定義filter異常的解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-11-11

最新評論