async注解,SpringBoot 中异步任务实现及自定义线程池执行异步任务

async注解,SpringBoot 中异步任务实现及自定义线程池执行异步任务详细介绍

本文目录一览： SpringBoot 中异步任务实现及自定义线程池执行异步任务

在SpringBoot项目开发中，异步任务可谓是提升用户体验的得力助手。通过异步处理，我们可以有效避免用户长时间的等待，从而提高交互的效率。

首先，我们可以通过模拟同步任务的方式，展示如何在Service层利用线程休眠来模拟复杂的业务逻辑。随后，在Controller层中调用这些服务，向前端返回初步的处理结果。这一过程不仅让开发者能够直观地理解异步任务的工作流程，同时也为后续的异步任务开发奠定了基础。

为了开启异步功能，我们只需在启动类上添加@EnableAsync注解。如此一来，我们便可以在Service方法上标注@Async，将原本需要等待的任务转变为异步执行。SpringBoot默认使用线程池来处理这些任务，而线程池的详细配置则可以通过application.yml文件进行灵活调整。

然而，在实际的项目开发中，不同的任务对系统资源的需求各不相同。例如，支付任务可能需要大量的系统资源，而邮件发送任务则相对资源需求较小。为了更好地优化资源调度，我们需要根据项目的实际需求来定制线程池。

自定义线程池的实现过程包括创建配置类，并使用@Bean注解将其注入到SpringBoot容器中。这样，我们就可以为每个线程池赋予特定的名称，以便于管理和维护。在Service方法中，通过@Async注解指定使用的线程池，就可以让任务在指定的线程池中执行。

此外，我们还可以定义多个线程池，根据具体任务的需求选择最合适的线程池。这样一来，我们就可以充分利用SpringBoot提供的异步任务处理机制，包括基础异步任务的使用和自定义线程池的配置，以适应项目中多样化的异步需求。

如有任何疑问或需要进一步的交流，欢迎在评论区留言。期待您能点赞、收藏本文，共同学习、共同进步！

@Async代理创建流程

上述注解的功能在于，它能够注册一个Bean，这个Bean实现了BeanPostProcessor接口，从而能够参与到Bean的初始化过程中。通过该注解，开发者可以定义一系列属性，并且“导入”了一个AsyncConfigurationSelector。这个类具有自动注册ProxyAsyncConfiguration的能力。也就是说，它注册了AsyncAnnotationBeanPostProcessor，这是一个能够完成Bean代理处理的组件。值得注意的是，AsyncAnnotationBeanPostProcessor仅仅实现了setBeanFactory方法。

在这个方法中，定义了一个名为AsyncAnnotationAdvisor的增强器。它的实现依赖于AbstractAdvisingBeanPostProcessor所定义的BeanPostProcessor方法。在Spring的上下文中，当存在多个自动代理器同时代理同一个Bean时，可能会产生Bean的二次代理问题。然而，AbstractAdvisingBeanPostProcessor已经充分考虑了这个问题。从命名上来看，“AbstractAdvisingBeanPostProcessor”即抽象增强后置处理器，而事务则依赖于AbstractAutoProxyCreator抽象的自动代理处理器。

当我们使用@Async注解时，Spring通过AsyncAnnotationBeanPostProcessor来完成处理工作。根据之前的分析，我们知道其子类重写了诸如isEligible、prepareProxyFactory和setBeanFactory等方法。Spring为此提供了一种工具方法——AopUtils.canApply()，这个方法不仅可以用于Spring容器内部，也可以脱离容器使用。

在启动项目后，Spring将校验Bean是否能够被@Async增强。这一校验过程包括检查方法和类上是否存在@Async注解。源码位于org.springframework.aop.support.MethodMatchers和org.springframework.aop.support.annotation等相关类中。其中，UnionMethodMatcher使用AnnotationClassFilter#matches进行验证类上是否存在@Async注解。而checkInherited参数则表示是否检查父类上是否存在注解，其默认值为true。

再来看AbstractAdvisingBeanPostProcessor，它是一个增强型的BeanPostProcessor。在处理器的内部定义了Advisor，这个操作是在org.springframework.scheduling.annotation.AsyncAnnotationBeanPostProcessor#setBeanFactory方法中完成的。源码中展示了org.springframework.aop.framework.autoproxy.AbstractBeanFactoryAwareAdvisingPostProcessor如何配置ProxyFactory以生成Proxy代理对象。这里的this对象指的就是AsyncAnnotationBeanPostProcessor实例，因为它实现了ProxyConfig接口（代理配置类），所以能够影响ProxyFactory的创建过程。当然，开发者也可以修改AsyncAnnotationBeanPostProcessor的BeanDefinition来定义自己的Proxy对象。