本篇文章給大家?guī)淼膬?nèi)容是關(guān)于spring事務(wù)隔離級(jí)別、傳播行為以及spring+mybatis+atomikos實(shí)現(xiàn)分布式事務(wù)管理,有一定的參考價(jià)值,有需要的朋友可以參考一下,希望對(duì)你有所幫助。
1.事務(wù)的定義:事務(wù)是指多個(gè)操作單元組成的合集,多個(gè)單元操作是整體不可分割的,要么都操作不成功,要么都成功。其必須遵循四個(gè)原則(ACID)。
-
原子性(atomicity):即事務(wù)是不可分割的最小工作單元,事務(wù)內(nèi)的操作要么全做,要么全不做;
-
一致性(Consistency):在事務(wù)執(zhí)行前數(shù)據(jù)庫(kù)的數(shù)據(jù)處于正確的狀態(tài),而事務(wù)執(zhí)行完成后數(shù)據(jù)庫(kù)的數(shù)據(jù)還是應(yīng)該處于正確的狀態(tài),即數(shù)據(jù)完整性約束沒有被破壞;如銀行轉(zhuǎn)帳,A轉(zhuǎn)帳給B,必須保證A的錢一定轉(zhuǎn)給B,一定不會(huì)出現(xiàn)A的錢轉(zhuǎn)了但B沒收到,否則數(shù)據(jù)庫(kù)的數(shù)據(jù)就處于不一致(不正確)的狀態(tài)。
-
隔離性(Isolation):并發(fā)事務(wù)執(zhí)行之間互不影響,在一個(gè)事務(wù)內(nèi)部的操作對(duì)其他事務(wù)是不產(chǎn)生影響,這需要事務(wù)隔離級(jí)別來指定隔離性;
-
持久性(Durability):事務(wù)一旦執(zhí)行成功,它對(duì)數(shù)據(jù)庫(kù)的數(shù)據(jù)的改變必須是永久的,不會(huì)因比如遇到系統(tǒng)故障或斷電造成數(shù)據(jù)不一致或丟失。
2.事務(wù)的類型
-
數(shù)據(jù)庫(kù)分為本地事務(wù)跟全局事務(wù)
-
本地事務(wù):普通事務(wù),獨(dú)立一個(gè)數(shù)據(jù)庫(kù),能保證在該數(shù)據(jù)庫(kù)上操作的ACID。
-
分布式事務(wù):涉及兩個(gè)或多個(gè)數(shù)據(jù)庫(kù)源的事務(wù),即跨越多臺(tái)同類或異類數(shù)據(jù)庫(kù)的事務(wù)(由每臺(tái)數(shù)據(jù)庫(kù)的本地事務(wù)組成的),分布式事務(wù)旨在保證這些本地事務(wù)的所有操作的ACID,使事務(wù)可以跨越多臺(tái)數(shù)據(jù)庫(kù);
Java事務(wù)類型分為JDBC事務(wù)跟JTA事務(wù)
-
JDBC事務(wù):即為上面說的數(shù)據(jù)庫(kù)事務(wù)中的本地事務(wù),通過connection對(duì)象控制管理。
-
JTA事務(wù):JTA指Java事務(wù)API(Java Transaction API),是Java EE數(shù)據(jù)庫(kù)事務(wù)規(guī)范, JTA只提供了事務(wù)管理接口,由應(yīng)用程序服務(wù)器廠商(如WebSphere Application Server)提供實(shí)現(xiàn),JTA事務(wù)比JDBC更強(qiáng)大,支持分布式事務(wù)。
按是否通過編程分為聲明式事務(wù)和編程式事務(wù),參考http://blog.csdn.net/liaohaojian/article/details/70139151
-
聲明式事務(wù):通過XML配置或者注解實(shí)現(xiàn)。
-
編程式事務(wù):通過編程代碼在業(yè)務(wù)邏輯時(shí)需要時(shí)自行實(shí)現(xiàn),粒度更小。
3.Spring事務(wù)隔離級(jí)別:spring有五大隔離級(jí)別,其在TransactionDefinition接口中定義。看源碼可知,其默isolation_default(底層數(shù)據(jù)庫(kù)默認(rèn)級(jí)別),其他四個(gè)隔離級(jí)別跟數(shù)據(jù)庫(kù)隔離級(jí)別一致。
-
ISOLATION_DEFAULT:用底層數(shù)據(jù)庫(kù)的默認(rèn)隔離級(jí)別,數(shù)據(jù)庫(kù)管理員設(shè)置什么就是什么
-
ISOLATION_READ_UNCOMMITTED(未提交讀):最低隔離級(jí)別、事務(wù)未提交前,就可被其他事務(wù)讀取(會(huì)出現(xiàn)幻讀、臟讀、不可重復(fù)讀)
-
ISOLATION_READ_COMMITTED(提交讀):一個(gè)事務(wù)提交后才能被其他事務(wù)讀取到(該隔離級(jí)別禁止其他事務(wù)讀取到未提交事務(wù)的數(shù)據(jù)、所以還是會(huì)造成幻讀、不可重復(fù)讀)、sql server默認(rèn)級(jí)別
-
ISOLATION_REPEATABLE_READ(可重復(fù)讀):可重復(fù)讀,保證多次讀取同一個(gè)數(shù)據(jù)時(shí),其值都和事務(wù)開始時(shí)候的內(nèi)容是一致,禁止讀取到別的事務(wù)未提交的數(shù)據(jù)(該隔離基本可防止臟讀,不可重復(fù)讀(重點(diǎn)在修改),但會(huì)出現(xiàn)幻讀(重點(diǎn)在增加與刪除))(MySql默認(rèn)級(jí)別,更改可通過set transaction isolation level 級(jí)別)
-
ISOLATION_SERIALIZABLE(序列化):代價(jià)最高最可靠的隔離級(jí)別(該隔離級(jí)別能防止臟讀、不可重復(fù)讀、幻讀)
-
丟失更新:兩個(gè)事務(wù)同時(shí)更新一行數(shù)據(jù),最后一個(gè)事務(wù)的更新會(huì)覆蓋掉第一個(gè)事務(wù)的更新,從而導(dǎo)致第一個(gè)事務(wù)更新的數(shù)據(jù)丟失,這是由于沒有加鎖造成的;
-
幻讀:同樣的事務(wù)操作過程中,不同時(shí)間段多次(不同事務(wù))讀取同一數(shù)據(jù),讀取到的內(nèi)容不一致(一般是行數(shù)變多或變少)。
-
臟讀:一個(gè)事務(wù)讀取到另外一個(gè)未提及事務(wù)的內(nèi)容,即為臟讀。
-
不可重復(fù)讀:同一事務(wù)中,多次讀取內(nèi)容不一致(一般行數(shù)不變,而內(nèi)容變了)。
幻讀與不可重復(fù)讀的區(qū)別:幻讀的重點(diǎn)在于插入與刪除,即第二次查詢會(huì)發(fā)現(xiàn)比第一次查詢數(shù)據(jù)變少或者變多了,以至于給人一種幻象一樣,而不可重復(fù)讀重點(diǎn)在于修改,即第二次查詢會(huì)發(fā)現(xiàn)查詢結(jié)果比第一次查詢結(jié)果不一致,即第一次結(jié)果已經(jīng)不可重現(xiàn)了。
數(shù)據(jù)庫(kù)隔離級(jí)別越高,執(zhí)行代價(jià)越高,并發(fā)執(zhí)行能力越差,因此在實(shí)際項(xiàng)目開發(fā)使用時(shí)要綜合考慮,為了考慮并發(fā)性能一般使用提交讀隔離級(jí)別,它能避免丟失更新和臟讀,盡管不可重復(fù)讀和幻讀不能避免,但可以在可能出現(xiàn)的場(chǎng)合使用悲觀鎖或樂觀鎖來解決這些問題。
4.傳播行為:有七大傳播行為,也是在TransactionDefinition接口中定義。
-
PROPAGATION_REQUIRED:支持當(dāng)前事務(wù),如當(dāng)前沒有事務(wù),則新建一個(gè)。
-
PROPAGATION_SUPPORTS:支持當(dāng)前事務(wù),如當(dāng)前沒有事務(wù),則已非事務(wù)性執(zhí)行(源碼中提示有個(gè)注意點(diǎn),看不太明白,留待后面考究)。
-
PROPAGATION_MANDATORY:支持當(dāng)前事務(wù),如當(dāng)前沒有事務(wù),則拋出異常(強(qiáng)制一定要在一個(gè)已經(jīng)存在的事務(wù)中執(zhí)行,業(yè)務(wù)方法不可獨(dú)自發(fā)起自己的事務(wù))。
-
PROPAGATION_REQUIRES_NEW:始終新建一個(gè)事務(wù),如當(dāng)前原來有事務(wù),則把原事務(wù)掛起。
-
PROPAGATION_NOT_SUPPORTED:不支持當(dāng)前事務(wù),始終已非事務(wù)性方式執(zhí)行,如當(dāng)前事務(wù)存在,掛起該事務(wù)。
-
PROPAGATION_NEVER:不支持當(dāng)前事務(wù);如果當(dāng)前事務(wù)存在,則引發(fā)異常。
-
PROPAGATION_NESTED:如果當(dāng)前事務(wù)存在,則在嵌套事務(wù)中執(zhí)行,如果當(dāng)前沒有事務(wù),則執(zhí)行與 PROPAGATION_REQUIRED 類似的操作(注意:當(dāng)應(yīng)用到JDBC時(shí),只適用JDBC 3.0以上驅(qū)動(dòng))。
5.Spring事務(wù)支持
1.spring提供了很多內(nèi)置事務(wù)管理器,支持不同數(shù)據(jù)源。常見的有三大類
DataSourceTransactionManager:org.springframework.jdbc.datasource包下,數(shù)據(jù)源事務(wù)管理類,提供對(duì)單個(gè)javax.sql.DataSource數(shù)據(jù)源的事務(wù)管理,只要用于JDBC,Mybatis框架事務(wù)管理。
HibernateTransactionManager:org.springframework.orm.hibernate3包下,數(shù)據(jù)源事務(wù)管理類,提供對(duì)單個(gè)org.hibernate.SessionFactory事務(wù)支持,用于集成Hibernate框架時(shí)的事務(wù)管理;注意:該事務(wù)管理器只支持Hibernate3+版本,且Spring3.0+版本只支持Hibernate 3.2+版本;
JtaTransactionManager:位于org.springframework.transaction.jta包中,提供對(duì)分布式事務(wù)管理的支持,并將事務(wù)管理委托給Java EE應(yīng)用服務(wù)器,或者自定義一個(gè)本地JTA事務(wù)管理器,嵌套到應(yīng)用程序中。
內(nèi)置事務(wù)管理器都繼承了抽象類AbstractPlatformTransactionManager,而AbstractPlatformTransactionManager又繼承了接口PlatformTransactionManager
Spring框架支持事務(wù)管理的核心是事務(wù)管理器抽象,對(duì)于不同的數(shù)據(jù)訪問框架通過實(shí)現(xiàn)策略接口PlatformTransactionManager,從而能支持多鐘數(shù)據(jù)訪問框架的事務(wù)管理。
PlatformTransactionManager接口定義如下
TransactionStatus接口定義如下:
public?interface?TransactionStatus?extends?SavepointManager?{?? ???????boolean?isNewTransaction();??//返回當(dāng)前事務(wù)是否是新的事務(wù) ???????boolean?hasSavepoint();??//返回當(dāng)前事務(wù)是否有保存點(diǎn) ???????void?setRollbackOnly();??//設(shè)置事務(wù)回滾 ???????boolean?isRollbackOnly();??//設(shè)置當(dāng)前事務(wù)是否應(yīng)該回滾 ???????void?flush();??//用于刷新底層會(huì)話中的修改到數(shù)據(jù)庫(kù),一般用于刷新如Hibernate/JPA的會(huì)話,可能對(duì)如JDBC類型的事務(wù)無任何影響; ???????boolean?isCompleted();??//返回事務(wù)是否完成 }2.Spring分布式事務(wù)配置
引用應(yīng)用服務(wù)器(如Tomcat)的JNDI數(shù)據(jù)源,間接實(shí)現(xiàn)JTA事務(wù)管理,依賴于應(yīng)用服務(wù)器
直接集成JOTM(官網(wǎng):http://jotm.objectweb.org/)、Atomikos(官網(wǎng):https://www.atomikos.com/)提供JTA事務(wù)管理(無應(yīng)用服務(wù)器支持,常用于單元測(cè)試)
使用特定于應(yīng)用服務(wù)器的事務(wù)管理器,使用JTA事務(wù)的高級(jí)功能(Weblogic,Websphere)
1).引用應(yīng)用服務(wù)器(如Tomcat)的JNDI數(shù)據(jù)源,間接實(shí)現(xiàn)JTA事務(wù)管理,配置如下
<beans> ?<!-- JNDI數(shù)據(jù)源 --> ??<jndi-lookup></jndi-lookup> ????<!-- JTA事務(wù)管理器 --> ?? <bean> ?? <!--transactionManagerName指定JTA事務(wù)管理器的JNDI名字,從而將事務(wù)管理委托給該事務(wù)管理器 --> ???? <property></property> ?? </bean></beans>2)使用Atomikos實(shí)現(xiàn)分布式事務(wù)管理,配置如下:
<?xml version="1.0" encoding="UTF-8"?><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" 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">?? <component-scan></component-scan><component-scan></component-scan> ????<!-- 此方法加載的配置文件僅僅在xml中使用,但是工具類都采用注解的方式 --> <bean><property></property></bean><!-- 僅僅支持注解不支持在xml配置中使用properties文件 在類中可以使用SPEL表達(dá)式來加載相應(yīng)的值 --><bean><property><array><value>classpath:public.properties</value></array></property></bean><bean>? ????????<property></property>??<!--獲取連接失敗重新獲等待最大時(shí)間,在這個(gè)時(shí)間內(nèi)如果有可用連接,將返回--> ????????<property></property>?<!--最大獲取數(shù)據(jù)時(shí)間,如果不設(shè)置這個(gè)值,Atomikos使用默認(rèn)的5分鐘,那么在處理大批量數(shù)據(jù)讀取的時(shí)候,一旦超過5分鐘,就會(huì)拋出類似 Resultset is close 的錯(cuò)誤.-->???????? ????????<property></property>??<!--連接回收時(shí)間-->???? ????????<property></property>?????<!--java數(shù)據(jù)庫(kù)連接池,最大可等待獲取datasouce的時(shí)間--> ????????<property></property> ????????<property></property>??<!-- 連接池中保留的最小連接數(shù) --> ????????<property></property>??<!-- 連接池中保留的最大連接數(shù) --> ????????<property></property>?<!-- 最大空閑時(shí)間,60秒內(nèi)未使用則連接被丟棄。若為0則永不丟棄。Default: 0 --> ????</bean>? ?????<!-- 配置2個(gè)數(shù)據(jù)源 mysql --> ?????<bean>?? ????? <!-- uniqueResourceName表示唯一資源名,如有多個(gè)數(shù)據(jù)源不可重復(fù); --> ????? <property></property> ????? <!-- xaDataSourceClassName是具體分布式數(shù)據(jù)源廠商實(shí)現(xiàn); --> ????? <property></property> ????? <!-- xaProperties屬性指定具體廠商數(shù)據(jù)庫(kù)屬性 --> ????? <property> ????????????<props> ????????????????<prop>${db.jdbcUrlOne}</prop> ????????????????<prop>${user}</prop> ????????????????<prop>${password}</prop> ????????????</props> ????????</property> ????</bean>?? <bean>?? <!-- uniqueResourceName表示唯一資源名,如有多個(gè)數(shù)據(jù)源不可重復(fù); --> <property></property><!-- xaDataSourceClassName是具體分布式數(shù)據(jù)源廠商實(shí)現(xiàn); --><property></property><!-- xaProperties屬性指定具體廠商數(shù)據(jù)庫(kù)屬性 --><property> ????????????<props> ????????????????<prop>${db.jdbcUrlTwo}</prop> ????????????????<prop>${user}</prop> ????????????????<prop>${password}</prop> ????????????</props> ????????</property> ????</bean>?? ????<!-- 動(dòng)態(tài)配置數(shù)據(jù)源 -->? ????<bean>?? ????????<property>?? ????????????<map>?? ????????????????<entry></entry>?>?? ????????????????<entry></entry>?>?? ????????????</map>?>? ????????</property>?? ????????<property></property>?? ????</bean> ????<bean>?? ???????<!-- 指定數(shù)據(jù)源 -->?? ???????<property></property>?? ???????<!-- 指定mybatis 的配置文件 -->?? ???????<property></property>?? </bean><bean>?? ???????<!-- 指定數(shù)據(jù)源 -->?? ???????<property></property>?? ???????<!-- 指定mybatis 的配置文件 -->?? ???????<property></property>?? </bean><!--CustomSqlSessionTemplate繼承SqlSessionTemplate重寫getSqlSessionFactory方法,具體請(qǐng)下載查看-->? <bean> ????????<constructor-arg></constructor-arg> ????????<property> ????????????<map>????? ????????????????<entry></entry>?>?? ????????????????<entry></entry>?>?? ????????????</map>? ????????</property> ????</bean>?? <!-- 配置atomikos事務(wù)管理器 --> <bean>???? ??????<property></property>???? </bean>???? <bean></bean><!-- 配置spring事務(wù)管理器 --><bean>???? ????<property>???? ????????<ref></ref>???? ????</property>???? ????<property>???? ????????<ref></ref>???? ????</property>? ????<!-- 必須設(shè)置,否則程序出現(xiàn)異常 JtaTransactionManager does not support custom isolation levels by default --> ????<property></property>???? </bean><advice><attributes> ????<!-- REQUIRED:必須要有事務(wù), 如果沒有就在上下文創(chuàng)建一個(gè) --> <method></method><method></method><method></method><method></method><method></method><!-- 支持,如果有就有,沒有就沒有 --><method></method></attributes></advice><config> ????<pointcut></pointcut> ????<!-- 吧 tx與aop的配置關(guān)聯(lián),才是完整的聲明事務(wù)配置 --> ????<advisor></advisor></config><!-- 采用包掃描機(jī)制,自動(dòng)會(huì)把指定的包里面的所有dao注冊(cè) --><bean><!-- 注意注入sqlSessionTemplate --> ????????<property></property><property></property></bean><bean><property><value>org.springframework.web.servlet.view.InternalResourceView</value></property><!--jsp存放的目錄--><property><value>/</value></property><!--jsp文件的后綴--><property><value>.jsp</value></property></bean><!-- 驗(yàn)證碼 --><bean>?? ????????<property>?? ????????????<bean>?? ????????????????<constructor-arg>?? ????????????????????<props>?? ????????????????????????<prop>no</prop>?? ????????????????????????<prop>105,179,90</prop>?? ????????????????????????<prop>red</prop>?? ????????????????????????<prop>200</prop>?? ????????????????????????<prop>60</prop>?? ????????????????????????<prop>80</prop>?? ????????????????????????<prop>code</prop>?? ????????????????????????<prop>4</prop>?? ????????????????????????<prop>宋體,楷體,微軟雅黑</prop>?? ????????????????????</props>?? ????????????????</constructor-arg>?? ????????????</bean>?? ????????</property>?? ????</bean> ????<bean>?? ????????<property></property>?? ????????<property></property>?? ????????<property></property>?? </bean></beans>