Spring事務(wù)管理—快速入門
先來講講臟讀 不可重復(fù)讀 和 幻讀。
- 臟讀:我們在并發(fā)編程中是很熟悉的，通俗的講就是你讀得數(shù)據(jù)已經(jīng)被修改了，已經(jīng)過時(shí)失去意義了。
- 不可重復(fù)讀： 同一個(gè)事務(wù)里面多次讀取同一行數(shù)據(jù)，卻返回不同的結(jié)果。
- 幻讀：同樣一筆查詢在整個(gè)事務(wù)過程中多次執(zhí)行后，查詢所得的結(jié)果集不一樣。
事務(wù)四大特性 ACID
1、原子性(Atomicity)
要求事務(wù)所包含的全部操作是一個(gè)不可分割的整體，如果有一步發(fā)生異常，則全部不提交。
2、一致性（Consistency）
A給B轉(zhuǎn)錢，A減和B增這兩個(gè)操作必須保持一致。
3、隔離性（Isolation）
事務(wù)會將一部分?jǐn)?shù)據(jù)與其他事務(wù)隔離，防止臟讀等。
4、持久性（Durability）
事務(wù)的結(jié)果被寫到持久化存儲器中。
事務(wù)四大隔離級別
隔離級別越高，則性能相對越低，反之亦然。
1、Read Uncommitted
最低的隔離級別，跟你直譯的意思一樣：可以讀取其它事務(wù)未完成的結(jié)果。(臟讀)
很明顯，臟讀 不可重復(fù)讀 和 幻讀這三個(gè)問題它都有。
2、Read Committed
大部分?jǐn)?shù)據(jù)庫采用的默認(rèn)隔離級別，比上一個(gè)隔離級別多了限定：在該事務(wù)完成后，才能讀取該事務(wù)的數(shù)據(jù)更新后的結(jié)果。
它可以避免臟讀，但是也有不可重復(fù)讀取和幻讀的問題。
3、Repeatable Read
可以保證在整個(gè)事務(wù)的過程中，對同一筆數(shù)據(jù)的讀取結(jié)果是相同的，不管其他事務(wù)是否同時(shí)在對同一筆數(shù)據(jù)進(jìn)行更新，也不管其他事務(wù)對同一筆數(shù) 據(jù)的更新提交與否。
Repeatable Read隔離級別避免了臟讀和不可重復(fù)讀取的問題，但無法避免幻讀。
4、Serializable
最為嚴(yán)格的隔離級別，所有的事務(wù)操作都必須依次順序執(zhí)行，可以避免其他隔離級別遇到的所有問題，是最為安全的隔離級別， 但同時(shí)也是性能最差的隔離級別。
通常情況下，我們會使用其他隔離級別加上相應(yīng)的并發(fā)鎖的機(jī)制來控制對數(shù)據(jù)的訪問，這樣既保證 了系統(tǒng)性能不會損失太大，也能夠一定程度上保證數(shù)據(jù)的一致性。
Spring事務(wù)傳播機(jī)制
事務(wù)傳播行為 | 含義 |
PROPAGATION_REQUIRED(默認(rèn)) | 必須在事務(wù)中執(zhí)行，如果沒有，就新new一個(gè)新事務(wù) |
PROPAGATION_SUPPORTS | 誰調(diào)用我我就在誰的事務(wù)中執(zhí)行，沒有的話就沒有 |
PROPAGATION_MANDATORY | 必須要有事務(wù)，沒有就報(bào)錯(cuò) |
PROPAGATION_REQUIRED_NEW | 不管調(diào)用我的方法有沒有事務(wù)，我都new一個(gè)事務(wù) |
PROPAGATION_NOT_SUPPORTED | 調(diào)用我的方法有事務(wù)，但我不在事務(wù)中執(zhí)行 |
PROPAGATION_NEVER | 不允許在事務(wù)中運(yùn)行，有事務(wù)則報(bào)錯(cuò) |
PROPAGATION_NESTED | 有事務(wù)則嵌套，沒有則new一個(gè)新事務(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ù)機(jī)制
Spring并不會直接管理事務(wù)，而是提供了事務(wù)管理器，將事務(wù)管理的職責(zé)委托給JPA JDBC JTA DataSourceTransaction JMSTransactionManager 等框架提供的事務(wù)來實(shí)現(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 {
// 傳播機(jī)制
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默認(rèn)事務(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)代理實(shí)現(xiàn)，其實(shí)重新渲染出的代碼和第一個(gè)使用方式類似，不過大大減少了開發(fā)復(fù)雜度。
擴(kuò)展：@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í)時(shí)間設(shè)置
int timeout() default -1;
// 讀寫或只讀事務(wù)，默認(rèn)讀寫
boolean readOnly() default false;
// 導(dǎo)致事務(wù)回滾的異常類數(shù)組
Class<? extends Throwable>[] rollbackFor() default {};
// 導(dǎo)致事務(wù)回滾的異常類名字?jǐn)?shù)組
String[] rollbackForClassName() default {};
// 不會導(dǎo)致事務(wù)回滾的異常類數(shù)組
Class<? extends Throwable>[] noRollbackFor() default {};
// 不會導(dǎo)致事務(wù)回滾的異常類名字?jǐn)?shù)組
String[] noRollbackForClassName() default {};
}Spring事務(wù)實(shí)踐
非入門選手下面的demo可能會引起你的不適(浪費(fèi)時(shí)間)。
假設(shè)我要完成一個(gè)功能，當(dāng)刪除用戶的時(shí)候，將與該用戶有關(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í)行(方法中有異常就自動回滾)。那怎么實(shí)現(xiàn)呢，只需要在方法上加一個(gè)注解：@Transactional
@Transactional
public void delUser(Integer userId) {
// 刪除和用戶相關(guān)的信息
otherRepository.deleteByUserId();
if (true) {
throw new RuntimeException("xxx");
}
// 刪除用戶
userRepository.deleteById(userId);
}Spring 加載第三方事務(wù)管理
比如我有個(gè)需求(接著上次的強(qiáng)票系統(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注解來實(shí)現(xiàn)對RabbitMQ的事務(wù)管理,其它框架也類似。
