springboot中使用@Async实现异步方法调用-蒲公英云

springboot中使用@Async实现异步方法调用

1、场景描述

我们在开发的过程中，可能会遇见如下场景：

一个业务A，这个A业务中包含了4个小业务，分别是a,b,c,d。在实际操作中，有时候第三个业务c，执行的时间比较长或者c业务是属于其他系统的api调用。这个时候，我们就期望a,c,d三个也是先执行完毕，然后提示用户业务成功。而不必等待c业务结束后，在提示用户。这样的好处是，能够实现业务分离，且用户体验较好。

常见的应用场景：如短信方法，订单提交，邮件发送，消息推送等。

常见的解决办法：

第一种：可以通过RabbitMQ\ActiveMQ\KAFKA等消息中间件实现

第二种：可以通过@Async注解实现

总结：

如果调用的服务涉及到其他系统建议使用消息中间件

如果调用的服务都在一个工程中，建议使用@Async注解，足够使用。

2、@Async实现异步调用方式

2.1、创建sprigboot工程

我使用的springboot是2.7.9版本，同时选择了springboot-web开发，包信息如下

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.7.9</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

2.2、在启动类中开启异步任务

@EnableAsync//开启异步任务
@SpringBootApplication
public class SpringbootAsyncApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringbootAsyncApplication.class, args);
    }
}

2.3、创建StudentAsyncService业务类

说明1：@Async注解写在类上，表示所有方法都异步执行，写在方法上表示某一个方法异步执行

说明2：StudentAsyncService需要被spring扫描到，如果是业务层使用@Service,其他地方使用@Component注解。

@Service
public class StudentAsyncService {
    @Async//那个方法需要使用异步调用，就使用该注解
    public void asyncMethod(String data) {
        try{
            Thread.sleep(6000);//模拟异步执行业务的时间
        }catch (Exception e){
            System.out.println(e.getStackTrace());
        }
        System.out.println("=======异步线程执行结束========");
    }
}

2.4、创建控制层类调用service异步方法

@Controller
public class StudentController {
    @Autowired
    private StudentAsyncService studentAsyncService;
    @RequestMapping("/testMethod")
    public String testMethod(){
        System.out.println("======主线程开始执行======");
        studentAsyncService.asyncMethod("你要传递的数据");//异步执行方法
        System.out.println("======主线程结束执行======");
        return "index";//返回的视图逻辑地址
    }
}