Spring事務(wù)失效的九大場景,你踩過幾個(gè)?
前言
在日常開發(fā)中,我們經(jīng)常使用Spring
事務(wù)。最近,一個(gè)朋友去面試,被問到了這樣一個(gè)面試題:在什么情況下,Spring 事務(wù)會(huì)失效?
今天,我將和大家聊聊Spring
事務(wù)失效的 9 種場景。
1. 拋出檢查異常(checked exceptions)
例如,你的事務(wù)控制代碼如下:
@Transactional
public void transactionTest() throws IOException {
User user = new User();
UserService.insert(user);
throw new IOException();
}
如果沒有特別指定@Transactional
,Spring 默認(rèn)只會(huì)在遇到運(yùn)行時(shí)異常RuntimeException
或錯(cuò)誤時(shí)回滾,而檢查異常如IOException
不會(huì)觸發(fā)回滾。
public boolean rollbackOn(Throwable ex) {
return (ex instanceof RuntimeException || ex instanceof Error);
}
解決方案:
知道原因后,解決方案也很簡單。配置rollbackFor
屬性,例如:@Transactional(rollbackFor = Exception.class)
。
@Transactional(rollbackFor = Exception.class)
public void transactionTest() throws IOException {
User user = new User();
UserService.insert(user);
throw new IOException();
}
2. 業(yè)務(wù)方法本身捕獲并處理了異常
@Transactional(rollbackFor = Exception.class)
public void transactionTest() {
try {
User user = new User();
UserService.insert(user);
int i = 1 / 0;
} catch (Exception e) {
e.printStackTrace();
}
}
在這個(gè)場景中,事務(wù)失效的原因也很簡單。Spring 是否回滾事務(wù)取決于你是否拋出了異常。如果你自己捕獲了異常,Spring 就無法處理事務(wù)了。
看了上面的代碼,你可能會(huì)覺得這么簡單的問題,自己不可能犯這種低級錯(cuò)誤。但我想告訴你,我身邊幾乎有一半的人都曾因此困擾過。
在編寫業(yè)務(wù)代碼時(shí),代碼可能會(huì)更復(fù)雜,有很多嵌套的方法。稍不注意,就很容易觸發(fā)這個(gè)問題。舉個(gè)簡單的例子,假設(shè)你有一個(gè)審計(jì)功能,每次方法執(zhí)行完后,將審計(jì)結(jié)果保存到數(shù)據(jù)庫中。那么代碼可能會(huì)寫成這樣:
@Service
public class TransactionService {
@Transactional(rollbackFor = Exception.class)
public void transactionTest() throws IOException {
User user = new User();
UserService.insert(user);
throw new IOException();
}
}
下面的切面會(huì)作用于TransactionService
:
@Component
publicclass AuditAspect {
@Autowired
private AuditService auditService;
@Around(value = "execution (* com.dylan.service.*.*(..))")
public Object around(ProceedingJoinPoint pjp) {
try {
Audit audit = new Audit();
Signature signature = pjp.getSignature();
MethodSignature methodSignature = (MethodSignature) signature;
String[] strings = methodSignature.getParameterNames();
audit.setMethod(signature.getName());
audit.setParameters(strings);
Object proceed = pjp.proceed();
audit.success(true);
return proceed;
} catch (Throwable e) {
log.error("{}", e);
audit.success(false);
}
auditService.save(audit);
returnnull;
}
}
在上面的例子中,如果程序執(zhí)行異常,事務(wù)也會(huì)失效。原因是Spring
的事務(wù)切面優(yōu)先級最低。如果異常被切面捕獲,Spring 自然無法正確處理事務(wù),因?yàn)槭聞?wù)管理器無法捕獲到異常。
解決方案:
只需移除try-catch
。雖然我們知道在處理事務(wù)時(shí),業(yè)務(wù)代碼不能自己捕獲異常,但只要代碼變得復(fù)雜,我們很容易不小心犯錯(cuò)。
3. 同一個(gè)類中的方法調(diào)用
@Service
publicclass DefaultTransactionService implements Service {
public void saveUser() throws Exception {
// do something
doInsert();
}
@Transactional(rollbackFor = Exception.class)
public void doInsert() throws IOException {
User user = new User();
UserService.insert(user);
thrownew IOException();
}
}
這也是一個(gè)容易出錯(cuò)的場景。事務(wù)失效的原因也很簡單。因?yàn)?Spring 的事務(wù)管理功能是通過動(dòng)態(tài)代理實(shí)現(xiàn)的,而 Spring 默認(rèn)使用 JDK 動(dòng)態(tài)代理,JDK 動(dòng)態(tài)代理通過接口實(shí)現(xiàn),并通過反射調(diào)用目標(biāo)類。簡單理解,在saveUser()
方法中,調(diào)用this.doInsert()
時(shí),this
是真實(shí)對象,因此會(huì)直接執(zhí)行doInsert
的業(yè)務(wù)邏輯,而不是代理邏輯,從而導(dǎo)致事務(wù)失效。
解決方案:
方案 1:直接在saveUser
方法上添加@Transactional
注解。
方案 2:可以將這兩個(gè)方法拆分到不同的類中。
方案 3:不使用注解實(shí)現(xiàn)事務(wù),而是使用編程式事務(wù)來包裹需要開啟事務(wù)的代碼塊。例如:transactionTemplate.execute()
。
public void doInsert() throws IOException {
transactionTemplate.execute(() -> {
User user = new User();
UserService.insert(user);
throw new IOException();
});
}
4. 方法使用了final
或static
關(guān)鍵字
如果 Spring 使用 Cglib 代理實(shí)現(xiàn)(當(dāng)你的代理類沒有實(shí)現(xiàn)接口時(shí)),而你的業(yè)務(wù)方法恰好使用了final
或static
關(guān)鍵字,那么事務(wù)控制也會(huì)失效。因?yàn)?Cglib 使用字節(jié)碼增強(qiáng)技術(shù)生成被代理類的子類,并重寫被代理類的方法來實(shí)現(xiàn)代理。如果被代理的方法使用了final
或static
關(guān)鍵字,子類就無法重寫被代理的方法。
如果 Spring 使用 JDK 動(dòng)態(tài)代理實(shí)現(xiàn),JDK 動(dòng)態(tài)代理是基于接口實(shí)現(xiàn)的,那么被final
和static
修飾的方法也無法被代理。
總之,如果方法連代理都沒有,那么事務(wù)回滾肯定無法實(shí)現(xiàn)。
解決方案:
盡量移除方法上的final
或static
關(guān)鍵字。
5. 方法不是public
如果方法不是public
,Spring 事務(wù)也會(huì)失效,因?yàn)樵?Spring 事務(wù)管理的源碼AbstractFallbackTransactionAttributeSource
中,computeTransactionAttribute()
方法會(huì)判斷目標(biāo)方法是否是public
。如果不是public
,則返回null
。
// Don't allow no-public methods as required.
if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {
return null;
}
解決方案:
將當(dāng)前方法的訪問級別改為public
。
6. 傳播機(jī)制使用不當(dāng)
Spring
事務(wù)的傳播機(jī)制指的是當(dāng)多個(gè)事務(wù)方法相互調(diào)用時(shí),事務(wù)應(yīng)該如何傳播的策略。Spring
提供了七種事務(wù)傳播機(jī)制:REQUIRED
、SUPPORTS
、MANDATORY
、REQUIRES_NEW
、NOT_SUPPORTED
、NEVER
、NESTED
。如果你不了解這些傳播策略的原理,很容易導(dǎo)致事務(wù)失效。
@Service
publicclass TransactionsService {
@Autowired
private UserMapper userMapper;
@Autowired
private AddressMapper addressMapper;
@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
public void doInsert(User user, Address address) throws Exception {
// do something
userMapper.insert(user);
saveAddress(address);
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void saveAddress(Address address) {
// do something
addressMapper.insert(address);
}
}
在上面的例子中,如果用戶插入失敗,不會(huì)導(dǎo)致saveAddress()
回滾,因?yàn)檫@里使用的傳播機(jī)制是REQUIRES_NEW
。REQUIRES_NEW
的原理是,如果當(dāng)前方法沒有事務(wù),則創(chuàng)建一個(gè)新事務(wù)。如果當(dāng)前方法已經(jīng)有事務(wù),則掛起當(dāng)前事務(wù)并創(chuàng)建一個(gè)新事務(wù)。父事務(wù)會(huì)等到當(dāng)前事務(wù)完成后才提交。如果父事務(wù)發(fā)生異常,不會(huì)影響子事務(wù)的提交。
解決方案:
將事務(wù)傳播策略改為默認(rèn)值REQUIRED
。REQUIRED
的原理是,如果當(dāng)前有事務(wù),則加入該事務(wù)。如果沒有事務(wù),則創(chuàng)建一個(gè)新事務(wù)。父事務(wù)和被調(diào)用的事務(wù)處于同一個(gè)事務(wù)中。即使被調(diào)用的事務(wù)捕獲了異常,整個(gè)事務(wù)仍然會(huì)回滾。
7. 沒有被 Spring 管理
// @Service
public class OrderServiceImpl implements OrderService {
@Transactional
public void updateOrder(Order order) {
// update order
}
}
如果此時(shí)@Service
注解被注釋掉,這個(gè)類就不會(huì)被 Spring 加載為 Bean,那么這個(gè)類就不會(huì)被 Spring 管理,事務(wù)自然也會(huì)失效。
解決方案:
確保每個(gè)使用事務(wù)注解的Service
都被 Spring 管理。
8. 多線程調(diào)用
@Service
publicclass UserService {
@Autowired
private UserMapper userMapper;
@Autowired
private RoleService roleService;
@Transactional
public void add(UserModel userModel) throws Exception {
userMapper.insertUser(userModel);
new Thread(() -> {
try {
test();
} catch (Exception e) {
roleService.doOtherThing();
}
}).start();
}
}
@Service
publicclass RoleService {
@Transactional
public void doOtherThing() {
try {
int i = 1 / 0;
System.out.println("save role table data");
} catch (Exception e) {
thrownew RuntimeException();
}
}
}
我們可以看到,在事務(wù)方法add
中,調(diào)用了事務(wù)方法doOtherThing
,但doOtherThing
是在另一個(gè)線程中被調(diào)用的。
這會(huì)導(dǎo)致兩個(gè)方法不在同一個(gè)線程中,獲取的數(shù)據(jù)庫連接也不同,因此是兩個(gè)不同的事務(wù)。如果在doOtherThing
方法中拋出異常,add
方法是不可能回滾的。
我們所說的同一個(gè)事務(wù),實(shí)際上指的是同一個(gè)數(shù)據(jù)庫連接。只有在同一個(gè)數(shù)據(jù)庫連接下,才能同時(shí)提交和回滾。如果在不同的線程中,獲取的數(shù)據(jù)庫連接肯定不同,因此它們是不同的事務(wù)。
解決方案:
這有點(diǎn)像分布式事務(wù)。盡量確保在同一個(gè)事務(wù)中處理。
9. 沒有配置開啟事務(wù)
如果在項(xiàng)目中沒有配置 Spring 的事務(wù)管理器,即使使用了 Spring 的事務(wù)管理功能,Spring 的事務(wù)也不會(huì)生效。例如,如果你是一個(gè) Spring Boot 項(xiàng)目,并且沒有在 Spring Boot 項(xiàng)目中配置以下代碼:
@EnableTransactionManagement
解決方案:
確保在項(xiàng)目中正確配置了事務(wù)管理器。
總結(jié)
本文簡要闡述了 Spring 事務(wù)的實(shí)現(xiàn)原理,并列出了 9 種 Spring 事務(wù)失效的場景。相信很多朋友可能都遇到過這些問題。文章也詳細(xì)解釋了失效的原因,希望大家對 Spring 事務(wù)有新的理解。