詳解Spring中的Transactional屬性

一、Transactional

聲明式事務管理建立在AOP之上的。其本質是對方法前後進行攔截,然後在目標方法開始之前創建或者加入一個事務,在執行完目標方法之後根據執行情況提交或者回滾事務。

簡而言之,@Transactional註解在代碼執行出錯的時候能夠進行事務的回滾。

在這裡插入圖片描述

二、使用說明

在這裡插入圖片描述

  • 在啟動類上添加@EnableTransactionManagement註解。
  • 用於類上時,該類的所有 public 方法將都具有該類型的事務屬性,同時,我們也可以在方法級別使用該標註來覆蓋類級別的定義。
  • 在項目中,@Transactional(rollbackFor=Exception.class),如果類加瞭這個註解,那麼這個類裡面的方法拋出異常,就會回滾,數據庫裡面的數據也會回滾。
  • 在@Transactional註解中如果不配置rollbackFor屬性,那麼事物隻會在遇到RuntimeException的時候才會回滾,加上rollbackFor=Exception.class,可以讓事物在遇到非運行時異常時也回滾。

而至於什麼是運行時異常(RuntimeException),什麼是非運行時異常,可通過下圖所示理解(圖片截取網絡)

在這裡插入圖片描述

三、註解失效問題

正常情況下,隻要在方法上添加@Transactional註解就完事瞭,但是需要註意的是,雖然使用簡單,但是如果不合理地使用註解,還是會存在註解失效的問題。

@Transactional 應用在非 public 修飾的方法上

事務攔截器在目標方法執行前後進行攔截,內部會調用方法來獲取Transactional 註解的事務配置信息,調用前會檢查目標方法的修飾符是否為 public,不是 public則不會獲取@Transactional 的屬性配置信息。

@Transactional 註解屬性 rollbackFor 設置錯誤

rollbackFor 可以指定能夠觸發事務回滾的異常類型。Spring默認拋出瞭未檢查unchecked異常(繼承自 RuntimeException 的異常)或者 Error才回滾事務;其他異常不會觸發回滾事務。如果在事務中拋出其他類型的異常,但卻期望 Spring 能夠回滾事務,就需要指定rollbackFor屬性。

同一個類中方法調用,導致@Transactional失效

開發中避免不瞭會對同一個類裡面的方法調用,比如有一個類Test,它的一個方法A,A再調用本類的方法B(不論方法B是用public還是private修飾),但方法A沒有聲明註解事務,而B方法有。則外部調用方法A之後,方法B的事務是不會起作用的。這也是經常犯錯誤的一個地方。
那為啥會出現這種情況?其實這還是由於使用Spring AOP代理造成的,因為隻有當事務方法被當前類以外的代碼調用時,才會由Spring生成的代理對象來管理。

異常被你的 catch“吃瞭”導致@Transactional失效

如果你手動的catch捕獲這個異常並進行處理,事務管理器會認為當前事務應該正常commit,就會導致註解失效,如果非要捕獲且不失效,就必須在代碼塊內throw new Exception拋出異常。

數據庫引擎不支持事務

開啟事務的前提就是需要數據庫的支持,我們一般使用的Mysql引擎時支持事務的,所以一般不會出現這種問題。

開啟多線程任務時,事務管理會受到影響

因為線程不屬於spring托管,故線程不能夠默認使用spring的事務,也不能獲取spring註入的bean在被spring聲明式事務管理的方法內開啟多線程,多線程內的方法不被事務控制。
如下代碼,線程內調用insert方法,spring不會把insert方法加入事務就算在insert方法上加入@Transactional註解,也不起作用。

@Service  
public class ServiceA {  
   
    @Transactional  
    public void threadMethod(){  
        this.insert();  
         System.out.println("main insert is over");  
        for(int a=0 ;a<3;a++){  
            ThreadOperation threadOperation= new ThreadOperation();  
            Thread innerThread = new Thread(threadOperation);  
            innerThread.start();  
        }  
    }  
   
    public  class ThreadOperation implements Runnable {  
        public ThreadOperation(){  
        }  
        @Override  
        public void run(){  
            insert();  
            System.out.println("thread insert is over");  
        }  
    }  
   
    public void insert(){  
   
    //do insert......  
   
    }  
}  

如果把上面insert方法提出到新的類中,加入事務註解,就能成功的把insert方法加入到事務管理當中

@Service  
public class ServiceA {  
   
@Autowired  
private ServiceB serviceB;  
   
    @Transactional  
    public void threadMethod(){  
        this.insert();  
        System.out.println("main insert is over");  
        for(int a=0 ;a<3;a++){  
            ThreadOperation threadOperation= new ThreadOperation();  
            Thread innerThread = new Thread(threadOperation);  
            innerThread.start();  
        }  
    }  
   
    public  class ThreadOperation implements Runnable {  
        public ThreadOperation(){  
        }  
        @Override  
        public void run(){  
            serviceB.insert();  
            System.out.println("thread insert is over");  
        }  
    }  
   
    public void insert(){  
   
        //do insert......  
   
    }  
}  
   
@Service  
public class ServiceB {  
   
    @Transactional  
    public void insert(){  
   
        //do insert......  
   
    }  
   
}  

另外,使用多線程事務的情況下,進行回滾,比較麻煩。thread的run方法,有個特別之處,它不會拋出異常,但異常會導致線程終止運行。

最麻煩的是,在線程中拋出的異常即使在主線程中使用try…catch也無法截獲這非常糟糕,我們必須要“感知”到異常的發生。比如某個線程在處理重要的事務,當thread異常終止,我必須要收到異常的報告,才能回滾事務。這時可以使用線程的UncaughtExceptionHandler進行異常處理,UncaughtExceptionHandler名字意味著處理未捕獲的異常。更明確的說,它處理未捕獲的運行時異常。

如下代碼
線程出要使用
①處要拋出異常
②處要捕捉異常,並且要拋出RuntimeException
③處手動處理回滾邏輯

@Service  
public class ServiceA {  
   
@Autowired  
private ServiceB serviceB;  
   
    @Transactional  
    public void threadMethod(){  
        this.insert();  
        System.out.println("main insert is over");  
        for(int a=0 ;a<3;a++){  
            ThreadOperation threadOperation= new ThreadOperation();  
            Thread innerThread = new Thread(threadOperation);  
            innerThread.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {  
               public void uncaughtException(Thread t, Throwable e) {  
                   try {  
                        serviceB.delete();③  
                   } catch (Exception e1) {  
                       e1.printStackTrace();  
                   }  
               }  
            });  
            innerThread.start();  
        }  
    }  
   
    public  class ThreadOperation implements Runnable {  
        public ThreadOperation(){  
        }  
        @Override  
        public void run(){  
            try {  
               serviceB.insert();  
           }catch (Exception ex){ ②  
            System.out.println(" Exception in run ");  
               throw new RuntimeException();  
           }  
            System.out.println("thread insert is over");  
        }  
    }  
   
    public void insert(){  
   
        //do insert......  
   
    }  
}  
   
@Service  
public class ServiceB {  
   
    @Transactional  
    public void insert() throws Exception{ ①  
   
    //do insert......  
   
    }  
   
    @Transactional  
    public void delete() throws Exception{   
   
        //do delete......  
   
    }  
   
}  

到此這篇關於詳解Spring中的Transactional屬性的文章就介紹到這瞭,更多相關Transactional屬性詳解內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!

推薦閱讀: