目 录CONTENT

文章目录

CompletableFuture事务问题

ByteNews
2022-11-17 / 0 评论 / 0 点赞 / 6,480 阅读 / 5,988 字 / 正在检测是否收录...
温馨提示:
本文最后更新于 2022-11-17,若内容或图片失效,请留言反馈。部分素材来自网络,若不小心影响到您的利益,请联系我们删除。

前段时间写了关于CompletableFuture的使用博客,CompletableFuture使用方法详细说明CompletableFuture的thenCompose使用具体说明

但在实际中使用的时候发现,CompletableFuture开启的线程和当前事务是脱离开的,也就是当前上下文的事务和CompletableFuture中执行的事务是两个事务,谁也不影响谁,这样就会出现业务上的错乱。

例如:当前上下文执行失败,但是CompletableFuture中的执行成功了,而上下文因为失败进行了事务回滚,此时CompletableFuture中的是不会回滚的,这并不是我们想要的,所以针对这种情况进行测试说明和如何避免。

1.准备

1.1.表结构

CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) DEFAULT NULL COMMENT '名称',
  `age` int(11) DEFAULT NULL COMMENT '年龄',
  `address` varchar(50) DEFAULT NULL COMMENT '地址',
  `tranmemo` varchar(100) DEFAULT NULL COMMENT '备注',
  `createtime` datetime DEFAULT NULL COMMENT '创建时间',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8

插入几条测试数据:

insert into user values (null, 'zhangsan', 18, 'CHINA', '我是中国的张三', SYSDATE())
, (null, 'lisi', 28, 'CHINA', '我是中国的李四', SYSDATE())
, (null, 'wangwu', 38, 'CHINA', '我是中国的王五', SYSDATE())
, (null, 'tom', 5, 'USA', 'Tom and Jerry', SYSDATE())
, (null, 'jerry', 5, 'USA', 'Tom and Jerry', SYSDATE());

查询user
在这里插入图片描述

1.2.线程池

线程池参考 ThreadPoolTaskExecutor线程池创建

2.复现事务问题

2.1.模拟业务正常情况

创建CompletableFutureTransactionalController, 代码如下:

/**
 * 测试CompletableFuture事务问题
 *
 * @author jiangkd
 * @date 2022/10/07 15:44:31
 */
@RequiredArgsConstructor
@RequestMapping("/cf")
@RestController
public class CompletableFutureTransactionalController {

    private final CompletableFutureTransactionalService CompletableFutureTransactionalService;

    /**
     * 根据id修改User, 测试CompletableFuture事务问题
     *
     * @param userId User主键值
     */
    @PostMapping("/test/transactional")
    public String updateUser(@RequestParam("userId") Integer userId) throws ExecutionException, InterruptedException {
        //
        CompletableFutureTransactionalService.updateUser(userId);
        return String.valueOf(userId);
    }

}

创建CompletableFutureTransactionalService, 代码如下:

/**
 * @author jiangkd
 * @date 2022/10/07 16:08:44
 */
@RequiredArgsConstructor
@Slf4j
@Service
public class CompletableFutureTransactionalService {

    private final ThreadPoolTaskExecutor threadPoolTaskExecutor;

    private final UserDAO userDAO;

    /**
     * 根据id修改User, 测试CompletableFuture事务问题
     *
     * @param userId User主键值
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateUser(final Integer userId) throws ExecutionException, InterruptedException {
        /*
        创建CompletableFuture线程
         */
        final CompletableFuture<Void> completableFuture = CompletableFuture.runAsync(() -> {
            //
            log.info("runAsync线程执行, 线程名:{}", Thread.currentThread().getName());

            // 根据参数查询user对象
            final User user = userDAO.oneById(userId);
            // 修改age
            user.setAge(100);
            // 执行update
            user.update();
        }, threadPoolTaskExecutor);

        // 执行CompletableFuture, runAsync没有返回, 所以这里使用Void接收
        final Void unused = completableFuture.get();
        log.info("CompletableFuture线程执行, 更新userId:{}的age成功, 返回结果:{}", userId, unused);

        /*
        再次查询userId对应的user对象
         */
        final User user = userDAO.oneById(userId);
        // 修改备注
        user.setTranmemo("测试CompletableFuture事务问题");
        // 执行update
        user.update();
        log.info("当前上下文, 更新userId:{}的tranmemo成功~", userId);

    }
}

可以看出,这里的Service使用CompletableFuture开启线程更新了userId对应的age,然后上下文又更新了userId对应的tranmemo,这时候如果没有报错,那么正常的结果就是最后userId对应的age和tranmemo都被修改了。

注意: 这时候Service的方法updateUser上已经添加了事务注解 @Transactional(rollbackFor = Exception.class)

执行代码,结果如下:
在这里插入图片描述
对于返回结果,我在项目中实现了ResponseBodyAdvice进行统一返回格式,这里不多说,只要在乎结果执行成功了即可。

数据库查看user表:

在这里插入图片描述
很明显,userId为1对应的数据中,age和tranmemo都成功的修改成功了。

2.2.模拟异常情况 – CompletableFuture执行异常

现在我们假设CompletableFuture中的线程在update之后发生了异常,小小的修改一下代码。

