SpringBoot面试题, Spring Boot 中如何实现异步处理?

Step 1

Q:: 如何在 Spring Boot 中实现异步处理？

A:: 在 Spring Boot 中，可以使用 @Async 注解来实现异步处理。首先需要在配置类或启动类上加上 @EnableAsync 注解以启用异步支持。然后，在需要异步执行的方法上添加 @Async 注解。该方法会在独立的线程中异步执行，不会阻塞主线程。例如：

 
@Async
public void asyncMethod() {
   // 业务逻辑
}
 

注意，@Async 注解的方法必须是 public 的，并且不能是同一个类中调用，必须通过 Spring 容器管理才能生效。

Step 2

Q:: Spring Boot 中 @Async 的工作原理是什么？

A:: Spring Boot 中的 @Async 注解通过 AOP（面向切面编程）实现异步处理。Spring 在运行时会生成一个代理对象，当调用标记了 @Async 的方法时，代理对象会拦截调用并将其提交给一个线程池异步执行。默认情况下，Spring 使用 SimpleAsyncTaskExecutor，但可以通过定义一个 ThreadPoolTaskExecutor Bean 来自定义线程池。

Step 3

Q:: 如何自定义 Spring Boot 中的异步线程池？

A:: 可以通过在配置类中定义一个 ThreadPoolTaskExecutor Bean 来自定义异步线程池。例如：

 
@Bean(name = "taskExecutor")
public Executor taskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(5);
    executor.setMaxPoolSize(10);
    executor.setQueueCapacity(25);
    executor.initialize();
    return executor;
}
 

然后在 @Async 注解的方法上可以通过参数指定使用的线程池：

 
@Async("taskExecutor")
public void asyncMethod() {
    // 业务逻辑
}
 

Step 4

Q:: 如何处理异步方法的异常？

A:: 可以在 Spring Boot 中使用 @Async 注解的异步方法中通过 try-catch 块捕获异常并进行处理。此外，还可以通过设置自定义的 AsyncUncaughtExceptionHandler 来处理未捕获的异常。可以在配置类中定义一个 AsyncConfigurer 接口的实现来设置全局的异步异常处理器：

 
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new CustomAsyncExceptionHandler();
    }
}
 

Step 5

Q:: 异步方法的返回值如何处理？

A:: 在 Spring Boot 中，标记为 @Async 的异步方法可以返回一个 java.util.concurrent.Future 或 org.springframework.util.concurrent.ListenableFuture 对象。通过这些对象可以获取异步任务的执行结果或处理其完成事件。例如：

 
@Async
public Future<String> asyncMethodWithReturn() {
    // 业务逻辑
    return new AsyncResult<>("result");
}
 

ListenableFuture 还提供了回调机制，可以注册成功或失败的回调函数。