Spring框架七、Spring Transactional传播特性

2024-09-03 01:38
文章标签 java 特性 spring 框架 传播 transactional

本文主要是介绍Spring框架七、Spring Transactional传播特性，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、事务的传播特性

事务的传播特性指的是当一个事务方法被另一个事务方法调用时，这个事务方法应该如何进行？

spring的事务传播行为一共有7种：
在这里插入图片描述

二、测试事务的传播特性

1、环境准备

application_context.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:context="http://www.springframework.org/schema/context"xmlns:tx="http://www.springframework.org/schema/tx"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd"><context:property-placeholder location="classpath:db_config.properties"></context:property-placeholder><bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"><property name="username" value="${jdbc.username}"></property><property name="password" value="${jdbc.password}"></property><property name="url" value="${url}"></property><property name="driverClassName" value="${driverClassName}"></property></bean><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><constructor-arg name="dataSource" ref="dataSource"></constructor-arg></bean><context:component-scan base-package="com.bobo"></context:component-scan><!--事务控制--><!--配置事务管理器的bean--><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"></property></bean><!--开启基于注解的事务控制模式，依赖tx名称空间--><tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>
</beans>

db_config.properties

jdbc.username=root
jdbc.password=root
url=jdbc:mysql://localhost:3306/tx
driverClassName=com.mysql.jdbc.Driver

BookDao.java

package com.bobo.dao;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import org.springframework.jdbc.core.JdbcTemplate;@Repository
public class BookDao {@Autowiredprivate JdbcTemplate jdbcTemplate;/*** 按照图书的id来获取图书的价格** @param id* @return*/public int getPrice(int id) {String sql = "select price from book where id=?";return jdbcTemplate.queryForObject(sql, Integer.class, id);}/*** 减去某个用户的余额** @param username* @param price*/public void updateBalance(String username, int price) {String sql = "update account set balance=balance-? where username=?";jdbcTemplate.update(sql, price, username);}/*** 减库存，减去某本书的库存** @param id*/public void updateStock(int id) {String sql = "update book_stock set stock=stock-1 where id =?";jdbcTemplate.update(sql, id);}/*** 修改图书价格* @param id*/public void updatePrice(int id) {String sql = "update book set price=price-1 where id =?";jdbcTemplate.update(sql, id);}
}

BookService.java

