2. 程式人生 > >spring-boot入門（七）atomikos+druid+多資料來源下的分散式事務配置

spring-boot入門（七）atomikos+druid+多資料來源下的分散式事務配置

阿新 • • 發佈：2018-12-31

spring-boot入門（七）atomikos+druid+多資料來源下的分散式事務配置

本章內容是基於spring-boot入門（六）多資料來源的基礎之上進行的，如果還不瞭解多資料來源怎麼配置，請參考上一章節的內容。在上一章節的末尾我們遺留了一個問題：多資料來源下的分散式事務問題。在分散式事務下我們需要使用JTA（Java Transaction API）事務來處理事務，保證事務的強一致性，即要成功都成功，一個失敗全部回滾。Atomikos 是一個為Java平臺提供增值服務的並且開源類事務管理器，本章我們將使用Atomikos 來解決分散式事務問題。

1. 配置atomikos

JTA事務的配置需要配置：XA資料來源和JTA事務管理器

1.1 引入atomikos依賴

spring boot整合atomikos，只需新增一下依賴即可

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

1.2 自定義atomikos相關屬性(自動注入JTA事務管理器)

如果不自定義相關屬性，那麼spring boot 會初始化預設的atomikos配置，可看org.springframework.boot.autoconfigure.transaction.jta.AtomikosJtaConfiguration是如何初始化預設的配置。當然也可以自定義atomikos，通過該配置spring boot會啟用atomikos實現的JTA事務管理器。

spring:
  jta:
    atomikos:
      properties:
        max-actives: 50
        max-timeout: 300000
        default-jta
 
-timeout: 10000
        enable-logging: true

上面是atomikos的一個配置示例。更多可檢視org.springframework.boot.jta.atomikos.AtomikosProperties。

1.3 配置XA資料來源

   @Bean
    @Primary
    @ConfigurationProperties(prefix = "boc.datasource")
    public DataSource bocDataSource(@Qualifier("bocDataSourceProperties") DataSourceProperties dataSourceProperties) throws SQLException {
        DruidXADataSource druidXADataSource = new DruidXADataSource();
        InitDruidDataSource(druidXADataSource, dataSourceProperties);

        AtomikosDataSourceBean atomikosDataSource = new AtomikosDataSourceBean();
        atomikosDataSource.setUniqueResourceName("bocDataSource");
        atomikosDataSource.setXaDataSource(druidXADataSource);
        atomikosDataSource.setTestQuery("SELECT 1");
        return atomikosDataSource;
    }

    @Bean
    @ConfigurationProperties(prefix = "ccb.datasource")
    public DataSource ccbDataSource(@Qualifier("ccbDataSourceProperties") DataSourceProperties dataSourceProperties) throws SQLException {
        DruidXADataSource druidXADataSource = new DruidXADataSource();
        InitDruidDataSource(druidXADataSource, dataSourceProperties);

        //也可以使用mysql預設的xa資料來源
        //MysqlXADataSource mysqlXADataSource = new MysqlXADataSource();
        //mysqlXADataSource.setUrl(dataSourceProperties.getUrl());
        //mysqlXADataSource.setUser(dataSourceProperties.getUsername());
        //mysqlXADataSource.setPassword(dataSourceProperties.getPassword());

        AtomikosDataSourceBean atomikosDataSource = new AtomikosDataSourceBean();
        atomikosDataSource.setUniqueResourceName("ccbDataSource");
        atomikosDataSource.setXaDataSource(druidXADataSource);
        atomikosDataSource.setTestQuery("SELECT 1");
        return atomikosDataSource;
    }

在這裡我們返回的是AtomikosDataSourceBean ，是Druid實現的一個XA資料來源也可以用註釋中的MysqlXADataSource,配置了XAdatasource還需要將其轉換為AtomikosDataSourceBean(Atomikos使用的是該資料來源，用於包裝不同的XA資料來源實現，使得底層架構不變，對擴充套件開放)，springboot預設配置的時候會使用AtomikosXADataSourceWrapper來包裹XAdatasource:
這裡寫圖片描述
因為我們是手動注入DataSource，所以需要自己重新包裝一次。

到此XA資料來源和JTA事務都配置完畢，這時使用@Transactional註解將使用atomikos實現的事務管理器。

2.測試

還是沿用上節的測試程式碼，當我們執行testTransferAccountCcbToBocOnException()測試方法，會發現ccb庫的資料成功回滾。而且根據console日誌能檢視事務提交和回滾的完整過程：

