前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Spring详解--一篇文章让你弄懂spring事物管理

Spring详解--一篇文章让你弄懂spring事物管理

作者头像
Java编程指南
发布2019-08-02 11:45:11
4600
发布2019-08-02 11:45:11
举报
文章被收录于专栏:Java编程指南Java编程指南

前言:

本文篇幅有些长,希望能耐心看完一定对你有很大帮助。

1、事务介绍

  事务(Transaction),一般是指要做的或所做的事情。在计算机术语中是指访问并可能更新数据库中各种数据项的一个程序执行单元(unit)。

  这里我们以取钱的例子来讲解:比如你去ATM机取1000块钱,大体有两个步骤:第一步输入密码金额,银行卡扣掉1000元钱;第二步从ATM出1000元钱。这两个步骤必须是要么都执行要么都不执行。如果银行卡扣除了1000块但是ATM出钱失败的话,你将会损失1000元;如果银行卡扣钱失败但是ATM却出了1000块,那么银行将损失1000元。

  如何保证这两个步骤不会出现一个出现异常了,而另一个执行成功呢?事务就是用来解决这样的问题。事务是一系列的动作,它们综合在一起才是一个完整的工作单元,这些动作必须全部完成,如果有一个失败的话,那么事务就会回滚到最开始的状态,仿佛什么都没发生过一样。 在企业级应用程序开发中,事务管理是必不可少的技术,用来确保数据的完整性和一致性。

2、事务的四个特性(ACID)

  ①、原子性(Atomicity):事务是一个原子操作,由一系列动作组成。事务的原子性确保动作要么全部完成,要么完全不起作用。

  ②、一致性(Consistency):一旦事务完成(不管成功还是失败),系统必须确保它所建模的业务处于一致的状态,而不会是部分完成部分失败。在现实中的数据不应该被破坏。

  ③、隔离性(Isolation):可能有许多事务会同时处理相同的数据,因此每个事务都应该与其他事务隔离开来,防止数据损坏。

  ④、持久性(Durability):一旦事务完成,无论发生什么系统错误,它的结果都不应该受到影响,这样就能从任何系统崩溃中恢复过来。通常情况下,事务的结果被写到持久化存储器中。

3、Spring 事务管理的核心接口

  首先我们创建一个Java工程,然后导入 Spring 核心事务包

  我们打开Spring的核心事务包,查看如下类:org.springframework.transaction

  上面所示的三个类文件便是Spring的事务管理接口。如下图所示:下面我们分别对这三个接口进行简单的介绍

4、 PlatformTransactionManager 事务管理器

Spring事务管理器的接口是org.springframework.transaction.PlatformTransactionManager,如上图所示,Spring并不直接管理事务,通过这个接口,Spring为各个平台如JDBC、Hibernate等都提供了对应的事务管理器,也就是将事务管理的职责委托给Hibernate或者JTA等持久化机制所提供的相关平台框架的事务来实现。

我们进入到 PlatformTransactionManager 接口,查看源码:

  ①、TransactionStatus getTransaction(TransactionDefinition definition) ,事务管理器 通过TransactionDefinition,获得“事务状态”,从而管理事务。

  ②、void commit(TransactionStatus status) 根据状态提交

  ③、void rollback(TransactionStatus status) 根据状态回滚

  也就是说Spring事务管理的为不同的事务API提供一致的编程模型,具体的事务管理机制由对应各个平台去实现。

  比如下面我们导入实现事务管理的两种平台:JDBC和Hibernate

  然后我们再次查看PlatformTransactionManager接口,会发现它多了几个实现类,如下:

5、TransactionStatus 事务状态

  在上面 PlatformTransactionManager 接口中,有如下方法:

  这个方法返回的是 TransactionStatus对象,然后程序根据返回的对象来获取事务状态,然后进行相应的操作。

  而 TransactionStatus 这个接口的内容如下:

  这个接口描述的是一些处理事务提供简单的控制事务执行和查询事务状态的方法,在回滚或提交的时候需要应用对应的事务状态。

6、TransactionDefinition 基本事务属性的定义

  上面讲到的事务管理器接口PlatformTransactionManager通过getTransaction(TransactionDefinition definition)方法来得到事务,这个方法里面的参数是TransactionDefinition类,这个类就定义了一些基本的事务属性。

那么什么是事务属性呢?事务属性可以理解成事务的一些基本配置,描述了事务策略如何应用到方法上。事务属性包含了5个方面,如图所示:

  TransactionDefinition 接口方法如下:

