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

相关文章
|
22天前
|
前端开发 Java 微服务
《深入理解Spring》:Spring、Spring MVC与Spring Boot的深度解析
Spring Framework是Java生态的基石,提供IoC、AOP等核心功能;Spring MVC基于其构建,实现Web层MVC架构;Spring Boot则通过自动配置和内嵌服务器,极大简化了开发与部署。三者层层演进,Spring Boot并非替代,而是对前者的高效封装与增强,适用于微服务与快速开发,而深入理解Spring Framework有助于更好驾驭整体技术栈。
|
2月前
|
消息中间件 存储 Java
RabbitMQ 和 Spring Cloud Stream 实现异步通信
本文介绍了在微服务架构中,如何利用 RabbitMQ 作为消息代理,并结合 Spring Cloud Stream 实现高效的异步通信。内容涵盖异步通信的优势、RabbitMQ 的核心概念与特性、Spring Cloud Stream 的功能及其与 RabbitMQ 的集成方式。通过这种组合,开发者可以构建出具备高可用性、可扩展性和弹性的分布式系统,满足现代应用对快速响应和可靠消息传递的需求。
156 2
RabbitMQ 和 Spring Cloud Stream 实现异步通信
|
8月前
|
前端开发 Java 测试技术
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestParam
本文介绍了 `@RequestParam` 注解的使用方法及其与 `@PathVariable` 的区别。`@RequestParam` 用于从请求中获取参数值(如 GET 请求的 URL 参数或 POST 请求的表单数据),而 `@PathVariable` 用于从 URL 模板中提取参数。文章通过示例代码详细说明了 `@RequestParam` 的常用属性,如 `required` 和 `defaultValue`,并展示了如何用实体类封装大量表单参数以简化处理流程。最后,结合 Postman 测试工具验证了接口的功能。
436 0
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestParam
|
8月前
|
JSON 前端开发 Java
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestBody
`@RequestBody` 是 Spring 框架中的注解,用于将 HTTP 请求体中的 JSON 数据自动映射为 Java 对象。例如,前端通过 POST 请求发送包含 `username` 和 `password` 的 JSON 数据,后端可通过带有 `@RequestBody` 注解的方法参数接收并处理。此注解适用于传递复杂对象的场景,简化了数据解析过程。与表单提交不同,它主要用于接收 JSON 格式的实体数据。
663 0
|
8月前
|
前端开发 Java 微服务
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@PathVariable
`@PathVariable` 是 Spring Boot 中用于从 URL 中提取参数的注解,支持 RESTful 风格接口开发。例如,通过 `@GetMapping("/user/{id}")` 可以将 URL 中的 `{id}` 参数自动映射到方法参数中。若参数名不一致,可通过 `@PathVariable("自定义名")` 指定绑定关系。此外,还支持多参数占位符,如 `/user/{id}/{name}`,分别映射到方法中的多个参数。运行项目后,访问指定 URL 即可验证参数是否正确接收。
429 0
|
8月前
|
JSON 前端开发 Java
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestMapping
@RequestMapping 是 Spring MVC 中用于请求地址映射的注解,可作用于类或方法上。类级别定义控制器父路径,方法级别进一步指定处理逻辑。常用属性包括 value(请求地址)、method(请求类型,如 GET/POST 等,默认 GET)和 produces(返回内容类型)。例如:`@RequestMapping(value = "/test", produces = "application/json; charset=UTF-8")`。此外,针对不同请求方式还有简化注解,如 @GetMapping、@PostMapping 等。
374 0
|
8月前
|
JSON 前端开发 Java
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RestController
本文主要介绍 Spring Boot 中 MVC 开发常用的几个注解及其使用方式,包括 `@RestController`、`@RequestMapping`、`@PathVariable`、`@RequestParam` 和 `@RequestBody`。其中重点讲解了 `@RestController` 注解的构成与特点:它是 `@Controller` 和 `@ResponseBody` 的结合体,适用于返回 JSON 数据的场景。文章还指出,在需要模板渲染(如 Thymeleaf)而非前后端分离的情况下,应使用 `@Controller` 而非 `@RestController`
279 0
|
4月前
|
前端开发 Java API
Spring Cloud Gateway Server Web MVC报错“Unsupported transfer encoding: chunked”解决
本文解析了Spring Cloud Gateway中出现“Unsupported transfer encoding: chunked”错误的原因,指出该问题源于Feign依赖的HTTP客户端与服务端的`chunked`传输编码不兼容,并提供了具体的解决方案。通过规范Feign客户端接口的返回类型,可有效避免该异常,提升系统兼容性与稳定性。
291 0
|
4月前
|
人工智能 安全 Java
Spring Boot 中使用 Function 和异步线程池处理列表拆分任务并汇总结果
在Java开发中,处理大规模数据时常常需要将列表拆分为多个子列表进行异步处理并汇总结果。本文介绍如何在Spring Boot中使用Function和异步线程池实现高效且可维护的代码,涵盖结果封装、线程池配置、列表拆分处理及结果汇总等关键步骤。
164 0
|
4月前
|
SQL Java 数据库连接
Spring、SpringMVC 与 MyBatis 核心知识点解析
我梳理的这些内容,涵盖了 Spring、SpringMVC 和 MyBatis 的核心知识点。 在 Spring 中,我了解到 IOC 是控制反转,把对象控制权交容器;DI 是依赖注入,有三种实现方式。Bean 有五种作用域,单例 bean 的线程安全问题及自动装配方式也清晰了。事务基于数据库和 AOP,有失效场景和七种传播行为。AOP 是面向切面编程,动态代理有 JDK 和 CGLIB 两种。 SpringMVC 的 11 步执行流程我烂熟于心,还有那些常用注解的用法。 MyBatis 里,#{} 和 ${} 的区别很关键,获取主键、处理字段与属性名不匹配的方法也掌握了。多表查询、动态
138 0