修改后的代码如下:

在这里插入图片描述
执行,结果如下:
在这里插入图片描述
可以看到,结果执行失败了,异常信息就是我们添加的 int i = 1/0 导致的,现在我们看看数据库中的结果

在这里插入图片描述
no~,age发生了改变, 但是tranmemo却没有被修改,这说明啥?是的,CompletableFuture中的线程执行失败后(其实就是 final Void unused = completableFuture.get() 这一行代码的执行失败了,失败后因为没有对异常的处捕获处理,所以就执行失败抛出了异常),后面的上下文代码没有执行了。

但是CompletableFuture中的update却依然生效,这显然不是我们想要的。

这里补充一点,如果CompletableFuture的runAsync方法执行后我们还使用了exceptionally, 结果就会有差异了,我们这里可以试一试。

添加exceptionally后的代码如下:
在这里插入图片描述
让我们看看现在执行后的结果:
在这里插入图片描述
数据库结果:
在这里插入图片描述

看到了嘛!!!age和tranmemo都执行成功了!!!为什么呢?

其实很简单,就是因为添加的exceptionally导致的,还是开头说的,看一看 CompletableFuture使用方法详细说明 后或许你就会明白了(如果你还是不明白,留言就行)。

现在我们继续往下走。

2.3.模拟异常情况 – 上下文执行异常

现在我们继续假设CompletableFuture中的线程执行成功,但是上下文执行失败的情况。

代码修改后, 如下:
在这里插入图片描述
取消了CompletableFuture中的模拟异常,范围在上下文的最后添加模拟异常。

执行结果如下:

在这里插入图片描述

执行失败了,这是上下文的异常报出来的,我们再看一下数据库结果:

在这里插入图片描述
age被修改了,但是tranmemo没有变化,因为上下文抛出了异常,@transactional起了作用,事务发生了回滚

进而说明,CompletableFuture中的事务和上下文的事务是分离的,上下文发生回滚的时候,无法回滚CompletableFuture中的修改内容。

显然,这种情况也不是我们想要的。

3.问题解决

针对刚才我们进行的测试,可以总结,无论CompletableFuture还是上下文,只要发生了异常,都存在结果不对的可能,而我们想要的是,无论谁存在问题,结果会回滚。

如何解决问题呢?

那就是手动开启CompletableFuture中的事务,手动回滚!!!

其实可以发现,无论CompletableFuture还是上下文发生异常,我们最终需要控制的,都是CompletableFuture的事务。

3.1.手动回滚异常

好了,现在该来解决刚才出现的问题了,不多说,直接上代码:
在这里插入图片描述
代码也贴一遍

@RequiredArgsConstructor
@Slf4j
@Service
public class CompletableFutureTransactionalService {

    private final ThreadPoolTaskExecutor threadPoolTaskExecutor;

    private final UserDAO userDAO;

    private final DataSourceTransactionManager dataSourceTransactionManager;

    /**
     * 根据id修改User, 测试CompletableFuture事务问题
     *
     * @param userId User主键值
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateUser(final Integer userId) throws ExecutionException, InterruptedException {
        /*
        创建CompletableFuture线程
         */
        final CompletableFuture<Void> completableFuture = CompletableFuture.runAsync(() -> {
            //
            log.info("runAsync线程执行, 线程名:{}", Thread.currentThread().getName());
            /*
             手动开启事务
             */
            DefaultTransactionDefinition def = new DefaultTransactionDefinition();
            // 事物隔离级别,开启新事务,这样会比较安全些。
            def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
            // 获得事务状态
            TransactionStatus status = dataSourceTransactionManager.getTransaction(def);

            try {
                // 根据参数查询user对象
                final User user = userDAO.oneById(userId);
                // 修改age
                user.setAge(666);
                // 执行update
                user.update();

                /*
                模拟CompletableFuture异常
                 */
                int i = 1 / 0;

            } catch (Exception e) {
                // 事务回滚
                dataSourceTransactionManager.rollback(status);
                throw new RuntimeException("runAsync线程执行失败", e);
            }

        }, threadPoolTaskExecutor);

        // 执行CompletableFuture, runAsync没有返回, 所以这里使用Void接收
        final Void unused = completableFuture.get();
        log.info("CompletableFuture线程执行, 更新userId:{}的age成功, 返回结果:{}", userId, unused);

        /*
        再次查询userId对应的user对象
         */
        final User user = userDAO.oneById(userId);
        // 修改备注
        user.setTranmemo("222222");
        // 执行update
        user.update();

        log.info("当前上下文, 更新userId:{}的tranmemo成功~", userId);

    }
}

我们再次执行:
在这里插入图片描述
注意,最然这里执行失败了,但是因为我们在catch中手动抛出了异常,如果不手动抛出异常,上下文就会继续执行,最后执行完修改了tranmemo,这是不对的,因为虽然执行成功了,但实际CompletableFuture是执行失败的(我们回滚了事务)。

再看数据库表:
在这里插入图片描述
好了,age和tranmemo都没有改变。

其实万变不离其宗,无论实际业务是怎么样,只要出现这种情况,需要手动控制事务,就这么处理即可(不是百分百这么些,根据实际需要)。

0

评论区