Spring之Transaction

什么是事务

事务是一系列操作组成的工作单元,该工作单元具有不可分割性,一损俱损。满足ACID(原子性,一致性,隔离性,持久性)

事务按分布式划分可以分为本地事务,和分布式事务

分别由JDBC事务JTA事务与其对应。

Transaction其实在某些具体业务上,是相当实用的利器。但是我在工作之前对他的认识只是停留在概念的层面,现在想想还是很有必要好好总结一下的。

事务最经典的例子就是银行转账问题,A用户转账5000元给B用户,如果在不发生任何意外的情况下,那么是一点问题没有的,但是如果这两部操作中间出现了意外(例如发生了异常),很有可能这500元只转出了,并没有转入。那么这个问题的根本原因是两个操作在代码层面来看是相互独立的,并不具备原子性导致的。Spring又是怎么解决这个问题的呢?

再来通过代码层面分析一下这个问题,转出的时候,我们通过DataSource拿到一个Connection对象,当执行没有异常的时候,直接提交事务,代码并不知道还有转入操作的存在。

所以spring针对这一点,如果在Service层的一个方法开启了事务,那么会关闭在这个方法中调用Dao方法自动提交事务的属性,等到整个service执行后再做提交,具体的步骤如下:

  1. 获取DataSource对象
  2. 通过DataSource对象获取对应的Connection对象
  3. 关闭事务的自动提交机制,在Connection对象中
  4. 把Connection对象绑定到当前线程中
  5. 在Dao中通过取得当前线程的Connection然后执行操作
  6. 如果整个Service都ok则Commit,否则进行rollback

事务的隔离机制

数据库的并发的问题,应运而生:例如说脏读,虚读,第一类丢失更新,第二类丢失更新。

解决的办法就是通过不同的隔离机制,进行隔离:

  • Read Uncommited
  • Read Commited
  • Repeatable Read
  • Serializable

Oracle 默认使用Read Comited, Mysql默认使用 Repeatable Read。

隔离机制越高,性能越差。

事务的传播规则

在一个事务方法中,调用了别的事务,应该按照什么规则进行传递。

传播规则一共分为七种:

现在有这样一种情况A方法调用了B方法。

  1. required:必须存在一个事务,如果有事务,则加入到该事务,如果没有则新建。解读:A如果有事务,B就用A的事务,如果A没有事务,则B新建一个事务
  2. supports:如果有事务,则用。没有则不用。解读:A如果有事务,B就用A的,A如果没有,B则不用事务。
  3. Mandatory:必须存在事务,当前如果有事务,则用。没有则直接报异常。解读:A如果有事务,B就用A的事务,如果没有,则直接报错。
  4. required_new: 不管当前是否存在事务,都会创建一个新的,这个在平常比较多。
  5. not_supports: 以非事务方式执行,如果当前存在事务,则将当前事务挂起 解读:A有自己的事务,B不使用A的事务,B不参与A事务的管理。
  6. never:不支持事务,当前如果存在事务,则抛出异常。
  7. nested:寄生事务。如果内部事务进行回滚,不会影响到外部事务,如果外部事务回滚了,内部事务会被影响。

Spring对事务的支持

Spring的事务管理一定要在业务层上的

  • PlatformTransactionManager 根据TransactionBefination提供的事务信息,进行配置。是多种事务管理器的基类。Hibernate使用的是HibernateTransactionManager,Mybatis/JDBC使用的是DataSourceTransactionManager。PlatformTransactionManager 一共拥有三个方法:
    • getTransaction(TransactionDefination),在当前环境中取得一个事务,如果不存在,则新建。有点像是一种缓存机制
    • commit:提交事务
    • rollback:回滚事务
  • TransactionDefination:封装了事务隔离级别,超时时间等。
  • TransactionStatus:封装了事务具体运行的状态,是否是新开的事务,是否已经提交事务
Xml方式进行配置:

下方是Spring官网给的例子

//业务接口:
public interface FooService {

    Foo getFoo(String fooName);

    Foo getFoo(String fooName, String barName);

    void insertFoo(Foo foo);

