漯河市住房和乡镇建设局官方网站,cms企业网站源码,做网站管理员需要哪些知识,django校园网站开发10 种 Spring事务失效场景
1.概述
Spring针对Java Transaction API (JTA)、JDBC、Hibernate和Java Persistence API(JPA)等事务 API#xff0c;实现了一致的编程模型#xff0c;而Spring的声明式事务功能更是提供了极其方便的事务配置方式#xff0c;配合Spring Boot的自动…10 种 Spring事务失效场景
1.概述
Spring针对Java Transaction API (JTA)、JDBC、Hibernate和Java Persistence API(JPA)等事务 API实现了一致的编程模型而Spring的声明式事务功能更是提供了极其方便的事务配置方式配合Spring Boot的自动配置大多数Spring Boot项目只需要在方法上标记Transactional注解即可一键开启方法的事务性配置。
但是事务如果没有被正确出很有可能会导致事务的失效带来意想不到的数据不一致问题随后就是大量的人工接入查看和修复数据该篇主要分享Spring事务在技术上的正确使用方式避免因为事务处理不当导致业务逻辑产生大量偶发性BUG。
在分析事务失效的常见场景之前我们先来了解一下事务的传播类型 和 Transactionnal 注解的不同属性的含义。
2.事务的传播类型
//如果有事务, 那么加入事务, 没有的话新建一个(默认)
Transactional(propagationPropagation.REQUIRED)
//容器不为这个方法开启事务
Transactional(propagationPropagation.NOT_SUPPORTED)
//不管是否存在事务, 都创建一个新的事务, 原来的挂起, 新的执行完毕, 继续执行老的事务
Transactional(propagationPropagation.REQUIRES_NEW)
//必须在一个已有的事务中执行, 否则抛出异常
Transactional(propagationPropagation.MANDATORY)
//必须在一个没有的事务中执行, 否则抛出异常(与Propagation.MANDATORY相反)
Transactional(propagationPropagation.NEVER)
//如果其他bean调用这个方法, 在其他bean中声明事务, 那就用事务, 如果其他bean没有声明事务, 那就不用事务
Transactional(propagationPropagation.SUPPORTS) 3.isolation
该属性用于设置底层数据库的事务隔离级别事务的隔离级别介绍
// 读取未提交数据(会出现脏读, 不可重复读) 基本不使用
Transactional(isolation Isolation.READ_UNCOMMITTED)
// 读取已提交数据(会出现不可重复读和幻读) Oracle默认
Transactional(isolation Isolation.READ_COMMITTED)
// 可重复读(会出现幻读) MySQL默认
Transactional(isolation Isolation.REPEATABLE_READ)
// 串行化
Transactional(isolation Isolation.SERIALIZABLE)4.Transactionnal注解属性
Transactional注解可以作用于接口、接口方法、类以及类方法上它可以通过不同的参数来选择什么类型Exception异常下执行回滚或者不回滚操作。 5.Spring事务失效的场景
1. 事务方法未被Spring管理
如果事务方法所在的类没有注册到Spring IOC容器中也就是说事务方法所在类并没有被Spring管理则Spring事务会失效举个例子
public class ProductServiceImpl extends ServiceImplProductMapper, Product implements IProductService {Autowiredprivate ProductMapper productMapper;OverrideTransactional(propagation Propagation.REQUIRES_NEW)public void updateProductStockById(Integer stockCount, Long productId) {productMapper.updateProductStockById(stockCount, productId);}
}ProductServiceImpl实现类上没有添加Service注解Product的实例也就没有被加载到Spring IOC容器此时updateProductStockById()方法的事务就会在Spring中失效。
2. 方法使用final类型修饰
有时候某个方法不想被子类重写这时可以将该方法定义成final的。普通方法这样定义是没问题的但如果将事务方法定义成final例如
Service
public class OrderServiceImpl {Transactionalpublic final void cancel(OrderDTO orderDTO) {// 取消订单cancelOrder(orderDTO);}
}OrderServiceImpl的cancel取消订单方法被final修饰符修饰Spring事务底层使用了AOP也就是通过JDK动态代理或者cglib帮我们生成了代理类在代理类中实现的事务功能。但如果某个方法用final修饰了那么在它的代理类中就无法重写该方法从而无法添加事务功能。这种情况事务就会在Spring中失效。
3. 非public修饰的方法
如果事务方式不是public修饰此时Spring事务会失效举个例子
Service
public class ProductServiceImpl extends ServiceImplProductMapper, Product implements IProductService {Autowiredprivate ProductMapper productMapper;OverrideTransactional(propagation Propagation.REQUIRES_NEW)private void updateProductStockById(Integer stockCount, String productId) {productMapper.updateProductStockById(stockCount, productId);}
}虽然ProductServiceImpl添加了Service注解同时updateProductStockById()方法上添加了Transactional(propagation Propagation.REQUIRES_NEW)注解但是由于事务方法updateProductStockById()被 private 定义为方法内私有同样Spring事务会失效。
4. 同一个类中的方法相互调用
Service
public class OrderServiceImpl extends ServiceImplOrderMapper, Order implements IOrderService {Autowiredprivate OrderMapper orderMapper;Autowiredprivate ProductMapper productMapper;Overridepublic ResponseEntity submitOrder(Order order) {// 保存生成订单信息long orderNo Math.abs(ThreadLocalRandom.current().nextLong(1000));order.setOrderNo(ORDER_ orderNo);orderMapper.insert(order);// 扣减库存this.updateProductStockById(order.getProductId(), 1L);return new ResponseEntity(HttpStatus.OK);}Transactional(propagation Propagation.REQUIRES_NEW)public void updateProductStockById(Integer num, Long productId) {productMapper.updateProductStockById(num, productId);}
}submitOrder()方法和updateProductStockById()方法都在OrderService类中然而submitOrder()方法没有添加事务注解updateProductStockById()方法虽然添加了事务注解这种情况updateProductStockById()会在Spring事务中失效。
5. 方法的事务传播类型不支持事务
如果内部方法的事务传播类型为不支持事务的传播类型则内部方法的事务同样会在Spring中失效举个例子
Service
public class OrderServiceImpl extends ServiceImplOrderMapper, Order implements IOrderService {Autowiredprivate OrderMapper orderMapper;Autowiredprivate ProductMapper productMapper;OverrideTransactional(propagation Propagation.REQUIRES_NEW)public ResponseEntity submitOrder(Order order) {long orderNo Math.abs(ThreadLocalRandom.current().nextLong(1000));order.setOrderNo(ORDER_ orderNo);orderMapper.insert(order);// 扣减库存this.updateProductStockById(order.getProductId(), 1L);return new ResponseEntity(HttpStatus.OK);}/*** 扣减库存方法事务类型声明为NOT_SUPPORTED不支持事务的传播*/Transactional(propagation Propagation.NOT_SUPPORTED)public void updateProductStockById(Integer num, Long productId) {productMapper.updateProductStockById(num, productId);}
}6.异常被内部catch程序生吞异常
Service
public class OrderServiceImpl extends ServiceImplOrderMapper, Order implements IOrderService {Autowiredprivate OrderMapper orderMapper;Autowiredprivate ProductMapper productMapper;OverrideTransactionalpublic ResponseEntity submitOrder(Order order) {long orderNo Math.abs(ThreadLocalRandom.current().nextLong(1000));order.setOrderNo(ORDER_ orderNo);orderMapper.insert(order);// 扣减库存this.updateProductStockById(order.getProductId(), 1L);return new ResponseEntity(HttpStatus.OK);}/*** 扣减库存方法事务类型声明为NOT_SUPPORTED不支持事务的传播*/Transactional(propagation Propagation.REQUIRES_NEW)public void updateProductStockById(Integer num, Long productId) {try {productMapper.updateProductStockById(num, productId);} catch (Exception e) {// 这里仅仅是捕获异常之后的打印相当于程序吞掉了异常log.error(Error updating product Stock: {}, e);}}
}7. 数据库不支持事务
Spring事务生效的前提是连接的数据库支持事务如果底层的数据库都不支持事务则Spring事务肯定会失效的例如使用MySQL数据库选用MyISAM存储引擎因为MyISAM存储引擎本身不支持事务因此事务毫无疑问会失效。
8. 未配置开启事务
如果项目中没有配置Spring的事务管理器即使使用了Spring的事务管理功能Spring的事务也不会生效例如如果你是Spring Boot项目没有在SpringBoot项目中配置如下代码
Bean
public PlatformTransactionManager transactionManager(DataSource dataSource) {return new DataSourceTransactionManager(dataSource);
}如果是以往的Spring MVC项目如果没有配置下面的代码Spring事务也不会生效正常需要在applicationContext.xml文件中手动配置事务相关参数比如
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:contexthttp://www.springframework.org/schema/context xmlns:txhttp://www.springframework.org/schema/txxsi:schemaLocationhttp://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/tx http://www.springframework.org/schema/tx/spring-tx.xsd!--配置要扫描的包--context:component-scan base-packagecom.llp.spring.tx.dao/context:component-scan base-packagecom.llp.spring.tx.service/!--引入外部的jdbc.properties文件--context:property-placeholder locationclasspath:jdbc.properties/!--配置数据源对象-DataSoruce--bean classcom.mchange.v2.c3p0.ComboPooledDataSource iddataSource!--给数据源对象配置属性值--property nameuser value${jdbc.user}/property namepassword value${jdbc.pwd}/property namedriverClass value${jdbc.driver}/property namejdbcUrl value${jdbc.url}//bean!--配置JdbcTemplate对象--bean classorg.springframework.jdbc.core.JdbcTemplate idjdbcTemplate!--给JdbcTemplate对象配置dataSource--property namedataSource refdataSource//bean!--配置事务管理器-对象1. DataSourceTransactionManager 这个对象是进行事务管理-debug源码2. 一定要配置数据源属性这样指定该事务管理器 是对哪个数据源进行事务控制--bean classorg.springframework.jdbc.datasource.DataSourceTransactionManager idtransactionManagerproperty namedataSource refdataSource//bean!--配置启动基于注解的声明式事务管理功能--tx:annotation-driven transaction-managertransactionManager/
/beans9. 错误的传播特性
其实我们在使用Transactional注解时是可以指定propagation参数的。
该参数的作用是指定事务的传播特性目前Spring支持7种传播特性
REQUIRED 如果当前上下文中存在事务那么加入该事务如果不存在事务创建一个事务这是默认的传播属性值。SUPPORTS 如果当前上下文存在事务则支持事务加入事务如果不存在事务则使用非事务的方式执行。MANDATORY 如果当前上下文中存在事务否则抛出异常。REQUIRES_NEW 每次都会新建一个事务并且同时将上下文中的事务挂起执行当前新建事务完成以后上下文事务恢复再执行。NOT_SUPPORTED 如果当前上下文中存在事务则挂起当前事务然后新的方法在没有事务的环境中执行。NEVER 如果当前上下文中存在事务则抛出异常否则在无事务环境上执行代码。NESTED 如果当前上下文中存在事务则嵌套事务执行如果不存在事务则新建事务。
如果我们在手动设置propagation参数的时候把传播特性设置错了比如
Service
public class OrderServiceImpl {Transactional(propagation Propagation.NEVER)public void cancelOrder(UserModel userModel) {// 取消订单cancelOrder(orderDTO);// 还原库存restoreProductStock(orderDTO.getProductId(), orderDTO.getProductCount());}
}我们可以看到cancelOrder()方法的事务传播特性定义成了Propagation.NEVER这种类型的传播特性不支持事务如果有事务则会抛异常。
10. 多线程调用
在实际项目开发中多线程的使用场景还是挺多的。如果Spring事务用在多线程场景中使用不当也会导致事务无法生效。
Slf4j
Service
public class OrderServiceImpl {Autowiredprivate OrderMapper orderMapper;Autowiredprivate MessageService messageService;Transactionalpublic void orderCommit(orderModel orderModel) throws Exception {orderMapper.insertOrder(orderModel);new Thread(() - {messageService.sendSms();}).start();}
}Service
public class MessageService {Transactionalpublic void sendSms() {// 发送短信}
}通过示例我们可以看到订单提交的事务方法orderCommit()中调用了发送短信的事务方法sendSms()但是发送短信的事务方法sendSms()是另起了一个线程调用的。
这样会导致两个方法不在同一个线程中从而是两个不同的事务。如果是sendSms()方法中抛了异常orderCommit()方法也回滚是不可能的。
实际上Spring的事务是通过ThreadLocal来保证线程安全的事务和当前线程绑定多个线程自然会让事务失效。
