Spring Boot 中的异步 @Async

效率工具

推荐一个程序员常用的工具网站：程序员常用工具（http://cxytools.com），有时间戳、JSON格式化、文本对比、HASH生成、UUID生成等常用工具，效率加倍嘎嘎好用。

小报童专栏精选Top100

推荐一个小报童专栏导航站：小报童精选Top100（http://xbt100.top），收录了生财有术项目精选、AI海外赚钱、纯银的产品分析等专栏，陆续会收录更多的专栏，欢迎体验～

云服务器

云服务器限时免费领：轻量服务器2核4G
腾讯云：2核2G4M云服务器新老同享99元/年，续费同价
阿里云：2核2G3M的ECS服务器只需99元/年，续费同价

Spring Boot 中的异步 @Async

在开发中，有时我们会遇到一些需要耗费较长时间的操作，例如发送邮件、调用外部接口、批量处理数据等。如果在主线程中执行这些操作，可能会导致主线程阻塞，影响系统的响应速度和用户体验。为了解决这个问题，Spring Boot 提供了异步执行的支持，其中就包括了 @Async 注解。本文将介绍 Spring Boot 中的异步处理机制以及如何使用 @Async 注解进行异步方法调用。

1. 异步处理的优势

在介绍 @Async 注解之前，让我们先了解一下为什么需要异步处理：

提升系统的响应速度： 将一些耗时的操作异步执行，可以释放主线程，使系统更快地响应用户的请求。
提高系统的并发能力： 异步处理可以让系统同时处理多个请求，提高系统的并发处理能力。
避免阻塞： 如果在主线程中执行耗时操作，可能会导致主线程阻塞，影响其他请求的处理。

2. @Async 注解的使用

在 Spring Boot 中，通过 @Async 注解可以将方法标记为异步执行。使用 @Async 注解的方法会在调用时自动被 Spring 放入线程池中执行，并且可以在方法上返回 Future 或 CompletableFuture 对象，以便获取异步执行的结果。

2.1 添加 @Async 注解

要使用 @Async 注解，需要进行以下步骤：

在 Spring Boot 启动类上添加 @EnableAsync 注解，开启异步方法的支持。

import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
@EnableAsync
public class MyApplication {public static void main(String[] args) {SpringApplication.run(MyApplication.class, args);}
}

在需要异步执行的方法上添加 @Async 注解。

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;@Service
public class MyService {@Asyncpublic void asyncMethod() {// 异步执行的方法体}
}

2.2 返回 Future 对象

如果需要获取异步方法的执行结果，可以在方法上返回 Future 对象：

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import java.util.concurrent.Future;@Service
public class MyService {@Asyncpublic Future<String> asyncMethod() {// 异步执行的方法体return new AsyncResult<>("异步方法执行完成");}
}

3. 异步方法的注意事项

在使用 @Async 注解时，需要注意以下几点：

方法不能为 private： 异步方法不能为 private，否则无法被代理。
异步方法与调用方在同一个类中无效： 如果异步方法和调用方在同一个类中，@Async 注解无效，因为 Spring 会直接调用该方法而不会经过代理。
异步方法不能捕获异常： 如果异步方法内部抛出异常，无法被捕获，因为异常会被封装到 Future 或 CompletableFuture 中，需要通过 Future.get() 方法获取。

4. 示例：使用 @Async 注解发送邮件

让我们通过一个示例来演示如何使用 @Async 注解发送邮件：

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.beans.factory.annotation.Autowired;@Service
public class EmailService {@Autowiredprivate JavaMailSender mailSender;@Asyncpublic void sendEmail(String to, String subject, String text) {SimpleMailMessage message = new SimpleMailMessage();message.setTo(to);message.setSubject(subject);message.setText(text);mailSender.send(message);}
}