spring事務隔離級別、傳播行為以及spring+mybatis+atomikos實現分布式事務管理的方法

小編給大家分享一下spring事務隔離級別、傳播行為以及spring+mybatis+atomikos實現分布式事務管理的方法，希望大家閱讀完這篇文章后大所收獲，下面讓我們一起去探討吧！

1.事務的定義：事務是指多個操作單元組成的合集，多個單元操作是整體不可分割的，要么都操作不成功，要么都成功。其必須遵循四個原則（ACID）。

1. 原子性（Atomicity）：即事務是不可分割的最小工作單元，事務內的操作要么全做，要么全不做；

2. 一致性（Consistency）：在事務執行前數據庫的數據處于正確的狀態，而事務執行完成后數據庫的數據還是應該處于正確的狀態，即數據完整性約束沒有被破壞；如銀行轉帳，A轉帳給B，必須保證A的錢一定轉給B，一定不會出現A的錢轉了但B沒收到，否則數據庫的數據就處于不一致（不正確）的狀態。

3. 隔離性（Isolation）：并發事務執行之間互不影響，在一個事務內部的操作對其他事務是不產生影響，這需要事務隔離級別來指定隔離性；

4. 持久性（Durability）：事務一旦執行成功，它對數據庫的數據的改變必須是永久的，不會因比如遇到系統故障或斷電造成數據不一致或丟失。
   

2.事務的類型

1. 數據庫分為本地事務跟全局事務

• 本地事務：普通事務，獨立一個數據庫，能保證在該數據庫上操作的ACID。

• 分布式事務：涉及兩個或多個數據庫源的事務，即跨越多臺同類或異類數據庫的事務（由每臺數據庫的本地事務組成的），分布式事務旨在保證這些本地事務的所有操作的ACID，使事務可以跨越多臺數據庫；

2. Java事務類型分為JDBC事務跟JTA事務

• JDBC事務：即為上面說的數據庫事務中的本地事務，通過connection對象控制管理。

• JTA事務：JTA指Java事務API(Java Transaction API)，是Java EE數據庫事務規范， JTA只提供了事務管理接口，由應用程序服務器廠商（如WebSphere Application Server）提供實現，JTA事務比JDBC更強大，支持分布式事務。

3. 按是否通過編程分為聲明式事務和編程式事務，參考http://blog.csdn.net/liaohaojian/article/details/70139151

• 聲明式事務：通過XML配置或者注解實現。

• 編程式事務：通過編程代碼在業務邏輯時需要時自行實現，粒度更小。

3.Spring事務隔離級別：spring有五大隔離級別，其在TransactionDefinition接口中定義。看源碼可知，其默isolation_default（底層數據庫默認級別），其他四個隔離級別跟數據庫隔離級別一致。

1. ISOLATION_DEFAULT：用底層數據庫的默認隔離級別，數據庫管理員設置什么就是什么

2. ISOLATION_READ_UNCOMMITTED（未提交讀）：最低隔離級別、事務未提交前，就可被其他事務讀取（會出現幻讀、臟讀、不可重復讀）

3. ISOLATION_READ_COMMITTED（提交讀）：一個事務提交后才能被其他事務讀取到（該隔離級別禁止其他事務讀取到未提交事務的數據、所以還是會造成幻讀、不可重復讀）、sql server默認級別

4. ISOLATION_REPEATABLE_READ（可重復讀）：可重復讀，保證多次讀取同一個數據時，其值都和事務開始時候的內容是一致，禁止讀取到別的事務未提交的數據（該隔離基本可防止臟讀，不可重復讀（重點在修改），但會出現幻讀（重點在增加與刪除））（MySql默認級別，更改可通過set transaction isolation level 級別）

5. ISOLATION_SERIALIZABLE（序列化）：代價最高最可靠的隔離級別（該隔離級別能防止臟讀、不可重復讀、幻讀）

1. 丟失更新：兩個事務同時更新一行數據，最后一個事務的更新會覆蓋掉第一個事務的更新，從而導致第一個事務更新的數據丟失，這是由于沒有加鎖造成的；

2. 幻讀：同樣的事務操作過程中，不同時間段多次（不同事務）讀取同一數據，讀取到的內容不一致（一般是行數變多或變少）。

3. 臟讀：一個事務讀取到另外一個未提及事務的內容，即為臟讀。

4. 不可重復讀：同一事務中，多次讀取內容不一致（一般行數不變，而內容變了）。

幻讀與不可重復讀的區別：幻讀的重點在于插入與刪除，即第二次查詢會發現比第一次查詢數據變少或者變多了，以至于給人一種幻象一樣，而不可重復讀重點在于修改，即第二次查詢會發現查詢結果比第一次查詢結果不一致，即第一次結果已經不可重現了。

