- Java锁的逻辑(结合对象头和ObjectMonitor)
- 还在用饼状图?来瞧瞧这些炫酷的百分比可视化新图形(附代码实现)⛵
- 自动注册实体类到EntityFrameworkCore上下文,并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
作为Java开发工程师,相信大家对 Spring 种事务的使用并不陌生。但是你可能只是停留在基础的使用层面上,在遇到一些比较特殊的场景,事务可能没有生效,直接在生产上暴露了,这可能就会导致比较严重的生产事故。今天,我们就简单来说下Spring事务的原理,然后总结一下spring事务失败的场景,并提出对应的解决方案.
大家还记得在JDBC中是如何操作事务的吗?伪代码可能如下:
//Get database connection
Connection connection = DriverManager.getConnection();
//Set autoCommit is false
connection.setAutoCommit(false);
//use sql to operate database
.........
//Commit or rollback
connection.commit()/connection.rollback
connection.close();
需要在各个业务代码中编写代码如 commit() 、 close() 来控制事务.
但是Spring不乐意这么干了,这样对业务代码侵入性太大了,所有就用一个事务注解 @Transactional 来控制事务,底层实现是基于切面编程 AOP 实现的,而 Spring 中实现 AOP 机制采用的是动态代理,具体分为 JDK 动态代理和 CGLIB 动态代理两种模式.
Spring
的 bean
的初始化过程中,发现方法有 Transactional
注解,就需要对相应的 Bean
进行代理,生成代理对象。 另外注意一点的是, Spring 本身不实现事务,底层还是依赖于 数据库的事务 。没有数据库事务的支持, Spring 事务是不会生效的.
接下来我们进入正题,看看哪些场景会导致 Spring 事务失败.
比如你的事务控制代码如下:
@Transactional
public void transactionTest() throws IOException{
User user = new User();
UserService.insert(user);
throw new IOException();
}
如果 @Transactional 没有特别指定,Spring 只会在遇到运行时异常RuntimeException或者error时进行回滚,而 IOException 等检查异常不会影响回滚.
public boolean rollbackOn(Throwable ex) {
return (ex instanceof RuntimeException || ex instanceof Error);
}
解决方案:
知道原因后,解决方法也很简单。配置 rollbackFor 属性,例如 @Transactional(rollbackFor = Exception.class) .
@Transactional(rollbackFor = Exception.class)
public void transactionTest() {
try {
User user = new User();
UserService.insert(user);
int i = 1 / 0;
}catch (Exception e) {
e.printStackTrace();
}
}
这种场景下,事务失败的原因也很简单, Spring 是否进行回滚是根据你是否抛出异常决定的,所以如果你自己捕获了异常, Spring 也无能为力.
看了上面的代码,你可能认为这么简单的问题你不可能犯这么愚蠢的错误,但是我想告诉你的是,我身边几乎一半的人都被这一幕困扰过.
写业务代码的时候,代码可能比较复杂,嵌套的方法很多。如果你不小心,很可能会触发此问题。举一个非常简单的例子,假设你有一个审计功能。每个方法执行后,审计结果保存在数据库中,那么代码可能会这样写.
@Service
public class TransactionService {
@Transactional(rollbackFor = Exception.class)
public void transactionTest() throws IOException {
User user = new User();
UserService.insert(user);
throw new IOException();
}
}
@Component
public class AuditAspect {
@Autowired
private auditService auditService;
@Around(value = "execution (* com.alvin.*.*(..))")
public Object around(ProceedingJoinPoint pjp) {
try {
Audit audit = new Audit();
Signature signature = pjp.getSignature();
MethodSignature methodSignature = (MethodSignature) signature;
String[] strings = methodSignature.getParameterNames();
audit.setMethod(signature.getName());
audit.setParameters(strings);
Object proceed = pjp.proceed();
audit.success(true);
return proceed;
} catch (Throwable e) {
log.error("{}", e);
audit.success(false);
}
auditService.save(audit);
return null;
}
}
在上面的示例中,事务将失败。原因是 Spring 的事务切面优先级最低,所以如果异常被切面捕获,Spring自然不能正常处理事务,因为事务管理器无法捕获异常.
解决方案:
看,虽然我们知道在处理事务时业务代码不能自己捕获异常,但是只要代码变得复杂,我们就很可能再次出错,所以我们在处理事务的时候要小心,还是不要使用声明式事务, 并使用编程式事务— transactionTemplate.execute() .
@Service
public class DefaultTransactionService implement Service {
public void saveUser() throws Exception {
//do something
doInsert();
}
@Transactional(rollbackFor = Exception.class)
public void doInsert() throws IOException {
User user = new User();
UserService.insert(user);
throw new IOException();
}
}
这也是一个容易出错的场景。事务失败的原因也很简单,因为 Spring 的事务管理功能是通过动态代理实现的,而 Spring 默认使用 JDK 动态代理,而 JDK 动态代理采用接口实现的方式,通过反射调用目标类。简单理解,就是 saveUser() 方法中调用 this.doInsert() ,这里的 this 是被真实对象,所以会直接走 doInsert 的业务逻辑,而不会走切面逻辑,所以事务失败.
解决方案:
方案一 :解决方法可以是直接在启动类中添加@Transactional注解 saveUser() 。
方案二 : @EnableAspectJAutoProxy(exposeProxy = true) 在启动类中添加,会由 Cglib 代理实现.
如果 Spring 使用了 Cglib 代理实现(比如你的代理类没有实现接口),而你的业务方法恰好使用了 final 或者 static 关键字,那么事务也会失败。更具体地说,它应该抛出异常,因为 Cglib 使用字节码增强技术生成被代理类的子类并重写被代理类的方法来实现代理。如果被代理的方法的方法使用 final 或 static 关键字,则子类不能重写被代理的方法.
如果 Spring 使用 JDK 动态代理实现, JDK 动态代理是基于接口实现的,那么 final 和 static 修饰的方法也就无法被代理.
总而言之,方法连代理都没有,那么肯定无法实现事务回滚了.
解决方案:
想办法去掉final或者static关键字 。
如果方法不是 public , Spring 事务也会失败,因为 Spring 的事务管理源码 AbstractFallbackTransactionAttributeSource 中有判断 computeTransactionAttribute()。 如果目标方法不是公共的,则 TransactionAttribute 返回 null .
// Don't allow no-public methods as required.
if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {
return null;
}
解决方案:
是将当前方法访问级别更改为 public .
Spring 事务的传播机制是指在多个事务方法相互调用时,确定事务应该如何传播的策略。 Spring 提供了七种事务传播机制: REQUIRED 、 SUPPORTS 、 MANDATORY 、 REQUIRES_NEW 、 NOT_SUPPORTED 、 NEVER 、 NESTED 。如果不知道这些传播策略的原理,很可能会导致交易失败.
@Service
public class TransactionService {
@Autowired
private UserMapper userMapper;
@Autowired
private AddressMapper addressMapper;
@Transactional(propagation = Propagation.REQUIRES_NEW,rollbackFor = Exception.class)
public void doInsert(User user,Address address) throws Exception {
//do something
userMapper.insert(user);
saveAddress(address);
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void saveAddress(Address address) {
//do something
addressMapper.insert(address);
}
}
在上面的例子中,如果用户插入失败,不会导致 saveAddress() 回滚,因为这里使用的传播是 REQUIRES_NEW ,传播机制 REQUIRES_NEW 的原理是如果当前方法中没有事务,就会创建一个新的事务。如果一个事务已经存在,则当前事务将被挂起,并创建一个新事务。在当前事务完成之前,不会提交父事务。如果父事务发生异常,则不影响子事务的提交.
事务的传播机制说明如下:
REQUIRED
如果当前上下文中存在事务,那么加入该事务,如果不存在事务,创建一个事务,这是默认的传播属性值。 SUPPORTS
如果当前上下文存在事务,则支持事务加入事务,如果不存在事务,则使用非事务的方式执行。 MANDATORY
如果当前上下文中存在事务,否则抛出异常。 REQUIRES_NEW
每次都会新建一个事务,并且同时将上下文中的事务挂起,执行当前新建事务完成以后,上下文事务恢复再执行。 NOT_SUPPORTED
如果当前上下文中存在事务,则挂起当前事务,然后新的方法在没有事务的环境中执行。 NEVER
如果当前上下文中存在事务,则抛出异常,否则在无事务环境上执行代码。 NESTED
如果当前上下文中存在事务,则嵌套事务执行,如果不存在事务,则新建事务。 解决方案
将事务传播策略更改为默认值 REQUIRED 。 REQUIRED 原理是如果当前有一个事务被添加到一个事务中,如果没有,则创建一个新的事务,父事务和被调用的事务在同一个事务中。即使被调用的异常被捕获,整个事务仍然会被回滚.
// @Service
public class OrderServiceImpl implements OrderService {
@Transactional
public void updateOrder(Order order) {
// update order
}
}
如果此时把 @Service 注解注释掉,这个类就不会被加载成一个 Bean ,那这个类就不会被 Spring 管理了,事务自然就失效了.
解决方案
需要保证每个事务注解的每个Bean被Spring管理.
@Service
public class UserService {
@Autowired
private UserMapper userMapper;
@Autowired
private RoleService roleService;
@Transactional
public void add(UserModel userModel) throws Exception {
userMapper.insertUser(userModel);
new Thread(() -> {
try {
test();
} catch (Exception e) {
roleService.doOtherThing();
}
}).start();
}
}
@Service
public class RoleService {
@Transactional
public void doOtherThing() {
try {
int i = 1/0;
System.out.println("保存role表数据");
}catch (Exception e) {
throw new RuntimeException();
}
}
}
我们可以看到事务方法add中,调用了事务方法 doOtherThing ,但是事务方法 doOtherThing 是在另外一个线程中调用的.
这样会导致两个方法不在同一个线程中,获取到的数据库连接不一样,从而是两个不同的事务。如果想 doOtherThing 方法中抛了异常, add 方法也回滚是不可能的.
我们说的同一个事务,其实是指同一个数据库连接,只有拥有同一个数据库连接才能同时提交和回滚。如果在不同的线程,拿到的数据库连接肯定是不一样的,所以是不同的事务.
解决方案:
这里就有点分布式事务的感觉了,尽量还是保证在同一个事务中处理.
本文简单阐述了下 Spring 中事务实现的原理,同时列举了8种 Spring 事务失败的场景,相信很多朋友可能都遇到过, 失败的原因也有详细说明。希望大家对 Spring 事务有一个新的认识.
欢迎关注微信公众号「JAVA旭阳」交流和学习 更多学习资料请移步: 程序员成神之路 。
最后此篇关于8个Spring事务失效的场景,你碰到过几种?的文章就讲到这里了,如果你想了解更多关于8个Spring事务失效的场景,你碰到过几种?的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
websocket的用途/场景 先总结:高即时性服务,比如聊天室的群聊,server顺序收到了张三,李四的消息,立即就推送给王五,不能让王五等半天。 Ajax也可以一秒一刷,让王五去问张三说话没,如果
前端的工作过程里,本地开发、提供测试环境,总得有个用着顺手的服务器软件,这个场景里nginx很流行。 介绍两个好用的配置项:rewrite try_files @xxxx rewrite 比较
我有一个场景的两个不同角度的 2 个视频文件,我想重建场景的 3D 估计。它类似于 3D 传感器的作用(例如 Kinect、PrimeSense)。我正在寻找一个库,甚至是一个完善的机器视觉算法,以便
我已阅读RebaseProject页面并尝试了一个不平凡的例子(不是对一个完整的分支进行 rebase )。这与 rebase D 的情况类似我场景B。 这是rebase之前的情况: default
有没有办法将我的场景保存在 JavaFx 应用程序中单独的 Java 文件中?我尝试过这样的事情: public class MyApp extends Application { pri
我有这样的场景:用户想要查看大量有关自己的信息。例如:年龄、姓名、地位、收入、工作、爱好、 child 的名字、妻子的名字、酋长的名字、祖父/祖母的名字。大约 50 个变量。他可以选择任何变量来显示信
我希望有人能帮助我解决这个问题:我有一个包含条目的表。我想执行查询并根据模式获取得分最高的记录。模式将是:如果我的话按原样出现,那么该条目的分数将是最高的。如果该单词出现在句子中,则该条目的分数将低于
我正在尝试在我的应用程序委托(delegate)方法中实现一些逻辑。了解当前正在运行哪种场景将非常有帮助。 [[CCDirector sharedDirector] runningScene] 返回当
好的,这是一个有趣的。我有 2 个表:tbl_notes、tbl_notes_categories 简单地说,tbl_notes 有一个 categoryid,我将 2 个表与该 ID 相关联。所以,
我有一个使用并行运行的 Specflow、selenium、NUnit 的测试解决方案在 AssemblyInfo 中添加了这个:[程序集:Parallelizable(ParallelScope.F
我正在尝试弄清楚如何在 SpriteKit 中添加更多场景。如果我在 GameViewController 中使用 SpriteKit 生成的行 if let scene = GameScene.un
目录 1、业务背景 2、场景分析 3、流程设计 1、业务流程 2、导入流程
我是 Unity 的新手,所以修复起来可能非常简单。我使用了一个 3D Google SketchUp 模型,我想让玩家环顾模型。 super 简单。 我添加了 3D 平面,添加了相机并更新了设置以支
我需要标记要跳过的某些测试。但是,有些测试是参数化的,我只需要能够跳过某些场景。 我使用 py.test -m "hermes_only" 调用测试或 py.test -m "not hermes_o
我已经开始使用 SpecFlow 并想知道是否可以在规范之间重用场景 基本上我的想法是这样的(我可能从根本上是错误的:)) 我编写了一项功能来验证导航。 功能:导航 I should be able
在编写验证输入表单上的信息的 BDD 场景时,您将如何列出规则。 选项是: 1) 每个规则一个场景 2)场景大纲,每个领域和规则的例子 我们如何说某些不在特定字符集中的无效内容,例如: 鉴于我输入了一
我们如何使用 StoryQ 来测试预期出现异常的场景? 最佳答案 就实际代码而言,在测试代码的 .Then 部分,您需要创建一个 Action 或 Func 来确定正在测试的内容,然后在代码的 .Th
完成快速初学者努力通过点击按钮向场景添加节点。 我知道我可以使用点击手势来获取点击坐标并执行点击测试,然后在点击的 3D 空间中放置一个对象。但是,我想在设备屏幕的中央显示一个球体或十字准线,当点击屏
如何在表格中传递空格? Background: Given the following books |Author |(here several spaces)
我正在尝试从 Eric Haines' Standard Procedural Database (SPD) 渲染“mount”场景,但折射部分就是不想配合。我已经尝试了所有我能想到的方法来修复它。
我是一名优秀的程序员,十分优秀!