异步事务?关于异步@Async + 事务@Transactional的结合使用问题分析【享学Spring MVC】(下)

简介: 异步事务?关于异步@Async + 事务@Transactional的结合使用问题分析【享学Spring MVC】(下)

场景三:


@Slf4j
@Service
public class HelloServiceImpl implements HelloService {
    @Autowired
    private ApplicationContext applicationContext;
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Transactional
    @Override
    public void enter(Integer age) {
        System.out.println("enter的线程:" + Thread.currentThread().getName());
        String name = "fsx-" + age;
        String sql = "insert into user (name,age) values ('" + name + "'," + age + ")";
        jdbcTemplate.update(sql);
        // 进来后开始吃饭(但因为吃饭比较耗时  所以放到Async异步线程里去做)
        applicationContext.getBean(HelloService.class).eat(age);
        applicationContext.getBean(HelloService.class).play(age);
    }
    @Transactional // 因为吃饭也需要原子 所以也加上事务惊醒控制
    @Async
    @Override
    public void eat(Integer age) {
        System.out.println("eat的线程:" + Thread.currentThread().getName());
        String name = "eat-" + age;
        String sql = "insert into eat (eat_name) values ('" + name + "')";
        jdbcTemplate.update(sql);
        throw new RuntimeException("eat抛出运行异常");
    }
    @Transactional
    @Async
    @Override
    public void play(Integer age) {
        System.out.println("play的线程:" + Thread.currentThread().getName());
        String name = "play-" + age;
        String sql = "insert into play (play_name) values ('" + name + "')";
        jdbcTemplate.update(sql);
        throw new RuntimeException("play抛出运行异常");
    }
}


请注意示例区别:enter方法并没有主动throw抛出异常。

现象:user表插入成功。eat和play表均插入无效(被回滚)

结论:同上


场景四:


此场是我模拟的最后一个场景:异步线程里继续调用异步线程,并且加上事务


@Slf4j
@Service
public class HelloServiceImpl implements HelloService {
    @Autowired
    private ApplicationContext applicationContext;
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Transactional
    @Override
    public void enter(Integer age) {
        System.out.println("enter的线程:" + Thread.currentThread().getName());
        String name = "fsx-" + age;
        String sql = "insert into user (name,age) values ('" + name + "'," + age + ")";
        jdbcTemplate.update(sql);
        // 进来后开始吃饭(但因为吃饭比较耗时  所以放到Async异步线程里去做)
        applicationContext.getBean(HelloService.class).eat(age);
    }
    @Transactional // 因为吃饭也需要原子 所以也加上事务惊醒控制
    @Async
    @Override
    public void eat(Integer age) {
        System.out.println("eat的线程:" + Thread.currentThread().getName());
        String name = "eat-" + age;
        String sql = "insert into eat (eat_name) values ('" + name + "')";
        jdbcTemplate.update(sql);
        applicationContext.getBean(HelloService.class).play(age);
        throw new RuntimeException("eat抛出运行异常");
    }
    @Transactional
    @Async
    @Override
    public void play(Integer age) {
        System.out.println("play的线程:" + Thread.currentThread().getName());
        String name = "play-" + age;
        String sql = "insert into play (play_name) values ('" + name + "')";
        jdbcTemplate.update(sql);
    }
}


请注意此示例区别:enter里没主动抛出异常。enter异步调用eat,eat再异步调用play,并且play里没有抛出异常


现象:user插入成功。eat插入无效(被回滚),play插入成功

结论:不同线程之间的事务完全隔离,异步线程内仍是可以调用异步~


总结


本文没有新的内容,源于跟一个小伙伴讨论这块时,自己也有些打鼓的地方,因此就写了本文做一个记录,还好所有结论和我"预估"的保持一致。


本文主要是把异步@Async和事务@Transactional结合使用的一个场景来进行分析,因为开发中也比较常见,因此希望把这两块内容集合使用做些示例,希望可以做到心中有数,这样使用起来才会更加的胸有成竹嘛~

