1 概述

Spring針對(duì)Java Transaction API (JTA)、JDBC、Hibernate和Java Persistence API(JPA)等事務(wù) API，實(shí)現(xiàn)了一致的編程模型，而Spring的聲明式事務(wù)功能更是提供了極其方便的事務(wù)配置方式，配合Spring Boot的自動(dòng)配置，大多數(shù)Spring Boot項(xiàng)目只需要在方法上標(biāo)記@Transactional注解，即可一鍵開啟方法的事務(wù)性配置。

但是，事務(wù)如果沒有被正確出，很有可能會(huì)導(dǎo)致事務(wù)的失效，帶來意想不到的數(shù)據(jù)不一致問題，隨后就是大量的人工接入查看和修復(fù)數(shù)據(jù)，該篇主要分享Spring事務(wù)在技術(shù)上的正確使用方式，避免因?yàn)槭聞?wù)處理不當(dāng)導(dǎo)致業(yè)務(wù)邏輯產(chǎn)生大量偶發(fā)性BUG。

在分析事務(wù)失效的常見場(chǎng)景之前，我們先來了解一下：事務(wù)的傳播類型 和 @Transactionnal 注解的不同屬性的含義。

事務(wù)的傳播類型

//如果有事務(wù),那么加入事務(wù),沒有的話新建一個(gè)(默認(rèn))
@Transactional(propagation=Propagation.REQUIRED)
//容器不為這個(gè)方法開啟事務(wù)
@Transactional(propagation=Propagation.NOT_SUPPORTED)
//不管是否存在事務(wù),都創(chuàng)建一個(gè)新的事務(wù),原來的掛起,新的執(zhí)行完畢,繼續(xù)執(zhí)行老的事務(wù)
@Transactional(propagation=Propagation.REQUIRES_NEW)
//必須在一個(gè)已有的事務(wù)中執(zhí)行,否則拋出異常
@Transactional(propagation=Propagation.MANDATORY)
//必須在一個(gè)沒有的事務(wù)中執(zhí)行,否則拋出異常(與Propagation.MANDATORY相反)
@Transactional(propagation=Propagation.NEVER)
//如果其他bean調(diào)用這個(gè)方法,在其他bean中聲明事務(wù),那就用事務(wù),如果其他bean沒有聲明事務(wù),那就不用事務(wù)
@Transactional(propagation=Propagation.SUPPORTS)

isolation

該屬性用于設(shè)置底層數(shù)據(jù)庫(kù)的事務(wù)隔離級(jí)別，事務(wù)的隔離級(jí)別介紹：

//讀取未提交數(shù)據(jù)(會(huì)出現(xiàn)臟讀,不可重復(fù)讀)基本不使用
@Transactional(isolation=Isolation.READ_UNCOMMITTED)
//讀取已提交數(shù)據(jù)(會(huì)出現(xiàn)不可重復(fù)讀和幻讀)Oracle默認(rèn)
@Transactional(isolation=Isolation.READ_COMMITTED)
//可重復(fù)讀(會(huì)出現(xiàn)幻讀)MySQL默認(rèn)
@Transactional(isolation=Isolation.REPEATABLE_READ)
//串行化
@Transactional(isolation=Isolation.SERIALIZABLE)

@Transactionnal注解屬性

@Transactional注解可以作用于接口、接口方法、類以及類方法上，它可以通過不同的參數(shù)來選擇什么類型Exception異常下執(zhí)行回滾或者不回滾操作。

1. 事務(wù)方法未被Spring管理

如果事務(wù)方法所在的類沒有注冊(cè)到Spring IOC容器中，也就是說，事務(wù)方法所在類并沒有被Spring管理，則Spring事務(wù)會(huì)失效，舉個(gè)例子：

publicclassProductServiceImplextendsServiceImplimplementsIProductService{

@Autowired
privateProductMapperproductMapper;

@Override
@Transactional(propagation=Propagation.REQUIRES_NEW)
publicvoidupdateProductStockById(IntegerstockCount,LongproductId){
productMapper.updateProductStockById(stockCount,productId);
}
}

ProductServiceImpl實(shí)現(xiàn)類上沒有添加@Service注解，Product的實(shí)例也就沒有被加載到Spring IOC容器，此時(shí)updateProductStockById()方法的事務(wù)就會(huì)在Spring中失效。

2. 方法使用final類型修飾

有時(shí)候，某個(gè)方法不想被子類重新，這時(shí)可以將該方法定義成final的。普通方法這樣定義是沒問題的，但如果將事務(wù)方法定義成final，例如：

@Service
publicclassOrderServiceImpl{

@Transactional
publicfinalvoidcancel(OrderDTOorderDTO){
//取消訂單
cancelOrder(orderDTO);
}
}

OrderServiceImpl的cancel取消訂單方法被final修飾符修飾，Spring事務(wù)底層使用了AOP，也就是通過JDK動(dòng)態(tài)代理或者cglib，幫我們生成了代理類，在代理類中實(shí)現(xiàn)的事務(wù)功能。但如果某個(gè)方法用final修飾了，那么在它的代理類中，就無法重寫該方法，從而無法添加事務(wù)功能。這種情況事務(wù)就會(huì)在Spring中失效。

