今天在工作中遇到了一個(gè)spring事務(wù)的問題：

在service方法內(nèi)需要通過線程去執(zhí)行添加用戶積分和用戶積分日志的情況，試了下通過@Transactional聲明式事務(wù)不起作用，只能使用手動(dòng)事務(wù)去控制

因此寫了這篇博客,記錄一下這個(gè)情況

一、事務(wù)的重要性

相信在實(shí)際開發(fā)過程中，都有很深的了解了。

但是存在一個(gè)問題我們經(jīng)常在開發(fā)的時(shí)候一般情況下都是用的注解的方式來進(jìn)行事務(wù)的控制，說白了基于spring的7種事務(wù)控制方式來進(jìn)行事務(wù)的之間的協(xié)調(diào)。

二、spring的7中事務(wù)傳播行為

三、數(shù)據(jù)庫四大特性和MySQL事務(wù)的隔離級(jí)別

1）四大特性

a、原子性（Atomicity）　　

原子性是指事務(wù)包含的所有操作要么全部成功，要么全部失敗回滾。

b、 一致性（Consistency）　　

一致性是指事務(wù)必須使數(shù)據(jù)庫從一個(gè)一致性狀態(tài)變換到另一個(gè)一致性狀態(tài)，也就是說一個(gè)事務(wù)執(zhí)行之前和執(zhí)行之后都必須處于一致性狀態(tài)。

c、隔離性（Isolation）　　

隔離性是當(dāng)多個(gè)用戶并發(fā)訪問數(shù)據(jù)庫時(shí)，比如操作同一張表時(shí)，數(shù)據(jù)庫為每一個(gè)用戶開啟的事務(wù)，不能被其他事務(wù)的操作所干擾，多個(gè)并發(fā)事務(wù)之間要相互隔離。

d、 持久性（Durability）　　

持久性是指一個(gè)事務(wù)一旦被提交了，那么對(duì)數(shù)據(jù)庫中的數(shù)據(jù)的改變就是永久性的，即便是在數(shù)據(jù)庫系統(tǒng)遇到故障的情況下也不會(huì)丟失提交事務(wù)的操作。

2）隔離級(jí)別

a、臟讀是指在一個(gè)事務(wù)處理過程里讀取了另一個(gè)未提交的事務(wù)中的數(shù)據(jù)。（讀取未提交的數(shù)據(jù)）

b、不可重復(fù)讀是指在對(duì)于數(shù)據(jù)庫中的某個(gè)數(shù)據(jù)，一個(gè)事務(wù)范圍內(nèi)多次查詢卻返回了不同的數(shù)據(jù)值，這是由于在查詢間隔，被另一個(gè)事務(wù)修改并提交了。（邊讀邊寫）

c、幻讀指兩個(gè)事務(wù)同時(shí)發(fā)生，兩個(gè)事務(wù)修改數(shù)據(jù)，讀到的數(shù)據(jù)不是自己開始修改的數(shù)據(jù)?；米x和不可重復(fù)讀都是讀取了另一條已經(jīng)提交的事務(wù)（這點(diǎn)就臟讀不同），所不同的是不可重復(fù)讀查詢的都是同一個(gè)數(shù)據(jù)項(xiàng)，而幻讀針對(duì)的是一批數(shù)據(jù)整體。（同時(shí)寫，同時(shí)讀）

3）數(shù)據(jù)庫事務(wù)級(jí)別

默認(rèn)使用Repeatable read級(jí)別，列表級(jí)別從下往上級(jí)別越低。

查看級(jí)別

select @@tx_isolation;

四、寫上面spring事務(wù)和數(shù)據(jù)庫事務(wù)隔離級(jí)別

主要的目的就是了解事務(wù)之間存在的傳遞關(guān)系，這樣在控制的時(shí)候，spring會(huì)通過事務(wù)與事務(wù)之間關(guān)系，來達(dá)到回滾或者提交的效果。

五、如果在沒有辦法使用注解的時(shí)候（比如多線程等）

就要使用手動(dòng)的方式來做事務(wù)管理了，這也就是編程式的事務(wù)管理。

1）首先加入注解

這就是spring的jdbc框架中提供的事務(wù)管理方式

    @Autowired
    private PlatformTransactionManager platformTransactionManager;

    @Autowired
    private TransactionDefinition transactionDefinition;

2）看一下源碼

（DataSourceTransactionManagerAutoConfiguration.class、TransactionTemplate.class）

        @Bean
        @ConditionalOnMissingBean({PlatformTransactionManager.class})
        public DataSourceTransactionManager transactionManager(DataSourceProperties properties) {
            DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(this.dataSource);
            if (this.transactionManagerCustomizers != null) {
                this.transactionManagerCustomizers.customize(transactionManager);
            }

            return transactionManager;
        }

備注：有興趣可以了解一下DataSourceTransactionManager的寫法和原理。

        @Bean
        @ConditionalOnMissingBean
        public TransactionTemplate transactionTemplate() {
            return new TransactionTemplate(this.transactionManager);
        }

注意，這里的所有事務(wù)傳播方式包括處理，都需要自己手動(dòng)去處理。

3）編寫方式

TransactionStatus transactionStatus = platformTransactionManager.getTransaction(transactionDefinition);
platformTransactionManager.commit(transactionStatus);
platformTransactionManager.rollback(transactionStatus);

說明：這里開發(fā)事務(wù)過后，返回一個(gè)事務(wù)狀態(tài)，這個(gè)狀態(tài)記錄了東西，用來控制事務(wù)的管理，當(dāng)然，多個(gè)事務(wù)之間的控制需要人為控制。

4）編程式的事務(wù)控制經(jīng)量少用

因?yàn)榭刂瞥潭壬厦鎭碚fspring的方式還是來的更加不錯(cuò)，編程式的方式，更多用于在需要事務(wù)的時(shí)候，沒有辦法加入事務(wù)，才采取手動(dòng)控制事務(wù)的方式。

使用示例 :

1 在service內(nèi)注入 這兩個(gè)bean 
@Autowired
private PlatformTransactionManager platformTransactionManager;

@Autowired
private TransactionDefinition transactionDefinition;

2在 service方法內(nèi)創(chuàng)建TransactionStatus
TransactionStatus transactionStatus = platformTransactionManager.getTransaction(transactionDefinition);
通過 platformTransactionManager.commit(transactionStatus); 提交事務(wù)
通過 platformTransactionManager.rollback(transactionStatus); 回滾事務(wù) 

示例代碼: 

@Autowired
private PlatformTransactionManager platformTransactionManager;

@Autowired
private TransactionDefinition transactionDefinition;

public void b(){
    TransactionStatus transactionStatus = platformTransactionManager.getTransaction(transactionDefinition);

    UserIntegralInfo info = new UserIntegralInfo();
    info.setUserId(1L);
    info.setPoint(1);
    info.setOp("");
    info.setCurrIntegral(1);
    integralMapper.insert(info);
    platformTransactionManager.commit(transactionStatus);
    throw new RuntimeException();
}

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

最新評(píng)論