@Transactional 事務失效問題


事物概念:

  1. 事務必須服從ACID原則。ACID指的是原子性(atomicity)、一致性(consistency)、隔離性(isolation)和持久性(durability)。
  2. 通俗理解,事務其實就是一系列指令的集合。
  • 原子性:操作這些指令時,要么全部執行成功,要么全部不執行。只要其中一個指令執行失敗,所有的指令都執行失敗,數據進行回滾,回到執行指令前的數據狀態。
  • 一致性:事務的執行使數據從一個狀態轉換為另一個狀態,但是對於整個數據的完整性保持穩定。
  • 隔離性:在該事務執行的過程中,無論發生的任何數據的改變都應該只存在於該事務之中,對外界不存在任何影響。只有在事務確定正確提交之后,才會顯示該事務對數據的改變。其他事務才能獲取到這些改變后的數據。
  • 持久性:當事務正確完成后,它對於數據的改變是永久性的。

Spring事務管理接口:

  • PlatformTransactionManager: (平台)事務管理器
  • TransactionDefinition: 事務定義信息(事務隔離級別、傳播行為、超時、只讀、回滾規則)
  • TransactionStatus: 事務運行狀態

所謂事務管理,其實就是“按照給定的事務規則來執行提交或者回滾操作”。

PlatformTransactionManager接口介紹

Spring並不直接管理事務,而是提供了多種事務管理器 ,他們將事務管理的職責委托給Hibernate或者JTA等持久化機制所提供的相關平台框架的事務來實現。 Spring事務管理器的接口是: org.springframework.transaction.PlatformTransactionManager ,通過這個接口,Spring為各個平台如JDBC、Hibernate等都提供了對應的事務管理器,但是具體的實現就是各個平台自己的事情了。

PlatformTransactionManager接口代碼如下:

PlatformTransactionManager接口中定義了三個方法:

Public interface PlatformTransactionManager()...{  

    // Return a currently active transaction or create a new one, according to the specified propagation behavior(根據指定的傳播行為,返回當前活動的事務或創建一個新事務。)

    TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException; 

    // Commit the given transaction, with regard to its status(使用事務目前的狀態提交事務)
    Void commit(TransactionStatus status) throws TransactionException;  
    // Perform a rollback of the given transaction(對執行的事務進行回滾)

    Void rollback(TransactionStatus status) throws TransactionException;  
    } 

復制代碼

TransactionDefinition接口介紹

事務管理器接口 PlatformTransactionManager 通過 getTransaction(TransactionDefinition definition) 方法來得到一個事務,這個方法里面的參數是 TransactionDefinition類 ,這個類就定義了一些基本的事務屬性。

那么什么是事務屬性呢?

事務屬性可以理解成事務的一些基本配置,描述了事務策略如何應用到方法上。事務屬性包含了5個方面。

TransactionDefinition接口中的方法如下:

TransactionDefinition接口中定義了5個方法以及一些表示事務屬性的常量比如隔離級別、傳播行為等等的常量。

我下面只是列出了TransactionDefinition接口中的方法而沒有給出接口中定義的常量,該接口中的常量信息會在后面依次介紹到。

public interface TransactionDefinition {
    // 返回事務的傳播行為
    int getPropagationBehavior(); 
    // 返回事務的隔離級別,事務管理器根據它來控制另外一個事務可以看到本事務內的哪些數據
    int getIsolationLevel(); 
    // 返回事務必須在多少秒內完成
    //返回事務的名字
    String getName();
    int getTimeout();  
    // 返回是否優化為只讀事務。
    boolean isReadOnly();
} 

(1)事務隔離級別(定義了一個事務可能受其他並發事務影響的程度):

我們先來看一下 並發事務帶來的問題 ,然后再來介紹一下 TransactionDefinition 接口 中定義了五個表示隔離級別的常量。

並發事務帶來的問題

在典型的應用程序中,多個事務並發運行,經常會操作相同的數據來完成各自的任務(多個用戶對統一數據進行操作)。並發雖然是必須的,但可能會導致一下的問題。

  • 臟讀(Dirty read): 當一個事務正在訪問數據並且對數據進行了修改,而這種修改還沒有提交到數據庫中,這時另外一個事務也訪問了這個數據,然后使用了這個數據。因為這個數據是還沒有提交的數據,那么另外一個事務讀到的這個數據是“臟數據”,依據“臟數據”所做的操作可能是不正確的。

  • 丟失修改(Lost to modify): 指在一個事務讀取一個數據時,另外一個事務也訪問了該數據,那么在第一個事務中修改了這個數據后,第二個事務也修改了這個數據。這樣第一個事務內的修改結果就被丟失,因此稱為丟失修改。

    例如:事務1讀取某表中的數據A=20,事務2也讀取A=20,事務1修改A=A-1,事務2也修改A=A-1,最終結果A=19,事務1的修改被丟失。

  • 不可重復讀(Unrepeatableread): 指在一個事務內多次讀同一數據。在這個事務還沒有結束時,另一個事務也訪問該數據。那么,在第一個事務中的兩次讀數據之間,由於第二個事務的修改導致第一個事務兩次讀取的數據可能不太一樣。這就發生了在一個事務內兩次讀到的數據是不一樣的情況,因此稱為不可重復讀。

  • 幻讀(Phantom read): 幻讀與不可重復讀類似。它發生在一個事務(T1)讀取了幾行數據,接着另一個並發事務(T2)插入了一些數據時。在隨后的查詢中,第一個事務(T1)就會發現多了一些原本不存在的記錄,就好像發生了幻覺一樣,所以稱為幻讀。

