工作六年，@Transactional 注解用的一塌糊涂
接手新項(xiàng)目一言難盡，別的不說(shuō)單單就一個(gè) @Transactional 注解用的一塌糊涂，五花八門的用法，很大部分還失效無(wú)法回滾。
圖片
有意識(shí)的在涉及事務(wù)相關(guān)方法上加@Transactional注解，是個(gè)好習(xí)慣。不過(guò)，很多同學(xué)只是下意識(shí)地添加這個(gè)注解，一旦功能正常運(yùn)行，很少有人會(huì)深入驗(yàn)證異常情況下事務(wù)是否能正確回滾。@Transactional 注解雖然用起來(lái)簡(jiǎn)單，但這貨總是能在一些你意想不到的情況下失效，防不勝防！
我把這些事務(wù)問(wèn)題歸結(jié)成了三類：不必要、不生效、不回滾，接下用一些demo演示下各自的場(chǎng)景。
不必要
1. 無(wú)需事務(wù)的業(yè)務(wù)
在沒(méi)有事務(wù)操作的業(yè)務(wù)方法上使用 @Transactional 注解，比如：用在僅有查詢或者一些 HTTP 請(qǐng)求的方法，雖然加上影響不大，但從編碼規(guī)范的角度來(lái)看還是不夠嚴(yán)謹(jǐn)，建議去掉。
@Transactional
public String testQuery() {
standardBak2Service.getById(1L);
return "testB";
}2. 事務(wù)范圍過(guò)大
有些同學(xué)為了省事直接將 @Transactional 注解加在了類上或者抽象類上，這樣做導(dǎo)致的問(wèn)題就是類內(nèi)的方法或抽象類的實(shí)現(xiàn)類中所有方法全部都被事務(wù)管理。增加了不必要的性能開(kāi)銷或復(fù)雜性，建議按需使用，只在有事務(wù)邏輯的方法上加@Transactional。
@Transactional
public abstract class BaseService {
}
@Slf4j
@Service
public class TestMergeService extends BaseService{
private final TestAService testAService;
public String testMerge() {
testAService.testA();
return "ok";
}
}如果在類中的方法上添加 @Transactional 注解，它將覆蓋類級(jí)別的事務(wù)配置。例如，類級(jí)別上配置了只讀事務(wù)，方法級(jí)別上的 @Transactional 注解也會(huì)覆蓋該配置，從而啟用讀寫(xiě)事務(wù)。
@Transactional(readOnly = true)
public class TestMergeService {
private final TestBService testBService;
private final TestAService testAService;
@Transactional
public String testMerge() {
testAService.testA();
testBService.testB();
return "ok";
}
}不生效
3. 方法權(quán)限問(wèn)題
不要把 @Transactional注解加在 private 級(jí)別的方法上！
我們知道 @Transactional 注解依賴于Spring AOP切面來(lái)增強(qiáng)事務(wù)行為，這個(gè) AOP 是通過(guò)代理來(lái)實(shí)現(xiàn)的，而 private 方法恰恰不能被代理的，所以 AOP 對(duì) private 方法的增強(qiáng)是無(wú)效的，@Transactional也就不會(huì)生效。
@Transactional
private String testMerge() {
testAService.testA();
testBService.testB();
return "ok";
}那如果我在 testMerge() 方法內(nèi)調(diào)用 private 的方法事務(wù)會(huì)生效嗎？
答案：事務(wù)會(huì)生效
@Transactional
public String testMerge() throws Exception {
ccc();
return "ok";
}
private void ccc() {
testAService.testA();
testBService.testB();
}4. 被用 final 、static 修飾方法
和上邊的原因類似，被用 final 、static 修飾的方法上加 @Transactional 也不會(huì)生效。
- static 靜態(tài)方法屬于類本身的而非實(shí)例，因此代理機(jī)制是無(wú)法對(duì)靜態(tài)方法進(jìn)行代理或攔截的
- final 修飾的方法不能被子類重寫(xiě)，事務(wù)相關(guān)的邏輯無(wú)法插入到 final 方法中，代理機(jī)制無(wú)法對(duì) final 方法進(jìn)行攔截或增強(qiáng)。
這些都是java基礎(chǔ)概念了，使用時(shí)要注意。
@Transactional
public static void b() {
}
@Transactional
public final void b() {
}5. 同類內(nèi)部方法調(diào)用問(wèn)題
注意了，這種情況經(jīng)常發(fā)生??！
同類內(nèi)部方法間的調(diào)用是 @Transactional 注解失效的重災(zāi)區(qū)，網(wǎng)上你總能看到方法內(nèi)部調(diào)用另一個(gè)同類的方法時(shí)，這種調(diào)用是不會(huì)經(jīng)過(guò)代理的，因此事務(wù)管理不會(huì)生效。但這說(shuō)法比較片面，要分具體情況。
比如：testMerge() 方法開(kāi)啟事務(wù)，調(diào)用同類非事務(wù)的方法 a() 和 b() ，此時(shí) b() 拋異常，根據(jù)事務(wù)的傳播性 a()、b() 事務(wù)均生效。
@Transactional
public String testMerge() {
a();
b();
return "ok";
}
public void a() {
standardBakService.save(testAService.buildEntity());
}
public void b() {
standardBak2Service.save(testBService.buildEntity2());
throw new RuntimeException("b error");
}如果 testMerge() 方法未開(kāi)啟事務(wù)，并且在同類中調(diào)用了非事務(wù)方法 a() 和事務(wù)方法 b()，當(dāng) b() 拋出異常時(shí)，a() 和 b() 的事務(wù)都不會(huì)生效。因?yàn)檫@種調(diào)用直接通過(guò) this 對(duì)象進(jìn)行，未經(jīng)過(guò)代理，因此事務(wù)管理無(wú)法生效。這經(jīng)常出問(wèn)題的！
public String testMerge() {
a();
b();
return "ok";
}
public void a() {
standardBakService.save(testAService.buildEntity());
}
@Transactional
public void b() {
standardBak2Service.save(testBService.buildEntity2());
throw new RuntimeException("b error");
}5.1 獨(dú)立的 Service 類
要想 b() 方法的事務(wù)生效也容易，最簡(jiǎn)單的方法將它剝離放在獨(dú)立的Service類注入使用，交給spring管理就行了。不過(guò)，這種方式會(huì)創(chuàng)建很多類。
@Slf4j
@Service
public class TestBService {
@Transactional
public void b() {
standardBak2Service.save(testBService.buildEntity2());
throw new RuntimeException("b error");
}
}5.2 自注入方式
或者通過(guò)自己注入自己的方式解決，盡管解決了問(wèn)題，邏輯看起來(lái)很奇怪，它破壞了依賴注入的原則，雖然 spring 支持我們這樣用，還是要注意下循環(huán)依賴的問(wèn)題。
@Slf4j
@Service
public class TestMergeService {
@Autowired
private TestMergeService testMergeService;
public String testMerge() {
a();
testMergeService.b();
return "ok";
}
public void a() {
standardBakService.save(testAService.buildEntity());
}
@Transactional
public void b() {
standardBak2Service.save(testBService.buildEntity2());
throw new RuntimeException("b error");
}
}5.3 手動(dòng)獲取代理對(duì)象
b() 方法它不是沒(méi)被代理嘛，那我們手動(dòng)獲取代理對(duì)象調(diào)用 b() 方法也可以。通過(guò) AopContext.currentProxy() 方法返回當(dāng)前的代理對(duì)象實(shí)例，這樣調(diào)用代理的方法時(shí)，就會(huì)經(jīng)過(guò) AOP 的切面，@Transactional注解就會(huì)生效了。
@Slf4j
@Service
public class TestMergeService {
public String testMerge() {
a();
((TestMergeService) AopContext.currentProxy()).b();
return "ok";
}
public void a() {
standardBakService.save(testAService.buildEntity());
}
@Transactional
public void b() {
standardBak2Service.save(testBService.buildEntity2());
throw new RuntimeException("b error");
}
}6. Bean 未被 spring 管理
上邊我們知道 @Transactional 注解通過(guò) AOP 來(lái)管理事務(wù)，而 AOP 依賴于代理機(jī)制。因此，Bean 必須由Spring管理實(shí)例！ 要確保為類加上如 @Controller、@Service 或 @Component注解，讓其被Spring所管理，這很容易忽視。
@Service
public class TestBService {
@Transactional
public String testB() {
standardBak2Service.save(entity2);
return "testB";
}
}7. 異步線程調(diào)用
如果我們?cè)?testMerge() 方法中使用異步線程執(zhí)行事務(wù)操作，通常也是無(wú)法成功回滾的，來(lái)個(gè)具體的例子。
testMerge() 方法在事務(wù)中調(diào)用了 testA()，testA() 方法中開(kāi)啟了事務(wù)。接著，在 testMerge() 方法中，我們通過(guò)一個(gè)新線程調(diào)用了 testB()，testB() 中也開(kāi)啟了事務(wù)，并且在 testB() 中拋出了異常。
此時(shí)的回滾情況是怎樣的呢？
@Transactional
public String testMerge() {
testAService.testA();
new Thread(() -> {
try {
testBService.testB();
} catch (Exception e) {
// e.printStackTrace();
throw new RuntimeException();
}
}).start();
return "ok";
}
@Transactional
public String testB() {
DeepzeroStandardBak2 entity2 = buildEntity2();
dataImportJob2Service.save(entity2);
throw new RuntimeException("test2");
}
@Transactional
public String testA() {
DeepzeroStandardBak entity = buildEntity();
standardBakService.save(entity);
return "ok";
}答案是：testA() 和 testB() 中的事務(wù)都不會(huì)回滾。
testA() 無(wú)法回滾是因?yàn)闆](méi)有捕獲到新線程中 testB()拋出的異常；testB()方法無(wú)法回滾，是因?yàn)槭聞?wù)管理器只對(duì)當(dāng)前線程中的事務(wù)有效，因此在新線程中執(zhí)行的事務(wù)不會(huì)回滾。
由于在多線程環(huán)境下，Spring 的事務(wù)管理器不會(huì)跨線程傳播事務(wù)，事務(wù)的狀態(tài)（如事務(wù)是否已開(kāi)啟）是存儲(chǔ)在線程本地的 ThreadLocal 來(lái)存儲(chǔ)和管理事務(wù)上下文信息。這意味著每個(gè)線程都有一個(gè)獨(dú)立的事務(wù)上下文，事務(wù)信息在不同線程之間不會(huì)共享。
8. 不支持事務(wù)的引擎
不支持事務(wù)的數(shù)據(jù)庫(kù)引擎不在此次 Review 范圍內(nèi)，只做了解就好。我們通常使用的關(guān)系型數(shù)據(jù)庫(kù)，如 MySQL，默認(rèn)使用支持事務(wù)的 InnoDB 引擎，而非事務(wù)的 MyISAM 引擎則使用較少。
以前開(kāi)啟啟用 MyISAM 引擎是為了提高查詢效率。不過(guò)，現(xiàn)在非關(guān)系型數(shù)據(jù)庫(kù)如 Redis、MongoDB 和 Elasticsearch 等中間件提供了更高性價(jià)比的解決方案。
不回滾
9. 用錯(cuò)傳播屬性
@Transactional注解有個(gè)關(guān)鍵的參數(shù)propagation，它控制著事務(wù)的傳播行為，有時(shí)事務(wù)傳播參數(shù)配置錯(cuò)誤也會(huì)導(dǎo)致事務(wù)的不回滾。
propagation 支持 7 種事務(wù)傳播特性：
- REQUIRED：默認(rèn)的傳播行為，如果當(dāng)前沒(méi)有事務(wù)，則創(chuàng)建一個(gè)新事務(wù)；如果存在事務(wù)，則加入當(dāng)前事務(wù)。
- MANDATORY：支持當(dāng)前事務(wù)，如果不存在則拋出異常
- NEVER：非事務(wù)性執(zhí)行，如果存在事務(wù)，則拋出異常
- REQUIRES_NEW：無(wú)論當(dāng)前是否存在事務(wù)，都會(huì)創(chuàng)建一個(gè)新事務(wù)，原有事務(wù)被掛起。
- NESTED：嵌套事務(wù)，被調(diào)用方法在一個(gè)嵌套的事務(wù)中運(yùn)行，這個(gè)事務(wù)依賴于當(dāng)前的事務(wù)。
- SUPPORTS：如果當(dāng)前存在事務(wù)，則加入；如果沒(méi)有，就以非事務(wù)方式執(zhí)行。
- NOT_SUPPORTED：以非事務(wù)方式執(zhí)行，如果當(dāng)前存在事務(wù)，將其掛起。
為了加深印象，我用案例來(lái)模擬下每種特性的使用場(chǎng)景。
REQUIRED
REQUIRED 是默認(rèn)的事務(wù)傳播行為。如果 testMerge() 方法開(kāi)啟了事務(wù)，那么其內(nèi)部調(diào)用的 testA() 和 testB() 方法也將加入這個(gè)事務(wù)。如果 testMerge() 沒(méi)有開(kāi)啟事務(wù)，而 testA() 和 testB() 方法上使用了 @Transactional 注解，這些方法將各自創(chuàng)建新的事務(wù)，只控制自身的回滾。
@Component
@RequiredArgsConstructor
@Slf4j
@Service
public class TestMergeService {
private final TestBService testBService;
private final TestAService testAService;
@Transactional
public String testMerge() {
testAService.testA();
testBService.testB();
return "ok";
}
}
@Transactional
public String testA() {
log.info("testA");
DeepzeroStandardBak entity = buildEntity();
standardBakService.save(entity);
return "ok";
}
@Transactional
public String testB() {
log.info("testB");
DeepzeroStandardBak2 entity2 = buildEntity2();
standardBak2Service.save(entity2);
throw new RuntimeException("testB");
}MANDATORY
MANDATORY 傳播特性簡(jiǎn)單來(lái)說(shuō)就是只能被開(kāi)啟事務(wù)的上層方法調(diào)用，例如 testMerge() 方法未開(kāi)啟事務(wù)調(diào)用 testB() 方法，那么將拋出異常；testMerge() 開(kāi)啟事務(wù)調(diào)用 testB() 方法，則加入當(dāng)前事務(wù)。
@Component
@RequiredArgsConstructor
@Slf4j
@Service
public class TestMergeService {
private final TestBService testBService;
private final TestAService testAService;
public String testMerge() {
testAService.testA();
testBService.testB();
return "ok";
}
}
@Transactional
public String testA() {
log.info("testA");
DeepzeroStandardBak entity = buildEntity();
standardBakService.save(entity);
return "ok";
}
@Transactional(propagation = Propagation.MANDATORY)
public String testB() {
log.info("testB");
DeepzeroStandardBak2 entity2 = buildEntity2();
standardBak2Service.save(entity2);
throw new RuntimeException("testB");
}拋出的異常信息
org.springframework.transaction.IllegalTransactionStateException: No existing transaction found for transaction marked with propagation 'mandatory'
NEVER
NEVER 傳播特性是強(qiáng)制你的方法只能以非事務(wù)方式運(yùn)行，如果方法存在事務(wù)操作會(huì)拋出異常，我實(shí)在是沒(méi)想到有什么使用場(chǎng)景。
@Transactional(propagation = Propagation.NEVER)
public String testB() {
log.info("testB");
DeepzeroStandardBak2 entity2 = buildEntity2();
standardBak2Service.save(entity2);
// throw new RuntimeException("testB");
return "ok";
}拋出的異常信息
org.springframework.transaction.IllegalTransactionStateException: Existing transaction found for transaction marked with propagation 'never'
REQUIRES_NEW
我們?cè)谑褂?Propagation.REQUIRES_NEW 傳播特性時(shí)，不論當(dāng)前事務(wù)的狀態(tài)如何，調(diào)用該方法都會(huì)創(chuàng)建一個(gè)新的事務(wù)。
例如，testMerge() 方法開(kāi)始一個(gè)事務(wù)，調(diào)用 testB() 方法時(shí)，它會(huì)暫停 testMerge() 的事務(wù)，并啟動(dòng)一個(gè)新的事務(wù)。如果 testB() 方法內(nèi)部發(fā)生異常，新事務(wù)會(huì)回滾，但原先掛起的事務(wù)不會(huì)受影響。這意味著，掛起的事務(wù)不會(huì)因?yàn)樾率聞?wù)的回滾而受到影響，也不會(huì)因?yàn)樾率聞?wù)的失敗而回滾。
@Transactional
public String testMerge() {
testAService.testA();
testBService.testB();
return "ok";
}
@Transactional
public String testA() {
log.info("testA");
DeepzeroStandardBak entity = buildEntity();
standardBakService.save(entity);
return "ok";
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public String testB() {
log.info("testB");
DeepzeroStandardBak2 entity2 = buildEntity2();
standardBak2Service.save(entity2);
throw new RuntimeException("testB");
}NESTED
方法的傳播行為設(shè)置為 NESTED，其內(nèi)部方法會(huì)開(kāi)啟一個(gè)新的嵌套事務(wù)（子事務(wù)）。在沒(méi)有外部事務(wù)的情況下 NESTED 與 REQUIRED 效果相同；存在外部事務(wù)的情況下，一旦外部事務(wù)回滾，它會(huì)創(chuàng)建一個(gè)嵌套事務(wù)（子事務(wù)）。
也就是說(shuō)外部事務(wù)回滾時(shí)，子事務(wù)會(huì)跟著回滾；但子事務(wù)的回滾不會(huì)對(duì)外部事務(wù)和其他同級(jí)事務(wù)造成影響。
@Component
@RequiredArgsConstructor
@Slf4j
@Service
public class TestMergeService {
private final TestBService testBService;
private final TestAService testAService;
@Transactional
public String testMerge() {
testAService.testA();
testBService.testB();
throw new RuntimeException("testMerge");
return "ok";
}
}
@Transactional
public String testA() {
log.info("testA");
DeepzeroStandardBak entity = buildEntity();
standardBakService.save(entity);
return "ok";
}
@Transactional(propagation = Propagation.NESTED)
public String testB() {
log.info("testB");
DeepzeroStandardBak2 entity2 = buildEntity2();
standardBak2Service.save(entity2);
throw new RuntimeException("testB");
}NOT_SUPPORTED
NOT_SUPPORTED 事務(wù)傳播特性表示該方法必須以非事務(wù)方式運(yùn)行。當(dāng)方法 testMerge() 開(kāi)啟事務(wù)并調(diào)用事務(wù)方法 testA() 和 testB() 時(shí)，如果 testA() 和 testB() 的事務(wù)傳播特性為 NOT_SUPPORTED，那么 testB() 將以非事務(wù)方式運(yùn)行，并掛起當(dāng)前的事務(wù)。
默認(rèn)傳播特性的情況下 testB() 異常事務(wù)加入會(huì)導(dǎo)致 testA() 回滾，而掛起的意思是說(shuō)，testB() 其內(nèi)部一旦拋出異常，不會(huì)影響 testMerge() 中其他 testA() 方法的回滾。
@Component
@RequiredArgsConstructor
@Slf4j
@Service
public class TestMergeService {
private final TestBService testBService;
private final TestAService testAService;
@Transactional
public String testMerge() {
testAService.testA();
testBService.testB();
return "ok";
}
}
@Transactional
public String testA() {
log.info("testA");
DeepzeroStandardBak entity = buildEntity();
standardBakService.save(entity);
return "ok";
}
@Transactional(propagation = Propagation.NOT_SUPPORTED)
public String testB() {
log.info("testB");
DeepzeroStandardBak2 entity2 = buildEntity2();
standardBak2Service.save(entity2);
throw new RuntimeException("testB");
}SUPPORTS
如果當(dāng)前方法的事務(wù)傳播特性是 SUPPORTS，那么只有在調(diào)用該方法的上層方法開(kāi)啟了事務(wù)的情況下，該方法的事務(wù)才會(huì)有效。如果上層方法沒(méi)有開(kāi)啟事務(wù)，那么該方法的事務(wù)特性將無(wú)效。
例如，如果入口方法 testMerge() 沒(méi)有開(kāi)啟事務(wù)，而 testMerge() 調(diào)用的方法 testA() 和 testB() 的事務(wù)傳播特性為 SUPPORTS，那么由于 testMerge() 沒(méi)有事務(wù)，testA() 和 testB() 將以非事務(wù)方式執(zhí)行。即使在這些方法上加上 @Transactional 注解，也不會(huì)回滾異常。
@Component
@RequiredArgsConstructor
@Slf4j
@Service
public class TestMergeService {
private final TestBService testBService;
private final TestAService testAService;
public String testMerge() {
testAService.testA();
testBService.testB();
return "ok";
}
}
@Transactional(propagation = Propagation.SUPPORTS)
public String testA() {
log.info("testA");
DeepzeroStandardBak entity = buildEntity();
standardBakService.save(entity);
return "ok";
}
@Transactional(propagation = Propagation.SUPPORTS)
public String testB() {
log.info("testB");
DeepzeroStandardBak2 entity2 = buildEntity2();
standardBak2Service.save(entity2);
throw new RuntimeException("testB");
}10. 自己吞了異常
在整個(gè) review 的過(guò)程中我發(fā)現(xiàn)導(dǎo)致事務(wù)不回滾的場(chǎng)景，多數(shù)是開(kāi)發(fā)同學(xué)在業(yè)務(wù)代碼中手動(dòng) try...catch 捕獲了異常，然后又沒(méi)拋出異常....
比如：testMerge() 方法開(kāi)啟了事務(wù)，并調(diào)用了非事務(wù)方法 testA() 和 testB()，同時(shí)在 testMerge() 中捕獲了異常。如果 testB() 中發(fā)生了異常并拋出，但 testMerge() 捕獲了這個(gè)異常而沒(méi)有繼續(xù)拋出，Spring 事務(wù)將無(wú)法捕獲到異常，從而無(wú)法進(jìn)行回滾。
@RequiredArgsConstructor
@Slf4j
@Service
public class TestMergeService {
private final TestBService testBService;
private final TestAService testAService;
@Transactional
public String testMerge() {
try {
testAService.testA();
testBService.testB();
} catch (Exception e) {
log.error("testMerge error:{}", e);
}
return "ok";
}
}
@Service
public class TestAService {
public String testA() {
standardBakService.save(entity);
return "ok";
}
}
@Service
public class TestBService {
public String testB() {
standardBakService.save(entity2);
throw new RuntimeException("test2");
}
}為了確保 Spring 事務(wù)能夠正常回滾，需要我們?cè)?catch 塊中主動(dòng)重新拋出它能夠處理的 RuntimeException 或者 Error 類型的異常。
@Transactional
public String testMerge() {
try {
testAService.testA();
testBService.testB();
} catch (Exception e) {
log.error("testMerge error:{}", e);
throw new RuntimeException(e);
}
return "ok";
}捕獲異常并不意味著一定不會(huì)回滾，這取決于具體情況。
例如，當(dāng) testB() 方法上也加上了 @Transactional 注解時(shí)，如果在該方法中發(fā)生異常，事務(wù)會(huì)捕獲到這個(gè)異常。由于事務(wù)傳播的特性，testB() 的事務(wù)會(huì)合并到上層方法的事務(wù)中。因此，即使在 testMerge() 中捕獲了異常而未拋出，事務(wù)仍然可以成功回滾。
@Transactional
public String testB() {
DeepzeroStandardBak2 entity2 = buildEntity2();
dataImportJob2Service.save(entity2);
throw new RuntimeException("test2");
// return "ok";
}但這有個(gè)提前，必須在 testMerge() 方法上添加 @Transactional 注解以啟用事務(wù)。如果 testMerge() 方法沒(méi)有開(kāi)啟事務(wù)，不論其內(nèi)部是否使用 try 塊，都只能部分回滾 testB()，而 testA() 將無(wú)法回滾。
11. 事務(wù)無(wú)法捕獲的異常
Spring 的事務(wù)默認(rèn)會(huì)回滾 RuntimeException 及其子類，以及 Error 類型的異常。
如果拋出的是其他類型的異常，例如 checked exceptions（檢查型異常），即繼承自 Exception 但不繼承自 RuntimeException 的異常，比如 SQLException、DuplicateKeyException，事務(wù)將不會(huì)回滾。
所以，我們?cè)谥鲃?dòng)拋出異常時(shí)，要確保該異常是事務(wù)能夠捕獲的類型。
@Transactional
public String testMerge() throws Exception {
try {
testAService.testA();
testBService.testB();
} catch (Exception e) {
log.error("testMerge error:{}", e);
// throw new RuntimeException(e);
throw new Exception(e);
}
return "ok";
}如果你非要拋出默認(rèn)情況下不會(huì)導(dǎo)致事務(wù)回滾的異常，務(wù)必要在 @Transactional 注解的 rollbackFor 參數(shù)中明確指定該異常，這樣才能進(jìn)行回滾。
@Transactional(rollbackFor = Exception.class)
public String testMerge() throws Exception {
try {
testAService.testA();
testBService.testB();
} catch (Exception e) {
log.error("testMerge error:{}", e);
// throw new RuntimeException(e);
throw new Exception(e);
}
return "ok";
}問(wèn)問(wèn)你身邊的同學(xué)，哪些異常屬于運(yùn)行時(shí)異常，哪些屬于檢查型異常，十有八九他們可能無(wú)法給出準(zhǔn)確的回答！
所以減少出現(xiàn) bug 的風(fēng)險(xiǎn)，我建議使用 @Transactional 注解時(shí)，將 rollbackFor 參數(shù)設(shè)置為 Exception 或 Throwable，這樣可以擴(kuò)大事務(wù)回滾的范圍。
12. 自定義異常范圍問(wèn)題
針對(duì)不同業(yè)務(wù)定制異常類型是比較常見(jiàn)的做法，@Transactional 注解的 rollbackFor 參數(shù)支持自定義的異常，但我們往往習(xí)慣于將這些自定義異常繼承自 RuntimeException。
那么這就出現(xiàn)和上邊同樣的問(wèn)題，事務(wù)的范圍不足，許多異常類型仍然無(wú)法觸發(fā)事務(wù)回滾。
@Transactional(rollbackFor = CustomException.class)
public String testMerge() throws Exception {
try {
testAService.testA();
testBService.testB();
} catch (Exception e) {
log.error("testMerge error:{}", e);
// throw new RuntimeException(e);
throw new Exception(e);
}
return "ok";
}想要解決這個(gè)問(wèn)題，可以在 catch 中主動(dòng)拋出我們自定義的異常。
@Transactional(rollbackFor = CustomException.class)
public String testMerge() throws Exception {
try {
testAService.testA();
testBService.testB();
} catch (Exception e) {
log.error("testMerge error:{}", e);
throw new CustomException(e);
}
return "ok";
}13. 嵌套事務(wù)問(wèn)題
還有一種場(chǎng)景就是嵌套事務(wù)問(wèn)題，比如，我們?cè)?testMerge() 方法中調(diào)用了事務(wù)方法 testA() 和事務(wù)方法 testB()，此時(shí)不希望 testB() 拋出異常讓整個(gè) testMerge() 都跟著回滾；這就需要單獨(dú) try catch 處理 testB() 的異常，不讓異常在向上拋。
@RequiredArgsConstructor
@Slf4j
@Service
public class TestMergeService {
private final TestBService testBService;
private final TestAService testAService;
@Transactional
public String testMerge() {
testAService.testA();
try {
testBService.testB();
} catch (Exception e) {
log.error("testMerge error:{}", e);
}
return "ok";
}
}
@Service
public class TestAService {
@Transactional
public String testA() {
standardBakService.save(entity);
return "ok";
}
}
@Service
public class TestBService {
@Transactional
public String testB() {
standardBakService.save(entity2);
throw new RuntimeException("test2");
}
}總結(jié)
上面的關(guān)于 @Transactional 注解的使用注意事項(xiàng)是我在代碼審查和搜集網(wǎng)絡(luò)觀點(diǎn)后整理出的。