Tips: 如果某個(gè)方法是static的，同樣無法通過動(dòng)態(tài)代理將方法聲明為事務(wù)方法。

3. 非public修飾的方法

如果事務(wù)方式不是public修飾，此時(shí)Spring事務(wù)會(huì)失效，舉個(gè)例子：

@Service
publicclassProductServiceImplextendsServiceImplimplementsIProductService{

@Autowired
privateProductMapperproductMapper;

@Override
@Transactional(propagation=Propagation.REQUIRES_NEW)
privatevoidupdateProductStockById(IntegerstockCount,StringproductId){
productMapper.updateProductStockById(stockCount,productId);
}
}

雖然ProductServiceImpl添加了@Service注解，同時(shí)updateProductStockById()方法上添加了@Transactional(propagation = Propagation.REQUIRES_NEW)注解，但是由于事務(wù)方法updateProductStockById()被 private 定義為方法內(nèi)私有，同樣Spring事務(wù)會(huì)失效。

4. 同一個(gè)類中的方法相互調(diào)用

@Service
publicclassOrderServiceImplextendsServiceImplimplementsIOrderService{
@Autowired
privateOrderMapperorderMapper;
@Autowired
privateProductMapperproductMapper;

@Override
publicResponseEntitysubmitOrder(Orderorder){
//保存生成訂單信息
longorderNo=Math.abs(ThreadLocalRandom.current().nextLong(1000));
order.setOrderNo("ORDER_"+orderNo);
orderMapper.insert(order);

//扣減庫(kù)存
this.updateProductStockById(order.getProductId(),1L);
returnnewResponseEntity(HttpStatus.OK);
}

@Transactional(propagation=Propagation.REQUIRES_NEW)
publicvoidupdateProductStockById(Integernum,LongproductId){
productMapper.updateProductStockById(num,productId);
}
}

submitOrder()方法和updateProductStockById()方法都在OrderService類中，然而submitOrder()方法沒有添加事務(wù)注解，updateProductStockById()方法雖然添加了事務(wù)注解，這種情況updateProductStockById()會(huì)在Spring事務(wù)中失效。

5. 方法的事務(wù)傳播類型不支持事務(wù)

如果內(nèi)部方法的事務(wù)傳播類型為不支持事務(wù)的傳播類型，則內(nèi)部方法的事務(wù)同樣會(huì)在Spring中失效，舉個(gè)例子：

@Service
publicclassOrderServiceImplextendsServiceImplimplementsIOrderService{
@Autowired
privateOrderMapperorderMapper;
@Autowired
privateProductMapperproductMapper;

@Override
@Transactional(propagation=Propagation.REQUIRES_NEW)
publicResponseEntitysubmitOrder(Orderorder){
longorderNo=Math.abs(ThreadLocalRandom.current().nextLong(1000));
order.setOrderNo("ORDER_"+orderNo);
orderMapper.insert(order);

//扣減庫(kù)存
this.updateProductStockById(order.getProductId(),1L);
returnnewResponseEntity(HttpStatus.OK);
}


/**
*扣減庫(kù)存方法事務(wù)類型聲明為NOT_SUPPORTED不支持事務(wù)的傳播
*/
@Transactional(propagation=Propagation.NOT_SUPPORTED)
publicvoidupdateProductStockById(Integernum,LongproductId){
productMapper.updateProductStockById(num,productId);
}
}

6. 異常被內(nèi)部catch，程序生吞異常

@Service
publicclassOrderServiceImplextendsServiceImplimplementsIOrderService{
@Autowired
privateOrderMapperorderMapper;
@Autowired
privateProductMapperproductMapper;

@Override
@Transactional(propagation=Propagation.REQUIRES_NEW)
publicResponseEntitysubmitOrder(Orderorder){
longorderNo=Math.abs(ThreadLocalRandom.current().nextLong(1000));
order.setOrderNo("ORDER_"+orderNo);
orderMapper.insert(order);

//扣減庫(kù)存
this.updateProductStockById(order.getProductId(),1L);
returnnewResponseEntity(HttpStatus.OK);
}

/**
*扣減庫(kù)存方法事務(wù)類型聲明為NOT_SUPPORTED不支持事務(wù)的傳播
*/
@Transactional(propagation=Propagation.NOT_SUPPORTED)
publicvoidupdateProductStockById(Integernum,LongproductId){
try{
productMapper.updateProductStockById(num,productId);
}catch(Exceptione){
//這里僅僅是捕獲異常之后的打?。ㄏ喈?dāng)于程序吞掉了異常）
log.error("ErrorupdatingproductStock:{}",e);
}
}
}

7. 數(shù)據(jù)庫(kù)不支持事務(wù)

Spring事務(wù)生效的前提是連接的數(shù)據(jù)庫(kù)支持事務(wù)，如果底層的數(shù)據(jù)庫(kù)都不支持事務(wù)，則Spring事務(wù)肯定會(huì)失效的，例如：使用MySQL數(shù)據(jù)庫(kù)，選用MyISAM存儲(chǔ)引擎，因?yàn)镸yISAM存儲(chǔ)引擎本身不支持事務(wù)，因此事務(wù)毫無疑問會(huì)失效。