數據庫隔離級別越高，執行代價越高，并發執行能力越差，因此在實際項目開發使用時要綜合考慮，為了考慮并發性能一般使用提交讀隔離級別，它能避免丟失更新和臟讀，盡管不可重復讀和幻讀不能避免，但可以在可能出現的場合使用悲觀鎖或樂觀鎖來解決這些問題。

4.傳播行為：有七大傳播行為，也是在TransactionDefinition接口中定義。

1. PROPAGATION_REQUIRED：支持當前事務，如當前沒有事務，則新建一個。

2. PROPAGATION_SUPPORTS：支持當前事務，如當前沒有事務，則已非事務性執行（源碼中提示有個注意點，看不太明白，留待后面考究）。
   

3. PROPAGATION_MANDATORY：支持當前事務，如當前沒有事務，則拋出異常（強制一定要在一個已經存在的事務中執行，業務方法不可獨自發起自己的事務）。
   

4. PROPAGATION_REQUIRES_NEW：始終新建一個事務，如當前原來有事務，則把原事務掛起。
   

5. PROPAGATION_NOT_SUPPORTED：不支持當前事務，始終已非事務性方式執行，如當前事務存在，掛起該事務。
   

6. PROPAGATION_NEVER：不支持當前事務；如果當前事務存在，則引發異常。
   

7. PROPAGATION_NESTED：如果當前事務存在，則在嵌套事務中執行，如果當前沒有事務，則執行與 PROPAGATION_REQUIRED 類似的操作（注意：當應用到JDBC時，只適用JDBC 3.0以上驅動）。
   

5.Spring事務支持

1.spring提供了很多內置事務管理器，支持不同數據源。常見的有三大類

• DataSourceTransactionManager：org.springframework.jdbc.datasource包下，數據源事務管理類，提供對單個javax.sql.DataSource數據源的事務管理，只要用于JDBC，Mybatis框架事務管理。

• HibernateTransactionManager：org.springframework.orm.hibernate3包下，數據源事務管理類，提供對單個org.hibernate.SessionFactory事務支持，用于集成Hibernate框架時的事務管理；注意：該事務管理器只支持Hibernate3+版本，且Spring3.0+版本只支持Hibernate 3.2+版本；
  

• JtaTransactionManager：位于org.springframework.transaction.jta包中，提供對分布式事務管理的支持，并將事務管理委托給Java EE應用服務器，或者自定義一個本地JTA事務管理器，嵌套到應用程序中。
  

內置事務管理器都繼承了抽象類AbstractPlatformTransactionManager，而AbstractPlatformTransactionManager又繼承了接口PlatformTransactionManager

Spring框架支持事務管理的核心是事務管理器抽象，對于不同的數據訪問框架通過實現策略接口PlatformTransactionManager，從而能支持多鐘數據訪問框架的事務管理。

PlatformTransactionManager接口定義如下

TransactionStatus接口定義如下：

public interface TransactionStatus extends SavepointManager {  
       boolean isNewTransaction();  //返回當前事務是否是新的事務
       boolean hasSavepoint();  //返回當前事務是否有保存點
       void setRollbackOnly();  //設置事務回滾
       boolean isRollbackOnly();  //設置當前事務是否應該回滾
       void flush();  //用于刷新底層會話中的修改到數據庫，一般用于刷新如Hibernate/JPA的會話，可能對如JDBC類型的事務無任何影響；
       boolean isCompleted();  //返回事務是否完成
}

2.Spring分布式事務配置

• 引用應用服務器（如Tomcat）的JNDI數據源，間接實現JTA事務管理，依賴于應用服務器

• 直接集成JOTM（官網：http://jotm.objectweb.org/）、Atomikos（官網：https://www.atomikos.com/）提供JTA事務管理（無應用服務器支持，常用于單元測試）

• 使用特定于應用服務器的事務管理器，使用JTA事務的高級功能（Weblogic，Websphere）

1）.引用應用服務器（如Tomcat）的JNDI數據源，間接實現JTA事務管理，配置如下

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:jee="http://www.springframework.org/schema/jee"
    xsi:schemaLocation="
       http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
       http://www.springframework.org/schema/jee
       http://www.springframework.org/schema/jee/spring-jee-3.0.xsd">
 <!-- JNDI數據源 -->
  <jee:jndi-lookup id="dataSource" jndi-name="jdbc/test"/>
    <!-- JTA事務管理器  -->
  	<bean id="txManager" class="org.springframework.transaction.jta.JtaTransactionManager">
  		<!--transactionManagerName指定JTA事務管理器的JNDI名字，從而將事務管理委托給該事務管理器  -->
    	<property name="transactionManagerName" value="java:comp/TransactionManager"/>
  	</bean>