不可重復度和幻讀區別:

不可重復讀的重點是修改,幻讀的重點在於新增或者刪除。

例1(同樣的條件, 你讀取過的數據, 再次讀取出來發現值不一樣了 ):事務1中的A先生讀取自己的工資為 1000的操作還沒完成,事務2中的B先生就修改了A的工資為2000,導 致A再讀自己的工資時工資變為 2000;這就是不可重復讀。

例2(同樣的條件, 第1次和第2次讀出來的記錄數不一樣 ):假某工資單表中工資大於3000的有4人,事務1讀取了所有工資大於3000的人,共查到4條記錄,這時事務2 又插入了一條工資大於3000的記錄,事務1再次讀取時查到的記錄就變為了5條,這樣就導致了幻讀。

隔離級別

TransactionDefinition 接口中定義了五個表示隔離級別的常量:

  • TransactionDefinition.ISOLATION_DEFAULT: 使用后端數據庫默認的隔離級別,Mysql 默認采用的 REPEATABLE_READ隔離級別 Oracle 默認采用的 READ_COMMITTED隔離級別.
  • TransactionDefinition.ISOLATION_READ_UNCOMMITTED: 最低的隔離級別,允許讀取尚未提交的數據變更,可能會導致臟讀、幻讀或不可重復讀
  • TransactionDefinition.ISOLATION_READ_COMMITTED: 允許讀取並發事務已經提交的數據,可以阻止臟讀,但是幻讀或不可重復讀仍有可能發生
  • TransactionDefinition.ISOLATION_REPEATABLE_READ: 對同一字段的多次讀取結果都是一致的,除非數據是被本身事務自己所修改,可以阻止臟讀和不可重復讀,但幻讀仍有可能發生。
  • TransactionDefinition.ISOLATION_SERIALIZABLE: 最高的隔離級別,完全服從ACID的隔離級別。所有的事務依次逐個執行,這樣事務之間就完全不可能產生干擾,也就是說,該級別可以防止臟讀、不可重復讀以及幻讀。但是這將嚴重影響程序的性能。通常情況下也不會用到該級別。

(2)事務傳播行為(為了解決業務層方法之間互相調用的事務問題):

當事務方法被另一個事務方法調用時,必須指定事務應該如何傳播。例如:方法可能繼續在現有事務中運行,也可能開啟一個新事務,並在自己的事務中運行。在TransactionDefinition定義中包括了如下幾個表示傳播行為的常量:

支持當前事務的情況:

  • TransactionDefinition.PROPAGATION_REQUIRED: 如果當前存在事務,則加入該事務;如果當前沒有事務,則創建一個新的事務。
  • TransactionDefinition.PROPAGATION_SUPPORTS: 如果當前存在事務,則加入該事務;如果當前沒有事務,則以非事務的方式繼續運行。
  • TransactionDefinition.PROPAGATION_MANDATORY: 如果當前存在事務,則加入該事務;如果當前沒有事務,則拋出異常。(mandatory:強制性)

不支持當前事務的情況:

  • TransactionDefinition.PROPAGATION_REQUIRES_NEW: 創建一個新的事務,如果當前存在事務,則把當前事務掛起。
  • TransactionDefinition.PROPAGATION_NOT_SUPPORTED: 以非事務方式運行,如果當前存在事務,則把當前事務掛起。
  • TransactionDefinition.PROPAGATION_NEVER: 以非事務方式運行,如果當前存在事務,則拋出異常。

其他情況:

  • TransactionDefinition.PROPAGATION_NESTED: 如果當前存在事務,則創建一個事務作為當前事務的嵌套事務來運行;如果當前沒有事務,則該取值等價於TransactionDefinition.PROPAGATION_REQUIRED。

這里需要指出的是,前面的六種事務傳播行為是 Spring 從 EJB 中引入的,他們共享相同的概念。而 PROPAGATION_NESTED 是 Spring 所特有的。以 PROPAGATION_NESTED 啟動的事務內嵌於外部事務中(如果存在外部事務的話),此時,內嵌事務並不是一個獨立的事務,它依賴於外部事務的存在,只有通過外部的事務提交,才能引起內部事務的提交,嵌套的子事務不能單獨提交。如果熟悉 JDBC 中的保存點(SavePoint)的概念,那嵌套事務就很容易理解了,其實嵌套的子事務就是保存點的一個應用,一個事務中可以包括多個保存點,每一個嵌套子事務。另外,外部事務的回滾也會導致嵌套子事務的回滾。

(3) 事務超時屬性(一個事務允許執行的最長時間)

