伍佰目录 短网址
  当前位置:海洋目录网 » 站长资讯 » 站长资讯 » 文章详细 订阅RssFeed

Spring注解@Async和@Transactional失效问题究竟是什么原因,强势解释一波

来源:本站原创 浏览:149次 时间:2021-08-01

知音专栏

程序员的出路

写程序时该追求什么,什么是次要的?

如何准备Java初级和高级的技术面试

算法的力量,李开复聊算法的重要性

提前说说

项目中涉及到的代码我都会上传到码云(gitee)或者github上,提供给大家下载参考,文中就以最简单的方式说明执行过程。源码的地址在文末哦!

问题场景重现

场景一:

Spring的异步执行注解@Async,在调用这个方法的时候发现,不对劲,耗时的逻辑我已经加入到异步取做了,怎么接口请求的响应这么慢,赶紧看日志,懵X,加了异步注解,却没有异步执行。

场景二:

在项目中用到@Transactional注解实现事务是必须滴,如果你还在用xml配置,那我只能说……。

但是有时候我们会发现在方法上加了@Transactional注解却出现灵异事件,在方法内出现异常,数据还是插入到数据库,没有回滚,事务哪里去了,明明是加了的。

@Async注解实现原因分析和解决方案

在看下面的内容之前,对动态代理不是很熟悉的可以看一下我之前的一篇文章:http://blog.zdydoit.com/blogs/2018/06/dynamic-static-proxy/。

这里添加的注解是通过Spring AOP对方法的一种增强,而Spring AOP的原理就是动态代理,他的代理有两种,分别是CGLB和JDK自带的代理,Spring AOP会根据具体的实现不同,采用不同的代理方式。

动态代理的原理了解了,下面的问题就可以很好的理解。

异步测试接口

public interface AsyncAopService {   void addOrder();   void sendMsg(int result);}

异步测试接口实现

@Service@Slf4jpublic class AsyncAopServiceImpl implements AsyncAopService {   @Autowired   private OrderDao orderDao;   @Autowired   private MsgDao msgDao;   /**    * 添加订单后会给用户异步的推送信息    */   @Transactional //这里为了让该被代理,加此注解   public void addOrder() {       int result = orderDao.insert(OrderModel.builder()               .amount(10000L)               .orderId("ORDER_2018042601")               .phone("15600001212")               .userId("U_001")               .build());       String currentThreadName = Thread.currentThread().getName();       sendMsg(result);       System.out.println(currentThreadName + "------>下单结束:mark");   }   @Async   public void sendMsg(int result) {       try {           Thread thread = Thread.currentThread();           thread.sleep(3000);//停留3秒           String currentThreadName = thread.getName();           if (result == 1) {               msgDao.insert(MsgModel.builder().msgContent("下单成功!").receiver("15600001212").build());               System.out.println(currentThreadName + "------>发送信息成功");           } else {               msgDao.insert(MsgModel.builder().msgContent("下单失败!").receiver("15600001212").build());               System.out.println(currentThreadName + "------>发送信息失败");           }       } catch (Exception e) {           e.printStackTrace();       }   }}

测试类

@Testpublic void AsyncTest() throws InterruptedException { System.out.println("=======async test start======="); asyncAopService.addOrder(); System.out.println("=======async test end======="); /**  * 在这里让线程睡5秒的原因是为了能够看到异步执行的结果日志  * 小知识点:在Junit测试中,如果主线程执行结束,  *整个测试过程也结束了,存在的异步逻辑如果没有执行完就不会执行啦!  * 测试方式:把这行代码去掉,执行测试,t_order_info表中会插入数据,  *但是t_msg_info表中无数据插入。  */ Thread.sleep(5000);}

测试类上的注解:

@RunWith(SpringJUnit4Cla***unner.class)@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)

Spring Boot启动类的注解:

@SpringBootApplication@MapperScan("com.minuor.aop.dao")@EnableAspectJAutoProxy@EnableAsync //开启异步功能

测试结果

=======async test start=======main------>发送信息成功main------>下单结束:mark=======async test end=======

运行的过程很慢,两行日志的线程名称相同,并且mark日志是在发送信息成功后再输出的,回到代码可以知道发送信息逻辑是异步的执行,为什么会和下单过程的线程名称相同,并且异步执行发送消息是延迟的,为何日志还在mark日志前。种种迹象表明,这不是一个异步执行,而是顺序执行。但是这里是加了异步的注解的,实际没有生效。

在addOrder()方法里面直接调用sendMsg(……)方法,这里还隐含一个关键字,那就是this,实际上这里调用是这样的:this.sendMsg(),this是当前对象。而addOrder()是被代理的,在代理对象中执行结束增强后,通过invoke,用实际AsyncAopServiceImpl对象来调用addOrder()方法执行业务逻辑。在业务逻辑内又调用了sendMsg(……)方法,调用的对象是当前对象,当前对象是AsyncAopServiceImpl,问题就出在这里,因为要想用异步执行sendMsg(……),必须用代理对象执行,因为代理对象要做异步相关的增强,但是此时却直接用AsyncAopServiceImpl对象调用,绕过了代理对象增强的部分,也就是说代理增强部分失效,@Async注解失效。原来想异步执行的逻辑,变成了顺序执行。