</beans>

2）使用Atomikos實現分布式事務管理，配置如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
	xmlns:p="http://www.springframework.org/schema/p"
	xmlns:aop="http://www.springframework.org/schema/aop"	
	xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:context="http://www.springframework.org/schema/context"
    xmlns:task="http://www.springframework.org/schema/task"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
	http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
	http://www.springframework.org/schema/context 
	http://www.springframework.org/schema/context/spring-context-3.0.xsd
	http://www.springframework.org/schema/tx
	http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
	http://www.springframework.org/schema/task
	http://www.springframework.org/schema/task/spring-task-3.0.xsd
	http://www.springframework.org/schema/aop
	http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"
	>  
	<context:component-scan base-package="com.suicai.*.service.impl" />
	<context:component-scan base-package="com.suicai.util" />
    <!-- 此方法加載的配置文件僅僅在xml中使用,但是工具類都采用注解的方式 -->
	<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
		<property name="location" value="classpath:conn.properties" />
	</bean>
	<!-- 僅僅支持注解不支持在xml配置中使用properties文件  在類中可以使用SPEL表達式來加載相應的值 -->
	<bean id="temp" class="org.springframework.beans.factory.config.PropertiesFactoryBean">
		<property name="locations">
			<array>
				<value>classpath:public.properties</value>
			</array>
		</property>
	</bean>
	<bean id="abstractXADataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init"  destroy-method="close" abstract="true"> 
        <property name="borrowConnectionTimeout" value="60"/>  <!--獲取連接失敗重新獲等待最大時間，在這個時間內如果有可用連接，將返回-->
        <property name="reapTimeout" value="20"/> <!--最大獲取數據時間，如果不設置這個值，Atomikos使用默認的5分鐘，那么在處理大批量數據讀取的時候，一旦超過5分鐘，就會拋出類似 Resultset is close 的錯誤.-->        
        <property name="maintenanceInterval" value="60" />  <!--連接回收時間-->    
        <property name="loginTimeout" value="60" />     <!--java數據庫連接池，最大可等待獲取datasouce的時間-->
        <property name="logWriter" value="60"/>
        <property name="minPoolSize" value="1" />  <!-- 連接池中保留的最小連接數   -->
        <property name="maxPoolSize" value="3" />  <!-- 連接池中保留的最大連接數    -->
        <property name="maxIdleTime" value="60" /> <!-- 最大空閑時間,60秒內未使用則連接被丟棄。若為0則永不丟棄。Default: 0 -->
    </bean> 
     <!-- 配置2個數據源 mysql -->
     <bean id="ds_suicai" parent="abstractXADataSource">  
     	<!-- uniqueResourceName表示唯一資源名，如有多個數據源不可重復； -->
     	<property name="uniqueResourceName" value="suicaifortest" />
     	<!--  xaDataSourceClassName是具體分布式數據源廠商實現； -->
     	<property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
     	<!-- xaProperties屬性指定具體廠商數據庫屬性 -->
     	<property name="xaProperties">
            <props>
                <prop key="URL">${db.jdbcUrlOne}</prop>
                <prop key="user">${user}</prop>
                <prop key="password">${password}</prop>
            </props>
        </property>
    </bean>  
	<bean id="ds_kaizhi"  parent="abstractXADataSource">  
		<!-- uniqueResourceName表示唯一資源名，如有多個數據源不可重復； -->
		<property name="uniqueResourceName" value="puildingpurchasefortest" />
		<!-- xaDataSourceClassName是具體分布式數據源廠商實現； -->
		<property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
		<!-- xaProperties屬性指定具體廠商數據庫屬性 -->
		<property name="xaProperties">
            <props>
                <prop key="URL">${db.jdbcUrlTwo}</prop>
                <prop key="user">${user}</prop>
                <prop key="password">${password}</prop>
            </props>
        </property>
    </bean>  
    <!-- 動態配置數據源 --> 
    <bean id="dataSource2" class="com.suicai.common.datasource.DynamicDataSource">  
        <property name="targetDataSources">  
            <map key-type ="java.lang.String">  
                <entry value-ref ="ds_suicai" key="ds_suicai"></entry >  
                <entry value-ref ="ds_kaizhi" key="ds_kaizhi"></entry >  
            </map > 
        </property>  
        <property name ="defaultTargetDataSource" ref="ds_suicai"></property>  
    </bean>
    <bean id ="sqlSessionFactoryBeanA" class="org.mybatis.spring.SqlSessionFactoryBean" >  
       <!-- 指定數據源 -->  
       <property name ="dataSource" ref="ds_suicai" />  
       <!-- 指定mybatis 的配置文件 -->  
       <property name ="configLocation" value="classpath:mybatis.cfg.xml" />  
	</bean>
	<bean id ="sqlSessionFactoryBeanB" class="org.mybatis.spring.SqlSessionFactoryBean" >  
       <!-- 指定數據源 -->  
       <property name ="dataSource" ref="ds_kaizhi" />  
       <!-- 指定mybatis 的配置文件 -->  
       <property name ="configLocation" value="classpath:mybatis.cfg.xml" />  
	</bean>
	<!--CustomSqlSessionTemplate繼承SqlSessionTemplate重寫getSqlSessionFactory方法，具體請下載查看--> 
	<bean id="sqlSessionTemplate" class="com.suicai.util.CustomSqlSessionTemplate" scope="prototype">
        <constructor-arg ref="sqlSessionFactoryBeanA" />
        <property name="targetSqlSessionFactorys">
            <map>     
                <entry value-ref ="sqlSessionFactoryBeanA" key="ds_suicai1"></entry >  
                <entry value-ref ="sqlSessionFactoryBeanB" key="ds_kaizhi1"></entry >  
            </map> 
        </property>
    </bean>  
	<!-- 配置atomikos事務管理器 -->
	<bean id="atomikosTransactionManager" class = "com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method = "close">    
	      <property name="forceShutdown" value="true"/>    
	</bean>    
	<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp"></bean>
	<!-- 配置spring事務管理器 -->
	<bean id="transactionManager" 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>
	<tx:advice id="advice" transaction-manager="transactionManager">
		<tx:attributes>
		    <!-- REQUIRED：必須要有事務, 如果沒有就在上下文創建一個 -->
			<tx:method name="save*" propagation="REQUIRED"/>
			<tx:method name="creat*" propagation="REQUIRED"/>
			<tx:method name="add*" propagation="REQUIRED"/>
			<tx:method name="update*" propagation="REQUIRED"/>
			<tx:method name="delete*" propagation="REQUIRED"/>
			<!-- 支持,如果有就有,沒有就沒有 -->
			<tx:method name="*" propagation="SUPPORTS"/>
		</tx:attributes>
	</tx:advice>
	<aop:config>
	    <aop:pointcut expression="execution(* com.suicai.*.service.impl.*.*(..))" id="pointcut"/>
	    <!-- 吧 tx與aop的配置關聯,才是完整的聲明事務配置 -->
	    <aop:advisor advice-ref="advice" pointcut-ref="pointcut"/>
	</aop:config>
	<!-- 采用包掃描機制,自動會把指定的包里面的所有dao注冊 -->
	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
		<!-- 注意注入sqlSessionTemplate -->
        <property name="sqlSessionTemplateBeanName" value="sqlSessionTemplate"/>
		<property name="basePackage" value="com.suicai.*.dao" />
	</bean>
	<bean id="viewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver">
		<property name="viewClass">
			<value>org.springframework.web.servlet.view.InternalResourceView</value>
		</property>
		<!--jsp存放的目錄-->
		<property name="prefix">
			<value>/</value>
		</property>
		<!--jsp文件的后綴-->
		<property name="suffix">
			<value>.jsp</value>
		</property>
	</bean>
	<!-- 驗證碼 -->
	<bean id="captchaProducer" class="com.google.code.kaptcha.impl.DefaultKaptcha">  
        <property name="config">  
            <bean class="com.google.code.kaptcha.util.Config">  
                <constructor-arg>  
                    <props>  
                        <prop key="kaptcha.border">no</prop>  
                        <prop key="kaptcha.border.color">105,179,90</prop>  
                        <prop key="kaptcha.textproducer.font.color">red</prop>  
                        <prop key="kaptcha.image.width">200</prop>  
                        <prop key="kaptcha.textproducer.font.size">60</prop>  
                        <prop key="kaptcha.image.height">80</prop>  
                        <prop key="kaptcha.session.key">code</prop>  
                        <prop key="kaptcha.textproducer.char.length">4</prop>  
                        <prop key="kaptcha.textproducer.font.names">宋體,楷體,微軟雅黑</prop>  
                    </props>  
                </constructor-arg>  
            </bean>  
        </property>  
    </bean>
    <bean id="messageSource" class="org.springframework.context.support.ReloadableResourceBundleMessageSource">  
        <property name="basename" value="classpath:messages"/>  
        <property name="fileEncodings" value="utf-8"/>  
        <property name="cacheSeconds" value="120"/>  
	</bean>
</beans>

看完了這篇文章，相信你對spring事務隔離級別、傳播行為以及spring+mybatis+atomikos實現分布式事務管理的方法有了一定的了解，想了解更多相關知識，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！