記錄總結(jié)Spring核心知識(shí)點(diǎn)：事務(wù)使用與它的傳播機(jī)制

前言

這里不打算討論Spring底層源碼，只討論測(cè)試場(chǎng)景和總結(jié). 不斷整理讓大腦中的知識(shí)體系沉淀。

問題場(chǎng)景

某項(xiàng)目系統(tǒng)中，serviceA 中調(diào)用的 serviceB ，并且對(duì) serviceB 進(jìn)行 tryCache

@Service("testAService")
public class TestAServiceImpl implements TestAService {
    @Resource
    private TestAMapper testAMapper;
    @Resource
    private TestBService testBService;
    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
    public void saveTestA(TestA entity) {
        testAMapper.insertSelective(entity);
        try {
            testBService.saveTestB(new TestB());
        } catch (Exception e) {
            logger.error("調(diào)用B失敗", e);
        }
        // 模擬做其他的數(shù)據(jù)庫操作事情
        testAMapper.updateSelective(entity);
    }
}

testBService 中模擬拋出異常：

@Service("testBService")
public class TestBServiceImpl mplements TestBService {
    @Resource
    private TestBMapper testBMapper;
    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
    @Override
    public void saveTestB(TestB entity) {
        testBMapper.insertSelective(entity);
        throw new RuntimeException("自定義異常");
    }
}

問 在Controller層中調(diào)用 TestAService.saveTestA() 會(huì)怎么樣？

    @Resource
    private TestAService testAService;
    @ApiOperation(value = "Spring事務(wù)嵌套測(cè)試")
    @GetMapping("springTransactionTest")
    public ResponseVO<NoBody> springTransactionTest() {
        testAService.saveTestA(new TestA());
        return ResponseVO.success();
    }

答案是：

testAService testBService 中的數(shù)據(jù)庫操作 全部回滾，并且拋出的錯(cuò)誤異常：

Transaction rolled back because it has been marked as rollback-only

原因是：

testBService.saveTestB 也增加了同樣的事務(wù)注解 @Transactional

且事務(wù)隔離機(jī)制為 “REQUIRED” ，因此 兩方法執(zhí)行期間為同一個(gè)數(shù)據(jù)庫事務(wù)，被同一個(gè)Spring事務(wù)管理器所管理著。

由于最開始開啟事務(wù)者為 testAService.saveTestA，則真正執(zhí)行回滾操作在 saveTestA 方法中 （Spring 規(guī)定了只有新創(chuàng)建的事務(wù)才會(huì)真正進(jìn)行提交或回滾），

因此 saveTestB 方法中異常時(shí)只設(shè)置了當(dāng)前事務(wù)狀態(tài)為 RollbackOnly

org.springframework.jdbc.datasource.DataSourceTransactionManager#doSetRollbackOnly

雖然 saveTestA 中 tryCache 了 saveTestB 中的異常，企圖吃掉異常信息讓 saveTestA 中的事務(wù)正常提交，但是 saveTestB 里面已經(jīng)設(shè)置了 當(dāng)前事務(wù)狀態(tài)為 RollbackOnly， 出現(xiàn)了沖突矛盾！

因此事務(wù)全部回滾，并且拋出異常信息：

 Transaction rolled back because it has been marked as rollback-only

Spring 管理事務(wù)的原理

首先，事務(wù)一般是關(guān)系型數(shù)據(jù)庫中的概念，主要目的就是 保證一系列的增刪改 SQL操作 要么全部成功，要么全部回滾。

MySQL中的事務(wù)管理

在MySQL中采用SQL命令進(jìn)行事務(wù)管理：

• START TRANSACTION 或 BEGIN 或 SET autocommit = 0 開啟事務(wù)
• 執(zhí)行 CRUD
• COMMIT 提交事務(wù)
• ROLLBACK 回滾事務(wù)

這里重點(diǎn)說下 多條SQL在一個(gè)事務(wù)中，其中有部分SQL執(zhí)行失敗情況下，最終執(zhí)行結(jié)果是什么

> begin;
> insert_sql1 （insert into test1(id,name)value(1,'aaa')） ;
> insert_sql2 （insert into test2(id,name)value(1,'bbb')） ;
> commit/ rollback;

上面示意代碼，如果 insert_sql1 成功， insert_sql2 失敗時(shí)，請(qǐng)問 insert_sql1 最終是否插入成功？

