spring事物的特性、傳播機制、分類

看到關于spring事物比較好的兩篇文章,轉載過來。

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

  1. 原子性(Atomicity):即事務是不可分割的最小工作單元,事務內的操作要么全做,要么全不做;
  2. 一致性(Consistency):在事務執(zhí)行前數據庫的數據處于正確的狀態(tài),而事務執(zhí)行完成后數據庫的數據還是應該處于正確的狀態(tài),即數據完整性約束沒有被破壞;如銀行轉帳,A轉帳給B,必須保證A的錢一定轉給B,一定不會出現A的錢轉了但B沒收到,否則數據庫的數據就處于不一致(不正確)的狀態(tài)。
  3. 隔離性(Isolation):并發(fā)事務執(zhí)行之間互不影響,在一個事務內部的操作對其他事務是不產生影響,這需要事務隔離級別來指定隔離性;
  4. 持久性(Durability):事務一旦執(zhí)行成功,它對數據庫的數據的改變必須是永久的,不會因比如遇到系統故障或斷電造成數據不一致或丟失。

2.事務的類型

  1. 數據庫分為本地事務跟全局事務
    • 本地事務:普通事務,獨立一個數據庫,能保證在該數據庫上操作的ACID。
    • 分布式事務:涉及兩個或多個數據庫源的事務,即跨越多臺同類或異類數據庫的事務(由每臺數據庫的本地事務組成的),分布式事務旨在保證這些本地事務的所有操作的ACID,使事務可以跨越多臺數據庫;
  2. Java事務類型分為JDBC事務跟JTA事務
    • JDBC事務:即為上面說的數據庫事務中的本地事務,通過connection對象控制管理。
    • JTA事務:JTA指Java事務API(Java Transaction API),是Java EE數據庫事務規(guī)范, JTA只提供了事務管理接口,由應用程序服務器廠商(如WebSphere Application Server)提供實現,JTA事務比JDBC更強大,支持分布式事務。
  3. 按是否通過編程分為聲明式事務和編程式事務,參考http://blog.csdn.net/liaohaojian/article/details/70139151
    • 聲明式事務:通過XML配置或者注解實現。
    • 編程式事務:通過編程代碼在業(yè)務邏輯時需要時自行實現,粒度更小。

3.Spring事務隔離級別:spring有五大隔離級別,其在TransactionDefinition接口中定義??丛创a可知,其默isolation_default(底層數據庫默認級別),其他四個隔離級別跟數據庫隔離級別一致。

  1. ISOLATION_DEFAULT:用底層數據庫的默認隔離級別,數據庫管理員設置什么就是什么
  2. ISOLATION_READ_UNCOMMITTED(未提交讀):最低隔離級別、事務未提交前,就可被其他事務讀?。〞霈F幻讀、臟讀、不可重復讀)
  3. ISOLATION_READ_COMMITTED(提交讀):一個事務提交后才能被其他事務讀取到(該隔離級別禁止其他事務讀取到未提交事務的數據、所以還是會造成幻讀、不可重復讀)、sql server默認級別
  4. ISOLATION_REPEATABLE_READ(可重復讀):可重復讀,保證多次讀取同一個數據時,其值都和事務開始時候的內容是一致,禁止讀取到別的事務未提交的數據(該隔離基本可防止臟讀,不可重復讀(重點在修改),但會出現幻讀(重點在增加與刪除))(MySql默認級別,更改可通過set transaction isolation level 級別)
  5. ISOLATION_SERIALIZABLE(序列化):代價最高最可靠的隔離級別(該隔離級別能防止臟讀、不可重復讀、幻讀)
    1. 丟失更新:兩個事務同時更新一行數據,最后一個事務的更新會覆蓋掉第一個事務的更新,從而導致第一個事務更新的數據丟失,這是由于沒有加鎖造成的;
    2. 幻讀:同樣的事務操作過程中,不同時間段多次(不同事務)讀取同一數據,讀取到的內容不一致(一般是行數變多或變少)。
    3. 臟讀:一個事務讀取到另外一個未提及事務的內容,即為臟讀。
    4. 不可重復讀:同一事務中,多次讀取內容不一致(一般行數不變,而內容變了)。

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

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

