hk2000c技術(shù)專欄

          技術(shù)源于哲學(xué),哲學(xué)來(lái)源于生活 關(guān)心生活,關(guān)注健康,關(guān)心他人

            BlogJava :: 首頁(yè) :: 新隨筆 :: 聯(lián)系 :: 聚合  :: 管理 ::
            111 隨筆 :: 1 文章 :: 28 評(píng)論 :: 0 Trackbacks

          Spring聲明式事務(wù)讓我們從復(fù)雜的事務(wù)處理中得到解脫。使得我們?cè)僖矡o(wú)需要去處理獲得連接、關(guān)閉連接、事務(wù)提交和回滾等這些操作。再也無(wú)需要我們?cè)谂c事務(wù)相關(guān)的方法中處理大量的try…catch…finally代碼。
          我們?cè)谑褂肧pring聲明式事務(wù)時(shí),有一個(gè)非常重要的概念就是事務(wù)屬性。事務(wù)屬性通常由事務(wù)的傳播行為,事務(wù)的隔離級(jí)別,事務(wù)的超時(shí)值和事務(wù)只讀標(biāo)志組成。我們?cè)谶M(jìn)行事務(wù)劃分時(shí),需要進(jìn)行事務(wù)定義,也就是配置事務(wù)的屬性。
          Spring在TransactionDefinition接口中定義這些屬性,以供PlatfromTransactionManager使用, PlatfromTransactionManager是spring事務(wù)管理的核心接口。

          代碼
          1. TransactionDefinition   
          2. public interface TransactionDefinition {   
          3.     int getPropagationBehavior();   
          4.     int getIsolationLevel();   
          5.     int getTimeout();   
          6.     boolean isReadOnly();   
          7. }  

           

          getTimeout()方法,它返回事務(wù)必須在多少秒內(nèi)完成。
          isReadOnly(),事務(wù)是否只讀,事務(wù)管理器能夠根據(jù)這個(gè)返回值進(jìn)行優(yōu)化,確保事務(wù)是只讀的。
          getIsolationLevel()方法返回事務(wù)的隔離級(jí)別,事務(wù)管理器根據(jù)它來(lái)控制另外一個(gè)事務(wù)可以看到本事務(wù)內(nèi)的哪些數(shù)據(jù)。

          在TransactionDefinition接口中定義了五個(gè)不同的事務(wù)隔離級(jí)別
          ISOLATION_DEFAULT 這是一個(gè)PlatfromTransactionManager默認(rèn)的隔離級(jí)別,使用數(shù)據(jù)庫(kù)默認(rèn)的事務(wù)隔離級(jí)別.另外四個(gè)與JDBC的隔離級(jí)別相對(duì)應(yīng)
          ISOLATION_READ_UNCOMMITTED 這是事務(wù)最低的隔離級(jí)別,它充許別外一個(gè)事務(wù)可以看到這個(gè)事務(wù)未提交的數(shù)據(jù)。這種隔離級(jí)別會(huì)產(chǎn)生臟讀,不可重復(fù)讀和幻像讀。
          例如:
          Mary的原工資為1000,財(cái)務(wù)人員將Mary的工資改為了8000,但未提交事務(wù)

          代碼
          1. Connection con1 = getConnection();   
          2. con.setAutoCommit(false);   
          3. update employee set salary = 8000 where empId ="Mary";  

          與此同時(shí),Mary正在讀取自己的工資
          代碼
          1. Connection con2 = getConnection();   
          2. select  salary from employee where empId ="Mary";   
          3. con2.commit();  

           

          Mary發(fā)現(xiàn)自己的工資變?yōu)榱?000,歡天喜地!
          而財(cái)務(wù)發(fā)現(xiàn)操作有誤,而回滾了事務(wù),Mary的工資又變?yōu)榱?000

          代碼
          1. //con1   
          2.   con1.rollback();  

          像這樣,Mary記取的工資數(shù)8000是一個(gè)臟數(shù)據(jù)。

           

          ISOLATION_READ_COMMITTED 保證一個(gè)事務(wù)修改的數(shù)據(jù)提交后才能被另外一個(gè)事務(wù)讀取。另外一個(gè)事務(wù)不能讀取該事務(wù)未提交的數(shù)據(jù)。這種事務(wù)隔離級(jí)別可以避免臟讀出現(xiàn),但是可能會(huì)出現(xiàn)不可重復(fù)讀和幻像讀。

          ISOLATION_REPEATABLE_READ 這種事務(wù)隔離級(jí)別可以防止臟讀,不可重復(fù)讀。但是可能出現(xiàn)幻像讀。它除了保證一個(gè)事務(wù)不能讀取另一個(gè)事務(wù)未提交的數(shù)據(jù)外,還保證了避免下面的情況產(chǎn)生(不可重復(fù)讀)。

          在事務(wù)1中,Mary 讀取了自己的工資為1000,操作并沒(méi)有完成

          代碼
          1. con1 = getConnection();   
          2. select salary from employee empId ="Mary";  

           

          在事務(wù)2中,這時(shí)財(cái)務(wù)人員修改了Mary的工資為2000,并提交了事務(wù).

          代碼
          1. con2 = getConnection();   
          2. update employee set salary = 2000;   
          3. con2.commit();  

           

          在事務(wù)1中,Mary 再次讀取自己的工資時(shí),工資變?yōu)榱?000

          代碼
          1. //con1   
          2. select salary from employee empId ="Mary";  

           

          在一個(gè)事務(wù)中前后兩次讀取的結(jié)果并不致,導(dǎo)致了不可重復(fù)讀。
          使用ISOLATION_REPEATABLE_READ可以避免這種情況發(fā)生。

          ISOLATION_SERIALIZABLE 這是花費(fèi)最高代價(jià)但是最可靠的事務(wù)隔離級(jí)別。事務(wù)被處理為順序執(zhí)行。除了防止臟讀,不可重復(fù)讀外,還避免了幻像讀。

          目前工資為1000的員工有10人。
          事務(wù)1,讀取所有工資為1000的員工。

          代碼
          1. con1 = getConnection();   
          2. Select * from employee where salary =1000;  
          共讀取10條記錄

           

          這時(shí)另一個(gè)事務(wù)向employee表插入了一條員工記錄,工資也為1000

          代碼
          1. con2 = getConnection();   
          2. Insert into employee(empId,salary) values("Lili",1000);   
          3. con2.commit();  

           

          事務(wù)1再次讀取所有工資為1000的員工

          代碼
          1. //con1   
          2. select * from employee where salary =1000;  

           

          共讀取到了11條記錄,這就產(chǎn)生了幻像讀。
          ISOLATION_SERIALIZABLE能避免這樣的情況發(fā)生。但是這樣也耗費(fèi)了最大的資源。

          getPropagationBehavior()返回事務(wù)的傳播行為,由是否有一個(gè)活動(dòng)的事務(wù)來(lái)決定一個(gè)事務(wù)調(diào)用。

          在TransactionDefinition接口中定義了七個(gè)事務(wù)傳播行為

          PROPAGATION_REQUIRED 如果存在一個(gè)事務(wù),則支持當(dāng)前事務(wù)。如果沒(méi)有事務(wù)則開啟一個(gè)新的事務(wù)。

          代碼
          1. //事務(wù)屬性 PROPAGATION_REQUIRED   
          2. methodA{   
          3. ……   
          4. methodB();   
          5. ……   
          6. }   
          7.   
          8. //事務(wù)屬性 PROPAGATION_REQUIRED   
          9. methodB{   
          10.    ……   
          11. }  

          使用spring聲明式事務(wù),spring使用AOP來(lái)支持聲明式事務(wù),會(huì)根據(jù)事務(wù)屬性,自動(dòng)在方法調(diào)用之前決定是否開啟一個(gè)事務(wù),并在方法執(zhí)行之后決定事務(wù)提交或回滾事務(wù)。

           

          單獨(dú)調(diào)用methodB方法

          代碼
          1. main{   
          2.   metodB();   
          3. }  

          相當(dāng)于
          代碼
          1. Main{   
          2. Connection con=null;   
          3.   
          4.    rry{   
          5.       con = getConnection();   
          6.       con.setAutoCommit(false);   
          7. //方法調(diào)用   
          8. methodB();   
          9. //提交事務(wù)   
          10. con.commit();   
          11. }   
          12. Catch(RuntimeException ex){   
          13.   //回滾事務(wù)   
          14.   con.rollback();     
          15. }   
          16. finally{   
          17.   //釋放資源   
          18.   closeCon();   
          19. }   
          20. }  

          Spring保證在methodB方法中所有的調(diào)用都獲得到一個(gè)相同的連接。在調(diào)用methodB時(shí),沒(méi)有一個(gè)存在的事務(wù),所以獲得一個(gè)新的連接,開啟了一個(gè)新的事務(wù)。

           

          單獨(dú)調(diào)用MethodA時(shí),在MethodA內(nèi)又會(huì)調(diào)用MethodB.

          執(zhí)行效果相當(dāng)于

          代碼
          1. main{   
          2.    Connection con = null;   
          3.    try{   
          4.       con = getConnection();   
          5.       methodA();   
          6.       con.commit();   
          7. }   
          8. cathc(RuntimeException ex){   
          9.  con.rollback();   
          10. }   
          11. finally{   
          12.   closeCon();   
          13. }    
          14. }  

          調(diào)用MethodA時(shí),環(huán)境中沒(méi)有事務(wù),所以開啟一個(gè)新的事務(wù).
          當(dāng)在MethodA中調(diào)用MethodB時(shí),環(huán)境中已經(jīng)有了一個(gè)事務(wù),所以methodB就加入當(dāng)前事務(wù)。

           

          PROPAGATION_SUPPORTS 如果存在一個(gè)事務(wù),支持當(dāng)前事務(wù)。如果沒(méi)有事務(wù),則非事務(wù)的執(zhí)行。但是對(duì)于事務(wù)同步的事務(wù)管理器,PROPAGATION_SUPPORTS與不使用事務(wù)有少許不同。

          代碼
          1. //事務(wù)屬性 PROPAGATION_REQUIRED    
          2. methodA(){   
          3.   methodB();   
          4. }   
          5.   
          6. //事務(wù)屬性 PROPAGATION_SUPPORTS    
          7. methodB(){   
          8.   ……   
          9. }  

          單純的調(diào)用methodB時(shí),methodB方法是非事務(wù)的執(zhí)行的。
          當(dāng)調(diào)用methdA時(shí),methodB則加入了methodA的事務(wù)中,事務(wù)地執(zhí)行。

           

          PROPAGATION_MANDATORY 如果已經(jīng)存在一個(gè)事務(wù),支持當(dāng)前事務(wù)。如果沒(méi)有一個(gè)活動(dòng)的事務(wù),則拋出異常。

          代碼
          1. //事務(wù)屬性 PROPAGATION_REQUIRED    
          2. methodA(){   
          3.   methodB();   
          4. }   
          5.   
          6. //事務(wù)屬性 PROPAGATION_MANDATORY    
          7. methodB(){   
          8.   ……   
          9. }  

          當(dāng)單獨(dú)調(diào)用methodB時(shí),因?yàn)楫?dāng)前沒(méi)有一個(gè)活動(dòng)的事務(wù),則會(huì)拋出異常
          throw new IllegalTransactionStateException("Transaction propagation 'mandatory' but no existing transaction found");

           

          當(dāng)調(diào)用methodA時(shí),methodB則加入到methodA的事務(wù)中,事務(wù)地執(zhí)行。

          PROPAGATION_REQUIRES_NEW 總是開啟一個(gè)新的事務(wù)。如果一個(gè)事務(wù)已經(jīng)存在,則將這個(gè)存在的事務(wù)掛起。

          代碼
          1. //事務(wù)屬性 PROPAGATION_REQUIRED    
          2. methodA(){   
          3.   doSomeThingA();   
          4. methodB();   
          5. doSomeThingB();   
          6. }   
          7.   
          8. //事務(wù)屬性 PROPAGATION_REQUIRES_NEW    
          9. methodB(){   
          10.   ……   
          11. }  

          當(dāng)單獨(dú)調(diào)用methodB時(shí),相當(dāng)于把methodb聲明為REQUIRED。開啟一個(gè)新的事務(wù),事務(wù)地執(zhí)行。

           

          當(dāng)調(diào)用methodA時(shí)

          代碼
          1. main(){   
          2.   methodA();   
          3. }  
          情況有些大不一樣.相當(dāng)于下面的效果。
          代碼
          1. main(){   
          2.  TransactionManager tm = null;   
          3. try{   
          4.   //獲得一個(gè)JTA事務(wù)管理器   
          5.    tm = getTransactionManager();   
          6.    tm.begin();//開啟一個(gè)新的事務(wù)   
          7.    Transaction ts1 = tm.getTransaction();   
          8.    doSomeThing();   
          9.    tm.suspend();//掛起當(dāng)前事務(wù)   
          10.    try{   
          11.      tm.begin();//重新開啟第二個(gè)事務(wù)   
          12.      Transaction ts2 = tm.getTransaction();   
          13.      methodB();   
          14.      ts2.commit();//提交第二個(gè)事務(wù)   
          15.         
          16.    }   
          17.   Catch(RunTimeException ex){   
          18.      ts2.rollback();//回滾第二個(gè)事務(wù)   
          19.   }   
          20.   finally{   
          21.     //釋放資源   
          22.   }   
          23.    //methodB執(zhí)行完后,復(fù)恢第一個(gè)事務(wù)   
          24.    tm.resume(ts1);   
          25. doSomeThingB();   
          26.    ts1.commit();//提交第一個(gè)事務(wù)   
          27. }   
          28. catch(RunTimeException ex){   
          29.   ts1.rollback();//回滾第一個(gè)事務(wù)   
          30. }   
          31. finally{   
          32.   //釋放資源   
          33. }   
          34. }  

          在這里,我把ts1稱為外層事務(wù),ts2稱為內(nèi)層事務(wù)。從上面的代碼可以看出,ts2與ts1是兩個(gè)獨(dú)立的事務(wù),互不相干。Ts2是否成功并不依賴于ts1。如果methodA方法在調(diào)用methodB方法后的doSomeThingB方法失敗了,而methodB方法所做的結(jié)果依然被提交。而除了methodB之外的其它代碼導(dǎo)致的結(jié)果卻被回滾了。
          使用PROPAGATION_REQUIRES_NEW,需要使用JtaTransactionManager作為事務(wù)管理器。

           

          PROPAGATION_NOT_SUPPORTED 總是非事務(wù)地執(zhí)行,并掛起任何存在的事務(wù)。

          代碼
          1. //事務(wù)屬性 PROPAGATION_REQUIRED    
          2. methodA(){   
          3.   doSomeThingA();   
          4. methodB();   
          5. doSomeThingB();   
          6. }   
          7.   
          8. //事務(wù)屬性 PROPAGATION_NOT_SUPPORTED    
          9. methodB(){   
          10.   ……   
          11. }  

          當(dāng)單獨(dú)調(diào)用methodB時(shí),不啟用任何事務(wù)機(jī)制,非事務(wù)地執(zhí)行。
          當(dāng)調(diào)用methodA時(shí),相當(dāng)于下面的效果

           

          代碼
          1. main(){   
          2.  TransactionManager tm = null;   
          3. try{   
          4.   //獲得一個(gè)JTA事務(wù)管理器   
          5.    tm = getTransactionManager();   
          6.    tm.begin();//開啟一個(gè)新的事務(wù)   
          7.    Transaction ts1 = tm.getTransaction();   
          8.    doSomeThing();   
          9.    tm.suspend();//掛起當(dāng)前事務(wù)   
          10.      methodB();   
          11.    //methodB執(zhí)行完后,復(fù)恢第一個(gè)事務(wù)   
          12.    tm.resume(ts1);   
          13. doSomeThingB();   
          14.    ts1.commit();//提交第一個(gè)事務(wù)   
          15. }   
          16. catch(RunTimeException ex){   
          17.   ts1.rollback();//回滾第一個(gè)事務(wù)   
          18. }   
          19. finally{   
          20.   //釋放資源   
          21. }   
          22. }  
          使用PROPAGATION_NOT_SUPPORTED,也需要使用JtaTransactionManager作為事務(wù)管理器。

           

          PROPAGATION_NEVER 總是非事務(wù)地執(zhí)行,如果存在一個(gè)活動(dòng)事務(wù),則拋出異常

          代碼
          1. //事務(wù)屬性 PROPAGATION_REQUIRED    
          2. methodA(){   
          3.   doSomeThingA();   
          4. methodB();   
          5. doSomeThingB();   
          6. }   
          7.   
          8. //事務(wù)屬性 PROPAGATION_NEVER    
          9. methodB(){   
          10.   ……   
          11. }  
          單獨(dú)調(diào)用methodB,則非事務(wù)的執(zhí)行。
          調(diào)用methodA則會(huì)拋出異常
          throw new IllegalTransactionStateException(
          "Transaction propagation 'never' but existing transaction found");

           

          PROPAGATION_NESTED如果一個(gè)活動(dòng)的事務(wù)存在,則運(yùn)行在一個(gè)嵌套的事務(wù)中. 如果沒(méi)有活動(dòng)事務(wù), 則按TransactionDefinition.PROPAGATION_REQUIRED 屬性執(zhí)行

          這是一個(gè)嵌套事務(wù),使用JDBC 3.0驅(qū)動(dòng)時(shí),僅僅支持DataSourceTransactionManager作為事務(wù)管理器。需要JDBC 驅(qū)動(dòng)的java.sql.Savepoint類。有一些JTA的事務(wù)管理器實(shí)現(xiàn)可能也提供了同樣的功能。

          使用PROPAGATION_NESTED,還需要把PlatformTransactionManager的nestedTransactionAllowed屬性設(shè)為true;
          而nestedTransactionAllowed屬性值默認(rèn)為false;

          代碼
          1. //事務(wù)屬性 PROPAGATION_REQUIRED    
          2. methodA(){   
          3.   doSomeThingA();   
          4. methodB();   
          5. doSomeThingB();   
          6. }   
          7.   
          8. //事務(wù)屬性 PROPAGATION_NESTED   
          9. methodB(){   
          10.   ……   
          11. }  

          如果單獨(dú)調(diào)用methodB方法,則按REQUIRED屬性執(zhí)行。

           

          如果調(diào)用methodA方法,相當(dāng)于下面的效果

          代碼
          1. main(){   
          2. Connection con = null;   
          3. Savepoint savepoint = null;   
          4. try{   
          5.   con = getConnection();   
          6.   con.setAutoCommit(false);   
          7.   doSomeThingA();   
          8.   savepoint = con2.setSavepoint();   
          9.   try  
          10.       methodB();   
          11.   }catch(RuntimeException ex){   
          12.      con.rollback(savepoint);   
          13.   }   
          14.   finally{   
          15.     //釋放資源   
          16.   }   
          17.   
          18.   doSomeThingB();   
          19.   con.commit();   
          20. }   
          21. catch(RuntimeException ex){   
          22.   con.rollback();   
          23. }   
          24. finally{   
          25.   //釋放資源   
          26. }   
          27. }  
          當(dāng)methodB方法調(diào)用之前,調(diào)用setSavepoint方法,保存當(dāng)前的狀態(tài)到savepoint。如果methodB方法調(diào)用失敗,則恢復(fù)到之前保存的狀態(tài)。但是需要注意的是,這時(shí)的事務(wù)并沒(méi)有進(jìn)行提交,如果后續(xù)的代碼(doSomeThingB()方法)調(diào)用失敗,則回滾包括methodB方法的所有操作。

           

          嵌套事務(wù)一個(gè)非常重要的概念就是內(nèi)層事務(wù)依賴于外層事務(wù)。外層事務(wù)失敗時(shí),會(huì)回滾內(nèi)層事務(wù)所做的動(dòng)作。而內(nèi)層事務(wù)操作失敗并不會(huì)引起外層事務(wù)的回滾

          PROPAGATION_NESTED 與PROPAGATION_REQUIRES_NEW的區(qū)別:它們非常類似,都像一個(gè)嵌套事務(wù),如果不存在一個(gè)活動(dòng)的事務(wù),都會(huì)開啟一個(gè)新的事務(wù)。使用PROPAGATION_REQUIRES_NEW時(shí),內(nèi)層事務(wù)與外層事務(wù)就像兩個(gè)獨(dú)立的事務(wù)一樣,一旦內(nèi)層事務(wù)進(jìn)行了提交后,外層事務(wù)不能對(duì)其進(jìn)行回滾。兩個(gè)事務(wù)互不影響。兩個(gè)事務(wù)不是一個(gè)真正的嵌套事務(wù)。同時(shí)它需要JTA事務(wù)管理器的支持。
          使用PROPAGATION_NESTED時(shí),外層事務(wù)的回滾可以引起內(nèi)層事務(wù)的回滾。而內(nèi)層事務(wù)的異常并不會(huì)導(dǎo)致外層事務(wù)的回滾,它是一個(gè)真正的嵌套事務(wù)。DataSourceTransactionManager使用savepoint支持PROPAGATION_NESTED時(shí),需要JDBC 3.0以上驅(qū)動(dòng)及1.4以上的JDK版本支持。其它的JTA TrasactionManager實(shí)現(xiàn)可能有不同的支持方式。

          PROPAGATION_REQUIRED應(yīng)該是我們首先的事務(wù)傳播行為。它能夠滿足我們大多數(shù)的事務(wù)需求。

          posted on 2007-11-01 16:13 hk2000c 閱讀(293) 評(píng)論(0)  編輯  收藏 所屬分類: CMS項(xiàng)目開發(fā)
          主站蜘蛛池模板: 亚东县| 疏附县| 从化市| 龙陵县| 道真| 保定市| 扎赉特旗| 凌源市| 通道| 开阳县| 伊宁市| 开远市| 云霄县| 五原县| 璧山县| 分宜县| 肇庆市| 锦州市| 汶川县| 鄯善县| 息烽县| 辛集市| 浙江省| 五指山市| 天镇县| 洞头县| 洛宁县| 保康县| 延川县| 张家川| 都匀市| 京山县| 余江县| 当涂县| 甘南县| 双鸭山市| 霍林郭勒市| 平阳县| 新乐市| 湘潭市| 绥棱县|