Spring如何使用自定义注解来实现自动管理事务？

人可以做他(她)想做的，但不能要他(她)想要的

一个目录

  • 前言
  • 业务代码展示
  • 手动挡
  • 自动挡
  • 事务失效的问题
  • 代码地址

前言

在两年半以前，我写了一篇博客：框架的灵魂之注解基础篇：
在这里插入图片描述
在那篇博客的结尾，我埋了一个坑：
在这里插入图片描述
如今，我练习时长达两年半，终于摔锅归来！
在这里插入图片描述

本篇博客基于SpringBoot整合MyBatis-plus，如果有不懂这个的，
可以查看我的这篇博客：快速CRUD的秘诀之SpringBoot整合MyBatis-Plus

注意：这篇博客的重点在于：如何利用自定义注解结合Spring的AOP思想来实现自动进行事务管理，

所以事务方面的知识可以说是一点也没有，需要这方面知识的可以划走了hhh
在这里插入图片描述

业务代码展示

0.老规矩，首先来配置一下配置文件application.yml：

# 配置数据源
spring:datasource:# 数据库路径jdbc:mysql://localhost:3306/mydb 的缩写,并配置时区url: jdbc:mysql:///mydb?serverTimezone=GMT%2B8username: rootpassword: 123456driver-class-name: com.mysql.cj.jdbc.Driver # 3.2.0开始支持SPI可省略此配置# 打印MyBatis SQL 日志
logging:level:com.guqueyue.myTransactional.dao: debug # 写接口的包名server:port: 8082 #端口

1.控制层

package com.guqueyue.myTransactional.controller;import com.guqueyue.myTransactional.entity.User;
import com.guqueyue.myTransactional.service.IUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;/*** @Author: guqueyue* @Description: 用户控制层* @Date: 2023/12/19**/
@RestController
@RequestMapping("/user")
public class UserController {@Autowiredprivate IUserService userService;/*** 插入用户* @return*/@RequestMapping("/insertUser")public Integer insertUser(User user) {System.out.println("接收到的用户为：" + user);return userService.insertUser(user);}
}

2.service接口

package com.guqueyue.myTransactional.service;import com.baomidou.mybatisplus.extension.service.IService;
import com.guqueyue.myTransactional.entity.User;/*** @Author: guqueyue* @Description: 用户service接口* @Date: 2023/12/19**/
public interface IUserService extends IService<User> {Integer insertUser(User user);
}

3.service实现类

package com.guqueyue.myTransactional.service.impl;import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.guqueyue.myTransactional.dao.UserMapper;
import com.guqueyue.myTransactional.entity.User;
import com.guqueyue.myTransactional.service.IUserService;
import org.springframework.stereotype.Service;import javax.annotation.Resource;/*** @Author: guqueyue* @Description: 用户实现类* @Date: 2023/12/19**/
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {@Resourceprivate UserMapper userMapper;@Overridepublic Integer insertUser(User user) {int result = userMapper.insert(user);// 写一个异常int i = 1/0;return result;}
}

4.持久层

package com.guqueyue.myTransactional.dao;import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.guqueyue.myTransactional.entity.User;/*** @Author: guqueyue* @Description: 映射接口UserMapper* @Date: 2023/12/19**/
public interface UserMapper extends BaseMapper<User> {}

我们这个时候启动项目，浏览器输入：http://localhost:8082/user/insertUser?username=张三&password=666666

我们在控制台可以看到SQL语句的执行，并且随后抛出了一个异常：
在这里插入图片描述
在这里插入图片描述
观察数据库发现，成功插入了一条数据：
在这里插入图片描述
但是这样肯定是不对的，如果一个方法发生了异常，一部分代码执行一部分代码没执行，这种情况是很危险的！！！

所以，我们需要回滚这个方法已经执行的SQL，不然就全乱套啦！

因此，我们需要事务管理来进行SQL的回滚。

那么，怎么实现呢？请看下文
在这里插入图片描述

手动挡

我们先来手动实现一下事务管理吧！

1.编写工具方法类MyTransactionalUtil便于处理事务：

package com.guqueyue.myTransactional.util;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Component;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.interceptor.DefaultTransactionAttribute;/*** @Author: guqueyue* @Description: 自定义事务工具类* @Date: 2023/12/28**/
@Component
public class MyTransactionalUtil {@Autowiredprivate DataSourceTransactionManager dataSourceTransactionManager;/*** @Description 开启事务* @Param []* @return org.springframework.transaction.TransactionStatus**/public TransactionStatus begin() {return dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());}/*** @Description 提交事务* @Param [transactionStatus]* @return void**/public void commit(TransactionStatus transactionStatus) {if (transactionStatus != null) {dataSourceTransactionManager.commit(transactionStatus);}}/*** @Description 回滚事务* @Param [transactionStatus]* @return void**/public void rollback(TransactionStatus transactionStatus) {if (transactionStatus != null) {dataSourceTransactionManager.rollback(transactionStatus);}}
}