答案是：

首先事務(wù)不會(huì)馬上回滾， 其次如果 此時(shí)執(zhí)行commit則 insert_sql1 會(huì)插入成功 ，如果執(zhí)行rollback則insert_sql1 會(huì)回滾。

那一般事務(wù)什么時(shí)候自動(dòng)回滾或者自動(dòng)提交？這里記錄一下常見場(chǎng)景：

• 如果事務(wù)執(zhí)行中出現(xiàn) DDL語句( alert create drop truncate等 ) 事務(wù)自動(dòng) commit;
• 如果事務(wù)執(zhí)行中又開啟了一個(gè)事務(wù)（又出現(xiàn) begin; sql命令）事務(wù)自動(dòng) commit;
• 如果執(zhí)行SQL的session 中途被關(guān)閉（SQL窗口關(guān)閉，服務(wù)器斷電等） 事務(wù)自動(dòng) rollback;

JDBC中的事務(wù)管理

JDBC中連接數(shù)據(jù)庫進(jìn)行事務(wù)管理：

• 獲取連接 Connection con = DriverManager.getConnection()
• con.setAutoCommit(true/false); 開啟事務(wù)
• 執(zhí)行CRUD
• con.commit() ; 提交事務(wù)
• con.rollback(); 回滾事務(wù)
• 關(guān)閉連接 conn.close();

JDBC 事務(wù)管理的本質(zhì)還是連接了數(shù)據(jù)庫執(zhí)行各類數(shù)據(jù)庫中開啟關(guān)閉事務(wù)的SQL命令

Spring中的事務(wù)管理

Spring通過自身AOP切面功能，代理各個(gè)業(yè)務(wù)方法調(diào)用 JDBC中的方法進(jìn)行開啟、關(guān)閉、提交、回滾事務(wù)等操作。

至于嵌套事務(wù)、各類傳播機(jī)制是如何實(shí)現(xiàn)， 這里簡單總結(jié)，雖然不能體現(xiàn)Spring 事務(wù)操作方面的強(qiáng)大，但可以很快有個(gè)大致理解。

Spring 通過 一個(gè)Map 存放了當(dāng)前數(shù)據(jù)庫連接對(duì)象，這是為了解決根據(jù)設(shè)定的傳播機(jī)制 ( propagation ) 決定是否要新開一個(gè)事務(wù)，新開另外一個(gè)事務(wù)需要重新申請(qǐng)一個(gè)數(shù)據(jù)庫連接。

Spring 通過 數(shù)據(jù)庫事務(wù)中的 SAVEPOINT 保留點(diǎn)功能實(shí)現(xiàn) 嵌套事務(wù)的傳播機(jī)制。

這里記錄一下一個(gè)HTTP請(qǐng)求 從Controller層發(fā)起數(shù)據(jù)庫操作請(qǐng)求到回滾的log日志，用于加強(qiáng)理解：

    @ApiOperation(value = "事務(wù)回滾測(cè)試")
    @PostMapping("rollbackTest")
    public ResponseVO<NoBody> rollbackTest() {
        // 簡單模擬插入一條記錄
        testAService.saveTestA(new TestA());
        return ResponseVO.success();
    }