所謂事務超時,就是指一個事務所允許執行的最長時間,如果超過該時間限制但事務還沒有完成,則自動回滾事務。在 TransactionDefinition 中以 int 的值來表示超時時間,其單位是秒。

(4) 事務只讀屬性(對事物資源是否執行只讀操作)

事務的只讀屬性是指,對事務性資源進行只讀操作或者是讀寫操作。所謂事務性資源就是指那些被事務管理的資源,比如數據源、 JMS 資源,以及自定義的事務性資源等等。如果確定只對事務性資源進行只讀操作,那么我們可以將事務標志為只讀的,以提高事務處理的性能。在 TransactionDefinition 中以 boolean 類型來表示該事務是否只讀。

(5) 回滾規則(定義事務回滾規則)

這些規則定義了哪些異常會導致事務回滾而哪些不會。默認情況下,事務只有遇到運行期異常時才會回滾,而在遇到檢查型異常時不會回滾(這一行為與EJB的回滾行為是一致的)。 但是你可以聲明事務在遇到特定的檢查型異常時像遇到運行期異常那樣回滾。同樣,你還可以聲明事務遇到特定的異常不回滾,即使這些異常是運行期異常。

異常介紹

異常分類:

1.所有的異常都是從Throwable繼承而來的,是所有異常的共同祖先。

2.Throwable有兩個子類,Error和Exception。其中Error是錯誤,對於所有的編譯時期的錯誤以及系統錯誤都是通過Error拋出的。這些錯誤表示故障發生於虛擬機自身、或者發生在虛擬機試圖執行應用時,如Java虛擬機運行錯誤(Virtual MachineError)、類定義錯誤(NoClassDefFoundError)等。這些錯誤是不可查的,因為它們在應用程序的控制和處理能力之 外,而且絕大多數是程序運行時不允許出現的狀況。對於設計合理的應用程序來說,即使確實發生了錯誤,本質上也不應該試圖去處理它所引起的異常狀況。在 Java中,錯誤通過Error的子類描述。

3.Exception,是另外一個非常重要的異常子類。它規定的異常是程序本身可以處理的異常。異常和錯誤的區別是,異常是可以被處理的,而錯誤是沒法處理的。

4.Checked Exception

可檢查的異常,這是編碼時非常常用的,所有checked exception都是需要在代碼中處理的。它們的發生是可以預測的,正常的一種情況,可以合理的處理。比如IOException,或者一些自定義的異常。除了RuntimeException及其子類以外,都是checked exception。

5.Unchecked Exception

RuntimeException及其子類都是unchecked exception。比如NPE空指針異常,除數為0的算數異常ArithmeticException等等,這種異常是運行時發生,無法預先捕捉處理的。Error也是unchecked exception,也是無法預先處理的。

@Transactional

事務聲明注解

特性

1、service類標簽(一般不建議在接口上)上添加@Transactional,可以將整個類納入spring事務管理,在每個業務方法執行時都會開啟一個事務,不過這些事務采用相同的管理方式。

2、@Transactional 注解只能應用到 public 可見度的方法上。 如果應用在protected、private或者 package可見度的方法上,也不會報錯,不過事務設置不會起作用。

3、默認情況下,Spring會對unchecked異常進行事務回滾;如果是checked異常則不回滾。
辣么什么是checked異常,什么是unchecked異常

java里面將派生於Error或者RuntimeException(比如空指針,1/0)的異常稱為unchecked異常,其他繼承自java.lang.Exception得異常統稱為Checked Exception,如IOException、TimeoutException等

辣么再通俗一點:你寫代碼出現的空指針等異常,會被回滾,文件讀寫,網絡出問題,spring就沒法回滾了。然后我教大家怎么記這個,因為很多同學容易弄混,你寫代碼的時候有些IOException我們的編譯器是能夠檢測到的,說以叫checked異常,你寫代碼的時候空指針等死檢測不到的,所以叫unchecked異常。

4、只讀事務:
@Transactional(propagation=Propagation.NOT_SUPPORTED,readOnly=true)
只讀標志只在事務啟動時應用,否則即使配置也會被忽略。
啟動事務會增加線程開銷,數據庫因共享讀取而鎖定(具體跟數據庫類型和事務隔離級別有關)。通常情況下,僅是讀取數據時,不必設置只讀事務而增加額外的系統開銷。

失效情況

1、檢查你方法是不是public的

2、你的異常類型是不是unchecked異常
如果我想check異常也想回滾怎么辦,注解上面寫明異常類型即可

@Transactional(rollbackFor=Exception.class) 

類似的還有norollbackFor,自定義不回滾的異常

3、數據庫引擎要支持事務,如果是MySQL,注意表要使用支持事務的引擎,比如innodb,如果是myisam,事務是不起作用的

4、是否開啟了對注解的解析

<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

5、spring是否掃描到你這個包,如下是掃描到org.test下面的包

<context:component-scan base-package="org.test" ></context:component-scan>

6、檢查是不是同一個類中的方法調用(如a方法調用同一個類中的b方法)【通過事務的傳播機制來限定】
7、異常是不是被你catch住了

  1. throw new RuntimeExcetion();
  2. TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


免責聲明!

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



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