2018-04-02 23:15:49.536  INFO 14076 --- [           main] c.a.icatch.imp.BaseTransactionManager    : createCompositeTransaction ( 10000 ): created new ROOT transaction with id 10.100.144.36.tm0000100001
2018-04-02 23:15:49.574  INFO 14076 --- [           main] c.atomikos.jdbc.AbstractDataSourceBean   : AtomikosDataSoureBean 'ccbDataSource': getConnection ( null )...
2018-04-02 23:15:49.574  INFO 14076 --- [           main] c.atomikos.jdbc.AbstractDataSourceBean   : AtomikosDataSoureBean 'ccbDataSource': init...
2018-04-02 23:15:49.628  INFO 14076 --- [           main] c.a.icatch.imp.CompositeTransactionImp   : addParticipant ( XAResourceTransaction: 31302E3130302E3134342E33362E746D30303030313030303031:31302E3130302E3134342E33362E746D31 ) for transaction 10.100.144.36.tm0000100001
2018-04-02 23:15:49.628  INFO 14076 --- [           main] c.a.datasource.xa.XAResourceTransaction  : XAResource.start ( 31302E3130302E3134342E33362E746D30303030313030303031:31302E3130302E3134342E33362E746D31 , XAResource.TMNOFLAGS ) on resource ccbDataSource represented by XAResource instance [email protected]
2018-04-02 23:15:49.689  INFO 14076 --- [           main] c.a.icatch.imp.CompositeTransactionImp   : registerSynchronization ( com.a[email protected]a9775fbb ) for transaction 10.100.144.36.tm0000100001
2018-04-02 23:15:49.689  INFO 14076 --- [           main] c.atomikos.jdbc.AtomikosConnectionProxy  : atomikos connection proxy for [email protected]: calling prepareStatement(UPDATE account_ccb SET balance = balance+? WHERE customer = ?;)...
2018-04-02 23:15:50.358  INFO 14076 --- [           main] c.f.service.impl.AccountCcbServiceImpl   : update balance ,[customer:10002,amount:-100]
2018-04-02 23:15:50.364  INFO 14076 --- [           main] c.atomikos.jdbc.AbstractDataSourceBean   : AtomikosDataSoureBean 'bocDataSource': getConnection ( null )...
2018-04-02 23:15:50.364  INFO 14076 --- [           main] c.atomikos.jdbc.AbstractDataSourceBean   : AtomikosDataSoureBean 'bocDataSource': init...
2018-04-02 23:15:50.367  INFO 14076 --- [           main] c.a.icatch.imp.CompositeTransactionImp   : addParticipant ( XAResourceTransaction: 31302E3130302E3134342E33362E746D30303030313030303031:31302E3130302E3134342E33362E746D32 ) for transaction 10.100.144.36.tm0000100001
2018-04-02 23:15:50.374  INFO 14076 --- [           main] c.a.datasource.xa.XAResourceTransaction  : XAResource.start ( 31302E3130302E3134342E33362E746D30303030313030303031:31302E3130302E3134342E33362E746D32 , XAResource.TMNOFLAGS ) on resource bocDataSource represented by XAResource instance [email protected]
2018-04-02 23:15:50.379  INFO 14076 --- [           main] c.a.icatch.imp.CompositeTransactionImp   : registerSynchronization ( com.a[email protected]a9775fbb ) for transaction 10.100.144.36.tm0000100001
2018-04-02 23:15:50.379  INFO 14076 --- [           main] c.atomikos.jdbc.AtomikosConnectionProxy  : atomikos connection proxy for [email protected]: calling prepareStatement(UPDATE account_boc SET balance = balance+? WHERE customer = ?;)...
2018-04-02 23:15:50.451  INFO 14076 --- [           main] c.a.icatch.imp.CompositeTransactionImp   : setRollbackOnly() called for transaction 10.100.144.36.tm0000100001
2018-04-02 23:15:50.452  INFO 14076 --- [           main] c.atomikos.jdbc.AtomikosConnectionProxy  : atomikos connection proxy for [email protected]: close()...
2018-04-02 23:15:50.452  INFO 14076 --- [           main] c.a.datasource.xa.XAResourceTransaction  : XAResource.end ( 31302E3130302E3134342E33362E746D30303030313030303031:31302E3130302E3134342E33362E746D31 , XAResource.TMSUCCESS ) on resource ccbDataSource represented by XAResource instance [email protected]
2018-04-02 23:15:50.453  INFO 14076 --- [           main] c.atomikos.jdbc.AtomikosConnectionProxy  : atomikos connection proxy for [email protected]: close()...
2018-04-02 23:15:50.453  INFO 14076 --- [           main] c.a.datasource.xa.XAResourceTransaction  : XAResource.end ( 31302E3130302E3134342E33362E746D30303030313030303031:31302E3130302E3134342E33362E746D32 , XAResource.TMSUCCESS ) on resource bocDataSource represented by XAResource instance [email protected]
2018-04-02 23:15:50.456  INFO 14076 --- [           main] c.a.datasource.xa.XAResourceTransaction  : XAResource.rollback ( 31302E3130302E3134342E33362E746D30303030313030303031:31302E3130302E3134342E33362E746D31 ) on resource ccbDataSource represented by XAResource instance [email protected]
2018-04-02 23:15:50.583  INFO 14076 --- [           main] c.a.datasource.xa.XAResourceTransaction  : XAResource.rollback ( 31302E3130302E3134342E33362E746D30303030313030303031:31302E3130302E3134342E33362E746D32 ) on resource bocDataSource represented by XAResource instance [email protected]
2018-04-02 23:15:50.587  INFO 14076 --- [           main] c.a.icatch.imp.CompositeTransactionImp   : rollback() done of transaction 10.100.144.36.tm0000100001

