Spring事务管理—快速入门

2023年 10月 8日 83.4k 0

先来讲讲脏读 不可重复读 和 幻读。

  • 脏读:我们在并发编程中是很熟悉的,通俗的讲就是你读得数据已经被修改了,已经过时失去意义了。
  • 不可重复读: 同一个事务里面多次读取同一行数据,却返回不同的结果。
  • 幻读:同样一笔查询在整个事务过程中多次执行后,查询所得的结果集不一样。

事务四大特性 ACID

1、原子性(Atomicity)

要求事务所包含的全部操作是一个不可分割的整体,如果有一步发生异常,则全部不提交。

2、一致性(Consistency)

A给B转钱,A减和B增这两个操作必须保持一致。

3、隔离性(Isolation)

事务会将一部分数据与其他事务隔离,防止脏读等。

4、持久性(Durability)

事务的结果被写到持久化存储器中。

事务四大隔离级别

隔离级别越高,则性能相对越低,反之亦然。

1、Read Uncommitted

最低的隔离级别,跟你直译的意思一样:可以读取其它事务未完成的结果。(脏读)

很明显,脏读 不可重复读 和 幻读这三个问题它都有。

2、Read Committed

大部分数据库采用的默认隔离级别,比上一个隔离级别多了限定:在该事务完成后,才能读取该事务的数据更新后的结果。

它可以避免脏读,但是也有不可重复读取和幻读的问题。

3、Repeatable Read

可以保证在整个事务的过程中,对同一笔数据的读取结果是相同的,不管其他事务是否同时在对同一笔数据进行更新,也不管其他事务对同一笔数 据的更新提交与否。

Repeatable Read隔离级别避免了脏读和不可重复读取的问题,但无法避免幻读。

4、Serializable

最为严格的隔离级别,所有的事务操作都必须依次顺序执行,可以避免其他隔离级别遇到的所有问题,是最为安全的隔离级别, 但同时也是性能最差的隔离级别。

通常情况下,我们会使用其他隔离级别加上相应的并发锁的机制来控制对数据的访问,这样既保证 了系统性能不会损失太大,也能够一定程度上保证数据的一致性。

Spring事务传播机制

事务传播行为

含义

PROPAGATION_REQUIRED(默认)

必须在事务中执行,如果没有,就新new一个新事务

PROPAGATION_SUPPORTS

谁调用我我就在谁的事务中执行,没有的话就没有

PROPAGATION_MANDATORY

必须要有事务,没有就报错

PROPAGATION_REQUIRED_NEW

不管调用我的方法有没有事务,我都new一个事务

PROPAGATION_NOT_SUPPORTED

调用我的方法有事务,但我不在事务中执行

PROPAGATION_NEVER

不允许在事务中运行,有事务则报错

PROPAGATION_NESTED

有事务则嵌套,没有则new一个新事务

从JDBC的事务说起

我们都知道,JDBC给我们提供了事务。

try{
     con.setAutoCommit(false);//开启事务
     ......
     con.commit();//try的最后提交事务      
} catch() {
    con.rollback();//回滚事务
}

获取事务隔离级别。

Connection.getTransactionIsolation()

设置事务隔离级别。

con.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);

Spring事务机制

Spring并不会直接管理事务,而是提供了事务管理器,将事务管理的职责委托给JPA JDBC JTA DataSourceTransaction JMSTransactionManager 等框架提供的事务来实现。

那么,Spring提供的事务管理器是什么呢?

是PlatformTransactionManager.java接口:

PlatformTransactionManager.java

Spring提供的事务管理器。不同的事务遵循该事务管理器的API,便能很轻松的交给Spring管理。

public interface PlatformTransactionManager {
    // 通过Transation定义 获取Transation
    TransactionStatus getTransaction(@Nullable TransactionDefinition var1) throws TransactionException;
    // 提交事务
    void commit(TransactionStatus var1) throws TransactionException;
    // 回滚事务
    void rollback(TransactionStatus var1) throws TransactionException;
}

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

TransactionDefinition.java

它里面包含了事务的定义。

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

事务的状态。

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

    boolean hasSavepoint();

    void setRollbackOnly();

    boolean isRollbackOnly();

    void flush();

    boolean isCompleted();
}

Spring默认事务使用

1、代码方式使用

@Autowired
private PlatformTransactionManager transactionManager;
public void testTX(){
    DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
    TransactionStatus status = transactionManager.getTransaction(definition);
    try {
        // 业务逻辑
        // ...
        
        // 提交事务
        transactionManager.commit(status);
    }catch (Exception e){
        // 发生异常,事务回滚
        transactionManager.rollback(status);
    }
}

2、注解方式使用

@Transactional
void testTX2(){
    // 业务逻辑 ...
}

这不是玄学,它的底层是依靠AOP动态代理实现,其实重新渲染出的代码和第一个使用方式类似,不过大大减少了开发复杂度。

扩展:@Transactional注解

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

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

@AliasFor("value")
String transactionManager() default "";
// 可选的事务传播行为设置
Propagation propagation() default Propagation.REQUIRED;
// 可选的事务隔离级别设置
Isolation isolation() default Isolation.DEFAULT;
// 事务超时时间设置
int timeout() default -1;
// 读写或只读事务,默认读写
boolean readOnly() default false;
// 导致事务回滚的异常类数组
Class

相关文章

JavaScript2024新功能:Object.groupBy、正则表达式v标志
PHP trim 函数对多字节字符的使用和限制
新函数 json_validate() 、randomizer 类扩展…20 个PHP 8.3 新特性全面解析
使用HTMX为WordPress增效:如何在不使用复杂框架的情况下增强平台功能
为React 19做准备:WordPress 6.6用户指南
如何删除WordPress中的所有评论

发布评论