企业官网建设流程全解析

核心作用：Spring 提供的注解，标注在类或方法上，使方法在异步线程中执行，调用者无需等待方法完成即可继续执行后续逻辑。

使用两步走：

1. 启动类添加@EnableAsync，开启异步任务支持；
2. 需异步执行的方法 / 类上添加@Async注解（示例中常用CompletableFuture处理异步结果）。

@Async 原理分析

@Async可以异步执行任务，本质上是使用动态代理来实现的。通过 Spring 中的后置处理器BeanPostProcessor为使用@Async注解的类创建动态代理，之后@Async注解方法的调用会被动态代理拦截，在拦截器中将方法的执行封装为异步任务提交给线程池处理。

开启异步：@EnableAsync 的作用

• @EnableAsync通过@Import(AsyncConfigurationSelector.class)加载配置类；
• AsyncConfigurationSelector根据AdviceMode（默认PROXY）选择加载ProxyAsyncConfiguration；
• ProxyAsyncConfiguration注册关键后置处理器AsyncAnnotationBeanPostProcessor。

后置处理器：动态代理的核心

• AsyncAnnotationBeanPostProcessor是@Async生效的关键，会为标注@Async的类创建动态代理；
• 该处理器通过setBeanFactory()方法创建AsyncAnnotationAdvisor（Spring AOP 的Advisor组件）。

创建Advisor：定义拦截规则与逻辑

dvisor包含Advice（通知逻辑）和Pointcut（切入点）：

• Advice：创建AnnotationAsyncExecutionInterceptor拦截器，负责异步执行逻辑；
• Pointcut：通过AnnotationMatchingPointcut匹配类 / 方法上的@Async注解（类级别 + 方法级别）。

后置处理器逻辑：生成代理对象

• Bean 初始化后，postProcessAfterInitialization()方法判断 Bean 是否符合Advisor规则；
• 符合规则则通过ProxyFactory创建代理对象，后续@Async方法调用会被代理拦截。

@Async 注解方法的拦截

1. 确定异步执行器（线程池）

• 优先从缓存获取，或通过@Async的value限定符查找自定义线程池；
• 无自定义线程池时，默认使用SimpleAsyncTaskExecutor（风险提示：每次创建新线程，无复用，高并发下易导致资源耗尽）。

2. 封装异步任务

• 将目标方法执行逻辑（invocation.proceed()）封装为Callable任务；
• 若方法返回Future类型，会阻塞等待结果（处理异步嵌套调用），其他类型执行后返回null。

3. 提交异步任务

根据方法返回值类型选择提交方式：

• CompletableFuture：用supplyAsync()提交；
• ListenableFuture：用submitListenable()提交；
• Future：直接submit()提交；
• void或其他类型：submit()提交后返回null。

总结

理解@Async原理的核心在于理解@EnableAsync注解，该注解开启了异步任务的功能。

主要流程如下图：

@Async 使用建议

必须自定义线程池

• 避免使用默认的SimpleAsyncTaskExecutor，推荐ThreadPoolTaskExecutor；
• 可配置核心线程数、最大线程数、队列容量等（示例：创建executor1、executor2等不同线程池，通过@Async("executor1")指定）。

避免 @Async 注解实效

规范返回值类型

• 无需结果：返回void；
• 需要结果：返回Future子类（如CompletableFuture、ListenableFuture）；
• 其他类型（如String、Object）：无法获取方法执行结果。

处理异步方法异常

• 全局处理：实现AsyncConfigurer重写getAsyncUncaughtExceptionHandler()，自定义异常处理器；
• 局部处理：用CompletableFuture的exceptionally()等方法捕获异常。

事务管理注意

• 异步方法需事务时，需添加@Transactional(propagation = Propagation.REQUIRES_NEW)，开启独立新事务（避免与调用方事务关联）。

控制执行顺序

• 异步方法默认无序，需按顺序执行时，用CompletableFuture的thenCompose()、thenAccept()等方法串联任务（如先执行fetchDataAsync，再执行processDataAsync）。