日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Spring事務(wù)管理—快速入門

先來講講臟讀 不可重復(fù)讀 和 幻讀。

讓客戶滿意是我們工作的目標(biāo),不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶,將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價值的長期合作伙伴,公司提供的服務(wù)項目有:空間域名、虛擬主機、營銷軟件、網(wǎng)站建設(shè)、河間網(wǎng)站維護、網(wǎng)站推廣。

  • 臟讀:我們在并發(fā)編程中是很熟悉的,通俗的講就是你讀得數(shù)據(jù)已經(jīng)被修改了,已經(jīng)過時失去意義了。
  • 不可重復(fù)讀: 同一個事務(wù)里面多次讀取同一行數(shù)據(jù),卻返回不同的結(jié)果。
  • 幻讀:同樣一筆查詢在整個事務(wù)過程中多次執(zhí)行后,查詢所得的結(jié)果集不一樣。

事務(wù)四大特性 ACID

1、原子性(Atomicity)

要求事務(wù)所包含的全部操作是一個不可分割的整體,如果有一步發(fā)生異常,則全部不提交。

2、一致性(Consistency)

A給B轉(zhuǎn)錢,A減和B增這兩個操作必須保持一致。

3、隔離性(Isolation)

事務(wù)會將一部分數(shù)據(jù)與其他事務(wù)隔離,防止臟讀等。

4、持久性(Durability)

事務(wù)的結(jié)果被寫到持久化存儲器中。

事務(wù)四大隔離級別

隔離級別越高,則性能相對越低,反之亦然。

1、Read Uncommitted

最低的隔離級別,跟你直譯的意思一樣:可以讀取其它事務(wù)未完成的結(jié)果。(臟讀)

很明顯,臟讀 不可重復(fù)讀 和 幻讀這三個問題它都有。

2、Read Committed

大部分數(shù)據(jù)庫采用的默認隔離級別,比上一個隔離級別多了限定:在該事務(wù)完成后,才能讀取該事務(wù)的數(shù)據(jù)更新后的結(jié)果。

它可以避免臟讀,但是也有不可重復(fù)讀取和幻讀的問題。

3、Repeatable Read

可以保證在整個事務(wù)的過程中,對同一筆數(shù)據(jù)的讀取結(jié)果是相同的,不管其他事務(wù)是否同時在對同一筆數(shù)據(jù)進行更新,也不管其他事務(wù)對同一筆數(shù) 據(jù)的更新提交與否。

Repeatable Read隔離級別避免了臟讀和不可重復(fù)讀取的問題,但無法避免幻讀。

4、Serializable

最為嚴格的隔離級別,所有的事務(wù)操作都必須依次順序執(zhí)行,可以避免其他隔離級別遇到的所有問題,是最為安全的隔離級別, 但同時也是性能最差的隔離級別。

通常情況下,我們會使用其他隔離級別加上相應(yīng)的并發(fā)鎖的機制來控制對數(shù)據(jù)的訪問,這樣既保證 了系統(tǒng)性能不會損失太大,也能夠一定程度上保證數(shù)據(jù)的一致性。

Spring事務(wù)傳播機制

事務(wù)傳播行為

含義

PROPAGATION_REQUIRED(默認)

必須在事務(wù)中執(zhí)行,如果沒有,就新new一個新事務(wù)

PROPAGATION_SUPPORTS

誰調(diào)用我我就在誰的事務(wù)中執(zhí)行,沒有的話就沒有

PROPAGATION_MANDATORY

必須要有事務(wù),沒有就報錯

PROPAGATION_REQUIRED_NEW

不管調(diào)用我的方法有沒有事務(wù),我都new一個事務(wù)

PROPAGATION_NOT_SUPPORTED

調(diào)用我的方法有事務(wù),但我不在事務(wù)中執(zhí)行

PROPAGATION_NEVER

不允許在事務(wù)中運行,有事務(wù)則報錯

PROPAGATION_NESTED

有事務(wù)則嵌套,沒有則new一個新事務(wù)

從JDBC的事務(wù)說起

我們都知道,JDBC給我們提供了事務(wù)。

try{
     con.setAutoCommit(false);//開啟事務(wù)
     ......
     con.commit();//try的最后提交事務(wù)      
} catch() {
    con.rollback();//回滾事務(wù)
}

獲取事務(wù)隔離級別。

Connection.getTransactionIsolation()

設(shè)置事務(wù)隔離級別。

con.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);

Spring事務(wù)機制

Spring并不會直接管理事務(wù),而是提供了事務(wù)管理器,將事務(wù)管理的職責(zé)委托給JPA JDBC JTA DataSourceTransaction JMSTransactionManager 等框架提供的事務(wù)來實現(xiàn)。

那么,Spring提供的事務(wù)管理器是什么呢?


PlatformTransactionManager.java接口:

PlatformTransactionManager.java

Spring提供的事務(wù)管理器。不同的事務(wù)遵循該事務(wù)管理器的API,便能很輕松的交給Spring管理。

public interface PlatformTransactionManager {
    // 通過Transation定義 獲取Transation
    TransactionStatus getTransaction(@Nullable TransactionDefinition var1) throws TransactionException;
    // 提交事務(wù)
    void commit(TransactionStatus var1) throws TransactionException;
    // 回滾事務(wù)
    void rollback(TransactionStatus var1) throws TransactionException;
}

可以看到它里面引用到了TransactionDefinition和TransactionStatus。

TransactionDefinition.java

它里面包含了事務(wù)的定義。

