SpringBoot 内部方法调用,事务不起作用的原因及解决办法

在业务开发中遇到一个问题,当定时任务内部调用一个带事务的方法时,事务在异常发生后未能回滚。问题源于内部方法使用`this`调用,未经过AOP代理,导致事务失效。解决方法包括:1) 通过@Autowired注入自身bean调用;2) 使用ApplicationContext获取bean调用;3) 利用AopContext获取当前类代理。以上三种方式都能确保事务正常工作。

摘要生成于 C知道 ,由 DeepSeek-R1 满血版支持, 前往体验 >

在做业务开发时,遇到了一个事务不起作用的问题。大概流程是这样的,方法内部的定时任务调用了一个带事务的方法,失败后事务没有回滚。查阅资料后,问题得到解决,记录下来分享给大家。

场景

我在这里模拟一个场景,大概的调用方式就如下面的代码这样。

@Override
@Transactional(rollbackFor = RuntimeException.class)
public void insertUser(User user) {
    userMapper.insertUser(user);
    throw new RuntimeException("");
}

/**
 * 内部调用新增方法
 *
 * @param user
 */
@Override
public void invokeInsertUser(User user) {
    this.insertUser(user);
}

原因

AOP使用的是动态代理的机制,它会给类生成一个代理类,事务的相关操作都在代理类上完成。内部方式使用this调用方式时,使用的是实例调用,并没有通过代理类调用方法,所以会导致事务失效。

解决办法

方法一 引入自身bean

在类内部通过@Autowired将本身bean引入,然后通过调用自身bean,从而实现使用AOP代理操作。

注入自身bean

@Autowired
@Lazy
private UserService service;

修改invokeInsertUser方法

/**
 * 解决方法一 在bean中将自己注入进来
 * @param user
 */
@Override
public void invokeInsertUser(User user) {
    this.service.insertUser(user);
}

方法二 通过ApplicationContext引入bean

通过ApplicationContext获取bean,通过bean调用内部方法,就使用了bean的代理类。

注入ApplicationContext

@Autowired
ApplicationContext applicationContext;

修改invokeInsertUser方法

/**
 * 解决方法二 通过applicationContext获取到bean
 * @param user
 */
@Override
public void invokeInsertUser(User user) {
    ((UserService)applicationContext.getBean("userService")).invokeInsertUser(user);
}

方法三 通过AopContext获取当前类的代理类

通过AopContext获取当前类的代理类,直接通过代理类调用方法

在引导类上添加@EnableAspectJAutoProxy(exposeProxy=true)注解

修改invokeInsertUser方法

/**
 * 解决方法三 通过AopContext获取到bean
 *
 * @param user
 */
@Override
public void invokeInsertUser(User user) {
    ((UserService) AopContext.currentProxy()).invokeInsertUser(user);
}

以上就是内部方法调用时,事务不起作用的原因及解决办法。

Spring Boot中,如果集成Activity(通常指Java的并发库如`CompletableFuture`)并尝试在其完成方法调用数据库操作以实现事务控制,可能会遇到事务失效的问题。这是因为`CompletableFuture`的回调不是在Spring管理的事务上下文中执行的。 要解决这个问题,你可以采用以下策略: 1. **手动声明事务**: - 使用`@Transactional`注解标记活动方法,确保在该方法内部的操作会自动加入到当前存在的事务中[^1]。 ```java @Transactional public CompletableFuture<Void> submitTask() { return CompletableFuture.runAsync(() -> { // 这里执行数据库操作 doDatabaseOperation(); }); } ``` 2. **使用AOP代理**: - 如果你想避免修改业务逻辑,可以使用SpringAOP(面向切面编程)来在`CompletableFuture`回调之前开启事务。 ```java @Aspect @Component public class CompletableFutureTransactionAspect { @Around("@annotation(com.txw.MyTransactional)") public Object wrapInTransaction(ProceedingJoinPoint joinPoint) throws Throwable { TransactionAspectSupport.startTransaction(joinPoint.getThis()); try { return joinPoint.proceed(); } finally { TransactionAspectSupport.commitAndCloseTransaction(joinPoint.getThis()); } } } ``` 其中,`MyTransactional`是你自定义的一个注解,用于标识需要事务包裹的方法。 3. **使用异步事务支持**: - 如果Spring Boot不直接支持异步事务,可能需要借助第三方库如`Reactive Spring Data`,它提供了对异步操作与事务管理的支持。 请注意,具体解决方案取决于你的项目结构和对事务一致性需求的具体情况。
评论
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值