脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → SpringBoot异步与事务一起使用

SpringBoot异步与事务一起使用的问题解决

 更新时间：2023年04月30日 09:22:57   作者：ghimi  
本文主要介绍了SpringBoot异步与事务一起使用的问题解决，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

最近遇到的一个场景,在一个被 @Transactional 注解的方法A中中调用了一个被 @Async 注解标记的方法B,由于方法B 在执行时方法A 的事务没有提交,但是方法B在执行过程中获取不到方法A中尚未提交的数据,从而最终倒是方法B执行异常。

@Transactional
public void create(User user){
  // 如果用户已存在，则先删除
  delete(user.id);
  // 创建用户
  int userId = insert(user);
  //  更新用户信息
  update(userId);
}
@Async
public void update(Integer userId){
  Icon icon = getUserIcon(userId);
  // 更新用户图片
  updateUserPohot(userId,icon);
}

像上面的代码，我为创建用户的方法上标记了@Transactional事务注解，然后在其中调用了update()更新方法，这个方法上标记了@Async 注解。这样代码虽然看起来没有什么问题，但是实际在执行update()方法时，由于是其他线程去执行的，就会导致有可能 create()方法对应的事务还没有提交，update() 方法就无法读取到新插入的 user 记录，从而导致更新失败。

解决方案

通过调整逻辑保证事务在调用异步方法前被提交

这个问题的原因是由于 @Transactional 和 @Async 注解一起使用导致的，那么我们可以从这个方向入手，首先我们可以先确认将create()方法的事务提交后，然后再去执行异步更新方法：

public void create(User user){
  int userId = doCreate(user);
  //  更新用户信息
  update(userId);
}
@Transactional
public void doCreate(User user){
    // 如果用户已存在，则先删除
  delete(user.id);
  // 创建用户
  return insert(user);
}
@Async
public void update(Integer userId){
  Icon icon = getUserIcon(userId);
  // 更新用户图片
  updateUserPohot(userId,icon);
}

异步方法放在事务方法外调用，这样异步方法就能够读取到已经提交的事务数据了。

或者我们还可以使用TransactionTemplate来代替 @Transactional 注解:

@Autowired
TransactionTemplate transactionTemplate;
public void create(User user){
  int userId = transactionTemplate.execute(status->{
    // 如果用户已存在，则先删除
    delete(user.id);
    // 创建用户
    return insert(user);
  });
  //  更新用户信息
  update(userId);
}
@Async
public void update(Integer userId){
  Icon icon = getUserIcon(userId);
  // 更新用户图片
  updateUserPohot(userId,icon);
}

通过 TransactionTemplate细化了事务粒度，可以保证在调用异步方法前事务已经被提交。

上面的方案基本都能 解决问题，下面是从网上找到的，spring 给出的解决方案：

@Transactional
public void create(User user){
  // 如果用户已存在，则先删除
  delete(user.id);
  // 创建用户
  int userId = insert(user);
  TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
    @Override
    public void afterCommit() {
      //  更新用户信息
      update(userId);
    }
  });
}
@Async
public void update(Integer userId){
  Icon icon = getUserIcon(userId);
  // 更新用户图片
  updateUserPohot(userId,icon);
}

通过将异步方法注册为事务提交后的操作，这样Spring可以自动帮我们在事务提交后执行对应的操作。

参考资料
异步事务？关于异步@Async + 事务
@Transactional 事务提交 与 @Async 异步执行

到此这篇关于SpringBoot异步与事务一起使用的问题解决的文章就介绍到这了,更多相关SpringBoot异步与事务一起使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Java多线程Atomic包操作原子变量与原子类详解

    Java多线程Atomic包操作原子变量与原子类详解

    这篇文章主要介绍了Java多线程Atomic包操作原子变量与原子类详解，简单介绍了Atomic，同时涉及java.util.concurrent中的原子变量，Atomic类的作用等相关内容，具有一定参考价值，需要的朋友可以了解下。
    2017-11-11
  • Java8中的类型注解浅析

    Java8中的类型注解浅析

    这篇文章主要介绍了Java8中的类型注解浅析,java8之前，注解只能是在声明的地方所使用,java8里面的注解则可以应用在任何地方,需要的朋友可以参考下
    2014-06-06
  • Spring—@Value在static中引用方式

    Spring—@Value在static中引用方式

    这篇文章主要介绍了Spring—@Value在static中引用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • java中aop实现接口访问频率限制

    java中aop实现接口访问频率限制

    本文主要介绍了java中aop实现接口访问频率限制，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2023-04-04
  • Mybatis中自定义TypeHandler处理枚举详解

    Mybatis中自定义TypeHandler处理枚举详解

    本文主要介绍了Mybatis中自定义TypeHandler处理枚举的相关知识。具有很好的参考价值，下面跟着小编一起来看下吧
    2017-02-02
  • java开放地址法和链地址法解决hash冲突的方法示例

    java开放地址法和链地址法解决hash冲突的方法示例

    这篇文章主要介绍了java开放地址法和链地址法解决hash冲突的方法示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-12-12
  • Spring如何在一个事务中开启另一个事务

    Spring如何在一个事务中开启另一个事务

    这篇文章主要介绍了Spring如何在一个事务中开启另一个事务,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-01-01
  • 解决Hmily与Feign冲突报错 NullPointerException的问题

    解决Hmily与Feign冲突报错 NullPointerException的问题

    这篇文章主要介绍了解决Hmily与Feign冲突报错 NullPointerException的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-11-11
  • protobuf与json转换小结

    protobuf与json转换小结

    protobuf对象不能直接使用jsonlib去转，因为protobuf生成的对象的get方法返回的类型有byte[]，而只有String类型可以作为json的key，protobuf提供方法进行转换
    2017-07-07
  • springboot max-http-header-size最大长度的那些事及JVM调优方式

    springboot max-http-header-size最大长度的那些事及JVM调优方式

    这篇文章主要介绍了springboot max-http-header-size最大长度的那些事及JVM调优方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-09-09

最新评论