[http-nio-9902-exec-5] o.s.web.servlet.DispatcherServlet        : POST "/api/rollbackTest", parameters={}
[http-nio-9902-exec-5] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped to com.guzt.main.model.test.web.DbTestController#rollbackTest()
[http-nio-9902-exec-5] o.s.j.d.DataSourceTransactionManager     : Creating new transaction with name [com.sdjictec.wms.main.model.test.service.impl.TestAServiceImpl.saveTestA]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT,-java.lang.Exception
[http-nio-9902-exec-5] o.s.j.d.DataSourceTransactionManager     : Acquired Connection [com.alibaba.druid.proxy.jdbc.ConnectionProxyImpl@7fec11ca] for JDBC transaction
[http-nio-9902-exec-5] o.s.j.d.DataSourceTransactionManager     : Switching JDBC Connection [com.alibaba.druid.proxy.jdbc.ConnectionProxyImpl@7fec11ca] to manual commit
[http-nio-9902-exec-5] c.s.w.m.m.t.d.T.insertSelective          : ==>  Preparing: INSERT INTO t_test_a ( ID,NAME ) VALUES(?,? )
[http-nio-9902-exec-5] c.s.w.m.m.t.d.T.insertSelective          : ==> Parameters: 1655001437939(String), p4xfy8(String)
[http-nio-9902-exec-5] c.s.w.m.m.t.d.T.insertSelective          : <==    Updates: 1
[http-nio-9902-exec-5] o.s.j.d.DataSourceTransactionManager     : Initiating transaction rollback
[http-nio-9902-exec-5] o.s.j.d.DataSourceTransactionManager     : Rolling back JDBC transaction on Connection [com.alibaba.druid.proxy.jdbc.ConnectionProxyImpl@7fec11ca]
[http-nio-9902-exec-5] o.s.j.d.DataSourceTransactionManager     : Releasing JDBC Connection [com.alibaba.druid.proxy.jdbc.ConnectionProxyImpl@7fec11ca] after transaction
[http-nio-9902-exec-5] c.s.w.m.c.p.context.CurrentUserContext   : CurrentUserContext remove CurrentUserVO...
[http-nio-9902-exec-5] c.s.w.m.f.a.CurrentUserContextAspect     : CurrentUserContextAspect doAfterThrowing  CurrentUserContext.remove()...
[http-nio-9902-exec-5] .m.m.a.ExceptionHandlerExceptionResolver : Using @ExceptionHandler com.guzt.main.framework.exception.GlobalExceptionHandler#handleBusinessException(BusinessException)
[http-nio-9902-exec-5] c.s.w.m.f.e.GlobalExceptionHandler       : BusinessException -- errorCode：E5111 errorMsg：模擬數(shù)據(jù)庫操作異常，主鍵重復(fù)
[http-nio-9902-exec-5] m.m.a.RequestResponseBodyMethodProcessor : Using 'application/json', given [*/*] and supported [application/json, application/json, application/*+json, application/json, application/*+json, application/cbor]
[http-nio-9902-exec-5] m.m.a.RequestResponseBodyMethodProcessor : Writing [ResponseVO(code=-1, message=模擬數(shù)據(jù)庫操作異常，主鍵重復(fù), data={"errorBody":"","bussinessCode":"E5111","extraMsg":""})]
[http-nio-9902-exec-5] .m.m.a.ExceptionHandlerExceptionResolver : Resolved [com.guzt.starter.common.exception.BusinessException: errorCode=E5111, errorMsg=FAIL]
[http-nio-9902-exec-5] o.s.web.servlet.DispatcherServlet        : Completed 200 OK

主要的步驟：

Creating new transaction

DataSourceTransactionManager 根據(jù) TransactionDefinition 創(chuàng)建 TransactionStatus 對(duì)象，準(zhǔn)備開啟事務(wù)Acquired Connection for JDBC transaction

通過數(shù)據(jù)庫連接池 申領(lǐng)一個(gè)數(shù)據(jù)庫連接Switching JDBC Connection to manual commit

開啟事務(wù)，底層是通過JDBC執(zhí)行 SET autocommit = 0; Initiating transaction rollback

準(zhǔn)備回滾事務(wù)，修改 TransactionStatus 狀態(tài)為回滾Rolling back JDBC transaction

回滾事務(wù) ，底層是通過JDBC執(zhí)行 rollback; SET autocommit = 1;Releasing JDBC Connection

釋放數(shù)據(jù)庫連接，最后是關(guān)閉了數(shù)據(jù)庫連接，底層調(diào)用了 JDBC Connection.close()

Spring中的事務(wù)接口

上面日志中提到了 TransactionDefinition TransactionStatus 等接口，這里也順便總結(jié)一下Spring事務(wù)中重要的幾個(gè)接口。

至于具體功能流程，這里不討論，自行看源碼，多debug即可明白。

到底回滾還是不回滾

本次討論重點(diǎn)就是 Spring的事務(wù)管理中，遇到了程序異常到底會(huì)不會(huì)回滾？

簡明答案

執(zhí)行事務(wù)的方法如果感知到了異常則將回滾事務(wù)

什么是執(zhí)行事務(wù)的方法

一般方法上增加了 @Transactional 注解或 其他Spring事務(wù)支持的方式AOP代理了的方法

  @Transactional
   public void saveTestA(TestA entity) {
        業(yè)務(wù)代碼
   }

什么情況下異常被感知

被Spring事務(wù)AOP所代理的業(yè)務(wù)方法執(zhí)行時(shí)出現(xiàn)異常，且異常類在Spring事務(wù)回滾范圍內(nèi)的將被調(diào)用方法所感知。

默認(rèn)Spring只對(duì) unchecked Exception 進(jìn)行回滾，一般手動(dòng)設(shè)定全部異常（rollbackFor = Exception.class）

什么情況下異常不被感知

一般這是討論事務(wù)不生效的場(chǎng)景。

• 方法訪問修飾符非public
• 法拋出的異常不是spring的事務(wù)支持的異常
• 被 Try-Cache 捕獲且不再向外拋出例如下面的場(chǎng)景代碼：

   @Transactional
   public void saveTestA(TestA entity) {
     try{
        業(yè)務(wù)代碼
     } catch (Exception e) {
         logger.error("內(nèi)部消化異常，不往外拋", e);
     }
   }

注解所在的類沒有被Spring 事務(wù)AOP代理

這種場(chǎng)景問題最隱蔽，一般需要有經(jīng)驗(yàn)或者多次debug才能發(fā)現(xiàn)

同一個(gè)類里面方法互相調(diào)用，一般建議采用 SpringUtil.getBean(this.getClass()).xxxx事務(wù)方法()

某些策略模式場(chǎng)景，需要將service對(duì)象放到一個(gè) Map<String, Service>中 ,如果是自行放置，則對(duì)象必須是 代理對(duì)象而非 this對(duì)象，建議采用 SpringUtil.getBean(this.getClass()) 對(duì)象。

參考代碼：

public class WxinOrderTypeServiceImpl implements OrderTypeService {
  @PostConstruct
  public void init() {
      ORDER_TYPE_SERVICE.put("orderTypeKey", SpringUtil.getBean(this.getClass());
  }
  @Transactional(rollbackFor = Exception.class)
  @Override
  public void saveOrder(Order order)
    logger.info("微信訂單");
  }
}

上面代碼意思是，將Spring代理的對(duì)象 WxinOrderTypeServiceImpl$Cjlibxxxx 放置到策略map ORDER_TYPE_SERVICE中去，如果用 this （ ORDER_TYPE_SERVICE.put("orderTypeKey",this)） 則事務(wù)不生效，因?yàn)閠his雖然也在Spring beanFactory中但沒有被事務(wù)AOP所代理，因此用this 會(huì)不生效。

備注： SpringUtil 其實(shí)就是實(shí)現(xiàn)了接口 ApplicationContextAware 獲得ApplicationContext，ApplicationContext 中有 getBean方法，當(dāng)然SpringBoot 可以在業(yè)務(wù)類里面直接注入 ApplicationContext

@Autowired
ApplicationContext applicationContext;

數(shù)據(jù)庫本身不支持事務(wù)

如果使用MySQL且存儲(chǔ)引擎是MyISAM，則事務(wù)是不起作用的

異常被感知后Spring做些什么

異常被感知后，Spring將會(huì)做回滾或更新TransactionStatus的狀態(tài)（doSetRollbackOnly）.

一旦TransactionStatus 被打上了 RollbackOnly標(biāo)志后，那么不管中間的業(yè)務(wù)代碼是什么 都會(huì)拋出異常進(jìn)行全部事務(wù)回滾。

那么什么時(shí)候 不做回滾只更新 TransactionStatus 為 RollbackOnly？

參見文章一開始的業(yè)務(wù)代碼，同屬于一個(gè)事務(wù)中（Propagation.REQUIRED）的多個(gè)執(zhí)行事務(wù)方法（業(yè)務(wù)代碼中嵌套調(diào)用其他service方法），如果不是首次開啟事務(wù)的那個(gè)方法則都只會(huì)更新 TransactionStatus 為 RollbackOnly，事務(wù)的提交回滾由首次事務(wù)開啟的那個(gè)方法執(zhí)行

參見源碼 org.springframework.transaction.support.AbstractPlatformTransactionManager# processRollback

回滾程度是多少

事務(wù)回滾到哪一個(gè)程度，是全部嵌套調(diào)用的方法都回滾還是部分方法回滾，這里主要是由Spring的事務(wù)傳播機(jī)制功能控制。

到此這篇關(guān)于Spring事務(wù)管理中的異常回滾是什么的文章就介紹到這了,更多相關(guān)Spring異?；貪L內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論