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

相关文章
|
SQL Java 关系型数据库
Spring事务传播机制:7种姿势教你玩转"事务接力赛"
事务传播机制是Spring框架中用于管理事务行为的重要概念,它决定了在方法调用时事务如何传递与执行。通过7种传播行为,开发者可以灵活控制事务边界,适应不同业务场景。例如:REQUIRED默认加入或新建事务,REQUIRES_NEW独立开启新事务,NESTED支持嵌套回滚等。合理使用传播机制不仅能保障数据一致性,还能提升系统性能与健壮性。掌握这“七种人格”,才能在复杂业务中游刃有余。
|
前端开发 Java 测试技术
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestParam
本文介绍了 `@RequestParam` 注解的使用方法及其与 `@PathVariable` 的区别。`@RequestParam` 用于从请求中获取参数值(如 GET 请求的 URL 参数或 POST 请求的表单数据),而 `@PathVariable` 用于从 URL 模板中提取参数。文章通过示例代码详细说明了 `@RequestParam` 的常用属性,如 `required` 和 `defaultValue`,并展示了如何用实体类封装大量表单参数以简化处理流程。最后,结合 Postman 测试工具验证了接口的功能。
1082 0
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestParam
|
Java 关系型数据库 数据库
微服务——SpringBoot使用归纳——Spring Boot事务配置管理——常见问题总结
本文总结了Spring Boot中使用事务的常见问题,虽然通过`@Transactional`注解可以轻松实现事务管理,但在实际项目中仍有许多潜在坑点。文章详细分析了三个典型问题:1) 异常未被捕获导致事务未回滚,需明确指定`rollbackFor`属性;2) 异常被try-catch“吃掉”,应避免在事务方法中直接处理异常;3) 事务范围与锁范围不一致引发并发问题,建议调整锁策略以覆盖事务范围。这些问题看似简单,但一旦发生,排查难度较大,因此开发时需格外留意。最后,文章提供了课程源代码下载地址,供读者实践参考。
547 0
|
Java 关系型数据库 数据库
微服务——SpringBoot使用归纳——Spring Boot事务配置管理——Spring Boot 事务配置
本文介绍了 Spring Boot 中的事务配置与使用方法。首先需要导入 MySQL 依赖,Spring Boot 会自动注入 `DataSourceTransactionManager`,无需额外配置即可通过 `@Transactional` 注解实现事务管理。接着通过创建一个用户插入功能的示例,展示了如何在 Service 层手动抛出异常以测试事务回滚机制。测试结果表明,数据库中未新增记录,证明事务已成功回滚。此过程简单高效,适合日常开发需求。
2034 0
|
Java 数据库 微服务
微服务——SpringBoot使用归纳——Spring Boot事务配置管理——事务相关
本文介绍Spring Boot事务配置管理,阐述事务在企业应用开发中的重要性。事务确保数据操作可靠,任一异常均可回滚至初始状态,如转账、购票等场景需全流程执行成功才算完成。同时,事务管理在Spring Boot的service层广泛应用,但根据实际需求也可能存在无需事务的情况,例如独立数据插入操作。
425 0
|
JSON 前端开发 Java
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestBody
`@RequestBody` 是 Spring 框架中的注解,用于将 HTTP 请求体中的 JSON 数据自动映射为 Java 对象。例如,前端通过 POST 请求发送包含 `username` 和 `password` 的 JSON 数据,后端可通过带有 `@RequestBody` 注解的方法参数接收并处理。此注解适用于传递复杂对象的场景,简化了数据解析过程。与表单提交不同,它主要用于接收 JSON 格式的实体数据。
1746 0
|
前端开发 Java 微服务
《深入理解Spring》:Spring、Spring MVC与Spring Boot的深度解析
Spring Framework是Java生态的基石,提供IoC、AOP等核心功能;Spring MVC基于其构建,实现Web层MVC架构;Spring Boot则通过自动配置和内嵌服务器,极大简化了开发与部署。三者层层演进,Spring Boot并非替代,而是对前者的高效封装与增强,适用于微服务与快速开发,而深入理解Spring Framework有助于更好驾驭整体技术栈。
|
Java 关系型数据库 数据库
深度剖析【Spring】事务:万字详解,彻底掌握传播机制与事务原理
在Java开发中,Spring框架通过事务管理机制,帮我们轻松实现了这种“承诺”。它不仅封装了底层复杂的事务控制逻辑(比如手动开启、提交、回滚事务),还提供了灵活的配置方式,让开发者能专注于业务逻辑,而不用纠结于事务细节。
1355 1
|
人工智能 Java 数据库连接
Spring事务失效场景
本文深入探讨了Spring框架中事务管理可能失效的几种常见场景及解决方案,包括事务方法访问级别不当、方法内部自调用、错误的异常处理、事务管理器或数据源配置错误、数据库不支持事务以及不合理的事务传播行为或隔离级别。通过合理配置和正确使用`@Transactional`注解,开发者可以有效避免这些问题,确保应用的数据一致性和完整性。
1274 10
|
前端开发 Java API
Spring Cloud Gateway Server Web MVC报错“Unsupported transfer encoding: chunked”解决
本文解析了Spring Cloud Gateway中出现“Unsupported transfer encoding: chunked”错误的原因,指出该问题源于Feign依赖的HTTP客户端与服务端的`chunked`传输编码不兼容,并提供了具体的解决方案。通过规范Feign客户端接口的返回类型,可有效避免该异常,提升系统兼容性与稳定性。
988 0