2.这样我们就可以直接在service实现类中注入MyTransactionalUtil来实现事务管理啦

package com.guqueyue.myTransactional.service.impl;import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.guqueyue.myTransactional.dao.UserMapper;
import com.guqueyue.myTransactional.entity.User;
import com.guqueyue.myTransactional.service.IUserService;
import com.guqueyue.myTransactional.util.MyTransactionalUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionStatus;import javax.annotation.Resource;/*** @Author: guqueyue* @Description: 用户实现类* @Date: 2023/12/19**/
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {@Autowiredprivate MyTransactionalUtil myTransactionalUtil;@Resourceprivate UserMapper userMapper;@Overridepublic Integer insertUser(User user) {int result = 0;TransactionStatus begin = null;try {// 开启事务begin = myTransactionalUtil.begin();result = userMapper.insert(user);// 写一个异常int i = 1/0;// 提交事务myTransactionalUtil.commit(begin);}catch (Exception e) {e.printStackTrace();// 回滚事务myTransactionalUtil.rollback(begin);//        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // 手动回滚return 0;}return result;}
}

重新启动项目，浏览器输入：http://localhost:8082/user/insertUser?username=李四&password=7777777

同样，观察控制台，我们可以看到SQL语句执行以及异常抛出：
在这里插入图片描述
在这里插入图片描述
但是刷新并观察数据库，我们并没有发现数据插入：

在这里插入图片描述
说明，我们的事务管理起了作用。

那么，看到这里，你可能发现并没有用到我文章开头说的自定义注解、AOP思想呀

在这里插入图片描述

我知道你很急，但你先别急，在下面 ↓↓↓

自动挡

在上一章节中，我们实现了事务管理，但是非常的麻烦，每一个方法都得如法炮制一遍！

但是，我们可以很明显的发现，其实这些代码都是一样的，那么有没有简便方法呢？

当然有！不过这个世间是平衡的，这个地方少了，那么其他地方就得多。

在这里插入图片描述
1.首先，我们创建一个自定义注解：

package com.guqueyue.myTransactional.annotation;import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/*** @Author: guqueyue* @Description: 自定义注解实现事务* @Date: 2023/12/28**/
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface MyTransactional {}

关于自定义注解不懂的可以看我的这篇博客：框架的灵魂之注解基础篇

2.上AOP

package com.guqueyue.myTransactional.aop;import com.guqueyue.myTransactional.util.MyTransactionalUtil;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.TransactionStatus;/*** @Author: guaueyue* @Description: 通过拦截自定义注解实现事务* @Date: 2023/12/28**/
@Slf4j
@Aspect
@Component
public class MyTransactionAspect {@Autowiredprivate MyTransactionalUtil transactionalUtil;/*** @Description 通过拦截自定义注解@MyTransactional来实现事务* 				@annotation()里为自定义注解的路径* @Param [joinPoint]* @return java.lang.Object**/@Around(value = "@annotation(com.guqueyue.myTransactional.annotation.MyTransactional)") public Object around(ProceedingJoinPoint joinPoint) {Object result = null;TransactionStatus begin = null;try {// 开启事务begin = transactionalUtil.begin();// 执行目标方法result = joinPoint.proceed();// 提交事务transactionalUtil.commit(begin);} catch (Throwable e) {transactionalUtil.rollback(begin);log.info("事务回滚...");e.printStackTrace();}return result;}
}

这里的joinPoint.proceed()方法就是执行需要事务管理方法的意思，

我们可以很明显的看出跟上文手动管理事务的逻辑是一样的，只不过抽象出来了

// 执行目标方法
Object proceed = joinPoint.proceed();

3.使用

 	@MyTransactional@Overridepublic Integer insertUser(User user) {int result = userMapper.insert(user);// 写一个异常int i = 1/0;return result;}

这下我们只需要在需要事务管理的方法上面加一个自定义注解就可以实现功能了，是不是很方便优雅？
在这里插入图片描述
4.效果

同样的，重新启动项目，浏览器输入：http://localhost:8082/user/insertUser?username=王五&password=888888

同样，观察控制台，我们可以看到SQL语句执行以及异常抛出：
在这里插入图片描述
在这里插入图片描述
但是刷新数据库，发现什么也没有发生！
在这里插入图片描述
说明功能实现啦！

4.原理

那么，这个功能是怎么实现的呢？

其实很简单，Spring会拦截使用了自定义注解@MyTransactional的方法，进行环绕增强。

这样方法就会变成类似于下面的效果（以下是伪代码无法执行）

	@Autowiredprivate MyTransactionalUtil transactionalUtil;/*** @Description 通过拦截自定义注解@MyTransactional来实现事务* @Param [joinPoint]* @return java.lang.Object**/@Around(value = "@annotation(com.guqueyue.myTransactional.annotation.MyTransactional)")public Object around(ProceedingJoinPoint joinPoint) {Object result = null;TransactionStatus begin = null;try {// 开启事务begin = transactionalUtil.begin();// 执行目标方法@Overridepublic int insertUser(User user) {int result = userMapper.insert(user);// 写一个异常int i = 1/0;return result;}// 提交事务transactionalUtil.commit(begin);} catch (Throwable e) {transactionalUtil.rollback(begin);log.info("事务回滚...");e.printStackTrace();}return result;}

（以上是伪代码无法执行）

5.后话

当然了，这个功能其实Spring框架已经实现了，大家用官方提供的@Transactional注解就好了，这里也只是给大家讲解一下原理：

	@Transactional@Overridepublic Integer insertUser(User user) {int result = userMapper.insert(user);// 写一个异常int i = 1/0;return result;}

文章篇幅有限，就不具体验证截图示意了。

事务失效的问题

大家难免在编写代码的过程中遇到又需要事务管理，又需要异常处理的问题，如代码里面使用了文件流

然后有些新手小伙伴可能代码就变成了：

 	@Transactional@Overridepublic Integer insertUser(User user) {int result = 0;try {result = userMapper.insert(user);// 写一个异常FileInputStream fileInputStream = new FileInputStream("");}catch (Exception e) {e.printStackTrace();}return result;}

重启项目，浏览器输入：http://localhost:8082/user/insertUser?username=赵六&password=999999

控制台可以看到SQL语句执行以及异常抛出：
在这里插入图片描述
在这里插入图片描述

但是刷新查看数据库发现插入了一条数据，说明事务失效了：
在这里插入图片描述
这个是为什么呢？

这里我就不卖关子了，因为如果你这样写的话，就成类似于这样了：
（以下是伪代码无法执行）

	@Autowiredprivate MyTransactionalUtil transactionalUtil;/*** @Description 通过拦截自定义注解@MyTransactional来实现事务* @Param [joinPoint]* @return java.lang.Object**/@Around(value = "@annotation(com.guqueyue.myTransactional.annotation.MyTransactional)")public Object around(ProceedingJoinPoint joinPoint) {Object result = null;TransactionStatus begin = null;try {// 开启事务begin = transactionalUtil.begin();// 执行目标方法@Overridepublic int insertUser(User user) {int result = 0;try {result = userMapper.insert(user);// 写一个异常FileInputStream fileInputStream = new FileInputStream("");}catch (Exception e) {e.printStackTrace();}return result;}// 提交事务transactionalUtil.commit(begin);} catch (Throwable e) {transactionalUtil.rollback(begin);log.info("事务回滚...");e.printStackTrace();}return result;}

（以上是伪代码无法执行）
在这里插入图片描述

我们可以很轻松的发现，方法内部有一个 try…catch ，所以外部的 try…catch 就失效了。

那么，怎么办呢？很简单，向外部抛出异常就好了，记得一直抛到控制层，不然代码会报错哦：

	@Transactional@Overridepublic Integer insertUser(User user) throws Exception{int result = userMapper.insert(user);// 写一个异常FileInputStream fileInputStream = new FileInputStream("");return result;}

至于效果，留有读者自行验证了。

其实不用验证了，上面代码肯定是无效的啦，

因为Spring的默认的事务规则是遇到运行异常（RuntimeException）和程序错误（Error）才会回滚。

而上文中的java.io.FileNotFoundException异常属于IO异常（IOException）

我们需要指定一下异常类型：

 	@Transactional(rollbackFor = Exception.class)@Overridepublic Integer insertUser(User user) throws Exception {int result = userMapper.insert(user);// 写一个异常FileInputStream fileInputStream = new FileInputStream("");return result;}

代码地址

本文代码已开源：

git clone https://gitee.com/guqueyue/my-blog-demo.git

请切换到gitee分支，然后查看myTransactional模块即可！

这戛然而止的结尾。

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

JAVA 学习 面试（八）集合类

JAVA 学习 面试（八）集合类

集合类 集合&#xff08;Collection&#xff09; 1、 List列表 &#xff1a; 有序 可重复 1、ArrayList : 数组列表 &#xff0c;内部是通过Array实现&#xff0c;对数据列表进行插入、删除操作时都需要对数组进行拷贝并重排序&#xff0c;因此在知道存储数据量时&#xff0c…
阅读更多...
【GAMES101】Lecture 09 重心坐标

【GAMES101】Lecture 09 重心坐标

我们之前说着色过程中以及这个计算法线的时候需要用到这个插值&#xff08;Interpolation&#xff09;&#xff0c;然后插值是通过这个重心坐标&#xff08;Barycentric Coordinates&#xff09;来实现的 目录 重心坐标 插值 重心坐标 注意哈我们这里说的三角形的重心坐标并…
阅读更多...
Java反射基础学习笔记

Java反射基础学习笔记

Java反射基础知识 一、Java反射的理解二、Java反射的知识1、如何获取Class类2、使用Class中的构造方法3、使用Class中的方法4、使用Class中的属性5、使用Class中的注解6、Class中的常用方法 Java反射要学习哪些内容&#xff0c;其实要知道的东西很少&#xff0c;也很简单掌握。…
阅读更多...
RK3399平台开发系列讲解（USB篇）BusHound 工具使用介绍

RK3399平台开发系列讲解（USB篇）BusHound 工具使用介绍

🚀返回专栏总目录 文章目录 一、BusHound简介二、BusHound的下载三、BusHound设备窗口四、BUSHound发送命令窗口沉淀、分享、成长，让自己和他人都能有所收获！😄 📢 BusHound软件是由美国perisoft公司研制的一种专用于PC机各种总线数据包监视和控制的开发工具软件，其名…
阅读更多...
前端面试——关于this指向问题？

前端面试——关于this指向问题？

想要知道关于this的指向问题&#xff0c;首先要了解this的绑定规则。那么this到底是什么样的绑定规则呢&#xff1f;一起来研究一下吧&#xff01; 绑定一&#xff1a;默认绑定 绑定二&#xff1a;饮食绑定 绑定三&#xff1a;显示绑定 绑定四&#xff1a;隐式绑定 1. 默认…
阅读更多...
【GitHub项目推荐--一款美观的开源社区系统】【转载】

【GitHub项目推荐--一款美观的开源社区系统】【转载】

推荐一款开源社区系统&#xff0c;该系统基于主流的 Java Web 技术栈&#xff0c;如果你是一名 Java 新手掌握了基本 JavaEE 框架知识&#xff0c;可以拿本项目作为练手项目。 开源社区系统功能还算完善包含发布帖子、发布评论、私信、系统通知、点赞、关注、搜索、用户设置、…
阅读更多...
What is `Filter` does?

What is `Filter` does?

过滤器&#xff08;Filter&#xff09;是Java Servlet规范中的一部分&#xff0c;它提供了一种在请求到达目标资源之前或响应发送给客户端之前进行预处理和后处理的能力。 通过编写自定义的过滤器类并将其注册到Web应用程序中&#xff0c;开发者可以实现诸如登录验证、权限控制…
阅读更多...
边缘计算及相关产品历史发展

边缘计算及相关产品历史发展

边缘计算及相关产品历史发展 背景边缘计算的历史CDN&#xff08;Content Delivery Network&#xff09;Cloudlet雾计算MEC&#xff08;Multi-Access Edge Computing&#xff0c;MEC&#xff09; 边缘计算的现状云计算厂商硬件厂商软件基金会 背景 最近&#xff0c;公司部分业务…
阅读更多...
RT-DETR优化改进：IoU系列篇 | Focaler-IoU​​​​​​​更加聚焦的IoU损失Focaler-IoU |2024年最新发表

RT-DETR优化改进：IoU系列篇 | Focaler-IoU​​​​​​​更加聚焦的IoU损失Focaler-IoU |2024年最新发表

🚀🚀🚀本文改进：Focaler-IoU更加聚焦的IoU损失Focaler-IoU，能够在不同的检测任务中聚焦不同的回归样本，使用线性区间映射的方法来重构IoU损失 🚀🚀🚀RT-DETR改进创新专栏：http://t.csdnimg.cn/vuQTz 🚀🚀🚀学姐带你学习YOLOv8，从入门到创新，轻轻松松搞…
阅读更多...
Redis中BigKey的分析与优化

Redis中BigKey的分析与优化

Redis中BigKey的分析与优化 Redis以其出色的性能和易用性&#xff0c;在互联网技术栈中占据了重要的地位。 但是&#xff0c;高效的工具使用不当也会成为性能瓶颈。在Redis中&#xff0c;BigKey是常见的性能杀手之一&#xff0c;它们会消耗过多的内存&#xff0c;导致网络拥塞…
阅读更多...
【每日一题】最大交换

【每日一题】最大交换

文章目录 Tag题目来源解题思路方法一&#xff1a;暴力法方法二&#xff1a;贪心 写在最后 Tag 【暴力法】【贪心法】【数组】【2024-01-22】 题目来源 670. 最大交换 解题思路 本题的数据规模比较小&#xff0c;暴力法也可以通过。以下将会介绍暴力法和本题最优法。 方法一…
阅读更多...
14027.ptp 控制流

14027.ptp 控制流

文章目录 1 ptp 控制流1.1 控制流分层 1 ptp 控制流 1.1 控制流分层 大体分为4层&#xff1a;1 ptp4l层&#xff1a; 获取配置文件、创建时钟、poll监控文件描述符。2 clock时钟层&#xff1a;提供提供clock_poll、clock_create、clock_sync 等3 port 端口层&#xff1a;port…
阅读更多...
后端MySQL常用命令

后端MySQL常用命令

不是专业后端的&#xff0c;所有可能有些不太准确&#xff0c;都是自己平时在项目当中总结的&#xff0c;谢谢ฅฅ* 添加/insert 给指定字段添加数据 INSERT INTO 表名 字段名 VALUES 值 INSERT INTO ninth_student (id,name,sex,age,weight,birth) VALUES (0,亚亚,女,18,4…
阅读更多...
为什么重写hashcode要一起重写equals方法

为什么重写hashcode要一起重写equals方法

为什要重写hashcode&#xff1f; hashcode方法得到一个hash值其实是要起到一个比较作用&#xff0c;比较两个未知的东西是不是同一个东西&#xff0c;因为我们要求hashcode方法产生的hash值对于”同一个东西“得到的hash值是一样的。 那这种特性可以做到去重的效果&#xff0…
阅读更多...
HBase学习五：运维排障之复制

HBase学习五：运维排障之复制

官方文档-HBase复制，包含相关命令信息 0 名词解释 在HBase中，HLog（也称为WAL）用于记录所有对HBase表的修改操作，以便在系统故障时可以恢复数据。 Entry的含义 Entry在HLog上下文中通常指的是WAL中的一个记录项。每个Entry包含了一次或多次对HBase表的修改操作的信息，这…
阅读更多...
通过 GScan 工具自动排查后门

通过 GScan 工具自动排查后门

一、简介 GScan 是一款为安全应急响应提供便利的工具&#xff0c;自动化监测系统中常见位置。 工具运行环境&#xff1a;CentOS (6、7) python (2.x、3.x) 工具检查项目&#xff1a; 1、主机信息获取 2、系统初始化 alias 检查 3、文件类安全扫描 3.1、系统重要文件完整行…
阅读更多...
Express.js 中动态路由解码：path-to-regexp介绍

Express.js 中动态路由解码：path-to-regexp介绍

1. path-to-regexp&#xff1a;将路径转化为模式 path-to-regexp 是一个 Node.js 工具&#xff0c;用于将路径字符串转换为正则表达式。它在像 Express.js 这样的网络框架中广泛用于处理动态路由。 主要功能及代码示例&#xff1a; 将路径转换为正则表达式&#xff1a; 它将带…
阅读更多...
linux shell脚本 条件语句

linux shell脚本 条件语句

test 测试文本的表达式 是否成立 格式&#xff1a; test 条件表达式 格式&#xff1a; [ 条件表达式 ] &#xff08;[] 内要空格 &#xff0c;不然不生效&#xff09; 如何测试&#xff1f; [ 操作符 文件或目录 ] echo $? 返回值是0 正确&#xff0c;返回值非0 …
阅读更多...
Unity——FSM有限状态机

Unity——FSM有限状态机

有限状态机就是有限个切换状态的条件&#xff0c;要制作有限状态机&#xff0c;有几个必要点&#xff1a;状态抽象类、FSMSystem类、FSMSystem实现类、FSM状态实现类。 每一个控制者都有一个状态机&#xff0c;每一个状态机都有其包含的状态&#xff0c;每一个状态都有能转换的…
阅读更多...
运维之道—生产环境安装mysql

运维之道—生产环境安装mysql

目录 1.前言 2.部署安装 2.1 下载mysql5.7版本的yum仓库 2.2 安装yum仓库 2.3 安装mysql-server 2.4 启动mysql-server 3. 生产配置 3.1 登录mysql 3.2 修改root账户密码 3.3 配置mysql
阅读更多...
最新文章

Copyright @ 2022~2023