springboot异步@Async的使用及失效场景介绍
引言
在 java 中很多业务涉及到异步线程，比如在业务流处理时，需要发短信发邮件通知用户，或者需要上传一些文件资源到其他服务器这种耗时的操作。
这种比较耗时的操作如果都在主线程里处理会阻塞整理流程，而且我们也不需要等待处理结果之后再进行下一步操作，这时候就可以使用异步线程进行处理，这样主线程不会因为这些耗时的操作而阻塞，保证主线程的流程可以正常进行。
一、@Async 使用位置
- 在方法上使用该@Async注解，表明该方法是一个异步任务
- 在类上面使用该@Async注解，表明该类中的所有方法都是异步任务
二、@Async 使用
在 Springboot 中使用 @Async：
- @Async 注解在使用时，如果不指定线程池的名称，则使用默认的线程池，Spring默认的线程池为
SimpleAsyncTaskExecutor。 - 方法上一旦标记了这个 @Async 注解，当其它线程调用这个方法时，就会开启一个新的子线程去异步处理该业务逻辑。
- 启动类中增加
@EnableAsync注解
代码示例：
本文不做新配置，全部使用默认的线程池及配置。
（1）创建 AsyncService 写异步方法
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
@Service
public class AsyncService {
@Async
public void Async() throws InterruptedException {
Thread.sleep(10000);
System.out.println("程序睡眠结束");
}
（2）编写业务层 AsyncTestService
package com.ruoyi.system.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
@Service
public class AsyncTestService {
@Autowired
private AsyncService asyncService;
public String testSync() throws InterruptedException {
System.out.println("开始进入方法");
System.out.println("进行时");
System.out.println("正在进行时");
asyncService.Async();
return "成功";
}
}
（3）编写接口 AsyncTestController
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping(value = "/async/lost")
public class AsyncTestController {
@Autowired
private AsyncTestService asyncTestService;
@RequestMapping(value = "/test", method = {RequestMethod.POST})
public String testAsync() throws InterruptedException {
asyncTestService.testSync();
System.out.println("调用Controller控制器结束");
return "成功";
}
}
postman 测试：
从下图测试结果可知，打印语句 “调用Controller控制器结束” 在 “程序睡眠结束” 之前执行，异步实现成功，没有影响到主线程的任务。
三、注解 @Async 失效的情况
（1）调用同一个类中的异步方法（内部调用）
从上面的 @Async 使用我们看到，添加注解的异步方法在一个单独的类 AsyncService 中，然后注入到 AsyncTestService 中进行调用。如果异步方法和调用的方法在同一个类中，还会正常进行异步调用吗？
AsyncTestService 代码如下：
@Service
public class AsyncTestService {
public String testSync() throws InterruptedException {
System.out.println("开始进入方法");
System.out.println("进行时");
System.out.println("正在进行时");
Async();
return "成功";
}
@Async
public void Async() throws InterruptedException {
Thread.sleep(10000);
System.out.println("程序睡眠结束");
}
}
postman 测试：
如上图所示，打印语句 “调用Controller控制器结束” 在 “程序睡眠结束” 之后执行，说明异步并没有生效，程序还是走了主线程。
这是因为 @Async注解是通过aop代理实现的，需要通过JDK动态代理或者cglib，生成代理对象。异步的功能，是在代理对象中增加的，我们必须调用代理对象的 testSync() 方法才行。而在类中直接进行方法的内部调用，在 testSync() 方法中调用Async()方法，调用的是该类原对象的Async方法，相当于调用了this.Async()方法，而并非AsyncTestService 代理类的 Async() 方法。 因此，像这种内部方法调用，@Async注解的异步功能会失效。
要想在同一个类中调用异步方法，需要使用 ApplicationContext 获得到该类。
AsyncTestService 代码如下：
import org.springframework.aop.support.AopUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
@Service
public class AsyncTestService {
@Autowired
private ApplicationContext applicationContext;
public String testSync() throws InterruptedException {
AsyncTestService asyncBean = applicationContext.getBean(AsyncTestService.class);
System.out.println("当前对象是否是代理对象:" + AopUtils.isAopProxy(asyncBean));
System.out.println("是否是cglib代理对象:" + AopUtils.isCglibProxy(asyncBean));
System.out.println("是否是jdk代理对象:" + AopUtils.isJdkDynamicProxy(asyncBean));
System.out.println(asyncBean == this);
asyncBean.Async();
return "成功";
}
@Async
public void Async() throws InterruptedException {
Thread.sleep(10000);
System.out.println("程序睡眠结束");
}
}
postman 测试：
打印控制器语句在前，异步实现成功。
（2）未使用 @EnableAsync 注解
在 Springboot 中要开启@Async注解异步的功能，需要在项目的启动类，或者配置类上，使用@EnableAsync注解。
@EnableAsync注解相当于一个开关，控制是否开启@Async注解异步的功能，默认是关闭的。
@EnableAsync
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
（3）注解@Async的方法不是public方法
异步的方法必须是 public修饰的，否则 aop 代理异常，异步失效。
（4）返回值错误
注解 @Async 的返回值只能为 void 或 Future。
（5）方法用static修饰了
使用@Async注解声明的方法，必须是能被重写的，很显然static修饰的方法，是类的静态方法，是不允许被重写的。
因此这种情况下，@Async注解的异步功能会失效。
（6）类中需要使用@Autowired或@Resource等注解自动注入,不能自己手动new对象
（7）方法用final修饰
（8）业务类没加@Service注解
到此这篇关于springboot异步@Async的使用及失效场景介绍的文章就介绍到这了,更多相关springboot异步@Async内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要为大家详细介绍了Java实现图片与二进制的互相转换，将图片转二进制再将二进制转成图片，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-03-03
致敬经典的warcraft，《warcraft java版》是一款即时战略题材单机游戏，采用魔兽原味风格和机制。本文将用java语言实现，采用了swing技术进行了界面化处理，感兴趣的可以了解一下2022-09-09
SpringBoot整合Springsecurity实现数据库登录及权限控制功能
本教程详细介绍了如何使用SpringBoot整合SpringSecurity实现数据库登录和权限控制,本文分步骤结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧2024-10-10
Swagger注解-@ApiModel和@ApiModelProperty的用法
这篇文章主要介绍了Swagger注解-@ApiModel和@ApiModelProperty的用法，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-06-06
这篇文章主要由浅入深为大家介绍了springboot中使用redis的方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-11-11
这篇文章主要介绍了JDK动态代理,代理接口没有实现类,实现动态代理方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-08-08
这篇文章主要介绍了java加载属性配置properties文件的方法,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-03-03
Maven Web项目使用Cargo插件实现自动化部署的详细步骤
cargo ，它是一组帮助用户实现自动化部署，操作Web容器的工具，并且几乎支持所有的Web容器，这篇文章主要介绍了Maven Web项目使用Cargo实现自动化部署,需要的朋友可以参考下2023-02-02
这篇文章主要介绍了SpringBoot和前端联动实现存储浏览记录功能,本文通过示例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧2024-01-01
下面小编就为大家带来一篇基于JVM性能监控命令介绍。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-09-09
最新评论