Spring声明式事务的一个注意点及原理简析

以前我们说过,Spring通过ThreadLocal机制解除了事务管理模块与数据访问层的紧密耦合,提高了模块的可重用性,也保证了多线程环境下的对connection资源的有效管理,实现了线程安全。而要将事务管理代码从整个业务逻辑中抽离出来,提供系统性的服务,就要使用Spring aop,在使用过程中,我们千万不可忘记了其动态代理的实质,不然在使用过程你会不知不觉掉进陷阱里,请看以下例子:

(1) 正常情况

外部调用:

orderService.addOrder(order,orderDto); 
Service内的addOrder方法:
 @Override
 @Transactional
public void addOrder(Order order,OrderDto orderDto) throws Exception {
 orderDAO.addOrder(order);
 OrderDetail orderDetail = new OrderDetail();
 orderDetail.setDiscount(orderDto.getDiscount());
 orderDetail.setQuantity(orderDto.getQuantity());
 Product productParam = new Product();
 productParam.setProductId(orderDto.getProductId());
 Product productGet = productService.getProducts(productParam).get(0);
 orderDetail.setProduct(productGet);
 productGet.getOrderDetail().add(orderDetail);
 orderDetail.setOrder(order);
 order.getOrderDetails().add(orderDetail);
productGet.setQuantity(productGet.getQuantity()-orderDetail.getQuantity());
 orderDetailDAO.addOrderDetail(orderDetail); 
 throw new RuntimeException("it's wrong");
} 

添加订单前数据:

添加订单后数据:

抛出异常,事务回滚,操作后表记录未变。

(2) 非正常情况

外部调用:

orderService.addOrderWrapper(order,orderDto);
@Override
public void addOrderWrapper(Order order,OrderDto orderDto) throws Exception{
//(1)中的addOrder方法,仍然有@Transactional注解
 addOrder(order, orderDto);
}

执行后数据

虽然抛出异常,但事务未回滚,操作后数据改变了。

为什么在orderService的addOrderWrapper()方法内部调用addOrder(),报运行时异常时就不会回滚了呢? 实际上,在第一种情况中,程序是通过orderService的代理类上调用addOrder()方法的,这样,与该方法相关的拦截器就会对请求进行拦截处理,提供相应的事务处理机制;而在第二种情况下,addOrder()方法虽然仍然有@Transaction注解,但仅仅是在orderService上的直接调用,而不是通过代理类调用,伪代码的形式展现如下:

第一种情况:

ProxyFactory factory = new ProxyFactory(orderServiceImpl);

factory.addInterceptor(transactionInterceptor);

OrderService proxy = (orderService) factory.getProxy();

proxy.addOrder();//通过代理调用

第二种情况:

同this.addOrder();//直接通过this调用,事务拦截方法不起作用。

在事务代理类上调用方法的过程见如图:

(图1-1 来源:spring-framework-reference)

无论Spring声明式事务使用什么形式(基于Xml配置文件或者Annotation),万变不离其宗,其底层都是使用了TransactionInterceptor。TransactionInterceptor是一个实现了MethodInterceptor接口的拦截器(Advice),具有相应的事务横切逻辑,被织入到系统中。若方法声明了相应的事务控制信息,它会在该方法执行前开启一个事务,完成时提交事务,发生异常时回滚事务,至于其中的具体规则(传播,隔离级别,超时时间,是否只读,针对何种异常进行回滚),可以通过xml或者@Transactional指定。

如图就是它实现的invoke方法的源代码:

createTransactionIfNecessary方法将会开启一个事务;断点处的proceed方法让程序沿着调用链传播(如图1-1所示)。completeTransactionAfterThrowing和commitTransactionAfterReturning方法则提交回滚事务。

原文发布于微信公众号 - java达人(drjava)

原文发表时间:2016-07-26

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Linux驱动

15.linux-LCD层次分析(详解)

如果我们的系统要用GUI(图形界面接口),这时LCD设备驱动程序就应该编写成frambuffer接口,而不是像之前那样只编写操作底层的LCD控制器接口。 什么是...

28460
来自专栏lgp20151222

rabbit的简单搭建,java使用rabbitmq queue的简单例子和一些坑

由于本人的码云太多太乱了,于是决定一个一个的整合到一个springboot项目里面。

44910
来自专栏分布式系统进阶

KafkaController分析7-启动流程

19210
来自专栏Hellovass 的博客

社交化分享组件踩坑

问题是这样的,项目里的社交化分享是基于 UMShare 封装成的一个 ShareLib module,为了让这个 module 对调用者说更透明,我将 WXEn...

38450
来自专栏lzj_learn_note

Volley源码分析学习

2)根据SDK版本来创建HttpStack的实现,如果是2.3以上的,则使用基于HttpUrlConnection实现的HurlStack,反之,则利用Http...

12560
来自专栏坚毅的PHP

jersey处理支付宝异步回调通知的问题:java.lang.IllegalArgumentException: Error parsing media type 'application/x-www

tcpflow以流为单位分析请求内容,非常适合服务器端接口类服务查问题 这次遇到的问题跟支付宝支付后的回调post结果有关 淘宝的代码例子: publi...

63450
来自专栏java达人

ThreadLocal与Spring 事务管理

编写线程安全代码的关键是管理程序中的共享可变状态,除了通过synchronized加锁机制防止多个线程同时访问同一段数据外,还有一种方法就是通过ThreadLo...

259100
来自专栏*坤的Blog

公司web安全等级提升

公司的一个web数据展示系统,本来是内网的,而且是一个单独的主机,不存在远程控制的问题,所以之前并没有考虑一些安全相关的测试.但是国调安全检查的需要添加这样子的...

22940
来自专栏IMWeb前端团队

React Native与OC之间通信那些事儿

React Native用IOS自带的JavaScriptCore作为JS的解析引擎,普通的JS-OC通信就是React Native在OC定义一个模块方法,J...

24270
来自专栏cloudskyme

网页中显示xml,直接显示xml格式的文件

第一种方法 使用<pre></pre>包围代码(在浏览器中测试不行啊,但是在富编辑器中又可以,怪); 使用<xmp></xmp>包围代码(官方不推荐,但是效果不...

52070

扫码关注云+社区

领取腾讯云代金券