事務的傳播機制


1.什么是事務:

  事務是程序中一系列嚴密的操作,所有操作執行必須成功完成,否則在每個操作所做的更改將會被撤銷,這也是事務的原子性(要么成功,要么失敗)。

  數據庫向用戶提供保存當前程序狀態的方法,叫事務提交(commit;當事務執行過程中,使數據庫忽略當前的狀態並回到前面保存的狀態的方法叫事務回滾(rollback

2.事務的傳播機制

  以spring的事務傳播機制為例子:

  Spring事務機制主要包括聲明式事務編程式事務,此處側重講解聲明式事務,編程式事務在實際開發中得不到廣泛使用,僅供學習參考。

  Spring聲明式事務讓我們從復雜的事務處理中得到解脫。使得我們再也無需要去處理獲得連接、關閉連接、事務提交和回滾等這些操作。再也無需要我們在與事務相關的方法中處理大量的try…catch…finally代碼。我們在使用Spring聲明式事務時,有一個非常重要的概念就是事務屬性。事務屬性通常由事務的傳播行為,事務的隔離級別,事務的超時值和事務只讀標志組成。我們在進行事務划分時,需要進行事務定義,也就是配置事務的屬性。


   spring在TransactionDefinition接口中定義了七個事務傳播行為:

    • propagation_requierd:如果當前沒有事務,就新建一個事務,如果已存在一個事務中,加入到這個事務中,這是最常見的選擇。
    • propagation_supports:支持當前事務,如果沒有當前事務,就以非事務方法執行。
    • propagation_mandatory:使用當前事務,如果沒有當前事務,就拋出異常。
    • propagation_required_new:新建事務,如果當前存在事務,把當前事務掛起。
    • propagation_not_supported:以非事務方式執行操作,如果當前存在事務,就把當前事務掛起。
    • propagation_never:以非事務方式執行操作,如果當前事務存在則拋出異常。
    • propagation_nested:如果當前存在事務,則在嵌套事務內執行。如果當前沒有事務,則執行與propagation_required類似的操作

  (1)PROPAGATION_REQUIRED  如果存在一個事務,則支持當前事務。如果沒有事務則開啟一個新的事務。

  Java代碼:

//事務屬性 PROPAGATION_REQUIRED 
methodA{ 
  …… 
  methodB(); 
  …… 
}
 
//事務屬性 PROPAGATION_REQUIRED 
methodB{ 
   …… 
}

  使用spring聲明式事務,spring使用AOP來支持聲明式事務,會根據事務屬性,自動在方法調用之前決定是否開啟一個事務,並在方法執行之后決定事務提交或回滾事務。

  單獨調用methodB方法:

Java代碼

main{
  metodB(); 
}

相當於

Java代碼

Main{ 
    Connection con=null; 
    try{ 
        con = getConnection(); 
        con.setAutoCommit(false); 
        //方法調用
        methodB(); 
        //提交事務
        con.commit(); 
    } 
    Catch(RuntimeException ex){ 
        //回滾事務
        con.rollback();   
    } 
    finally{ 
    //釋放資源
    closeCon(); 
    } 
}        

  Spring保證在methodB方法中所有的調用都獲得到一個相同的連接。在調用methodB時,沒有一個存在的事務,所以獲得一個新的連接,開啟了一個新的事務。

  單獨調用MethodA時,在MethodA內又會調用MethodB.

  執行效果相當於:

Java代碼

main{ 
     Connection con = null; 
    try{ 
         con = getConnection(); 
        methodA(); 
        con.commit(); 
    } 
    catch(RuntimeException ex){ 
        con.rollback(); 
    } 
    finally{ 
       closeCon(); 
    }  
}                

  調用MethodA時,環境中沒有事務,所以開啟一個新的事務.當在MethodA中調用MethodB時,環境中已經有了一個事務,所以methodB就加入當前事務。

(2)PROPAGATION_SUPPORTS 如果存在一個事務,支持當前事務。如果沒有事務,則非事務的執行。但是對於事務同步的事務管理器,PROPAGATION_SUPPORTS與不使用事務有少許不同。

Java代碼:

//事務屬性 PROPAGATION_REQUIRED 
methodA(){ 
  methodB(); 
}
 
//事務屬性 PROPAGATION_SUPPORTS 
methodB(){ 
  …… 
}

  單純的調用methodB時,methodB方法是非事務的執行的。當調用methdA時,methodB則加入了methodA的事務中,事務地執行。

(3)PROPAGATION_MANDATORY 如果已經存在一個事務,支持當前事務。如果沒有一個活動的事務,則拋出異常。

Java代碼:

//事務屬性 PROPAGATION_REQUIRED 
methodA(){ 
    methodB(); 
}
 
//事務屬性 PROPAGATION_MANDATORY 
methodB(){ 
    …… 
}

  當單獨調用methodB時,因為當前沒有一個活動的事務,則會拋出異常throw new IllegalTransactionStateException(“Transaction propagation ‘mandatory’ but no existing transaction found”);當調用methodA時,methodB則加入到methodA的事務中,事務地執行。

(4)PROPAGATION_REQUIRES_NEW 總是開啟一個新的事務。如果一個事務已經存在,則將這個存在的事務掛起。

Java代碼:

//事務屬性 PROPAGATION_REQUIRED 
methodA(){ 
   doSomeThingA(); 
   methodB(); 
   doSomeThingB(); 
}
 
//事務屬性 PROPAGATION_REQUIRES_NEW 
methodB(){ 
   …… 
}

Java代碼:

main(){ 
  methodA(); 
}

相當於

Java代碼:

main(){ 
  TransactionManager tm = null; 
try{ 
  //獲得一個JTA事務管理器 
    tm = getTransactionManager(); 
    tm.begin();//開啟一個新的事務 
    Transaction ts1 = tm.getTransaction(); 
    doSomeThing(); 
    tm.suspend();//掛起當前事務 
    try{ 
      tm.begin();//重新開啟第二個事務 
      Transaction ts2 = tm.getTransaction(); 
      methodB(); 
      ts2.commit();//提交第二個事務 
   } 
  Catch(RunTimeException ex){ 
      ts2.rollback();//回滾第二個事務 
  } 
  finally{ 
     //釋放資源 
   } 
    //methodB執行完后,復恢第一個事務 
    tm.resume(ts1); 
doSomeThingB(); 
    ts1.commit();//提交第一個事務 
} 
catch(RunTimeException ex){ 
   ts1.rollback();//回滾第一個事務 
} 
finally{ 
   //釋放資源 
} 
}

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

(5)PROPAGATION_NOT_SUPPORTED  總是非事務地執行,並掛起任何存在的事務。使用PROPAGATION_NOT_SUPPORTED,也需要使用JtaTransactionManager作為事務管理器。(代碼示例同上,可同理推出)

(6)PROPAGATION_NEVER 總是非事務地執行,如果存在一個活動事務,則拋出異常;

(7)PROPAGATION_NESTED如果一個活動的事務存在,則運行在一個嵌套的事務中. 如果沒有活動事務, 則按TransactionDefinition.PROPAGATION_REQUIRED 屬性執行。這是一個嵌套事務,使用JDBC 3.0驅動時,僅僅支持DataSourceTransactionManager作為事務管理器。需要JDBC 驅動的java.sql.Savepoint類。有一些JTA的事務管理器實現可能也提供了同樣的功能。使用PROPAGATION_NESTED,還需要把PlatformTransactionManager的nestedTransactionAllowed屬性設為true;而nestedTransactionAllowed屬性值默認為false;

Java代碼:

//事務屬性 PROPAGATION_REQUIRED 
methodA(){ 
   doSomeThingA(); 
   methodB(); 
   doSomeThingB(); 
}
 
//事務屬性 PROPAGATION_NESTED 
methodB(){ 
  …… 
}

如果單獨調用methodB方法,則按REQUIRED屬性執行。如果調用methodA方法,相當於下面的效果:

Java代碼:

main(){ 
Connection con = null; 
Savepoint savepoint = null; 
try{ 
   con = getConnection(); 
   con.setAutoCommit(false); 
   doSomeThingA(); 
   savepoint = con2.setSavepoint(); 
   try{ 
       methodB(); 
   }catch(RuntimeException ex){ 
      con.rollback(savepoint); 
   } 
   finally{ 
     //釋放資源 
  }
 
   doSomeThingB(); 
   con.commit(); 
} 
catch(RuntimeException ex){ 
  con.rollback(); 
} 
finally{ 
   //釋放資源 
} 
}

  當methodB方法調用之前,調用setSavepoint方法,保存當前的狀態到savepoint。如果methodB方法調用失敗,則恢復到之前保存的狀態。但是需要注意的是,這時的事務並沒有進行提交,如果后續的代碼(doSomeThingB()方法)調用失敗,則回滾包括methodB方法的所有操作。

  嵌套事務一個非常重要的概念就是內層事務依賴於外層事務。外層事務失敗時,會回滾內層事務所做的動作。而內層事務操作失敗並不會引起外層事務的回滾。

  Spring 默認的事務傳播行為PROPAGATION_REQUIRED,它適合於絕大多數的情況。假設 ServiveX#methodX() 都工作在事務環境下(即都被 Spring 事務增強了),假設程序中存在如下的調用鏈:Service1#method1()->Service2#method2()->Service3#method3(),那么這 3 個服務類的 3 個方法通過 Spring 的事務傳播機制都工作在同一個事務中。

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM