Spring-4-掌握Spring事务传播机制

news2025/1/24 14:36:01

今日目标

能够掌握Spring事务配置

Spring事务管理

1 Spring事务简介【重点】

1.1 Spring事务作用

  • 事务作用:在数据层保障一系列的数据库操作同成功同失败

  • Spring事务作用:在数据层或业务层保障一系列的数据库操作同成功同失败

1.2 案例分析Spring事务

  • 需求:实现任意两个账户间转账操作

  • 需求微缩:A账户减钱,B账户加钱

  • 分析: ①:数据层提供基础操作,指定账户减钱(outMoney),指定账户加钱(inMoney) ②:业务层提供转账操作(transfer),调用减钱与加钱的操作 ③:提供2个账号和操作金额执行转账操作 ④:基于Spring整合MyBatis环境搭建上述操作

  • 结果分析: ①:程序正常执行时,账户金额A减B加,没有问题 ②:程序出现异常后,转账失败,但是异常之前操作成功,异常之后操作失败,整体业务失败

  • 结构:

1.3 代码实现

【前置工作】环境准备

创建数据库和表

CREATE DATABASE IF NOT EXISTS `spring_db2` DEFAULT CHARACTER SET utf8
USE `spring_db2`;

DROP TABLE IF EXISTS `tbl_account`;
CREATE TABLE `tbl_account` (
                               `id` INT(11NOT NULL AUTO_INCREMENT,
                               `name` VARCHAR(20DEFAULT NULL,
                               `money` DOUBLE DEFAULT NULL,
                               PRIMARY KEY (`id`)
) ENGINE=INNODB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

INSERT  INTO `tbl_account`(`id`,`name`,`money`VALUES
(1,'Jack',1000),
(2,'Rose',1000);

DROP TABLE IF EXISTS `tbl_log`;
CREATE TABLE `tbl_log` (
                           `id` INT(11NOT NULL AUTO_INCREMENT,
                           `info` VARCHAR(255DEFAULT NULL,
                           `create_date` DATETIME DEFAULT NULL,
                           PRIMARY KEY (`id`)
) ENGINE=INNODB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

INSERT  INTO `tbl_log`(`id`,`info`,`create_date`VALUES
(2,'Jack向Rose转账520.0元','2021-11-04 17:19:18');

pom.xml添加依赖

    <dependencies>
        <!--导入spring的坐标spring-context,对应版本是5.2.10.RELEASE-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.3.15</version>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.28</version>
        </dependency>


        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.3.15</version>
        </dependency>
<!--mysql-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.27</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/org.mybatis/mybatis -->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.5.13</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>1.3.0</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/com.alibaba/druid -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.2.18</version>
        </dependency>

        <!--junit,spring对junit4的要求必须是4.12版本以上-->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13</version>
            <scope>test</scope>
        </dependency>
        <!--spring-test-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.3.22</version>
            <scope>test</scope>
        </dependency>

    </dependencies>

Spring整合Mybatis相关代码(依赖、JdbcConfig、MybatisConfig、SpringConfig) JdbcConfig

package com.zbbmeta.config;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;

import javax.sql.DataSource;


public class JdbcConfig {
    @Value("${jdbc.driverClassName}")
    private String driverClassName;
    @Value("${jdbc.url}")
    private String url;
    @Value("${jdbc.username}")
    private String userName;
    @Value("${jdbc.password}")
    private String password;

    @Bean
    public DataSource dataSource(){
        DruidDataSource ds = new DruidDataSource();
        ds.setDriverClassName(driverClassName);
        ds.setUrl(url);
        ds.setUsername(userName);
        ds.setPassword(password);
        return ds;
    }

    //spring提供的事务切面类:里面增强了事务管理功能,里面有事务提交和事务回滚功能
    @Bean
    public PlatformTransactionManager transactionManager(DataSource dataSource){
        DataSourceTransactionManager ptm = new DataSourceTransactionManager();
        ptm.setDataSource(dataSource);
        return ptm;
    }
}

MybatisConfig

package com.zbbmeta.config;


import org.apache.ibatis.logging.stdout.StdOutImpl;
import org.apache.ibatis.session.Configuration;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.mapper.MapperScannerConfigurer;
import org.springframework.context.annotation.Bean;

import javax.sql.DataSource;


public class MybatisConfig {

    @Bean  //不仅可以将返回值加入IOC容器,而且可以实现方法参数进行依赖注入,参数默认会根据类型从IOC容器中获取对象自动注入
    public SqlSessionFactoryBean sqlSessionFactoryBean(DataSource dataSource){
        SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();
        ssfb.setTypeAliasesPackage("com.zbbmeta.entity"); //告诉mybatis,设置实体类包别名
        ssfb.setDataSource(dataSource); //将IOC容器中连接池给到Mybatis

        //注意:必须导入org.apache.ibatis.session.Configuration;
        Configuration configuration = new Configuration();
        //设置整合mybatis驼峰命名映射
        configuration.setMapUnderscoreToCamelCase(true);
        //设置打印日志
        configuration.setLogImpl(StdOutImpl.class);

        ssfb.setConfiguration(configuration);
        return ssfb;
    }
}

SpringConfig

@Configuration
@ComponentScan("com.zbbmeta")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
public class SpringConfig {
}

Account

@ToString
@Data
public class Account {
    private Integer id;
    private String name;
    private Double money;

}

AccountDao

public interface AccountDao {

    @Update("update tbl_account set money = money + #{money} where name = #{name}")
    void inMoney(@Param("name") String name, @Param("money") Double money);

    @Update("update tbl_account set money = money - #{money} where name = #{name}")
    void outMoney(@Param("name") String name, @Param("money") Double money);
}
public interface AccountService {
    /**
     * 转账操作
     * @param out 传出方
     * @param in 转入方
     * @param money 金额
     */
    void transfer(String out,String in,Double money) ;
}

AccountServiceImpl

@Service
public class AccountServiceImpl implements AccountService {
    @Autowired
    private AccountDao accountDao;

    public void transfer(String out, String in, Double money) {
        //转出
        accountDao.outMoney(out, money);
        //模拟出现异常
        //System.out.println(1 / 0);
        //转入
        accountDao.inMoney(in, money);
        System.out.println("转账成功");
    }
}

【第一步】在业务层接口上添加Spring事务管理

在转账的方法上添加@Transactional注解

/**
 * 业务接口
 */
public interface AccountService {
    /**
     * 转账操作
     * @param out 传出方
     * @param in 转入方
     * @param money 金额
     */
    @Transactional
    void transfer(String out,String in ,Double money) ;
}

注意事项

  1. Spring注解式事务通常添加在业务层接口中而不会添加到业务层实现类中,降低耦合

  2. 注解式事务可以添加到业务方法上表示当前方法开启事务,也可以添加到接口上表示当前接口所有方法开启事务

【第二步】设置事务管理器(将事务管理器添加到IOC容器中)

说明:可以在JdbcConfig中配置事务管理器

//配置事务管理器,mybatis使用的是jdbc事务
@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource){
    DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
    transactionManager.setDataSource(dataSource);
    return transactionManager;
}

注意事项

  1. 事务管理器要根据实现技术进行选择

  2. MyBatis框架使用的是JDBC事务

【第三步】开启注解式事务驱动

@EnableTransactionManagement

@Configuration
@ComponentScan("com.itheima")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
@EnableTransactionManagement //开启事务注解扫描
public class SpringConfig {
}

【第四步】运行测试类,查看结果

  1. 去掉@EnableTransactionManagement注解,即没有进行事务管理,当转账出现问题时结果

  1. 加上@EnableTransactionManagement注解,账户钱都恢复成1000

结果

  1. 转账成功的时候

结果:

@RunWith(SpringJUnit4ClassRunner.class)  //指定第三方的运行器
@ContextConfiguration(classes = SpringConfig.class)  //读取类配置文件
public class AccountDaoTest {
    @Autowired  //自动注入业务对象
    private AccountService accountService;

    @Test
    public void testFindById() throws IOException {
        //直接使用业务方法
        accountService.transfer("Jack","Rose"100d);
    }
}

2 Spring事务角色【理解】

问题导入

什么是事务管理员,什么是事务协调员?

2.1 Spring事务角色

  • 事务管理员:发起事务方,在Spring中通常指代业务层开启事务的方法

  • 事务协调员:加入事务方,在Spring中通常指数据层方法,也可以是业务层方法

3 Spring事务相关配置

问题导入

什么样的异常,Spring事务默认是不进行回滚的?

3.1 @Transactional注解中与事务相关配置

属性作用示例
readOnly设置是否为只读事务readOnly=true 只读事务
timeout设置事务超时时间timeout = -1(永不超时)
rollbackFor设置事务回滚异常(class)rollbackFor = {FileNotFoundException.class}
rollbackForClassName设置事务回滚异常(String)同上格式为字符串
noRollbackFor设置事务不回滚异常(class)noRollbackFor = {FileNotFoundException.class}
noRollbackForClassName设置事务不回滚异常(String)同上格式为字符串
propagation设置事务传播行为……
属性作用示例
readOnly设置是否为只读事务readOnly=true 只读事务
timeout设置事务超时时间timeout = -1(永不超时)
rollbackFor设置事务回滚异常(class)rollbackFor = {FileNotFoundException.class}
rollbackForClassName设置事务回滚异常(String)同上格式为字符串
noRollbackFor设置事务不回滚异常(class)noRollbackFor = {FileNotFoundException.class}
noRollbackForClassName设置事务不回滚异常(String)同上格式为字符串
propagation设置事务传播行为……

说明:对于RuntimeException类型异常或者Error错误,Spring事务能够进行回滚操作。但是对于非运行时异常,Spring事务是不进行回滚的,所以需要使用rollbackFor来设置要回滚的异常。

3.2 案例:转账业务追加日志

需求和分析

  • 需求:实现任意两个账户间转账操作,并对每次转账操作在数据库进行记录

  • 需求微缩:A账户减钱,B账户加钱,数据库记录日志

  • 分析: ①:基于转账操作案例添加日志模块,实现数据库中记录日志 ②:业务层转账操作(transfer),调用减钱、加钱与记录日志功能

  • 实现效果预期: 无论转账操作是否成功,均进行转账操作的日志留痕

  • 存在的问题: 日志的记录与转账操作隶属同一个事务,同成功同失败

  • 实现效果预期改进: 无论转账操作是否成功,日志必须保留

  • 事务传播行为:事务协调员对事务管理员所携带事务的处理态度

【准备工作】环境整备

创建新的LogDao接口

public interface LogDao {
    @Insert("insert into tbl_log (info,create_date) values(#{info},now())")
    void log(String info);
}

创建业务接口使用事务

public interface LogService {
    /**
     * 记录日志
     * @param out 转出账户
     * @param in 转入账户
     * @param money 金额
     * 设置事务属性:传播行为设置为需要新事务
     */
    @Transactional
    void log(String out, String in, Double money);
}

实现类

@Service
public class LogServiceImpl implements LogService {

    @Autowired
    private LogDao logDao;

    public void log(String out, String in, Double money) {
        logDao.log("转账操作由" + out + "到" + in + ",金额:" + money);
    }
}

【第一步】在AccountServiceImpl中调用logService中添加日志的方法

因为无论成功与否,都需要记录日志,所以日志放在finally语句块中,但异常不需要捕获,要抛出用来激活事务的处理

/**
 * 业务接口
 */
public interface AccountService {
    /**
     * 转账操作
     * @param out 传出方
     * @param in 转入方
     * @param money 金额
     */
    @Transactional
    void transfer(String out,String in ,Double money) ;
}
@Service
public class AccountServiceImpl implements AccountService {
    @Autowired
    private AccountDao accountDao;

    @Autowired
    private LogService logService;

    public void transfer(String out,String in ,Double money) {
        try{
            accountDao.outMoney(out,money);
            //int i = 1/0;
            accountDao.inMoney(in,money);
        } finally {
            logService.log(out,in,money);
        }
    }
}

【第二步】在LogService的log()方法上设置事务的传播行为

需求:无论有没有异常日志都要记录下来,不能被回滚

  1. 先只设置@Transactional,查看运行结果

  2. 设置成当前操作需要新事务再查看运行结果

public interface LogService {
    //propagation设置事务属性:传播行为设置为当前操作需要新事务
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    void log(String out, String in, Double money);
}

【第三步】运行测试类,查看结果

@RunWith(SpringJUnit4ClassRunner.class)  //指定第三方的运行器
@ContextConfiguration(classes = SpringConfig.class)  //读取类配置文件
public class AccountServiceTest {

    @Autowired  //自动注入业务对象
    private AccountService accountService;
    /**
     * 转账的测试
     */
    @Test
    public void testTransfer() {
        accountService.transfer("Jack""Rose"10d);
    }
}

思考:为什么 在LogService的方法上设置propagation = Propagation.REQUIRES_NEW接可以创建新的事务?

这就是事务传播行为(经常会面试提问)

3.3 事务传播行为

传播属性Method1Method2
REQUIRED开启TI事务加入T1事务
新建T2事务
REQUIRES_NEW开启TI事务新建T2事务
新建T2事务
SUPPORTS开启TI事务加入T1事务
NOT_SUPPORTED开启TI事务
MANDATORY开启TI事务加入T1事务
ERROR
NEVER开启TI事务ERROR
NESTED

思考:事务会一直生效?有没有事务失效的情况?为什么会失效,大家可以思考一下,这也是一个长问面试题

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/894706.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Nginx前后端服务器部署

Nginx作为正反向代理的中转站&#xff0c;是连接前后端网络服务的媒介 Nginx下载&#xff1a;http://nginx.org/download/http://nginx.org/download/ 一、上传到服务器固定路径下并解压 上传到/opt/software/nginx-1.19.0.tar.gz cd /opt/software/ tar -zxvf nginx-1.19.0.…

C++学习一STL

文章目录 一、STL基本概念1.泛型程序设计2.STL中的基本的概念 二、容器概述1.简介2.顺序容器3.关联容器4.容器适配器5.成员函数 三、迭代器1.概念2.双向迭代器3.随机访问迭代器4.容器上的迭代器类别 四、算法1.概念2.不变序列算法2.变值算法4.删除算法5.变序算法6.排序算法7. 堆…

使用神卓互联内网穿透搭建远程访问公司ERP系统

神卓互联是一款企业级内网穿透软件&#xff0c;可以将内网中的服务映射到公网上&#xff0c;实现内网服务的访问。通过神卓互联&#xff0c;您可以远程访问ERP系统。在使用神卓互联进行内网穿透时&#xff0c;您只需要在生成的公网地址后面加上ERP系统的端口号&#xff0c;即可…

未来公文的智能化进程

随着技术的飞速发展&#xff0c;公文——这个有着悠久历史的官方沟通方式&#xff0c;也正逐步走向智能化的未来。自动化、人工智能、区块链...这些现代科技正重塑我们的公文制度&#xff0c;让其变得更加高效、安全和智慧。 1.语义理解与自动生成 通过深度学习和NLP&#xff…

爬虫代理一分钟请求数量升级

Hello&#xff0c;各位爬中高手&#xff01;你是否曾经遇到过爬虫代理一分钟请求数量过少的问题&#xff1f;别急&#xff0c;今天我来分享一些方法&#xff0c;让你的爬虫代理请求数量快速飙升&#xff01;这些技巧简单易行&#xff0c;让你的爬虫工作更加高效。 在进行爬虫工…

TikTok连续12个季度跻身全球下载量排行第一

据报道&#xff0c;美国数据公司SensorTower发布了《2023年第二季度全球移动应用下载报告》&#xff0c;数据统计了全球范围内以及各地区下载量最高的App&#xff0c;以及购物类App下载量最高的市场。数据显示&#xff0c;TikTok再次荣登全球下载量最高的应用程序榜首&#xff…

vue项目使用qrcodejs2遇到Cannot read property ‘appendChild‘ of null

这个问题是节点还没创建渲染完就读取节点&#xff0c;这个时候应该先让节点渲染完成在生成&#xff0c;解决方法有以下两种 1、使用$nextTick&#xff08;&#xff09;方法进行&#xff0c;这个方法是用来在节点创建渲染完成后进行的操作 that.$nextTick(() > {let qrcode …

【算法测试】盒子上绑定好的算法,只能输入rtsp流, 如何测试其精度? 讲图片拼接成视频,然后生成rtsp流

文章目录 前言1. 安装rtsp服务器2. 用ffmpeg推送视频到rtsp3.用VLC 承接播放&#xff0c;查看效果&#xff1a;4. 找一个测试集图片集&#xff0c;生成视频 前言 要测试盒子上的算法精度&#xff0c;但盒子的算法只能输入rtsp流&#xff0c;这样我们难道只能去摄像头底下演示效…

【多线程】JUC的常见类

1. Callable 接口 首先先来认识下什么是 JUC&#xff0c;JUC 全称为 java.util.concurrent&#xff0c;这个包里面放了并发编程(多线程相关的组件) Callable 接口类似于 Runnable 一样&#xff0c;Runnable 用来描述一个任务&#xff0c;而 Callable 也是用来描述一个任务的。 …

爱分析发布2023商业智能最佳实践案例,OceanMind海睿思再次入选!

近日&#xff0c;中国领先的产业数字化研究与咨询机构 爱分析&#xff0c;在北京举办了第五届数据智能高峰论坛&#xff0c;活动以“激活数据资产&#xff0c;释放数据价值”为主题。 中新赛克海睿思作为数字化转型优秀厂商代表受邀参会。 会上&#xff0c;爱分析重磅发布了《…

Keepalived + Nginx 实现高可用

一、简介 浮动IP、漂移IP地址又叫做VIP&#xff0c;也就是虚拟IP。 Keepalived 是一种高性能的服务器高可用或热备解决方案。 Keepalived 可以用来防止服务器单点故障的发生&#xff0c;通过配合 Nginx 可以实现 web 前端服务的高可用。 Keepalived 以 VRRP 协议为实现基础&a…

批量删除文件名前的数字编号?

批量删除文件名前的数字编号&#xff1f;如果你在网上经常下载文件&#xff0c;你会发现下载的文件名称前面一般都会有很的数字编号&#xff0c;这些数字编号有时候会非常的长&#xff0c;导致文件的名称也非常的长&#xff0c;这样对于文件的管理和查找使用是不利的。所以为了…

推荐一个绘图平台(可替代Visio)

不废话&#xff0c;简易记网址&#xff1a; draw.io 网站会重定向到&#xff1a;https://app.diagrams.net/

LeetCode 141.环形链表

文章目录 &#x1f4a1;题目分析&#x1f4a1;解题思路&#x1f514;接口源码&#x1f4a1;深度思考❓思考1❓思考2 题目链接&#x1f449; LeetCode 141.环形链表&#x1f448; &#x1f4a1;题目分析 给你一个链表的头节点 head &#xff0c;判断链表中是否有环。 如果链表中…

XDocReport文书生成总结

最近弄一个业务需要搞很多的word文档导出&#xff0c;供前端下载。之前的实现方式一般是先把word转成XML格式&#xff0c;然后赋值变量&#xff0c;这种方式虽然可行&#xff0c;但是遇到那种长篇且变量又多的文档&#xff0c;就很让人头大&#xff0c;密密麻麻的一堆代码&…

Spring-3-Spring AOP概念全面解析

今日目标 能够理解AOP的作用 能够完成AOP的入门案例 能够理解AOP的工作流程 能够说出AOP的五种通知类型 一、AOP 1 AOP简介 思考&#xff1a;什么是AOP,AOP的作用是什么&#xff1f; 1.1 AOP简介和作用【理解】 AOP(Aspect Oriented Programming)面向切面编程&#xff0c;一…

Windows系统修改域名DNS指向两种方式

一、直接打开对应文件进行修改 1、进入hosts文件目录&#xff1a;C:\Windows\System32\drivers\etc 2、右键打开HOSTS文件进行编辑&#xff0c;将需要对应的域名和IP地址进行配置 编写完成后 Ctrl s 进行保存即可。 二、使用DOS命令进行修改 1、按住键盘win键 r 打开命令…

设计师必备的5个PNG免抠素材网站,简直不要太好用~

广大设计师们是不是经常要用免抠素材的时候网上找的质量差&#xff0c;还要各种付费才能使用&#xff0c;最后只能打开PS慢慢的扣&#xff0c;真的很费时间。本期我就给大家推荐5个高质量、免费的免抠素材网站&#xff0c;有需要的朋友们赶紧收藏。 菜鸟图库 https://www.suc…

2021年3月全国计算机等级考试真题(C语言二级)

2021年3月全国计算机等级考试真题&#xff08;C语言二级&#xff09; 第1题 算法空间复杂度的度量方法是&#xff08;&#xff09; A. 算法程序的长度 B. 算法所处理的数据量 C. 执行算法所需要的工作单元 D. 执行算法所需要的存储空间 正确答案&#xff1a;D 第2题 下列叙…

wangEditor修改节点数据

前言 wangEditor简介 wangEditor 是一款基于 JavaScript 和 jQuery 的开源富文本编辑器&#xff0c;具有简单易用、功能丰富的特点。它提供了一整套的富文本编辑功能&#xff0c;包括文字样式设置、插入图片、插入表格、插入链接、代码块等。wangEditor 支持多种浏览器&#x…