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");

}   

添加订单前数据:

image

添加订单后数据:

image

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

(2) 非正常情况

外部调用:

orderService.addOrderWrapper(order,orderDto);

@Override

public void addOrderWrapper(Order order,OrderDto orderDto) throws Exception{

//(1)中的addOrder方法,仍然有@Transactional注解

 addOrder(order, orderDto);

}

执行后数据

image

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

为什么在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调用,事务拦截方法不起作用。

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

image

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

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

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

image

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

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,948评论 18 139
  • 前言 今天是平安夜,先祝大家平安夜快乐。 我们之前的数十篇文章分析了 Spring 和 Mybatis 的原理,基...
    莫那一鲁道阅读 14,215评论 3 31
  • 本文是我自己在秋招复习时的读书笔记,整理的知识点,也是为了防止忘记,尊重劳动成果,转载注明出处哦!如果你也喜欢,那...
    波波波先森阅读 12,327评论 6 86
  • Spring Boot 参考指南 介绍 转载自:https://www.gitbook.com/book/qbgb...
    毛宇鹏阅读 46,958评论 6 342
  • 秋至少新红,霜打青山悴。只有相思树永青,红豆颗颗媚。 枯叶恋枝头,不忍随风坠。都道菊花插满头,谁懂离人泪。
    合肥岁月静好阅读 287评论 0 8