public interface TransactionDefinition {
    // 傳播機制
    int PROPAGATION_REQUIRED = 0;
    int PROPAGATION_SUPPORTS = 1;
    int PROPAGATION_MANDATORY = 2;
    int PROPAGATION_REQUIRES_NEW = 3;
    int PROPAGATION_NOT_SUPPORTED = 4;
    int PROPAGATION_NEVER = 5;
    int PROPAGATION_NESTED = 6;
    // 隔離級別
    int ISOLATION_DEFAULT = -1;
    int ISOLATION_READ_UNCOMMITTED = 1;
    int ISOLATION_READ_COMMITTED = 2;
    int ISOLATION_REPEATABLE_READ = 4;
    int ISOLATION_SERIALIZABLE = 8;
    int TIMEOUT_DEFAULT = -1;

    int getPropagationBehavior();
    // 獲取隔離級別
    int getIsolationLevel();

    int getTimeout();
    
    boolean isReadOnly();

    @Nullable
    String getName();
}

TransactionStatus.java

事務(wù)的狀態(tài)。

public interface TransactionStatus extends SavepointManager, Flushable {
    boolean isNewTransaction();

    boolean hasSavepoint();

    void setRollbackOnly();

    boolean isRollbackOnly();

    void flush();

    boolean isCompleted();
}

Spring默認事務(wù)使用

1、代碼方式使用

@Autowired
private PlatformTransactionManager transactionManager;
public void testTX(){
    DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
    TransactionStatus status = transactionManager.getTransaction(definition);
    try {
        // 業(yè)務(wù)邏輯
        // ...
        
        // 提交事務(wù)
        transactionManager.commit(status);
    }catch (Exception e){
        // 發(fā)生異常,事務(wù)回滾
        transactionManager.rollback(status);
    }
}

2、注解方式使用

@Transactional
void testTX2(){
    // 業(yè)務(wù)邏輯 ...
}

這不是玄學(xué),它的底層是依靠AOP動態(tài)代理實現(xiàn),其實重新渲染出的代碼和第一個使用方式類似,不過大大減少了開發(fā)復(fù)雜度。

擴展:@Transactional注解

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface Transactional {

    //指定使用的事務(wù)管理器
    @AliasFor("transactionManager")
    String value() default "";

    @AliasFor("value")
    String transactionManager() default "";
    // 可選的事務(wù)傳播行為設(shè)置
    Propagation propagation() default Propagation.REQUIRED;
    // 可選的事務(wù)隔離級別設(shè)置
    Isolation isolation() default Isolation.DEFAULT;
    // 事務(wù)超時時間設(shè)置
    int timeout() default -1;
    // 讀寫或只讀事務(wù),默認讀寫
    boolean readOnly() default false;
    // 導(dǎo)致事務(wù)回滾的異常類數(shù)組 
    Class[] rollbackFor() default {};
    // 導(dǎo)致事務(wù)回滾的異常類名字數(shù)組
    String[] rollbackForClassName() default {};
    // 不會導(dǎo)致事務(wù)回滾的異常類數(shù)組
    Class[] noRollbackFor() default {};
    // 不會導(dǎo)致事務(wù)回滾的異常類名字數(shù)組
    String[] noRollbackForClassName() default {};
}

Spring事務(wù)實踐

非入門選手下面的demo可能會引起你的不適(浪費時間)。
假設(shè)我要完成一個功能,當(dāng)刪除用戶的時候,將與該用戶有關(guān)的所有數(shù)據(jù)行都刪除。

public void delUser(Integer userId) {
    // 刪除和用戶相關(guān)的信息
     otherRepository.deleteByUserId(userId); 
    // 刪除用戶
     userRepository.deleteById(userId);
}

這樣的寫法一般來講,會成功的完成任務(wù)。但是如果這樣一段代碼:

public void delUser(Integer userId) {
    // 刪除和用戶相關(guān)的信息
    otherRepository.deleteByUserId();
    if (true) {
        throw new RuntimeException("xxx");
    }
    // 刪除用戶
     userRepository.deleteById(userId);
}

結(jié)果會是:deleteByUserId()執(zhí)行成功,deleteById()執(zhí)行失敗,不滿足數(shù)據(jù)的一致性。

所以我們需要事務(wù)來限制:要么全部執(zhí)行,要么全部不執(zhí)行(方法中有異常就自動回滾)。那怎么實現(xiàn)呢,只需要在方法上加一個注解:@Transactional

@Transactional
public void delUser(Integer userId) {
    // 刪除和用戶相關(guān)的信息
    otherRepository.deleteByUserId();
    if (true) {
        throw new RuntimeException("xxx");
    }
    // 刪除用戶
     userRepository.deleteById(userId);
}

Spring 加載第三方事務(wù)管理

比如我有個需求(接著上次的強票系統(tǒng)II),要求信息不能丟失,要用到RabbitMQ的事務(wù)管理,那怎么去加載到Spring的事務(wù)管理器中呢?

@Bean
public ConnectionFactory connectionFactory() {
    CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
    return connectionFactory;
}

@Bean
public RabbitTransactionManager rabbitTransactionManager(ConnectionFactory connectionFactory) {
    return new RabbitTransactionManager(connectionFactory);
}

我們只需要這樣做便可以使的使用@Transactional注解來實現(xiàn)對RabbitMQ的事務(wù)管理,其它框架也類似。


當(dāng)前文章:Spring事務(wù)管理—快速入門
網(wǎng)頁鏈接:http://www.dlmjj.cn/article/dhcgepo.html