Spring中的事務(wù)傳播屬性詳解

字號(hào):

在使用Spring時(shí),大部分會(huì)用到他的聲明式事務(wù),簡(jiǎn)單的在配置文件中進(jìn)行一些規(guī)則配置,利用Spring的AOP功能就能輕松搞定事務(wù)問題;這里面就涉及到一個(gè)事務(wù)的傳播屬性問題Propagation,它在TransactionDefinition接口中定義,以供PlatfromTransactionManager使用,PlatfromTransactionManager是spring事務(wù)管理的核心接口。
    TransactionDefinition
    public interface TransactionDefinition {
    int getPropagationBehavior();
    int getIsolationLevel();
    int getTimeout();
    boolean isReadOnly();
    }
    getTimeout()方法,它返回事務(wù)必須在多少秒內(nèi)完成。
    isReadOnly(),事務(wù)是否只讀,事務(wù)管理器能夠根據(jù)這個(gè)返回值進(jìn)行優(yōu)化,確保事務(wù)是只讀的。
    getIsolationLevel()方法返回事務(wù)的隔離級(jí)別,事務(wù)管理器根據(jù)它來控制另外一個(gè)事務(wù)可以看到本事務(wù)內(nèi)的哪些數(shù)據(jù)。
    在TransactionDefinition接口中定義了五個(gè)不同的事務(wù)隔離級(jí)別,ISOLATION_DEFAULT 這是一個(gè)PlatfromTransactionManager默認(rèn)的隔離級(jí)別,使用數(shù)據(jù)庫默認(rèn)的事務(wù)隔離級(jí)別.另外四個(gè)與JDBC的隔離級(jí)別相對(duì)應(yīng),ISOLATION_READ_UNCOMMITTED 這是事務(wù)最低的隔離級(jí)別,它充許別外一個(gè)事務(wù)可以看到這個(gè)事務(wù)未提交的數(shù)據(jù)。這種隔離級(jí)別會(huì)產(chǎn)生臟讀,不可重復(fù)讀和幻像讀。
    在TransactionDefinition接口中共有7種選項(xiàng)可用:
    PROPAGATION_REQUIRED:支持當(dāng)前事務(wù),如果當(dāng)前沒有事務(wù),就新建一個(gè)事務(wù)。這是最常見的選擇。
    PROPAGATION_SUPPORTS:支持當(dāng)前事務(wù),如果當(dāng)前沒有事務(wù),就以非事務(wù)方式執(zhí)行。
    PROPAGATION_MANDATORY:支持當(dāng)前事務(wù),如果當(dāng)前沒有事務(wù),就拋出異常。
    PROPAGATION_REQUIRES_NEW:新建事務(wù),如果當(dāng)前存在事務(wù),把當(dāng)前事務(wù)掛起。
    PROPAGATION_NOT_SUPPORTED:以非事務(wù)方式執(zhí)行操作,如果當(dāng)前存在事務(wù),就把當(dāng)前事務(wù)掛起。
    PROPAGATION_NEVER:以非事務(wù)方式執(zhí)行,如果當(dāng)前存在事務(wù),則拋出異常。
    PROPAGATION_NESTED:支持當(dāng)前事務(wù),新增Savepoint點(diǎn),與當(dāng)前事務(wù)同步提交或回滾。
    現(xiàn)在結(jié)合一個(gè)實(shí)例,應(yīng)用以上各種傳播屬性來進(jìn)行說明:首先聲明兩個(gè)bean:ServiceA和ServiceB,其中ServiceB被引用;
    ServiceA {
    void methodA() {
    ServiceB.methodB();
    }
    }
    ServiceB {
    void methodB() {
    }
    }
    接下來,我們就一一分析下:
    PROPAGATION_REQUIRED
    加入當(dāng)前正要執(zhí)行的事務(wù)不在另外一個(gè)事務(wù)里,那么就起一個(gè)新的事務(wù);比如說,ServiceB.methodB的事務(wù)級(jí)別定義為PROPAGATION_REQUIRED, 那么由于執(zhí)行ServiceA.methodA的時(shí)候, ServiceA.methodA已經(jīng)起了事務(wù),這時(shí)調(diào)用ServiceB.methodB,ServiceB.methodB看到自己已經(jīng)運(yùn)行在ServiceA.methodA 的事務(wù)內(nèi)部,就不再起新的事務(wù)。而假如ServiceA.methodA運(yùn)行的時(shí)候發(fā)現(xiàn)自己沒有在事務(wù)中,他就會(huì)為自己分配一個(gè)事務(wù)。 這樣,在ServiceA.methodA或者在ServiceB.methodB內(nèi)的任何地方出現(xiàn)異常,事務(wù)都會(huì)被回滾。即使ServiceB.methodB的事務(wù)已經(jīng)被 提交,但是ServiceA.methodA在接下來fail要回滾,ServiceB.methodB也要回滾。
    PROPAGATION_SUPPORTS
    如果當(dāng)前在事務(wù)中,即以事務(wù)的形式運(yùn)行,如果當(dāng)前不再一個(gè)事務(wù)中,那么就以非事務(wù)的形式運(yùn)行。
    PROPAGATION_MANDATORY
    必須在一個(gè)事務(wù)中運(yùn)行。也就是說,他只能被一個(gè)父事務(wù)調(diào)用。否則,他就要拋出異常。
    PROPAGATION_REQUIRES_NEW
    比如我們?cè)O(shè)計(jì)ServiceA.methodA的事務(wù)級(jí)別為PROPAGATION_REQUIRED,ServiceB.methodB的事務(wù)級(jí)別為PROPAGATION_REQUIRES_NEW, 那么當(dāng)執(zhí)行到ServiceB.methodB的時(shí)候,ServiceA.methodA所在的事務(wù)就會(huì)掛起,ServiceB.methodB會(huì)起一個(gè)新的事務(wù),等待ServiceB.methodB的事務(wù)完成以后, 他才繼續(xù)執(zhí)行。他與PROPAGATION_REQUIRED 的事務(wù)區(qū)別在于事務(wù)的回滾程度了。因?yàn)镾erviceB.methodB是新起一個(gè)事務(wù),那么就是存在 兩個(gè)不同的事務(wù)。如果ServiceB.methodB已經(jīng)提交,那么ServiceA.methodA失敗回滾,ServiceB.methodB是不會(huì)回滾的。如果ServiceB.methodB失敗回滾, 如果他拋出的異常被ServiceA.methodA捕獲,ServiceA.methodA事務(wù)仍然可能提交。
    PROPAGATION_NOT_SUPPORTED
    當(dāng)前不支持事務(wù)。比如ServiceA.methodA的事務(wù)級(jí)別是PROPAGATION_REQUIRED ,而ServiceB.methodB的事務(wù)級(jí)別是PROPAGATION_NOT_SUPPORTED, 那么當(dāng)執(zhí)行到ServiceB.methodB時(shí),ServiceA.methodA的事務(wù)掛起,而他以非事務(wù)的狀態(tài)運(yùn)行完,再繼續(xù)ServiceA.methodA的事務(wù)。 網(wǎng)管聯(lián)盟bitsCN_com
    PROPAGATION_NEVER
    不能在事務(wù)中運(yùn)行。假設(shè)ServiceA.methodA的事務(wù)級(jí)別是PROPAGATION_REQUIRED, 而ServiceB.methodB的事務(wù)級(jí)別是PROPAGATION_NEVER, 那么ServiceB.methodB就要拋出異常了。
    PROPAGATION_NESTED
    理解Nested的關(guān)鍵是savepoint。他與PROPAGATION_REQUIRES_NEW的區(qū)別是,PROPAGATION_REQUIRES_NEW另起一個(gè)事務(wù),將會(huì)與他的父事務(wù)相互獨(dú)立, 而Nested的事務(wù)和他的父事務(wù)是相依的,他的提交是要等和他的父事務(wù)一塊提交的。也就是說,如果父事務(wù)最后回滾,他也要回滾的。 而Nested事務(wù)的好處也是他有一個(gè)savepoint:
    ServiceA {
    void methodA() {
    try {
    ServiceB.methodB();
    } catch (Exception e) {
    ServiceC.methodC();
    }
    }
    }
    也就是說ServiceB.methodB失敗回滾,那么ServiceA.methodA會(huì)回滾到savepoint點(diǎn)上,ServiceA.methodA可以選擇另外一個(gè)分支,比如 ServiceC.methodC,繼續(xù)執(zhí)行,來嘗試完成自己的事務(wù);但是這個(gè)事務(wù)并沒有在EJB標(biāo)準(zhǔn)中定義。