package com.bobo.service;import com.bobo.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;@Service
public class BookService {@Autowiredprivate BookDao bookDao;/***  结账：传入哪个用户买了哪本书* @param username* @param id*/@Transactional(propagation = Propagation.REQUIRED)public void checkout(String username, int id) {int price = bookDao.getPrice(id);bookDao.updateBalance(username, price);bookDao.updateStock(id);int i = 1 / 0;}@Transactional(propagation = Propagation.REQUIRED)public void updatePrice(int id) {bookDao.updatePrice(id);
//        int i = 1 / 0;}
}

MultiBookService.java

package com.bobo.service;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;@Service
public class MultiBookService {@Autowiredprivate BookService bookService;@Transactionalpublic void multi(String username, int id) {bookService.checkout(username, id);bookService.updatePrice(id);}
}

单元测试：

import com.bobo.service.BookService;
import com.bobo.service.MultiBookService;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;public class MyTest {@Testpublic void test01() {ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("application_context.xml");MultiBookService multiBookService = context.getBean(MultiBookService.class);multiBookService.multi("lisi", 1);}
}

2、Propagation.REQUIRED

通过上图的结果发现，如果设置的传播特性是Required，那么所有的事务都会统一成一个事务，一旦发生错误，所有的数据都要进行回滚。

3、Propagation.REQUIRES_NEW

1、将checkout()方法设置为REQUIRED，而updatePrice()方法设置为REQUIRES_NEW，并且在updatePrice()方法报出异常。
package com.bobo.service;import com.bobo.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;@Service
public class BookService {@Autowiredprivate BookDao bookDao;/***  结账：传入哪个用户买了哪本书* @param username* @param id*/@Transactional(propagation = Propagation.REQUIRED)public void checkout(String username, int id) {int price = bookDao.getPrice(id);bookDao.updateBalance(username, price);bookDao.updateStock(id);}@Transactional(propagation = Propagation.REQUIRES_NEW)public void updatePrice(int id) {bookDao.updatePrice(id);int i = 1 / 0;}
}

测试结果：checkout和updatePrice方法都会回滚。

2、将checkout()方法设置为REQUIRES_NEW，而updatePrice()方法设置为REQUIRED，并且在updatePrice()方法报出异常。
package com.bobo.service;import com.bobo.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;@Service
public class BookService {@Autowiredprivate BookDao bookDao;/***  结账：传入哪个用户买了哪本书* @param username* @param id*/@Transactional(propagation = Propagation.REQUIRES_NEW)public void checkout(String username, int id) {int price = bookDao.getPrice(id);bookDao.updateBalance(username, price);bookDao.updateStock(id);}@Transactional(propagation = Propagation.REQUIRED)public void updatePrice(int id) {bookDao.updatePrice(id);int i = 1 / 0;}
}

测试结果：checkout()方法不会回滚，updatePrice()方法会发生回滚

3、将checkout()方法设置为REQUIRES_NEW，而updatePrice()方法设置为REQUIRED，并且在multi()方法报出异常。
package com.bobo.service;import com.bobo.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;@Service
public class BookService {@Autowiredprivate BookDao bookDao;/*** 结账：传入哪个用户买了哪本书** @param username* @param id*/@Transactional(propagation = Propagation.REQUIRES_NEW)public void checkout(String username, int id) {int price = bookDao.getPrice(id);bookDao.updateBalance(username, price);bookDao.updateStock(id);}@Transactional(propagation = Propagation.REQUIRED)public void updatePrice(int id) {bookDao.updatePrice(id);}
}
package com.bobo.service;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;@Service
public class MultiBookService {@Autowiredprivate BookService bookService;@Transactionalpublic void multi(String username, int id) {bookService.checkout(username, id);bookService.updatePrice(id);int i = 1 / 0;}
}

测试发现：checkout()方法不会回滚，updatePrice()方法会回滚

4、将checkout()方法和updatePrice()都设置为REQUIRES_NEW，并且在updatePrice()方法报出异常。
package com.bobo.service;import com.bobo.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;@Service
public class BookService {@Autowiredprivate BookDao bookDao;/*** 结账：传入哪个用户买了哪本书** @param username* @param id*/@Transactional(propagation = Propagation.REQUIRES_NEW)public void checkout(String username, int id) {int price = bookDao.getPrice(id);bookDao.updateBalance(username, price);bookDao.updateStock(id);}@Transactional(propagation = Propagation.REQUIRES_NEW)public void updatePrice(int id) {bookDao.updatePrice(id);int i = 1 / 0;}
}

测试发现：updatePrice()方法会回滚，checkout()方法不会回滚

4、Propagation.NESTED

1、将checkout()方法设置为Propagation.NESTED，updatePrice()设置为Propagation.REQUIRED，并且在updatePrice()方法报出异常。
package com.bobo.service;import com.bobo.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;@Service
public class BookService {@Autowiredprivate BookDao bookDao;/*** 结账：传入哪个用户买了哪本书** @param username* @param id*/@Transactional(propagation = Propagation.NESTED)public void checkout(String username, int id) {int price = bookDao.getPrice(id);bookDao.updateBalance(username, price);bookDao.updateStock(id);}@Transactional(propagation = Propagation.REQUIRED)public void updatePrice(int id) {bookDao.updatePrice(id);int i = 1 / 0;}
}

测试发现：updatePrice()方法和checkout()方法都会回滚

2、将checkout()方法设置为Propagation.NESTED，updatePrice()设置为Propagation.REQUIRES_NEW，并且在updatePrice()方法报出异常。
package com.bobo.service;import com.bobo.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;@Service
public class BookService {@Autowiredprivate BookDao bookDao;/*** 结账：传入哪个用户买了哪本书** @param username* @param id*/@Transactional(propagation = Propagation.NESTED)public void checkout(String username, int id) {int price = bookDao.getPrice(id);bookDao.updateBalance(username, price);bookDao.updateStock(id);}@Transactional(propagation = Propagation.REQUIRES_NEW)public void updatePrice(int id) {bookDao.updatePrice(id);int i = 1 / 0;}
}

测试发现：updatePrice()方法和checkout()方法都会回滚，和上面一样的结果。

三、总结

  1. 事务传播级别是REQUIRED，当checkout()被调用时（假定被另一类中commit()调用），如果checkout()中的代码抛出异常，即便被捕获，commit()中的其他代码都会roll back。
  2. 是REQUIRES_NEW，如果checkout()中的代码抛出异常，并且被捕获，commit()中的其他代码不会roll back；如果commit()中的其他代码抛出异常，而且没有捕获，不会导致checkout()回滚。
  3. 是NESTED，如果checkout()中的代码抛出异常，并且被捕获，commit()中的其他代码不会roll back；如果commit()中的其他代码抛出异常，而且没有捕获，会导致checkout()回滚。

PROPAGATION_REQUIRES_NEW 启动一个新的, 不依赖于环境的 “内部” 事务. 这个事务将被完全 commited 或 rolled back 而不依赖于外部事务, 它拥有自己的隔离范围, 自己的锁, 等等. 当内部事务开始执行时, 外部事务将被挂起, 内务事务结束时, 外部事务将继续执行.
另一方面, PROPAGATION_NESTED 开始一个 “嵌套的” 事务, 它是已经存在事务的一个真正的子事务. 嵌套事务开始执行时, 它将取得一个 savepoint. 如果这个嵌套事务失败, 我们将回滚到此 savepoint. 潜套事务是外部事务的一部分, 只有外部事务结束后它才会被提交.
由此可见, PROPAGATION_REQUIRES_NEW 和 PROPAGATION_NESTED 的最大区别在于, PROPAGATION_REQUIRES_NEW 完全是一个新的事务, 而 PROPAGATION_NESTED 则是外部事务的子事务, 如果外部事务 commit, 嵌套事务也会被 commit, 这个规则同样适用于 roll back.

这篇关于Spring框架七、Spring Transactional传播特性的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1131656。

相关文章

Java编译生成多个.class文件的原理和作用

Java编译生成多个.class文件的原理和作用

《Java编译生成多个.class文件的原理和作用》作为一名经验丰富的开发者,在Java项目中执行编译后,可能会发现一个.java源文件有时会产生多个.class文件,从技术实现层面详细剖析这一现象... 目录一、内部类机制与.class文件生成成员内部类（常规内部类）局部内部类（方法内部类）匿名内部类二、
阅读更多...
SpringBoot实现数据库读写分离的3种方法小结

SpringBoot实现数据库读写分离的3种方法小结

《SpringBoot实现数据库读写分离的3种方法小结》为了提高系统的读写性能和可用性,读写分离是一种经典的数据库架构模式,在SpringBoot应用中,有多种方式可以实现数据库读写分离,本文将介绍三... 目录一、数据库读写分离概述二、方案一：基于AbstractRoutingDataSource实现动态
阅读更多...
Springboot @Autowired和@Resource的区别解析

Springboot @Autowired和@Resource的区别解析

《Springboot@Autowired和@Resource的区别解析》@Resource是JDK提供的注解,只是Spring在实现上提供了这个注解的功能支持,本文给大家介绍Springboot@... 目录【一】定义【1】@Autowired【2】@Resource【二】区别【1】包含的属性不同【2】@
阅读更多...
springboot循环依赖问题案例代码及解决办法

springboot循环依赖问题案例代码及解决办法

《springboot循环依赖问题案例代码及解决办法》在SpringBoot中,如果两个或多个Bean之间存在循环依赖（即BeanA依赖BeanB,而BeanB又依赖BeanA）,会导致Spring的... 目录1. 什么是循环依赖？2. 循环依赖的场景案例3. 解决循环依赖的常见方法方法 1：使用 @La
阅读更多...
Java枚举类实现Key-Value映射的多种实现方式

Java枚举类实现Key-Value映射的多种实现方式

《Java枚举类实现Key-Value映射的多种实现方式》在Java开发中,枚举(Enum)是一种特殊的类,本文将详细介绍Java枚举类实现key-value映射的多种方式,有需要的小伙伴可以根据需要... 目录前言一、基础实现方式1.1 为枚举添加属性和构造方法二、http://www.cppcns.co
阅读更多...
Elasticsearch 在 Java 中的使用教程

Elasticsearch 在 Java 中的使用教程

《Elasticsearch在Java中的使用教程》Elasticsearch是一个分布式搜索和分析引擎,基于ApacheLucene构建,能够实现实时数据的存储、搜索、和分析,它广泛应用于全文... 目录1. Elasticsearch 简介2. 环境准备2.1 安装 Elasticsearch2.2 J
阅读更多...
Java中的String.valueOf()和toString()方法区别小结

Java中的String.valueOf()和toString()方法区别小结

《Java中的String.valueOf()和toString()方法区别小结》字符串操作是开发者日常编程任务中不可或缺的一部分,转换为字符串是一种常见需求,其中最常见的就是String.value... 目录String.valueOf()方法方法定义方法实现使用示例使用场景toString()方法方法
阅读更多...
Java中List的contains()方法的使用小结

Java中List的contains()方法的使用小结

《Java中List的contains()方法的使用小结》List的contains()方法用于检查列表中是否包含指定的元素,借助equals()方法进行判断,下面就来介绍Java中List的c... 目录详细展开1. 方法签名2. 工作原理3. 使用示例4. 注意事项总结结论：List 的 contain
阅读更多...
Java实现文件图片的预览和下载功能

Java实现文件图片的预览和下载功能

《Java实现文件图片的预览和下载功能》这篇文章主要为大家详细介绍了如何使用Java实现文件图片的预览和下载功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... Java实现文件（图片）的预览和下载 @ApiOperation("访问文件") @GetMapping("
阅读更多...
Spring Boot + MyBatis Plus 高效开发实战从入门到进阶优化(推荐)

Spring Boot + MyBatis Plus 高效开发实战从入门到进阶优化(推荐)

《SpringBoot+MyBatisPlus高效开发实战从入门到进阶优化(推荐)》本文将详细介绍SpringBoot+MyBatisPlus的完整开发流程,并深入剖析分页查询、批量操作、动... 目录Spring Boot + MyBATis Plus 高效开发实战：从入门到进阶优化1. MyBatis
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2