SpringBoot中Async异步调用方法？

在 Spring Boot 中，你可以使用 @Async 注解来实现异步调用方法。异步方法的执行将在独立的线程中进行，而不会阻塞调用者的线程。以下是使用 @Async 注解的步骤：

1. 在主类上添加 @EnableAsync 注解：
   • 在你的主类（包含 main 方法的类）上添加 @EnableAsync 注解，以启用异步方法的支持。

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

2. 在异步方法上添加 @Async 注解：
   • 在希望异步执行的方法上添加 @Async 注解。

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

   上述代码中的 asyncMethod 就是一个异步方法。

3. 调用异步方法：
   • 在其他组件中调用异步方法。

   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.stereotype.Controller;
   import org.springframework.web.bind.annotation.GetMapping;
   
   @Controller
   public class MyController {
   
       @Autowired
       private MyService myService;
   
       @GetMapping("/invokeAsyncMethod")
       public String invokeAsyncMethod() {
           myService.asyncMethod();
           return "Async method invoked.";
       }
   }
   

   上述代码中，invokeAsyncMethod 方法调用了 MyService 中的 asyncMethod，而 asyncMethod 将在异步的线程中执行。

请注意以下几点：

• 异步方法通常应该返回 void，因为调用者无法等待异步方法的返回值。
• 异步方法通常需要在启动类上使用 @EnableAsync 启用异步支持。
• 异步方法通常需要在应用程序的配置中配置一个 TaskExecutor bean，以指定异步方法在哪个线程池中执行。如果没有配置，默认将使用一个合适的线程池。

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.SimpleAsyncTaskExecutor;
import org.springframework.core.task.TaskExecutor;

@Configuration
public class AsyncConfig {

    @Bean
    public TaskExecutor taskExecutor() {
        return new SimpleAsyncTaskExecutor();
    }
}

上述代码中，taskExecutor 方法配置了一个简单的线程池，你可以根据需要配置更复杂的线程池。