相关文章
|
1月前
|
SQL Java 关系型数据库
【SpringFramework】Spring事务
本文简述Spring中数据库及事务相关衍伸知识点。
50 9
|
2月前
|
Java 开发者 Spring
理解和解决Spring框架中的事务自调用问题
事务自调用问题是由于 Spring AOP 代理机制引起的,当方法在同一个类内部自调用时,事务注解将失效。通过使用代理对象调用、将事务逻辑分离到不同类中或使用 AspectJ 模式,可以有效解决这一问题。理解和解决这一问题,对于保证 Spring 应用中的事务管理正确性至关重要。掌握这些技巧,可以提高开发效率和代码的健壮性。
128 13
|
2月前
|
缓存 安全 Java
Spring高手之路26——全方位掌握事务监听器
本文深入探讨了Spring事务监听器的设计与实现,包括通过TransactionSynchronization接口和@TransactionalEventListener注解实现事务监听器的方法,并通过实例详细展示了如何在事务生命周期的不同阶段执行自定义逻辑,提供了实际应用场景中的最佳实践。
77 2
Spring高手之路26——全方位掌握事务监听器
|
2月前
|
Java 关系型数据库 数据库
京东面试:聊聊Spring事务?Spring事务的10种失效场景?加入型传播和嵌套型传播有什么区别?
45岁老架构师尼恩分享了Spring事务的核心知识点,包括事务的两种管理方式(编程式和声明式)、@Transactional注解的五大属性(transactionManager、propagation、isolation、timeout、readOnly、rollbackFor)、事务的七种传播行为、事务隔离级别及其与数据库隔离级别的关系,以及Spring事务的10种失效场景。尼恩还强调了面试中如何给出高质量答案,推荐阅读《尼恩Java面试宝典PDF》以提升面试表现。更多技术资料可在公众号【技术自由圈】获取。
|
3月前
|
JavaScript Java 关系型数据库
Spring事务失效的8种场景
本文总结了使用 @Transactional 注解时事务可能失效的几种情况,包括数据库引擎不支持事务、类未被 Spring 管理、方法非 public、自身调用、未配置事务管理器、设置为不支持事务、异常未抛出及异常类型不匹配等。针对这些情况,文章提供了相应的解决建议,帮助开发者排查和解决事务不生效的问题。
114 1
|
3月前
|
XML Java 数据库连接
Spring中的事务是如何实现的
Spring中的事务管理机制通过一系列强大的功能和灵活的配置选项,为开发者提供了高效且可靠的事务处理手段。无论是通过注解还是AOP配置,Spring都能轻松实现复杂的事务管理需求。掌握这些工具和最佳实践,能
121 3
|
3月前
|
Java 开发者 Spring
Spring高手之路24——事务类型及传播行为实战指南
本篇文章深入探讨了Spring中的事务管理,特别是事务传播行为(如REQUIRES_NEW和NESTED)的应用与区别。通过详实的示例和优化的时序图,全面解析如何在实际项目中使用这些高级事务控制技巧,以提升开发者的Spring事务管理能力。
83 1
Spring高手之路24——事务类型及传播行为实战指南
|
4月前
|
Java 关系型数据库 MySQL
Spring事务失效,我总结了这7个主要原因
本文详细探讨了Spring事务在日常开发中常见的七个失效原因,包括数据库不支持事务、类不受Spring管理、事务方法非public、异常被捕获、`rollbackFor`属性配置错误、方法内部调用事务方法及事务传播属性使用不当。通过具体示例和源码分析,帮助开发者更好地理解和应用Spring事务机制,避免线上事故。适合所有使用Spring进行业务开发的工程师参考。
61 2
|
4月前
|
Java 程序员 Spring
Spring事务的1道面试题
每次聊起Spring事务,好像很熟悉,又好像很陌生。本篇通过一道面试题和一些实践,来拆解几个Spring事务的常见坑点。
Spring事务的1道面试题
|
4月前
|
监控 Java 数据库
Spring事务中的@Transactional注解剖析
通过上述分析,可以看到 `@Transactional`注解在Spring框架中扮演着关键角色,它简化了事务管理的复杂度,让开发者能够更加专注于业务逻辑本身。合理运用并理解其背后的机制,对于构建稳定、高效的Java企业应用至关重要。
112 0