8. 未配置開啟事務(wù)

如果項(xiàng)目中沒有配置Spring的事務(wù)管理器，即使使用了Spring的事務(wù)管理功能，Spring的事務(wù)也不會(huì)生效，例如，如果你是Spring Boot項(xiàng)目，沒有在SpringBoot項(xiàng)目中配置如下代碼：

@Bean
publicPlatformTransactionManagertransactionManager(DataSourcedataSource){
returnnewDataSourceTransactionManager(dataSource);
}

如果是以往的Spring MVC項(xiàng)目，如果沒有配置下面的代碼，Spring事務(wù)也不會(huì)生效，正常需要在applicationContext.xml文件中，手動(dòng)配置事務(wù)相關(guān)參數(shù)，比如：

9. 錯(cuò)誤的傳播特性

其實(shí)，我們?cè)谑褂聾Transactional注解時(shí)，是可以指定propagation參數(shù)的。

該參數(shù)的作用是指定事務(wù)的傳播特性，目前Spring支持7種傳播特性：

REQUIRED 如果當(dāng)前上下文中存在事務(wù)，那么加入該事務(wù)，如果不存在事務(wù)，創(chuàng)建一個(gè)事務(wù)，這是默認(rèn)的傳播屬性值。

SUPPORTS 如果當(dāng)前上下文存在事務(wù)，則支持事務(wù)加入事務(wù)，如果不存在事務(wù)，則使用非事務(wù)的方式執(zhí)行。

MANDATORY 如果當(dāng)前上下文中存在事務(wù)，否則拋出異常。

REQUIRES_NEW 每次都會(huì)新建一個(gè)事務(wù)，并且同時(shí)將上下文中的事務(wù)掛起，執(zhí)行當(dāng)前新建事務(wù)完成以后，上下文事務(wù)恢復(fù)再執(zhí)行。

NOT_SUPPORTED 如果當(dāng)前上下文中存在事務(wù)，則掛起當(dāng)前事務(wù)，然后新的方法在沒有事務(wù)的環(huán)境中執(zhí)行。

NEVER 如果當(dāng)前上下文中存在事務(wù)，則拋出異常，否則在無事務(wù)環(huán)境上執(zhí)行代碼。

NESTED 如果當(dāng)前上下文中存在事務(wù)，則嵌套事務(wù)執(zhí)行，如果不存在事務(wù)，則新建事務(wù)。

如果我們?cè)谑謩?dòng)設(shè)置propagation參數(shù)的時(shí)候，把傳播特性設(shè)置錯(cuò)了，比如：

@Service
publicclassOrderServiceImpl{

@Transactional(propagation=Propagation.NEVER)
publicvoidcancelOrder(UserModeluserModel){
//取消訂單
cancelOrder(orderDTO);
//還原庫(kù)存
restoreProductStock(orderDTO.getProductId(),orderDTO.getProductCount());
}
}

我們可以看到cancelOrder()方法的事務(wù)傳播特性定義成了Propagation.NEVER，這種類型的傳播特性不支持事務(wù)，如果有事務(wù)則會(huì)拋異常。

10. 多線程調(diào)用

在實(shí)際項(xiàng)目開發(fā)中，多線程的使用場(chǎng)景還是挺多的。如果Spring事務(wù)用在多線程場(chǎng)景中使用不當(dāng)，也會(huì)導(dǎo)致事務(wù)無法生效。

@Slf4j
@Service
publicclassOrderServiceImpl{

@Autowired
privateOrderMapperorderMapper;
@Autowired
privateMessageServicemessageService;

@Transactional
publicvoidorderCommit(orderModelorderModel)throwsException{
orderMapper.insertOrder(orderModel);
newThread(()->{
messageService.sendSms();
}).start();
}
}

@Service
publicclassMessageService{

@Transactional
publicvoidsendSms(){
//發(fā)送短信
}
}

通過示例，我們可以看到訂單提交的事務(wù)方法orderCommit()中，調(diào)用了發(fā)送短信的事務(wù)方法sendSms()，但是發(fā)送短信的事務(wù)方法sendSms()是另起了一個(gè)線程調(diào)用的。

這樣會(huì)導(dǎo)致兩個(gè)方法不在同一個(gè)線程中，從而是兩個(gè)不同的事務(wù)。如果是sendSms()方法中拋了異常，orderCommit()方法也回滾是不可能的。

實(shí)際上，Spring的事務(wù)是通過ThreadLocal來保證線程安全的，事務(wù)和當(dāng)前線程綁定，多個(gè)線程自然會(huì)讓事務(wù)失效。

2 總結(jié)

本篇文章主要是介紹Spring事務(wù)傳播特性，闡明了@Transactional注解屬性的使用方式，通過不同的代碼示例演示了Spring事務(wù)失效的常見場(chǎng)景。

審核編輯：湯梓紅