在上面的日誌中我們可以看到，當其中一個事務失敗，會JTA呼叫setRollbackOnly()，然後XAResource連線呼叫各自的rollback()方法進行回滾。
到本章為止，使用spring boot訪問資料庫，及多資料來源和多資料來源下的分散式事務都已經介紹完了，之後的章節可能會介紹如何使用攔截器和過濾器及其它的一些web應用中的常見技術在spring boot中的應用。

本章完整程式碼在：https://github.com/Json-Lin/spring-boot-practice/tree/master/spring-boot-practice-atomikos

END

相關推薦

spring-boot入門（七）atomikos+druid+多資料來源下的分散式事務配置

spring-boot入門（七）atomikos+druid+多資料來源下的分散式事務配置 本章內容是基於spring-boot入門（六）多資料來源的基礎之上進行的，如果還不瞭解多資料來源怎麼配置，請參考上一章節的內容。在上一章節的末尾我們遺留了一個問題：多資料來源下的分散式事務問題

spring boot入門（七） springboot的攔截器Interceptor。最完整、簡單易懂、詳細的spring boot教程。

很多同學搞不懂攔截器和過濾器的區別，我們先說一下他們的區別： 過濾器和攔截器非常相似，但是它們有很大的區別 最簡單明瞭的區別就是過濾器可以修改request，而攔截器不能 過濾器需要在servlet容器中實現，攔截器可以適用於javaEE，javaSE等各種環境 攔截

Spring Boot 入門（四）微服務之 Config Server 統一配置中心

bootstra pan pat 默認 star default client efault localhost 一、目錄結構 二、pom文件 <!-- 配置服務依賴 --> <dependency> &l

Spring Boot入門（四）——使用模板FreeMaker

junit boot.s char pack utf put 常見 節點 簡單的 這周主要學習怎麽在Spring Boot中使用模板引擎FreeMaker，主要從以下幾方面進行學習。 (1) freemarker介紹： FreeMarker是一款模板引擎： 即

Spring boot入門（1）

概念 Spring Boot是由Pivotal團隊提供的全新框架，其設計目的是用來簡化新Spring應用的初始搭建以及開發過程。該框架使用了特定的方式來進行配置，從而使開發人員不再需要定義樣板化的配置。 spring boot對spring mvc、tomcat等都做了整合，只需要依

Spring Boot入門（三）起步依賴

Spring Boot起步依賴的功能：開發者只需指定功能，構建過程自動分析使用者需求，引入相關依賴 起步依賴本質上是一個Maven專案物件模型（Project Object Model,POM），定義了對其他庫的傳遞依賴，通過依賴疊加，實現功能支援，因此很多依賴

Spring boot入門（三）：SpringBoot整合結合AdminLTE(Freemarker)，利用generate自動生成程式碼，利用DataTable和PageHelper進行分頁顯示

　　關於SpringBoot和PageHelper，前篇部落格已經介紹過Spring boot入門（二）：Spring boot整合MySql,Mybatis和PageHelper外掛，前篇部落格大致講述了SpringBoot如何整合Mybatis和Pagehelper,但是沒有做出實際的範例，本篇部落格是連

Spring Boot 入門（三）： 自動化配置實現

