spring事務隔離等級、傳播行為以及spring+mybatis+atomikos實現分散式事務管理

坏嘻嘻
發布: 2018-09-15 11:04:58
原創
2285 人瀏覽過

這篇文章帶給大家的內容是關於spring事務隔離等級、傳播行為以及spring mybatis atomikos實現分散式事務管理,有一定的參考價值,有需要的朋友可以參考一下,希望對你有所幫助。

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

  1. 原子性(Atomicity):即事務是不可分割的最小工作單元,事務內的操作要麼全做,要麼全不做;

  2. 一致性(Consistency):在交易執行前資料庫的資料處於正確的狀態,而交易執行完成後資料庫的資料還是應該處於正確的狀態,即資料完整性限制沒有被破壞;如銀行轉帳,A轉帳給B,必須保證A的錢一定轉給B,一定不會出現A的錢轉了但B沒收到,否則資料庫的資料就處於不一致(不正確)的狀態。

  3. 隔離性(Isolation):並發事務執行之間互不影響,在一個事務內部的操作對其他事務是不產生影響,這需要事務隔離等級來指定隔離性;

  4. 持久性(Durability):交易一旦執行成功,它對資料庫的資料的改變必須是永久的,不會因例如遇到系統故障或斷電造成資料不一致或遺失。

2.事務的類型

  1. #資料庫分為本機事務跟全域事務

  • #本地事務:普通事務,獨立一個資料庫,能保證在該資料庫上操作的ACID。

  • 分散式事務:涉及兩個或多個資料庫來源的事務,即跨越多台同類或異類資料庫的事務(由每個資料庫的本地事務組成的),分佈式事務旨在保證這些本地事務的所有操作的ACID,使事務可以跨越多個資料庫;

  • Java事務類型分為JDBC事務跟JTA事務

    • JDBC事務:即為上面所說的資料庫事務中的本地事務,透過connection物件控制管理。

    • JTA事務:JTA指Java事務API(Java Transaction API),是Java EE資料庫事務規範, JTA只提供了事務管理介面,由應用程式伺服器廠商(如WebSphere Application Server)提供實現,JTA事務比JDBC更強大,支援分散式事務

  • 依是否透過程式設計分為宣告式交易與編程式事務,參考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實現分散式事務管理的詳細內容。更多資訊請關注PHP中文網其他相關文章!

    相關標籤:
    來源:php.cn
    本網站聲明
    本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
    熱門教學
    更多>
    最新下載
    更多>
    網站特效
    網站源碼
    網站素材
    前端模板
    關於我們 免責聲明 Sitemap
    PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!