溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

遇到Spring雙層事務(wù)不回滾怎么辦

發(fā)布時(shí)間:2021-12-02 16:02:56 來源:億速云 閱讀:132 作者:柒染 欄目:云計(jì)算

今天就跟大家聊聊有關(guān)遇到Spring雙層事務(wù)不回滾怎么辦,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。

最近有粉絲在朋友圈問我,面試遇到了Spring雙事務(wù)不會(huì)滾問題,怎么破解。下面結(jié)合一個(gè)簡單案例,希望能解決一部分人的疑惑。

系統(tǒng) A 調(diào)用系統(tǒng) B 執(zhí)行數(shù)據(jù)同步,系統(tǒng) B 返回了錯(cuò)誤提示,系統(tǒng) A 需要將前邊保存的回滾掉,同時(shí)把錯(cuò)誤信息向上拋。

大致代碼如下

@Service("noteService")
public class NoteServiceImpl implements NoteService {

    @Resource
    private SearchService searchService;


    @Transactional(rollbackFor = Throwable.class)
    @Override
    public CommonResponse<NoteEntity> save(NoteEntity note) {
        // 一系列 DB 操作

        try {
            searchService.sync(note);
        } catch (Exception e) {
            e.printStackTrace();
        }

        return CommonResponse.success(entity);
    }

}

@Service("searchService")
public class SearchServiceImpl implements SearchService {

    @Transactional(rollbackFor = Throwable.class)
    @Override
    public void sync(NoteEntity note) {
        // 一系列 DB 操作

        throw new RuntimeException("同步異常! [XXX]");
    }

}

@SpringBootTest
public class NoteTests {

    @Resource
    private NoteService noteService;

    @Test
    public void saveNote() {
        NoteEntity entity = new NoteEntity();
        entity.setTitle("念奴嬌赤壁懷古");
        entity.setContent("大江東去,浪淘盡,千古風(fēng)流人物。故壘西邊,人道是:三國周郎赤壁。。。");
        entity.setTags("蘇軾,宋代");
        entity.setCategory("蘇軾詩詞");

        try {
            noteService.save(entity);
        } catch (Exception e) {
            e.printStackTrace();
            // FIXME 我想在這里拿到的是 同步異常! [XXX]
            // FIXME 但是這里拿到的是 Transaction silently rolled back because it has been marked as rollback-only
            System.out.println(">>>>>>>>>> " + e.getMessage());
        }
    }

}

事出有因

代碼歷史久遠(yuǎn),為何這樣寫已無從追溯。

納悶了一會(huì)兒,看到雙層事務(wù),就想起了 Spring事務(wù)傳播機(jī)制,前邊理解得比較膚淺。

沒有特殊的配置,自然是走默認(rèn)的事務(wù)傳播機(jī)制了,也就是 Propagation.REQUIRED。

國際慣例,列出事務(wù)傳播機(jī)制:

1、PROPAGATION_REQUIRED
當(dāng)前沒事務(wù),則創(chuàng)建事務(wù);存在事務(wù),就加入該事務(wù),這是最常用的設(shè)置。

2、PROPAGATION_SUPPORTS
當(dāng)前存在事務(wù),就加入事務(wù),當(dāng)前不存在事務(wù),就以非事務(wù)方式執(zhí)行。

3、PROPAGATION_MANDATORY
當(dāng)前存在事務(wù),就加入事務(wù);當(dāng)前不存在事務(wù),就拋出異常。

4、PROPAGATION_REQUIRES_NEW
無條件創(chuàng)建新事務(wù)。

5、PROPAGATION_NOT_SUPPORTED
以非事務(wù)方式執(zhí)行,如果當(dāng)前存在事務(wù),就將當(dāng)前事務(wù)掛起。

6、PROPAGATION_NEVER
以非事務(wù)方式運(yùn)行,如果存在事務(wù),就拋出異常。

7、PROPAGATION_NESTED
開始執(zhí)行事務(wù)前,先保存一個(gè)savepoint,當(dāng)發(fā)生異常時(shí),就回滾到savepoint;沒有異常時(shí),跟著外部事務(wù)一起提交或回滾。

具體原因

1、看了上邊的事務(wù)傳播機(jī)制,繼續(xù)細(xì)化問題,內(nèi)外層共用一個(gè)事務(wù),內(nèi)層拋出異常,會(huì)導(dǎo)致整個(gè)事務(wù)失敗。

2、繼續(xù)分析,外層邏輯進(jìn)行了 try catch,就導(dǎo)致內(nèi)層的異常無法繼續(xù)向上拋出,外層事務(wù)會(huì)繼續(xù)提交。

3、事務(wù)提交時(shí),進(jìn)行事務(wù)狀態(tài)的判斷,就發(fā)現(xiàn)這個(gè)事務(wù)是失敗的,需要回滾,所以拋出了 Transaction silently rolled back because it has been marked as rollback-only 的異常。

怎么解決?

根據(jù)業(yè)務(wù)場景選擇合適的方案。

1、當(dāng)前這種場景,直接把外層邏輯中的 try catch 去掉即可。異常直接向上拋,事務(wù)就不會(huì)繼續(xù)提交,調(diào)用方拿到的就是一手的異常;

2、如果內(nèi)層不是核心邏輯,記錄個(gè)日志啥的,可以把內(nèi)層事務(wù)配置為 @Transactional(rollbackFor = Throwable.class, propagation = Propagation.REQUIRES_NEW), 無論如何,都創(chuàng)建新的事務(wù),外層事務(wù)不受內(nèi)層事務(wù)影響。但是有個(gè)問題,外層事務(wù)失敗了,內(nèi)層事務(wù)還是把記錄入庫了,有可能產(chǎn)生臟數(shù)據(jù);

3、如果外層事務(wù)失敗了,內(nèi)層事務(wù)也不能提交,那就可以使用 @Transactional(rollbackFor = Throwable.class, propagation = Propagation.NESTED)。注意:hibernate/jpa 不支持嵌套事務(wù) NESTED,可用 JdbcTemplate 代替。

最后,下面這位粉絲總結(jié)的事務(wù)不生效問題,大家牢記。面試中能全說出來,Offer基本穩(wěn)了。

看完上述內(nèi)容,你們對(duì)遇到Spring雙層事務(wù)不回滾怎么辦有進(jìn)一步的了解嗎?如果還想了解更多知識(shí)或者相關(guān)內(nèi)容,請(qǐng)關(guān)注億速云行業(yè)資訊頻道,感謝大家的支持。

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI