@Transactional 实现原理

1、简介

Transactional是spring中定义的事务注解，在方法或类上加该注解开启事务。主要是通过反射获取bean的注解信息，利用AOP对编程式事务进行封装实现。(spring-5.1.8.RELEASE)

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface Transactional {@AliasFor("transactionManager")String value() default "";@AliasFor("value")String transactionManager() default "";Propagation propagation() default Propagation.REQUIRED;Isolation isolation() default Isolation.DEFAULT;int timeout() default TransactionDefinition.TIMEOUT_DEFAULT;boolean readOnly() default false;Class<? extends Throwable>[] rollbackFor() default {};String[] rollbackForClassName() default {};Class<? extends Throwable>[] noRollbackFor() default {};String[] noRollbackForClassName() default {};
}

2、自定义注解

2.1 定义

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface MyAnnotation {//自定义注解的属性int id() default 0;String name() default "默认名称";String[]arrays();String title() default "默认标题";
}

2.2 测试

public class App {@MyAnnotation(name = "wqd", arrays = {"2", "3"})public void aMethod() {}public void bMethod() {}public static void main(String[] args) throws ClassNotFoundException {// 反射获取到类的信息Class<?> clazz = Class.forName("com.wyq.App");// 获取当前类（不包括继承）所有方法Method[] methods = clazz.getDeclaredMethods();// 遍历每个方法的信息for (Method method : methods) {System.out.println("方法名称：" + method.getName());// 获取方法上面的注解MyAnnotation annotation = method.getDeclaredAnnotation(MyAnnotation.class);if (annotation == null) {System.out.println("该方法上没有加注解...");} else {System.out.println("Id : " + annotation.id());System.out.println("Name : " + annotation.name());System.out.println("Title : " + annotation.title());System.out.println("Arrays : " + annotation.arrays());}System.out.println("--------------------------");}}
}控制台信息：方法名称：main
该方法上没有加注解...
--------------------------
方法名称：aMethod
Id : 0
Name : wqd
Title : 默认标题
Arrays : [Ljava.lang.String;@24d46ca6
--------------------------
方法名称：bMethod
该方法上没有加注解...
--------------------------

2.3 总结

通过上面这么一个小demo我们就能发现，反射获取到每一个方法的注解信息然后进行判断，如果这是@Transactional注解，spring就会开启事务。接下来我们可以按照这种思路自己实现一个事务注解。

3、手写事务注解

3.1 maven依赖

    <dependencies><!-- 引入Spring-AOP等相关Jar --><dependency><groupId>org.springframework</groupId><artifactId>spring-core</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-aop</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-orm</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjrt</artifactId><version>1.9.4</version></dependency><dependency><groupId>aspectj</groupId><artifactId>aspectjweaver</artifactId><version>1.5.4</version></dependency><dependency><groupId>cglib</groupId><artifactId>cglib</artifactId><version>3.3.0</version></dependency><dependency><groupId>com.mchange</groupId><artifactId>c3p0</artifactId><version>0.9.5.2</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.37</version></dependency></dependencies>

3.2 配置spring.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:aop="http://www.springframework.org/schema/aop"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd"><!--扫描指定路径--><context:component-scan base-package="com.wyq" /><!--开启切面代理--><aop:aspectj-autoproxy /><!--数据源对象，C3P0 连接池--><bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"><property name="driverClass" value="com.mysql.jdbc.Driver"/><property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test"/><property name="user" value="root"/><property name="password" value="123456"/></bean><!--JdbcTemplate 工具类实例--><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource" ref="dataSource"/></bean><!--配置事务--><bean id="dataSoutceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"></property></bean>
</beans>

3.3 自定义事务注解 (通过反射解析方法上的注解，如果有这个注解就执行事务逻辑)

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface MyAnnotation {//自定义注解的属性int id() default 0;String name() default "默认名称";String[] arrays() default {};String title() default "默认标题";
}

3.4 封装编程式事务

@Component
@Scope("prototype")
public class TransactionUtil {// 全局接受事务状态private TransactionStatus transactionStatus;// 获取事务原@Autowiredprivate DataSourceTransactionManager dataSourceTransactionManager;// 开启事务public TransactionStatus begin() {System.out.println("开启事务");transactionStatus = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());return transactionStatus;}// 提交事务public void commit(TransactionStatus transaction) {System.out.println("提交事务");if (dataSourceTransactionManager != null) {dataSourceTransactionManager.commit(transaction);}}public void rollback(TransactionStatus transaction) {System.out.println("回滚事务");if (dataSourceTransactionManager != null) {dataSourceTransactionManager.rollback(transaction);}}
}

3.5 通过AOP封装事务工具类, 基于环绕通知和异常通知来触发事务

@Component
@Aspect
public class AopTransaction {@Autowiredprivate TransactionUtil transactionUtil;private TransactionStatus transactionStatus;/*** 环绕通知，在方法 前---后 处理事情** @param pjp 切入点*/@Around("execution(* com.wyq.service.*.*(..))")public void around(ProceedingJoinPoint pjp) throws Throwable {// 获取方法的注解MyAnnotation annotation = this.getMethodMyAnnotation(pjp);// 判断是否需要开启事务transactionStatus = begin(annotation);// 调用目标代理对象方法pjp.proceed();// 判断关闭事务commit(transactionStatus);}/*** 获取代理方法上的事务注解** @param pjp* @return* @throws Exception*/private MyAnnotation getMethodMyAnnotation(ProceedingJoinPoint pjp) throws Exception {// 获取代理对象的方法String methodName = pjp.getSignature().getName();// 获取目标对象Class<?> classTarget = pjp.getTarget().getClass();// 获取目标对象类型Class<?>[] par = ((MethodSignature) pjp.getSignature()).getParameterTypes();// 获取目标对象方法Method objMethod = classTarget.getMethod(methodName, par);// 获取该方法上的事务注解MyAnnotation annotation = objMethod.getDeclaredAnnotation(MyAnnotation.class);return annotation;}/*** 开启事务** @param annotation* @return*/private TransactionStatus begin(MyAnnotation annotation) {if (annotation == null) {return null;}return transactionUtil.begin();}/*** 提交事务** @param transactionStatus*/private void commit(TransactionStatus transactionStatus) {if (transactionStatus != null) {transactionUtil.commit(transactionStatus);}}/*** 异常通知进行 回滚事务*/@AfterThrowing("execution(* com.wyq.service.*.*(..))")public void afterThrowing() {// 获取当前事务 直接回滚if (transactionStatus != null) {transactionUtil.rollback(transactionStatus);}}
}

3.6 dao 层

/*
CREATE TABLE `t_user0` (`name` varchar(20) NOT NULL,`age` int(5) DEFAULT NULL,PRIMARY KEY (`name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
*/
@Repository
public class UserDao {@Autowiredprivate JdbcTemplate jdbcTemplate;public int add(String name, Integer age) {String sql = "INSERT INTO t_user0(NAME, age) VALUES(?,?);";int result = jdbcTemplate.update(sql, name, age);System.out.println("插入成功");return result;}
}

3.7 service 层

@Service
public class UserService {@Autowiredprivate UserDao userDao;// 加上事务注解@MyAnnotationpublic void add() {userDao.add("test001", 20);int i = 1 / 0;  //设置异常，检查事务的正确性userDao.add("test002", 21);
//        // 如果非要try,那么出现异常不会被aop的异常通知监测到,必须手动在catch里面回滚事务。
//        try {
//            userDao.add("test001", 20);
//            int i = 1 / 0;
//            userDao.add("test002", 21);
//        } catch (Exception e) {
//            // 回滚当前事务
//            System.out.println("回滚");
//            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
//        }}public void del() {System.out.println("del...");}
}

3.8 测试

public class Test {public static void main(String[] args) {ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");UserService userService = (UserService) applicationContext.getBean("userService");// aop()对userService类进行了拦截,添加自定义事务注解的方法会触发事务逻辑userService.add();// del()方法没有加注解，则什么也不会触发。//userService.del();}
}

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

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

相关文章

在java中jvm目录_JVM具体在哪个文件夹下的

在java中jvm目录_JVM具体在哪个文件夹下的

\jdk1.6.0 -- JDK的根目录&#xff0c;包含一些软件版权&#xff0c;声明&#xff0c;和自述文件&#xff0c;同时包含归档了的Java平台源代码包src.zip\jdk1.6.0\bin -- JDK包含的一些开发工具执行文件\jdk1.6.0\jre\bin\client包含 Java HotSpotTM Client Virtual Machine 要…
阅读更多...
java值传递string_关于java：按值传递（StringBuilder与String）

java值传递string_关于java：按值传递（StringBuilder与String）

本问题已经有最佳答案&#xff0c;请猛点这里访问。我不明白为什么system.out.println(name)在不受方法的concat函数影响的情况下输出sam&#xff0c;而system.out.println(name)在方法的append方法的结果下输出sam4。为什么StringBuilder受到影响而不是String&#xff1f;通常…
阅读更多...
spring源码阅读--aop实现原理分析

spring源码阅读--aop实现原理分析

aop实现原理简介 首先我们都知道aop的基本原理就是动态代理思想&#xff0c;在设计模式之代理模式中有介绍过这两种动态代理的使用与基本原理&#xff0c;再次不再叙述。 这里分析的是&#xff0c;在spring中是如何基于动态代理的思想实现aop的。为了方便了解接下来的源码分析…
阅读更多...
java muki_再次学习 java 类的编译

java muki_再次学习 java 类的编译

做JAVA开发的都知道myeclipse&#xff0c; 我们在myeclipse中新建一个类&#xff0c;然后保存&#xff0c; 如何正常的话&#xff0c;那么在项目指定的目录(也就是项目的output目录)就会生成同名的class文件&#xff0c;可是&#xff0c;我们都知道myeclipse中的类的编译的原理…
阅读更多...
spring源码阅读--@Transactional实现原理

spring源码阅读--@Transactional实现原理

Transactional注解简介 Transactional是spring中声明式事务管理的注解配置方式&#xff0c;相信这个注解的作用大家都很清楚。Transactional注解可以帮助我们把事务开启、提交或者回滚的操作&#xff0c;通过aop的方式进行管理。通过Transactional注解就能让spring为我们管理事…
阅读更多...
MySQL中实现并、交、差

MySQL中实现并、交、差

简介 sql叫做结构化查询语言&#xff0c;本质利用的就是关系代数中的操作&#xff0c;比如常用的并、交、差、投影、选择等操作。 其中并、交、差是常用的操作&#xff0c;本文就看看MySQL中的sql语言是怎么提供对应的关系代数操作的。 并 并的符号是∪&#xff0c;含义就是…
阅读更多...
java获取http状态码_java获取Json和http状态码

java获取http状态码_java获取Json和http状态码

最近再做接口自动化测试&#xff0c;其中有几个方法比较重要1.获取http状态码/** 返回接口状态码**/public staticString getHttpCode(String url) {String code null;try{URL u newURL(url);URLConnection ucu.openConnection();HttpURLConnection huc(HttpURLConnection)uc;c…
阅读更多...
MySQL 普通索引和唯一索引的区别详解

MySQL 普通索引和唯一索引的区别详解

1 概念区分 普通索引和唯一索引 普通索引可重复&#xff0c;唯一索引和主键一样不能重复。 唯一索引可作为数据的一个合法验证手段&#xff0c;例如学生表的身份证号码字段&#xff0c;我们人为规定该字段不得重复&#xff0c;那么就使用唯一索引。&#xff08;一般设置学号字…
阅读更多...
win8.1已阻止java_win8系统下打开java程序时出现应用程序已被安全设置阻止的解决方法...

win8.1已阻止java_win8系统下打开java程序时出现应用程序已被安全设置阻止的解决方法...

今天和大家分享一下win7系统下打开java程序时出现应用程序已被安全设置阻止问题的解决方法&#xff0c;在使用win7系统的过程中经常不知道如何去解决win7系统下打开java程序时出现应用程序已被安全设置阻止的问题&#xff0c;有什么好的办法去解决win7系统下打开java程序时出现…
阅读更多...
MySql常用函数大全

MySql常用函数大全

MySql常用函数大全 MySQL数据库中提供了很丰富的函数。MySQL函数包括数学函数、字符串函数、日期和时间函数、条件判断函数、系统信息函数、加密函数、格式化函数等。通过这些函数&#xff0c;可以简化用户的操作。例如&#xff0c;字符串连接函数可以很方便的将多个字符串连接…
阅读更多...
android两个java文件内容_java – 在1个请求中将多个文件从Android上传...

android两个java文件内容_java – 在1个请求中将多个文件从Android上传...

我知道我可以使用multipart / form POST请求一次将1个文件上传到AppEngine. AppEngine也支持uploading multiple files,但你必须做一些运行的JSP东西才能工作.我有一个应用程序,要求我上传一些表单数据,2个图像和3个文本字段.这可以通过AppEngine完成吗&#xff1f;我一直在努力…
阅读更多...
LINUX下用YUM安装nginx出现No package nginx available.的问题与解决方案

LINUX下用YUM安装nginx出现No package nginx available.的问题与解决方案

一、问题描述 运行命令 yum install nginx 之后出现如下图情况。 二、解决过程如下 根据问题描述可以看出&#xff0c;是yum源出了问题&#xff0c;因此我们需要捣鼓以下yum源配置。具体解决过程如下。 1.备份CentOS-Base.repo mv /etc/yum.repos.d/CentOS-Base.repo /et…
阅读更多...
mysql开启yum search pt-mysql_Centos使用MySQL工具Percona Toolkit

mysql开启yum search pt-mysql_Centos使用MySQL工具Percona Toolkit

Centos使用MySQL工具Percona Toolkit安装Percona Toolkit 的Repo 得以支持直接用yum 安装二进制包yum install -y https://www.percona.com/redir/downloads/percona-release/redhat/latest/percona-release-0.1-4.noarch.rpmyum install -y percona-toolkit改MySQL表结构DDL p…
阅读更多...
Controller层使用@value注解获取不到properties属性值

Controller层使用@value注解获取不到properties属性值

说到Value注解&#xff0c;用过的应该都知道&#xff0c;这是Spring3的一个注解&#xff0c;通过value注解的方式获取properties文件中的配置值&#xff0c;大大简化了我们读取配置文件的代码。然而&#xff0c;最近在使用中发现在controller使用出现了获取不到值的问题 经过排…
阅读更多...
spring中context:property-placeholder标签详解

spring中context:property-placeholder标签详解

spring中context:property-placeholder标签的使用说明 1&#xff0c;有些参数在某些阶段中是常量。 在开发阶段我们连接数据库时的url&#xff0c;username&#xff0c;password等信息 分布式应用中client端的server地址&#xff0c;端口等这些参数在不同阶段之间又住住需要改…
阅读更多...
access mysql oracle数据库_Oracle Access 数据库连接 使用

access mysql oracle数据库_Oracle Access 数据库连接 使用

直接代码吧&#xff1a;/// /// Oracle数据库连接/// /// 数据库连接串&#xff0c;例如&#xff1a;(DESCRIPTION (ADDRESS_LIST (ADDRESS (PROTOCOL TCP)(HOST IP)(PORT *)))(CONNECT_DATA (SERVICE_NAME *)))/// 用户名/// 用户密码/// Oracle数据库连接对象private st…
阅读更多...
Jackson用法详解

Jackson用法详解

Spring MVC 默认采用Jackson解析Json&#xff0c;尽管还有一些其它同样优秀的json解析工具&#xff0c;例如Fast Json、GSON&#xff0c;但是出于最小依赖的考虑&#xff0c;也许Json解析第一选择就应该是Jackson。 一、简介 Jackson 是当前用的比较广泛的&#xff0c;用来序列…
阅读更多...
php7 cms,PHP7CMS 无条件前台GETSHELL

php7 cms,PHP7CMS 无条件前台GETSHELL

Version:2018-10-09//最新版中以修复此漏洞这个漏洞很简单&#xff0c;如果作者在写代码的时候考虑到一点点安全方面&#xff0c;其实都可以避免的。[PHP] 纯文本查看 复制代码// php7cms/Core/Controllers/Api/Api.php// 52~61 linepublic function save_form_data() {$rt \P…
阅读更多...
php服务器怎么设置cookie,php服务器如何清除浏览器cookie

php服务器怎么设置cookie,php服务器如何清除浏览器cookie

php服务器清除浏览器cookie的方法&#xff1a;1、设置cookie的过期时间&#xff1b;2、设置cookie的值为空&#xff0c;代码为【setcookie($cookiename, ) setcookie($cookiename, NULL);】。php服务器清除浏览器cookie的方法&#xff1a;一、设置cookie的过期时间//将过期时间…
阅读更多...
Java面试——RabbitMQ系列总结

Java面试——RabbitMQ系列总结

1.RabbitMQ是什么&#xff1f; RabbitMQ是一款开源的&#xff0c;Erlang编写的&#xff0c;基于AMQP&#xff08;高级消息队列协议&#xff09;协议的消息中间件。 2.为什么要使用消息队列&#xff1f; 从本质上来说是因为互联网的快速发展&#xff0c;业务不断扩张&#xff0c…
阅读更多...
最新文章

Copyright @ 2022~2023