springboot之异步调用@Async
本文内容纲要:
引言:在Java应用中,绝大多数情况下都是通过同步的方式来实现交互处理的;但是在处理与第三方系统交互的时候,容易造成响应迟缓的情况,之前大部分都是使用多线程来完成此类任务,其实,在spring3.x之后,就已经内置了@Async来完美解决这个问题,本文将介绍在springboot中如何使用@Async。
1、pom.xml中导入必要的依赖:
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.RELEASE</version>
</parent>
<dependencies>
<!--SpringBoot核心组件-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-tomcat</artifactId>
</dependency>
</dependencies>
2、写一个springboot的启动类:
importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.EnableAutoConfiguration;
importorg.springframework.context.annotation.ComponentScan;
importorg.springframework.scheduling.annotation.EnableAsync;
@ComponentScan(basePackages={"com.xwj.controller","com.xwj.service"})
@EnableAsync//开启异步调用
@EnableAutoConfiguration
publicclassApp{
publicstaticvoidmain(String[]args){
SpringApplication.run(App.class,args);
}
}
注意在这里一定要加上**@EnableAsync**注解开启异步调用
3、建一个controller包,然后新建一个IndexController类,用来获取请求
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RestController;
importcom.xwj.service.UserService;
@RestController
publicclassIndexController{
@Autowired
privateUserServiceuserService;
@RequestMapping("/async")
publicStringasync(){
System.out.println("####IndexController####1");
userService.sendSms();
System.out.println("####IndexController####4");
return"success";
}
}
4、建一个service包,然后新建一个UserService类:
importorg.springframework.scheduling.annotation.Async;
importorg.springframework.stereotype.Service;
@Service
publicclassUserService{
@Async
publicvoidsendSms(){
System.out.println("####sendSms####2");
IntStream.range(0,5).forEach(d->{
try{
Thread.sleep(1000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
});
System.out.println("####sendSms####3");
}
}
先注掉@EnableAsync和@Async两个注解,看下同步调用执行的效果。执行结果如下:
####IndexController####1
####sendSms####2
####sendSms####3
####IndexController####4
对于sendSms方法,我们并不关注它什么时候执行完,所以可以采用异步的方式去执行。放开@EnableAsync和@Async两个注解,执行结果如下:
####IndexController####1
####IndexController####4
####sendSms####2
####sendSms####3
bingo!达到了我们预期的效果
总结:
使用了@Async的方法,会被当成是一个子线程,所有整个sendSms方法,会在主线程执行完了之后执行
同一个类中,一个方法调用另外一个有@Async的方法,注解是不会生效的
本文内容总结:
原文链接:https://www.cnblogs.com/xuwenjin/p/8858050.html