一、传播行为:当事务方法被另一个事务方法调用时,必须指定事务应该如何传播。

    Spring 定义了如下七中传播行为,这里以A业务和B业务之间如何传播事务为例说明:

  ①、PROPAGATION_REQUIRED :required , 必须。默认值,A如果有事务,B将使用该事务;如果A没有事务,B将创建一个新的事务。

  ②、PROPAGATION_SUPPORTS:supports ,支持。A如果有事务,B将使用该事务;如果A没有事务,B将以非事务执行。

  ③、PROPAGATION_MANDATORY:mandatory ,强制。A如果有事务,B将使用该事务;如果A没有事务,B将抛异常。

  ④、PROPAGATION_REQUIRES_NEW :requires_new,必须新的。如果A有事务,将A的事务挂起,B创建一个新的事务;如果A没有事务,B创建一个新的事务。

  ⑤、PROPAGATION_NOT_SUPPORTED :not_supported ,不支持。如果A有事务,将A的事务挂起,B将以非事务执行;如果A没有事务,B将以非事务执行。

  ⑥、PROPAGATION_NEVER :never,从不。如果A有事务,B将抛异常;如果A没有事务,B将以非事务执行。

  ⑦、PROPAGATION_NESTED :nested ,嵌套。A和B底层采用保存点机制,形成嵌套事务。

二、隔离级别:定义了一个事务可能受其他并发事务影响的程度。

  并发事务引起的问题:

在典型的应用程序中,多个事务并发运行,经常会操作相同的数据来完成各自的任务。并发虽然是必须的,但可能会导致以下的问题。

①、脏读(Dirty reads)——脏读发生在一个事务读取了另一个事务改写但尚未提交的数据时。如果改写在稍后被回滚了,那么第一个事务获取的数据就是无效的。

②、不可重复读(Nonrepeatable read)——不可重复读发生在一个事务执行相同的查询两次或两次以上,但是每次都得到不同的数据时。这通常是因为另一个并发事务在两次查询期间进行了更新。

    ③、幻读(Phantom read)——幻读与不可重复读类似。它发生在一个事务(T1)读取了几行数据,接着另一个并发事务(T2)插入了一些数据时。在随后的查询中,第一个事务(T1)就会发现多了一些原本不存在的记录。

注意:不可重复读重点是修改,而幻读重点是新增或删除。

  在 Spring 事务管理中,为我们定义了如下的隔离级别:

  ①、ISOLATION_DEFAULT:使用后端数据库默认的隔离级别

  ②、ISOLATION_READ_UNCOMMITTED:最低的隔离级别,允许读取尚未提交的数据变更,可能会导致脏读、幻读或不可重复读

  ③、ISOLATION_READ_COMMITTED:允许读取并发事务已经提交的数据,可以阻止脏读,但是幻读或不可重复读仍有可能发生

  ④、ISOLATION_REPEATABLE_READ:对同一字段的多次读取结果都是一致的,除非数据是被本身事务自己所修改,可以阻止脏读和不可重复读,但幻读仍有可能发生

  ⑤、ISOLATION_SERIALIZABLE:最高的隔离级别,完全服从ACID的隔离级别,确保阻止脏读、不可重复读以及幻读,也是最慢的事务隔离级别,因为它通常是通过完全锁定事务相关的数据库表来实现的

  上面定义的隔离级别,在 Spring 的 TransactionDefinition.class 中也分别用常量 -1,0,1,2,4,8表示。比如 ISOLATION_DEFAULT 的定义:

三、只读

  这是事务的第三个特性,是否为只读事务。如果事务只对后端的数据库进行该操作,数据库可以利用事务的只读特性来进行一些特定的优化。通过将事务设置为只读,你就可以给数据库一个机会,让它应用它认为合适的优化措施。

四、事务超时

为了使应用程序很好地运行,事务不能运行太长的时间。因为事务可能涉及对后端数据库的锁定,所以长时间的事务会不必要的占用数据库资源。事务超时就是事务的一个定时器,在特定时间内事务如果没有执行完毕,那么就会自动回滚,而不是一直等待其结束。

五、回滚规则

  事务五边形的最后一个方面是一组规则,这些规则定义了哪些异常会导致事务回滚而哪些不会。默认情况下,事务只有遇到运行期异常时才会回滚,而在遇到检查型异常时不会回滚(这一行为与EJB的回滚行为是一致的) 。但是你可以声明事务在遇到特定的检查型异常时像遇到运行期异常那样回滚。同样,你还可以声明事务遇到特定的异常不回滚,即使这些异常是运行期异常。

7、Spring 编程式事务和声明式事务的区别 

编程式事务处理:所谓编程式事务指的是通过编码方式实现事务,允许用户在代码中精确定义事务的边界。即类似于JDBC编程实现事务管理。管理使用TransactionTemplate或者直接使用底层的PlatformTransactionManager。对于编程式事务管理,spring推荐使用TransactionTemplate。

声明式事务处理:管理建立在AOP之上的。其本质是对方法前后进行拦截,然后在目标方法开始之前创建或者加入一个事务,在执行完目标方法之后根据执行情况提交或者回滚事务。声明式事务最大的优点就是不需要通过编程的方式管理事务,这样就不需要在业务逻辑代码中掺杂事务管理的代码,只需在配置文件中做相关的事务规则声明(或通过基于@Transactional注解的方式),便可以将事务规则应用到业务逻辑中。

  简单地说,编程式事务侵入到了业务代码里面,但是提供了更加详细的事务管理;而声明式事务由于基于AOP,所以既能起到事务管理的作用,又可以不影响业务代码的具体实现。