悲觀鎖與樂觀鎖可參考:http://blog.csdn.net/liaohaojian/article/details/62416972

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

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

  2. PROPAGATION_SUPPORTS:支持當前事務,如當前沒有事務,則已非事務性執(zhí)行(源碼中提示有個注意點,看不太明白,留待后面考究)。

  3. PROPAGATION_MANDATORY:支持當前事務,如當前沒有事務,則拋出異常(強制一定要在一個已經存在的事務中執(zhí)行,業(yè)務方法不可獨自發(fā)起自己的事務)。

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

  5. PROPAGATION_NOT_SUPPORTED:不支持當前事務,始終已非事務性方式執(zhí)行,如當前事務存在,掛起該事務。

  6. PROPAGATION_NEVER:不支持當前事務;如果當前事務存在,則引發(fā)異常。

  7. PROPAGATION_NESTED:如果當前事務存在,則在嵌套事務中執(zhí)行,如果當前沒有事務,則執(zhí)行與 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接口定義如下

 public interface PlatformTransactionManager {
        //返回一個已經激活的事務或創(chuàng)建一個新的事務(具體由TransactionDefinition參數定義的事務屬性決定),
        // 返回的TransactionStatus對象代表了當前事務的狀態(tài),
        // 其中該方法拋出TransactionException(未檢查異常)表示事務由于某種原因失敗。
        TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException;
        //用于提交TransactionStatus參數代表的事務。
        void commit(TransactionStatus status) throws TransactionException;
        //用于回滾TransactionStatus參數代表的事務。
        void rollback(TransactionStatus status) throws TransactionException;
    }

TransactionDefinition接口定義如下:

public interface TransactionDefinition {        
        int getPropagationBehavior();  //返回定義的事務傳播行為       
        int getIsolationLevel(); //返回事務隔離級別       
        int getTimeout();  //返回定義的事務超時時間       
        boolean isReadOnly();  //返回定義的事務是否是只讀的       
        String getName();  //返回事務名稱
         } 

TransactionStatus接口定義如下:

public interface TransactionStatus extends SavepointManager {
       boolean isNewTransaction();  //返回當前事務是否是新的事務
       boolean hasSavepoint();  //返回當前事務是否有保存點
       void setRollbackOnly();  //設置事務回滾
       boolean isRollbackOnly();  //設置當前事務是否應該回滾
       //用于刷新底層會話中的修改到數據庫,一般用于刷新如Hibernate/JPA的會話,
       // 可能對如JDBC類型的事務無任何影響;
       void flush();  
       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>  
    <!-- 動態(tài)配置數據源 --> 
    <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:必須要有事務, 如果沒有就在上下文創(chuàng)建一個 -->
            <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>

atomikos所需包及相關配置文件下載路徑:http://download.csdn.net/detail/liaohaojian/9813868,其中文件jta.properties文件放到classpath根目錄下。

最后編輯于
?著作權歸作者所有,轉載或內容合作請聯系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內容(如有圖片或視頻亦包括在內)由作者上傳并發(fā)布,文章內容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內容

  • 很多人喜歡這篇文章,特此同步過來 由淺入深談論spring事務 前言 這篇其實也要歸納到《常識》系列中,但這重點又...
    碼農戲碼閱讀 4,904評論 2 59
  • 事物特性 ⑴原子性(Atomicity) 原子性是指事務包含的所有操作要么全部成功,要么全部失敗回滾,因此事務的操...
    HJJ_3c00閱讀 303評論 0 0
  • Spring 事務屬性分析 事務管理對于企業(yè)應用而言至關重要。它保證了用戶的每一次操作都是可靠的,即便出現了異常的...
    壹點零閱讀 1,378評論 0 2
  • 事務 回顧知識 1、什么是事務 事務邏輯上的一組操作,組成這組操作的各個邏輯單元,要么一起成功,要么一起失敗. 2...
    guan_xy閱讀 282評論 0 0
  • 在這兩天,有很多事情發(fā)生。比如說孫雨湘過生日讓我去,但是白浩宇也在那天過生日。雖然我最后去的是白浩宇生日,但是我一...
    陳騰芬4閱讀 483評論 0 0

友情鏈接更多精彩內容