解决方案

没有用代理对象执行sendMsg(……),被AsyncAopServiceImpl对象抢占了先机。那么解决就是要让代理对象来执行sendMsg(……)。

在调用sendMsg(……)之前添加下面的代码

AsyncAopService service = (AsyncAopService) AopContext.currentProxy();//获取代理对象service.sendMsg(result);//通过代理对象调用sendMsg,做异步增强

这里还不算完,如果就这样运行,那肯定会报错。

在@EnableAspectJAutoProxy添加属性值。

@EnableAspectJAutoProxy(exposeProxy = true)

运行结果

=======async test start=======main------>下单结束:mark=======async test end=======SimpleAsyncTaskExecutor-1------>发送信息成功

结果也是想要的结果,下单结束,整个测试结束,在测试结束后等待5秒,等待异步日志打印。主线程和异步线程是不同的两个。

如果对代理对象和当前对象有点懵的话,可以加上下面的两行代码:

System.out.println("------>代理对象:"+service.getClass());System.out.println("------>当前对象:"+this.getClass());

得到的结果:

------>代理对象:class com.minuor.aop.impl.AsyncAopServiceImpl$$EnhancerBySpringCGLIB$$9de92f4b //可以看出来是CGLB动态代理------>当前对象:class com.minuor.aop.impl.AsyncAopServiceImpl

@Transactional注解失效的原因分析

这个原因和上面的是相同的,代理被绕过,直接当前对象执行应该被增强的方法,导致方法没有被增强成功。但是可以说一下两个情况。

情况一:在非代理增强方法中调用加了@Transactional增强的方法

这个过程容易理解,不解释。

业务代码

@Servicepublic class TransactionalAopServiceImpl implements TransactionalAopService {   @Autow������,���¶�ired   private OrderDao orderDao;   @Autowired   private UserDao userDao;   public void addOrder() {       orderDao.insert(OrderModel.builder()               .userId("YK_002") //游客编号               .phone("13522203330")               .orderId("ORDER_2018042602")               .amount(10000L)               .build());       //默开用户       System.out.println("--->"+this.getClass());       addUser("13522203330");   }   @Transactional   public void addUser(String phone) {       userDao.insert(UserModel.builder().userName("zhangsan").userPhone(phone).build());       throw new RuntimeException();   }}

运行结果是order订单信息添加成功,同时user用户信息也添加成功,数据库都有数据,没有回滚。按照表面理解应该是order添加成功,user添加失败,因为addUser上加了事务,会回滚。原理参照@Async失效的原理解释。

情况二:addOrder和addUser方法上都添加@Transactional

这种情况下,是可以回滚的,但是不太清楚是在哪个事务回滚,也不太清楚@Transactional是都有效,还是其中一个有效。但是可以模拟,那就是定义三个异常,分别是OrderException、UserException、OtherException,然后在两个方法上指定回滚异常类。通过抛出不同的异常来看具体的结果。

@Transactional修改

@Transactional(rollbackFor = OrderException.class, noRollbackFor = RuntimeException.class)//addOrder方法上@Transactional(rollbackFor = UserException.class, noRollbackFor = RuntimeException.class)//addUser方法上

执行结果分析

1、抛OtherException异常,没有回滚,order、user数据都成功录入到数据库中;

2、抛UserException异常,没有回滚,order、user数据都成功录入到数据库中,这里可以看的出来addUser方法上的@Transactional注解是无效的;

3、抛OrderException异常,回滚成功,order、user数据都没有录入到数据库中,addOrder方法上的@Transactional有效。

这样的结果加上动态代理原理的分析不难得出结果,addUser方法的代理增强被绕过,只是普通的一个方法调用,而且这个方法是包含在addOrder方法事务内的。

源码提供

具体的代码是在com.minuor.aop包,测试类在test下com.minuor.MinuorAnnotationService。

gitHub:https://github.com/zdydoit/proxy

码云:https://gitee.com/zdydoit/proxy

  推荐站点

  • At-lib分类目录At-lib分类目录

    At-lib网站分类目录汇集全国所有高质量网站,是中国权威的中文网站分类目录,给站长提供免费网址目录提交收录和推荐最新最全的优秀网站大全是名站导航之家

    www.at-lib.cn
  • 中国链接目录中国链接目录

    中国链接目录简称链接目录,是收录优秀网站和淘宝网店的网站分类目录,为您提供优质的网址导航服务,也是网店进行收录推广,站长免费推广网站、加快百度收录、增加友情链接和网站外链的平台。

    www.cnlink.org
  • 35目录网35目录网

    35目录免费收录各类优秀网站,全力打造互动式网站目录,提供网站分类目录检索,关键字搜索功能。欢迎您向35目录推荐、提交优秀网站。

    www.35mulu.com
  • 就要爱网站目录就要爱网站目录

    就要爱网站目录,按主题和类别列出网站。所有提交的网站都经过人工审查,确保质量和无垃圾邮件的结果。

    www.912219.com
  • 伍佰目录伍佰目录

    伍佰网站目录免费收录各类优秀网站,全力打造互动式网站目录,提供网站分类目录检索,关键字搜索功能。欢迎您向伍佰目录推荐、提交优秀网站。

    www.wbwb.net