自動化配置實現 我們在上章編寫入門案例的時候，我們使用的是Spring Mvc 作為我們的表現層框架，但是我們都知道我們要使用Spring Mvc 我們就需要在web.xml檔案中配置Spring Mvc 的前端控制器DispatcherServlet。但是我們

Spring Boot入門（2）使用MySQL資料庫

介紹   本文將介紹如何在Spring專案中連線、處理MySQL資料庫。   該專案使用Spring Data JPA和Hibernate來連線、處理MySQL資料庫，當然，這僅僅是其中一種方式，你也可以使用Spring JDBC或者MyBatis.   

Spring Boot入門（11）實現檔案下載功能

  在這篇部落格中，我們將展示如何在Spring Boot中實現檔案的下載功能。   還是遵循筆者寫部落格的一貫風格，簡單又不失詳細，實用又能讓你學會。   本次建立的Spring Boot專案的主要功能為檔案下載，而且這也是唯一功能，當然，作為例子，要儘可

spring boot 入門（八）filter、servlet、listener

spring boot 入門（八）servlet、filter、listener 1. filter spring boot有兩種方式來配置filter 1.1 Servlet 3.0新特性，以註解方式配置Filter，需在啟動類上加入@ServletComponentSc

spring-boot入門（六）多資料來源

spring-boot入門（六）多資料來源 我們現在可以通過自定義的資料來源，用spring boot迅速的搭建起一個訪問資料庫的應用，有時候一個系統往往會和多個數據庫進行互動。當然可以通過遠端服務呼叫方式訪問多個數據庫，每個服務負責不同的資料庫訪問，但是多資料來源的方式可能會更加的

spring boot 入門（一）

轉自構建微服務：Spring boot 入門篇 什麼是spring boot Spring Boot是由Pivotal團隊提供的全新框架，其設計目的是用來簡化新Spring應用的初始搭建以及開發過程。該框架使用了特定的方式來進行配置，從而使開發人員不再需要定義樣板化的配置。用我的話來理解，就是spring

Spring Boot入門（12）實現頁面訪問量統計功能

  在日常的網站使用中，經常會碰到頁面的訪問量（或者訪問者人數）統計。那麼，在Spring Boot中該如何實現這個功能呢？   我們的想法是比較簡單的，那就是將訪問量儲存在某個地方，要用的時候取出來即可，儲存的位置可選擇資料庫或者其他檔案。本例所使用的例子為

spring boot入門（四） springboot事務管理。最完整、簡單易懂、詳細的spring boot教程。

本文緊接spring boot入門（三）。 事務管理是對於一系列資料庫操作進行管理，一個事務包含一個或多個SQL語句，是邏輯管理的工作單元（原子單元）。通俗的講，事務管理是指的“一次操作”要不就全做，要不就全不做。例如，在一個訂單系統中，包括生成訂單，扣除商品存庫等操作，如

spring-boot入門（四）與資料庫互動

package com.foo.configura; import org.apache.tomcat.jdbc.pool.DataSource; import org.hibernate.SessionFactory; import org.springframework.beans.factory.an

Spring Boot 入門 （一）——建一個最簡單的springboot專案

建立一個最簡單的springboot專案 廢話不多說直接開整！！ 開啟eclipse新建一個maven專案，目錄格式如下： 開啟pom.xml檔案，引入父依賴，web依賴，並設定JDK版本 <project xmlns="http://maven.apache.or

Spring Boot入門（6）前端接受後臺傳參

基礎知識   利用Spring Boot來製作Web應用，就必定會涉及到前端與後臺之間互相傳遞引數。在Spring Boot的MVC模型中，如果採用Thymeleaf來渲染檢視，則前端頁面怎麼才能獲得後臺執行傳遞的引數呢？   我們介紹兩種在Thymelea

Spring Boot：（七）預設日誌logback配置解析

前言今天來介紹下Spring Boot如何配置日誌logback,我們帶著下面幾個問題來學習。如何引入日誌？日誌輸出格式以及輸出方式如何配置？程式碼中如何使用？正文Spring Boot在所有內部日誌中使用Commons Logging，但是預設配置也提供了對常用日誌的支援，

Spring Boot入門（一）返回JSON資料及資料封裝

1.從建立的專案的環境裡可以看到Spring Boot預設載入了Jackson，所以Spring Boot專案預設使用Jackson來返回JSON資料。 Jackson對空屬性統一設定為null，不管該屬性是什麼資料型別，這不利於資料操作，可以對Jackson進行配置 （