    void updateFoo(Foo foo);

}
<!--xml文件关于事务的配置-->
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        https://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/tx
        https://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/aop
        https://www.springframework.org/schema/aop/spring-aop.xsd">

    <!-- 首先将刚刚的业务类注入进容器中 -->
    <bean id="fooService" class="x.y.service.DefaultFooService"/>

   <!-- 配置数据库连接池,因为连接池会作为属性注入到TransactionManager中 -->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
        <property name="url" value="jdbc:oracle:thin:@rj-t42:1521:elvis"/>
        <property name="username" value="scott"/>
        <property name="password" value="tiger"/>
    </bean>

    <!-- 配置PlatformTransactionManager -->
    <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>
  
  <!-- 配置transaction 具体的一些配置 -->
    <tx:advice id="txAdvice" transaction-manager="txManager">
        <!-- the transactional semantics... -->
        <tx:attributes>
            <!-- 如果是方法名以get作为开头的,说明是查询方法,那么配置只读操作-->
            <tx:method name="get*" read-only="true"/>
            <!-- 其他的增和改操作,就是用默认的即可-->
            <tx:method name="*"/>
        </tx:attributes>
    </tx:advice>
  
    <!-- 使用Aop把transactionManager作为对业务逻辑的增强操作 -->
    <aop:config>
        <aop:pointcut id="fooServiceOperation" expression="execution(* x.y.service.FooService.*(..))"/>
        <aop:advisor advice-ref="txAdvice" pointcut-ref="fooServiceOperation"/>
    </aop:config> 

    <!-- other <bean/> definitions here -->

</beans>

<tx:advice/>中的一些详细配置,官网也给出了相应的一些说明,如下图:

Attribute Required? Default Description
name Yes 事务管理的方法名称,并且支持通配符,例如 get*, handle*, on*Event, 等等).
propagation No REQUIRED Transaction propagation behavior.
isolation No DEFAULT 事务的隔离级别,当传递规则为 REQUIRED or REQUIRES_NEW才可以设置,当是默认值default的时候,指的是使用数据库隔离级别。其他四种都是Spring 通过代码模拟出来的
timeout No -1 事务超时时间 (seconds),当传递规则为 REQUIRED or REQUIRES_NEW才可以设置,默认值-1代表使用数据库本身的值,一般情况下,不需要进行修改。
read-only No false 一般对查询进行设置只读,可以提升事务的效率。只应用于 REQUIRED or REQUIRES_NEW.
rollback-for No java.lang.RunTimeException 遇到什么异常需要做事务的回滚,例如,com.foo.MyBusinessException,ServletException.
no-rollback-for No 遇到什么异常不做回滚,com.foo.MyBusinessException,ServletException.
Java注解方式

首先我们需要在配置类上,开启对事务的支持,使用@EnableTransactionManagement

官网的例子:

@Transactional(readOnly = true)
public class DefaultFooService implements FooService {

    public Foo getFoo(String fooName) {
        // do something
    }

    // these settings have precedence for this method
    @Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
    public void updateFoo(Foo foo) {
        // do something
    }
}

@Transactional 注解可以用来放在实现类上,也可以放在接口上,最好是放在实现类上。如果加在了实现类上,那么也就是说对这个类里的所有方法都支持开启事务。如果有哪个类需要一些定制化的属性,只需要在方法上再加上这个注解并且贴上定制的属性即可。

@Transactional可以使用的属性:

Property Type Description
value String
propagation enum: Propagation
isolation enum: Isolation 隔离级别的设置,用于传递属性为 REQUIRED or REQUIRES_NEW.
timeout int (in seconds of granularity) 事务超时时间用于传递属性为REQUIRES_NEW.
readOnly boolean 是否为只读. 用于传递属性为 REQUIRES_NEW.
rollbackFor Array of Class objects, which must be derived from Throwable.
rollbackForClassName Array of class names. The classes must be derived from Throwable. 哪些异常类处罚会导致回滚(使用异常类名)
noRollbackFor Array of Class objects, which must be derived from Throwable. 哪些异常类处罚不会导致回滚(使用异常类)
noRollbackForClassName Array of String class names, which must be derived from Throwable. 哪些异常类处罚不会导致回滚(使用异常类名)

可以看出来这些属性与xml配置的大同小异。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,547评论 6 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,399评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,428评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,599评论 1 274
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,612评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,577评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,941评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,603评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,852评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,605评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,693评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,375评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,955评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,936评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,172评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,970评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,414评论 2 342

推荐阅读更多精彩内容