8、不用事务实现转账

  我们还是以转账为实例。不用事务看如何实现转账。在数据库中有如下表 account ,内容如下:

  有两个用户 Tom 和 Marry 。他们初始账户余额都为 10000。这时候我们进行如下业务:Tom 向 Marry 转账 1000 块。那么这在程序中可以分解为两个步骤:

  ①、Tom 的账户余额 10000 减少 1000 块,剩余 9000 块。

  ②、Marry 的账户余额 10000 增加 1000 块,变为 11000块

  上面两个步骤要么都执行成功,要么都不执行。我们通过 TransactionTemplate 编程式事务来控制:

第一步:创建Java工程并导入相应的 jar 包(这里不用事务其实不需要这么多jar包,为了后面的讲解需要,我们一次性导入所有的jar包)

第二步:编写 Dao 层

    AccountDao 接口:

代码语言:javascript
复制
package com.ys.dao;

public interface AccountDao {

    /**

     * 汇款

     * @param outer 汇款人

     * @param money 汇款金额

     */

    public void out(String outer,int money);

    /**

     * 收款

     * @param inner 收款人

     * @param money 收款金额

     */

    public void in(String inner,int money);

}

AccountDaoImpl 接口实现类

代码语言:javascript
复制
package com.ys.dao.impl;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

import com.ys.dao.AccountDao;

public class AccountDaoImpl extends JdbcDaoSupport implements AccountDao {

    /**

     * 根据用户名减少账户金额

     */

    @Override

    public void out(String outer, int money) {

        this.getJdbcTemplate().update("update account set money = money - ? where username = ?",money,outer);

    }

    /**

     * 根据用户名增加账户金额

     */

    @Override

    public void in(String inner, int money) {

        this.getJdbcTemplate().update("update account set money = money + ? where username = ?",money,inner);

    }

}

第三步:实现 Service 层

    AccountService 接口

代码语言:javascript
复制
package com.ys.service;

public interface AccountService {

    /**

     * 转账

     * @param outer 汇款人

     * @param inner 收款人

     * @param money 交易金额

     */

    public void transfer(String outer,String inner,int money);

}

AccountServiceImpl 接口实现类

代码语言:javascript
复制
package com.ys.service.impl;

import com.ys.dao.AccountDao;

import com.ys.service.AccountService;

public class AccountServiceImpl implements AccountService{

    private AccountDao accountDao;

    public void setAccountDao(AccountDao accountDao) {

        this.accountDao = accountDao;

    }

    @Override

    public void transfer(String outer, String inner, int money) {

        accountDao.out(outer, money);

        accountDao.in(inner, money);

    }

}

第四步:Spring 全局配置文件 applicationContext.xml

代码语言:javascript
复制
<?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:context="http://www.springframework.org/schema/context"

       xmlns:aop="http://www.springframework.org/schema/aop"

       xsi:schemaLocation="http:

                           http:

                           http:

                           http:

                           http:

                           http:

    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">

        <property name="driverClass" value="com.mysql.jdbc.Driver"></property>

        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test"></property>

        <property name="user" value="root"></property>

        <property name="password" value="root"></property>

    </bean>

    <bean id="accountDao" class="com.ys.dao.impl.AccountDaoImpl">

        <property name="dataSource" ref="dataSource"></property>

    </bean>

    <bean id="accountService" class="com.ys.service.impl.AccountServiceImpl">

        <property name="accountDao" ref="accountDao"></property>

    </bean>

</beans>

第五步:测试

代码语言:javascript
复制
public class TransactionTest {

    @Test

    public void testNoTransaction(){

        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");

        AccountService account = (AccountService) context.getBean("accountService");

        account.transfer("Tom", "Marry", 1000);

    }

}

第六步:查看数据库表 account

  上面的结果和我们想的一样,Tom 账户 money 减少了1000块。而 Marry 账户金额增加了1000块。

  这时候问题来了,比如在 Tom 账户 money 减少了1000块正常。而 Marry 账户金额增加时发生了异常,实际应用中比如断电(这里我们人为构造除数不能为0的异常),如下:

  那么这时候我们执行测试程序,很显然会报错,那么数据库是什么情况呢?

  数据库account :

  我们发现,程序执行报错了,但是数据库 Tom 账户金额依然减少了 1000 块,但是 Marry 账户的金额却没有增加。这在实际应用中肯定是不允许的,那么如何解决呢?

本文参与 腾讯云自媒体分享计划,分享自微信公众号。
原始发表:2019-03-19,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 Java编程指南 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1、事务介绍
  • 2、事务的四个特性(ACID)
  • 3、Spring 事务管理的核心接口
  • 4、 PlatformTransactionManager 事务管理器
  • 5、TransactionStatus 事务状态
  • 6、TransactionDefinition 基本事务属性的定义
  • 7、Spring 编程式事务和声明式事务的区别 
  • 8、不用事务实现转账
相关产品与服务
数据库
云数据库为企业提供了完善的关系型数据库、非关系型数据库、分析型数据库和数据库生态工具。您可以通过产品选择和组合搭建,轻松实现高可靠、高可用性、高性能等数据库需求。云数据库服务也可大幅减少您的运维工作量,更专注于业务发展,让企业一站式享受数据上云及分布式架构的技术红利!
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档