2. 程式人生 > >Spring+JTA+Atomikos+mybatis分散式事務管理

Spring+JTA+Atomikos+mybatis分散式事務管理

阿新 • • 發佈：2018-11-21

 

背景描述：我們平時的工作中用到的Spring事務管理是管理一個數據源的。但是如果對多個數據源進行事務管理該怎麼辦呢？我們可以用JTA和Atomikos結合Spring來實現一個分散式事務管理的功能。

事務（官方解釋）：是由一組sql語句組成的“邏輯處理單元”。

事務具有如下四個屬性，通常稱為事務的ACID屬性 ： 
1. 原子性（Atomicity）: 事務是一個原子操作單元，要麼都執行，要麼都不執行。 
2. 一致性（Consistent）：在事務開始和完成時，資料都必須保持一致。 
3. 隔離性（Isoation）: 資料庫系統提供一定的隔離機制，保證事務在不受外部併發操作影響的“獨立”環境執行。 
4. 永續性（Durabe）: 事務完成之後，它對資料的修改是永久性的。

分散式事務 ： 分散式事務就是指事務的參與者，支援事務的伺服器，資源伺服器，以及事務管理器分別位於不同的分散式系統的不同節點之上。

本質上來說，分散式事務就是為了保證“不同資料庫的資料一致性” 。

分散式事務管理器 ：

XA 協議 是可以在資料庫conmit 之後進行回滾的。

XA：XA是一個分散式事務協議，由事務管理器和本地資源管理器兩部分組成。其中本地資源管理器往往由資料庫實現，比如Oracle，DB2這些商業資料庫都實現了XA介面。事務管理器作為全域性的排程者，負責各個本地資源的提交和回滾。

通過日誌記錄操作，從上到下任何一步有問題，就會回滾。

Atomikos優點：

XA協議比較簡單，使用分散式事務的成本比較低；缺點：效能不理想，XA無法滿足高併發場景，許多noSQL也沒有支援XA。

Atomikos是一個為java平臺提供的開源的事務管理器，主要實現了1：全面崩潰/重啟恢復；2：相容標準的SUN公司JTA API；3：巢狀事務；4：為XA和非XA提供內建的JDBC介面卡。

 

具體實現：

首先需要下載Atomikos需要的jar包：https://download.csdn.net/download/u013310119/10795168

步驟二：準備配置檔案。datasource.properties，jta.properties

datasource.properties

#資料來源A
dataSource.oracle.driver=oracle.jdbc.driver.OracleDriver
dataSource.oracle.url=jdbc:oracle:thin:@**.19.**.101:1521:xypjcp1
dataSource.oracle.username=inf_nsxycs
dataSource.oracle.password=inf_nsxycs


#資料來源B
#org.loushang.persistent.jdbc.datasource.PropertyDataSourceFactoryImpl
dataSource.oracle.nw.url=jdbc:oracle:thin:@**.19.**.91:1521:orcl
dataSource.oracle.nw.username=yhzx
dataSource.oracle.nw.password=yhzx

jta.properties

com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory
com.atomikos.icatch.console_file_name = tm.out   
com.atomikos.icatch.log_base_name = tmlog   
com.atomikos.icatch.tm_unique_name = com.atomikos.spring.jdbc.tm   
com.atomikos.icatch.console_log_level = INFO

步驟三：在datasource.xml中配置兩個資料來源

