异步事务?关于异步@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结合使用的一个场景来进行分析,因为开发中也比较常见,因此希望把这两块内容集合使用做些示例,希望可以做到心中有数,这样使用起来才会更加的胸有成竹嘛~

相关文章
|
5天前
|
安全 Java 数据库
一天十道Java面试题----第四天(线程池复用的原理------>spring事务的实现方式原理以及隔离级别)
这篇文章是关于Java面试题的笔记,涵盖了线程池复用原理、Spring框架基础、AOP和IOC概念、Bean生命周期和作用域、单例Bean的线程安全性、Spring中使用的设计模式、以及Spring事务的实现方式和隔离级别等知识点。
|
22天前
|
Java 关系型数据库 MySQL
Spring 事务失效场景总结
Spring 事务失效场景总结
39 4
|
6天前
|
Java 程序员 数据库连接
女朋友不懂Spring事务原理,今天给她讲清楚了!
该文章讲述了如何解释Spring事务管理的基本原理,特别是针对女朋友在面试中遇到的问题。文章首先通过一个简单的例子引入了传统事务处理的方式,然后详细讨论了Spring事务管理的实现机制。
女朋友不懂Spring事务原理,今天给她讲清楚了!
|
3天前
|
XML Java 数据库
Spring5入门到实战------15、事务操作---概念--场景---声明式事务管理---事务参数--注解方式---xml方式
这篇文章是Spring5框架的实战教程,详细介绍了事务的概念、ACID特性、事务操作的场景,并通过实际的银行转账示例,演示了Spring框架中声明式事务管理的实现,包括使用注解和XML配置两种方式,以及如何配置事务参数来控制事务的行为。
Spring5入门到实战------15、事务操作---概念--场景---声明式事务管理---事务参数--注解方式---xml方式
|
5天前
|
前端开发 Java 数据库连接
一天十道Java面试题----第五天(spring的事务传播机制------>mybatis的优缺点)
这篇文章总结了Java面试中的十个问题,包括Spring事务传播机制、Spring事务失效条件、Bean自动装配方式、Spring、Spring MVC和Spring Boot的区别、Spring MVC的工作流程和主要组件、Spring Boot的自动配置原理和Starter概念、嵌入式服务器的使用原因,以及MyBatis的优缺点。
|
16天前
|
JSON 前端开发 Java
Spring MVC返回JSON数据
综上所述,Spring MVC提供了灵活、强大的方式来支持返回JSON数据,从直接使用 `@ResponseBody`及 `@RestController`注解,到通过配置消息转换器和异常处理器,开发人员可以根据具体需求选择合适的实现方式。
41 4
|
16天前
|
XML 前端开发 Java
Spring MVC接收param参数(直接接收、注解接收、集合接收、实体接收)
Spring MVC提供了灵活多样的参数接收方式,可以满足各种不同场景下的需求。了解并熟练运用这些基本的参数接收技巧,可以使得Web应用的开发更加方便、高效。同时,也是提高代码的可读性和维护性的关键所在。在实际开发过程中,根据具体需求选择最合适的参数接收方式,能够有效提升开发效率和应用性能。
43 3
|
17天前
|
XML 前端开发 Java
Spring MVC接收param参数(直接接收、注解接收、集合接收、实体接收)
Spring MVC提供了灵活多样的参数接收方式,可以满足各种不同场景下的需求。了解并熟练运用这些基本的参数接收技巧,可以使得Web应用的开发更加方便、高效。同时,也是提高代码的可读性和维护性的关键所在。在实际开发过程中,根据具体需求选择最合适的参数接收方式,能够有效提升开发效率和应用性能。
40 2
|
18天前
|
Java 关系型数据库 MySQL
Spring Boot事务配置管理
主要总结了 Spring Boot 中如何使用事务,只要使用 @Transactional 注解即可使用,非常简单方便。除此之外,重点总结了三个在实际项目中可能遇到的坑点,这非常有意义,因为事务这东西不出问题还好,出了问题比较难以排查,所以总结的这三点注意事项,希望能帮助到开发中的朋友。
|
21天前
|
前端开发 Java API
Spring Boot 中的 MVC 支持
### Spring Boot 注解摘要 - **@RestController** - **@RequestMapping** - **@PathVariable** - **@RequestParam** - **@RequestBody**
20 2