SpringBoot中的事務(wù)處理問題
介紹
在實(shí)際的業(yè)務(wù)場景中,不光數(shù)據(jù)庫要實(shí)現(xiàn)事務(wù),我們的Service層業(yè)務(wù)也要實(shí)現(xiàn)事務(wù)。
例如:要實(shí)現(xiàn)數(shù)據(jù)的刪除,刪除數(shù)據(jù)庫中的數(shù)據(jù)并刪除Redis緩存中的數(shù)據(jù),他們在一個(gè)ServiceImpl的方法中,我們要實(shí)現(xiàn)這兩個(gè)操作放在一個(gè)事務(wù)中,兩個(gè)操作同時(shí)成功 / 失敗,所有,要使用Spring事務(wù)。
SpringBoot中事務(wù)實(shí)現(xiàn)
ServiceImpl的方法 / ServiceImpl類 上加上@Transactional。
- 方法:注解只對public方法有效(因?yàn)锧Transactional 工作原理是基于AOP實(shí)現(xiàn)的),如果在 protected、private 或者默認(rèn)方法上使用,沒有作用,也不報(bào)錯(cuò)。
- 類:該類的所有 public 方法將都具有該類型的事務(wù)屬性
注意:在方法級(jí)別使用該注解可以覆蓋類級(jí)別使用該注解。
// 這個(gè)類中的public方法如果拋出Exception,則該方法會(huì)回滾
@Transactional(rollbackFor = Exception.class)
public class DefaultFooService implements FooService {
public Foo getFoo(String fooName) {
// do something
}
// these settings have precedence for this method
//方法上注解屬性會(huì)覆蓋類注解上的相同屬性
@Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
public void updateFoo(Foo foo) {
// do something
}
}@EnableTransactionManagement
SpringBoot啟動(dòng)類上加上不用加@EnableTransactionManagement注解,SpringBoot自動(dòng)裝配已經(jīng)幫我們處理了,SpringBoot項(xiàng)目默認(rèn)支持事務(wù)。
@Transactional
作用位置:接口、接口方法、類以及類方法
Spring 建議不要在接口或者接口方法上使用該注解,因?yàn)檫@只有在使用基于接口的代理時(shí)它才會(huì)生效。
注意:
默認(rèn)情況下,只有來自外部的方法調(diào)用才會(huì)被AOP代理捕獲,也就是,類內(nèi)部方法調(diào)用本類內(nèi)部的其他方法并不會(huì)引起事務(wù)行為,即使被調(diào)用方法使用@Transactional注解進(jìn)行修飾。
Transactional類
package org.springframework.transaction.annotation;
import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Inherited;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.core.annotation.AliasFor;
import org.springframework.transaction.TransactionDefinition;
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface Transactional {
@AliasFor("transactionManager")
String value() default "";
@AliasFor("value")
String transactionManager() default "";
Propagation propagation() default Propagation.REQUIRED;
Isolation isolation() default Isolation.DEFAULT;
int timeout() default TransactionDefinition.TIMEOUT_DEFAULT;
boolean readOnly() default false;
Class<? extends Throwable>[] rollbackFor() default {};
String[] rollbackForClassName() default {};
Class<? extends Throwable>[] noRollbackFor() default {};
String[] noRollbackForClassName() default {};
}注解的屬性
| 屬性 | 類型 | 描述 |
| value | String | 可選的限定描述符,指定使用的事務(wù)管理器 |
| propagation | enum: Propagation | 可選的事務(wù)傳播行為設(shè)置 |
| isolation | enum: Isolation | 可選的事務(wù)隔離級(jí)別設(shè)置 |
| readOnly | boolean | 讀寫或只讀事務(wù),默認(rèn)讀寫 |
| timeout | int (in seconds granularity) | 事務(wù)超時(shí)時(shí)間設(shè)置 |
| rollbackFor | Class對象數(shù)組,必須繼承自Throwable | 導(dǎo)致事務(wù)回滾的異常類數(shù)組 |
| rollbackForClassName | 類名數(shù)組,必須繼承自Throwable | 導(dǎo)致事務(wù)回滾的異常類名字?jǐn)?shù)組 |
| noRollbackFor | Class對象數(shù)組,必須繼承自Throwable | 不會(huì)導(dǎo)致事務(wù)回滾的異常類數(shù)組 |
| noRollbackForClassName | 類名數(shù)組,必須繼承自Throwable | 不會(huì)導(dǎo)致事務(wù)回滾的異常類名字?jǐn)?shù)組 |
在Spring中定義了五種隔離級(jí)別常量
一般用默認(rèn)就可以。
package org.springframework.transaction.annotation;
import org.springframework.transaction.TransactionDefinition;
public enum Isolation {
DEFAULT(TransactionDefinition.ISOLATION_DEFAULT),
READ_UNCOMMITTED(TransactionDefinition.ISOLATION_READ_UNCOMMITTED),
READ_COMMITTED(TransactionDefinition.ISOLATION_READ_COMMITTED),
REPEATABLE_READ(TransactionDefinition.ISOLATION_REPEATABLE_READ),
SERIALIZABLE(TransactionDefinition.ISOLATION_SERIALIZABLE);
private final int value;
Isolation(int value) {
this.value = value;
}
public int value() {
return this.value;
}
}| 常量 | 說明 |
|---|---|
| TransactionDefinition.ISOLATION_DEFAULT | 數(shù)據(jù)庫默認(rèn)的隔離級(jí)別,MySQL默認(rèn)采用的 REPEATABLE_READ隔離級(jí)別 |
| TransactionDefinition.ISOLATION_READ_UNCOMMITTED | 最低的隔離級(jí)別,允許讀取未提交的數(shù)據(jù)變更,可能會(huì)導(dǎo)致臟讀、幻讀或不可重復(fù)讀。 |
| TransactionDefinition.ISOLATION_READ_COMMITTED | 允許讀取并發(fā)事務(wù)已經(jīng)提交的數(shù)據(jù),可以阻止臟讀,但是幻讀或不可重復(fù)讀仍有可能發(fā)生。 |
| TransactionDefinition.ISOLATION_REPEATABLE_READ | 對同一字段的多次讀取結(jié)果都是一致的,除非數(shù)據(jù)是被本身事務(wù)自己所修改,可以阻止臟讀和不可重復(fù)讀,但幻讀仍有可能發(fā)生。MySQL中通過MVCC解決了該隔離級(jí)別下出現(xiàn)幻讀的可能。 |
| TransactionDefinition.ISOLATION_SERIALIZABLE | 串行化隔離級(jí)別,該級(jí)別可以防止臟讀、不可重復(fù)讀以及幻讀,但是串行化會(huì)影響性能。 |
Spring定義了七種事務(wù)傳播行為
| 類型 | 說明 |
|---|---|
| PROPAGATION_REQUIRED | 如果當(dāng)前沒有事務(wù),就新建一個(gè)事務(wù),如果已經(jīng)存在一個(gè)事務(wù)中,加入到這個(gè)事務(wù)中。這是最常見的選擇 |
| PROPAGATION_SUPPORTS | 支持當(dāng)前事務(wù),如果當(dāng)前沒有事務(wù),就以非事務(wù)方式執(zhí)行。 |
| PROPAGATION_MANDATORY | 使用當(dāng)前的事務(wù),如果當(dāng)前沒有事務(wù),就拋出異常。 |
| PROPAGATION_REQUIRES_NEW | 新建事務(wù),如果當(dāng)前存在事務(wù),把當(dāng)前事務(wù)掛起。 |
| PROPAGATION_NOT_SUPPORTED | 以非事務(wù)方式執(zhí)行操作,如果當(dāng)前存在事務(wù),就把當(dāng)前事務(wù)掛起。 |
| PROPAGATION_NEVER | 以非事務(wù)方式執(zhí)行,如果當(dāng)前存在事務(wù),則拋出異常。 |
| PROPAGATION_NESTED | 如果當(dāng)前存在事務(wù),則在嵌套事務(wù)內(nèi)執(zhí)行。如果當(dāng)前沒有事務(wù),則執(zhí)行與PROPAGATION_REQUIRED類似的操作。 |
Spring事務(wù)什么情況下會(huì)失效
【1】@Transactional 應(yīng)用在非 public 修飾的方法上
@Transactional 工作原理是基于AOP實(shí)現(xiàn)的
所以,注解必須作用在public的方法上,否則失效。
【2】數(shù)據(jù)庫引擎是否支持事務(wù)(MySql的MyIsam引擎不支持事物)
【3】@Transactional注解屬性 propagation 設(shè)置錯(cuò)誤
- TransactionDefinition.PROPAGATION_SUPPORTS:如果當(dāng)前存在事務(wù),則加入該事務(wù);如果當(dāng)前沒有事務(wù),則以非事務(wù)的方式繼續(xù)運(yùn)行。
- TransactionDefinition.PROPAGATION_NOT_SUPPORTED:以非事務(wù)方式運(yùn)行,如果當(dāng)前存在事務(wù),則把當(dāng)前事務(wù)掛起。
- TransactionDefinition.PROPAGATION_NEVER:以非事務(wù)方式運(yùn)行,如果當(dāng)前存在事務(wù),則拋出異。
【4】@Transactional 注解屬性 rollbackFor 設(shè)置錯(cuò)誤?
- Spring默認(rèn)是回滾RuntimeException才回滾。
- 當(dāng)然自定義的RuntimeException異常類也是可以的。
- 如果希望Spring能夠回滾別類型的異常,那就需要使用rollbackFor去指定(當(dāng)然如果是指定異常的子類,也同樣會(huì)回滾)。
【5】同一個(gè)類中方法調(diào)用,導(dǎo)致@Transactional失效?
在同一個(gè)類中,沒有加事務(wù)的方法A調(diào)用加事務(wù)的方法B,方法B的事務(wù)失效。
( 其實(shí)這還是由于使用Spring AOP代理造成的),所以:建議把整個(gè)類加上事務(wù)注解。
【6】異常被捕獲了?
這個(gè)就比較簡單了,就是你自己捕捉到了異常,并且自己處理,并不會(huì)拋出到上層的方法調(diào)用。
那就不會(huì)生效了。
@Transactional
public void contextLoads() {
try {
int i = 0;
}catch (Exception e){
System.out.println("不可以回滾");
}
}可以手動(dòng)設(shè)置回滾
@Transactional
public void contextLoads() {
try {
int i = 0;
}catch (Exception e){
// 手動(dòng)回滾
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
System.out.println("可以回滾");
}
}【7】新開啟一個(gè)線程
Spring實(shí)現(xiàn)事務(wù)的原理是通過ThreadLocal把數(shù)據(jù)庫連接綁定到當(dāng)前線程中,新開啟一個(gè)線程獲取到的連接就不是同一個(gè)了。
總結(jié)
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
5種必會(huì)的Java異步調(diào)用轉(zhuǎn)同步的方法你會(huì)幾種
這篇文章主要介紹了5種必會(huì)的Java異步調(diào)用轉(zhuǎn)同步的方法你會(huì)幾種,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-12-12
Java中Builder模式的實(shí)現(xiàn)詳解
在設(shè)計(jì)模式中對Builder模式的定義是用于構(gòu)建復(fù)雜對象的一種模式,所構(gòu)建的對象往往需要多步初始化或賦值才能完成。下面這篇文章主要給大家介紹了在Java各個(gè)版本中Builder模式實(shí)現(xiàn)的相關(guān)資料,文中介紹的非常詳細(xì),需要的朋友可以參考學(xué)習(xí)。2017-05-05
Java數(shù)據(jù)結(jié)構(gòu)之單鏈表的實(shí)現(xiàn)與面試題匯總
由于順序表的插入刪除操作需要移動(dòng)大量的元素,影響了運(yùn)行效率,因此引入了線性表的鏈?zhǔn)酱鎯?chǔ)——單鏈表。本文為大家介紹了單鏈表的實(shí)現(xiàn)與面試題匯總,感興趣的可以了解一下2022-10-10
Caused by: java.lang.ClassNotFoundException: org.apache.comm
這篇文章主要介紹了Caused by: java.lang.ClassNotFoundException: org.objectweb.asm.Type異常,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07
12個(gè)SpringBoot配置文件的實(shí)用技巧分享
配置文件是SpringBoot應(yīng)用的核心組成部分,它決定了應(yīng)用的行為、連接參數(shù)以及功能特性,本文為大家整理了12個(gè)SpringBoot配置文件的實(shí)用技巧,有需要的可以了解下2025-05-05