<?xml version="1.0" encoding="UTF-8"?>
<!-- wbw 2016.8.22 -->
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jdbc="http://www.springframework.org/schema/jdbc"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
		http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
		http://www.springframework.org/schema/jdbc 
		http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd">
	
	
	<!-- 多個數據源的公用配置，方便下面直接引用 -->
     <bean id="abstractXADataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean"
             destroy-method="close">
        <property name="xaDataSourceClassName" value="oracle.jdbc.xa.client.OracleXADataSource"/>
        <property name="poolSize" value="30" />
        <property name="minPoolSize" value="30"/>
        <property name="maxPoolSize" value="100"/>
        <property name="borrowConnectionTimeout" value="600"/>
        <property name="reapTimeout" value="200"/>
        <property name="maxIdleTime" value="1200"/>
        <property name="maintenanceInterval" value="1200" />
        <property name="loginTimeout" value="1200"/>
        <property name="logWriter" value="1200"/>
        <property name="testQuery">
            <value>SELECT * from dual</value>
        </property>
    </bean> 
   <!--資料來源A-->
    
     <bean id="dataSourcegs3" parent="abstractXADataSource">
        <property name="uniqueResourceName" value="dataSourcegs3" />
        <property name="xaDataSourceClassName"
            value="oracle.jdbc.xa.client.OracleXADataSource" />
        <property name="xaProperties">
            <props>
                <prop key="URL">${dataSource.oracle.gs3.url}</prop>
                    <prop key="user">${dataSource.oracle.gs3.username}</prop>
                    <prop key="password">${dataSource.oracle.gs3.password}</prop>
                    <prop key="pinGlobalTxToPhysicalConnection">true</prop>
            </props>
         </property>
    </bean>
  
 <!--資料來源B-->
  <bean id="dataSourceds3" parent="abstractXADataSource">
        <property name="uniqueResourceName" value="dataSourceds3" />
        <property name="xaDataSourceClassName"
            value="oracle.jdbc.xa.client.OracleXADataSource" />
        <property name="xaProperties">
            <props>
                <prop key="URL">${dataSource.oracle.ds3.url}</prop>
                    <prop key="user">${dataSource.oracle.ds3.username}</prop>
                    <prop key="password">${dataSource.oracle.ds3.password}</prop>
                     <prop key="pinGlobalTxToPhysicalConnection">true</prop>
            </props>
        </property>
       
    </bean>
  
   
</beans>

步驟四：配置分散式事務

 <!-- jta配置開始 -->
    <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"
        init-method="init" destroy-method="close">
        <property name="forceShutdown">
            <value>true</value>
        </property>
    </bean>
 
    <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
        <property name="transactionTimeout" value="300" />
    </bean>
 
    <bean id="springTransactionManager"
        class="org.springframework.transaction.jta.JtaTransactionManager">
        <property name="transactionManager">
            <ref bean="atomikosTransactionManager" />
        </property>
        <property name="userTransaction">
            <ref bean="atomikosUserTransaction" />
        </property>
         <!-- 必須設定，否則程式出現異常 JtaTransactionManager does not support custom isolation levels by default -->
        <property name="allowCustomIsolationLevels" value="true" />
    </bean>
    <!-- jta配置結束 -->
    
	<!-- 配置事務管理 -->
     <tx:annotation-driven transaction-manager="springTransactionManager" proxy-target-class="true" />

 

 

步驟五、配置mybatis

<bean id="sqlSessionFactorygs3" class="org.mybatis.spring.SqlSessionFactoryBean">
		<property name="dataSource" ref="dataSourcegs3" />
		<property name="databaseIdProvider" ref="databaseIdProvider" />
		<property name="mapperLocations">
            <list>
                <value>classpath:com/inspur/ahgs3/dao/mapper/*.xml</value>
            </list>
        </property>
		<property name="configLocation" value="/WEB-INF/spring/mybatis-config.xml" />
	</bean>
	
	<bean id="sqlSessionFactoryds3" class="org.mybatis.spring.SqlSessionFactoryBean">
		<property name="dataSource" ref="dataSourceds3" />
		<property name="databaseIdProvider" ref="databaseIdProvider" />
		<property name="mapperLocations">
            <list>
                <value>classpath:com/inspur/ahds3/dao/mapper/*.xml</value>
            </list>
        </property>
		<property name="configLocation" value="/WEB-INF/spring/mybatis-config.xml" />
	</bean>

 

配置mybatis對映檔案自動掃描

	
	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
		<property name="basePackage" value="com.inspur.ahgs3.dao" />
		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactorygs3" />
	</bean>
	
	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
		<property name="basePackage" value="com.inspur.ahds3.dao" />
		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactoryds3" />
	</bean>

步驟六：Service層程式碼

@Service
public class Gs3Service {
	@Autowired
	private gs3dao g3dao;
	
	@Autowired
	private ds3dao d3dao;
	
	@Transactional(value="springTransactionManager",rollbackFor=Exception.class)
	public void findAll(Map<String, String> bodyMap){
		
			 Map<String,String> bodyMap1 = new HashMap<String,String>();
			 
			 bodyMap1.put("id", "111");
			 bodyMap1.put("name", "lixiao");
			 bodyMap1.put("age", "23");
			
			 g3dao.insert( bodyMap);
			 
			 
			 d3dao.insert(bodyMap1);
		
	}
		
}

步驟七：編寫測試Controller

@Controller
@RequestMapping("TestJTATransactionManager")
public class TestJTATransactionManager{
	
	private static Logger logger = LoggerFactory.getLogger(TestJTATransactionManager.class); 
	
	 @Autowired
	 private Gs3Service Gs3;
	
	
	 @ResponseBody
	 @RequestMapping(value="/TestJTAT",produces = "text/plain;charset=utf-8")
	 public  void sendSQLMessage(HttpServletRequest request, HttpServletResponse response) throws NamingException, JMSException, InterruptedException, ParseException{
		 Map<String,String> bodyMap = new HashMap<String,String>();
		 
		 bodyMap.put("id", "110");
		 bodyMap.put("name", "lixiao");
		 bodyMap.put("age", "23");
		
		 Gs3.insertAll(bodyMap);
		
	}
	
	
}

model 和 mapper 沒什麼可說的，這裡就不貼上了。

分別在資料來源A和資料來源B中建立Student表，其中一個數據源B中Student表主鍵為id。第一次執行http://localhost:7001/ahyhzx/service/TestJTATransactionManager/TestJTAT.do則兩個庫中Student表同時插入一條資料，在此執行，資料來源B後臺報錯：主鍵衝突。這是發現數據源A中student表中同樣沒有插入資料，兩個資料來源同時回滾。

後續備註：

如果操作的資料來源為MySQL資料庫，則xaDataSourceClassName的值設定為：com.mysql.jdbc.jdbc2.optional.MysqlXADataSource

配置參考如下示例：

<bean id="abstractXADataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init"
          destroy-method="close" abstract="true">
        <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
        <property name="poolSize" value="10" />
        <property name="minPoolSize" value="10"/>
        <property name="maxPoolSize" value="30"/>
        <property name="borrowConnectionTimeout" value="60"/>
        <property name="reapTimeout" value="20"/>
        <!-- 最大空閒時間 -->
        <property name="maxIdleTime" value="60"/>
        <property name="maintenanceInterval" value="60"/>
        <property name="loginTimeout" value="60"/>
        <property name="testQuery">
            <value>select 1</value>
        </property>
    </bean>

    <bean id="qadataSource" parent="abstractXADataSource">
        <!-- value只要兩個資料來源不同就行，隨便取名 -->
        <property name="uniqueResourceName" value="mysql/sitestone1" />
        <property name="xaDataSourceClassName"
                  value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
        <property name="xaProperties">
            <props>
                <prop key="URL">${qa.db.url}</prop>
                <prop key="user">${qa.db.user}</prop>
                <prop key="password">${qa.db.password}</prop>
                <prop key="pinGlobalTxToPhysicalConnection">true</prop>
            </props>
        </property>
    </bean>

    <bean id="devdataSource" parent="abstractXADataSource">
        <!-- value只要兩個資料來源不同就行，隨便取名 -->
        <property name="uniqueResourceName" value="mysql/sitestone" />
        <property name="xaDataSourceClassName"
                  value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" />
        <property name="xaProperties">
            <props>
                <prop key="URL">${dev.db.url}</prop>
                <prop key="user">${dev.db.user}</prop>
                <prop key="password">${dev.db.password}</prop>
                <prop key="pinGlobalTxToPhysicalConnection">true</prop>
            </props>
        </property>
    </bean>

如果發現atomikos 配置好後 @transactional 註解不生效的問題可以參考下面部落格：

https://blog.csdn.net/u011696259/article/details/71603480

 

相關推薦

Spring+JTA+Atomikos+mybatis分散式事務管理

  背景描述：我們平時的工作中用到的Spring事務管理是管理一個數據源的。但是如果對多個數據源進行事務管理該怎麼辦呢？我們可以用JTA和Atomikos結合Spring來實現一個分散式事務管理的功能。 事務（官方解釋）：是由一組sql語句組成的“邏輯處理單元”。 事務具有

spring boot配置mybatis和事務管理

生成 很多 -s 順序 south 位置 ron 技術 username spring boot配置mybatis和事務管理 一、spring boot與mybatis的配置 1.首先,spring boot 配置mybatis需要的全部依賴如下： <!-- Spri

SpringBoot使用jta+atomikos解決分散式事務

jta：Java Transaction API，即是java中對事務處理的api 即 api即是介面的意思 atomikos：Atomikos TransactionsEssentials 是一個為Java平臺提供增值服務的並且開源類事務管理器 1、pom依賴 2

Spring-Boot + Atomikos 實現跨庫的分散式事務管理

一、何為事務定義：事務是指多個操作單元組成的合集，多個單元操作是整體不可分割的，要麼都操作成功，要麼都不成功。其必須遵循的四個原則（ACID）：原子性（Atomicity -- 美 [ˌætəˈmɪsɪti]）：事務是不可分割的最小單位，事務內的操作要麼全成功（commit）

spring boot整合mybatis以及事務的管理

1、整合mybatis。 2、事務管理 一、整合mybatis            備註：通過mapper.xml檔案來進行與資料庫的操作（sql語句靈活，較常使用） 一、整合mybatis  &n

Spring boot 瞭解(四)（整合mybatis和事務管理）

對於SpringBoot 整合mybatis和事務管理的記錄 （學習地址：https://www.majiaxueyuan.com/front/couinfo/36） 目錄 1.整合mybatis 2.事務管理 1.整合mybatis 1.新增依賴 <de

springboot分散式事務管理（atomikos）

最近公司有用到分散式事務管理，結合公司和我上網查詢的一些資料，特來梳理一下我思路。 本篇文章使用時（atomikos）來進行springboot的分散式事務管理 1.引用jta-atomikos架包 <dependency> <groupId>

Spring整合MyBatis進行事務管理

1、引入的Spring和MyBatis依賴的jar包    引入c3p0.jar與mchange-commons.jar是為了使用資料庫連線池，資料庫連線池會在MyBatis以及Spring的事務管理器介面PlatformTransactionManager中使用到。    

Spring 使用註解方式進行事務管理 /==/ Spring分散式事務實現

使用步驟： 步驟一、在spring配置檔案中引入<tx:>名稱空間 <beans xmlns="http://www.springframework.org/schema/beans"  xmlns:xsi="http://www.w3.org/2001/XMLSchema-ins

spring整合mybatis的事務管理

<pre name="code" class="html"><?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper

spring多資料來源的配置（分散式事務管理）

<bean id="dataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"> <property name="uniqueResource

Spring JDBC-混合框架的事務管理

組合 manager 延遲 發生 required 應用 conf 一個 研究 ? Spring 抽象的 DAO 體系兼容多種數據訪問技術，它們各有特色，各有千秋。 Hibernate 是非常優秀的 ORM 實現方案，但對底層 SQL 的控制不太方便 M

MyBatis的事務管理和快取機制

一、MyBatis的事務管理 1.事務的概念：事務是一個或幾個操作組成的一個整體執行單元，它們要麼全部執行，要麼全不執行，不能只執行其中的某幾個操作；可以理解為一個事務是一個程式中執行的最小單元。 2.事務的特性：事務包含四個特性：原子性、一致性、隔離性、永續性，簡稱ACID性，具體詳解如下

Spring 使用註解方式進行事務管理

正在 als 也不會 實現 指定 ati nbsp 負責 spring 事務 事務的傳播行為和隔離級別 大家在使用spring的註解式事務管理時，對事務的傳播行為和隔離級別可能有點不知所措，下邊就詳細的介紹下以備方便查閱。 事物註解方式: @Transactional 當標

LCN基於Spring cloud2.0實現分散式事物管理（一）LCN的修改和部署

首先，對專案進行編譯，裝好maven環境，jdk環境。命令如下，注意這裡需要jdk1.8以上 mvn install -Dmaven.test.skip=true 打包之後，將編譯好的jar包上傳到自己的私服。 獲取最新的tx-manager的jar

（二）Spring Cloud實踐：使用Spring Cloud Config實現分散式配置管理

Spring Cloud Config為微服務應用提供了統一的分散式配置管理，將配置檔案放到git上，所有的微服務應用均從git上獲取這些配置檔案。  該種情況下，如果將配置檔案放在第三方提供的版本控制器上，需要網路可訪問，另外，也可以自己搭建gitlab私服，來存放自己的

Spring文件閱讀之事務管理

1.Transaction Management Spring提供了持久層抽象用於事務管理，可以提供如下便利： 穿插多個事務API的持久層模型：Java Transaction API（JTA），JDBC，Hibernate以及Java Persistence API（JPA）。 支援宣告式的事務管理。

Spring 多資料來源 @Transactional 註解事務管理

在 Spring，MyBatis 下兩個資料來源，通過 @Transactional 註解 配置簡單的事務管理 spring-mybatis.xml <!--******************************** data one start *********

Spring之—ApplicationListener 介面及事務管理

想在spring啟動時自動呼叫一些db操作作快取，於是在service實現ApplicationListener 介面。 並重寫onApplicationEvent操作。這樣就實現了要求，程式碼如下： @Service @Scope("singleton") publi

四、spring的JDBC模板和事務管理

Spring的JDBC模板 Spring是JavaEE開發的一站式框架，對各種持久化技術都提供了簡單的模板 ORM持久化技術 模板類 JDBC org.springframework.jdbc.core.JdbcTemplate