做一个购物网站,网站建设专业团队图片,apmserv搭建网站,满屏网站做多大尺寸在 Spring Boot 中#xff0c;Async 注解用于实现异步方法调用#xff0c;允许方法在单独的线程中执行#xff0c;从而避免阻塞主线程#xff0c;提升应用的并发处理能力。
1. 基本用法
在 Spring Boot 中使用 Async 很简单#xff0c;主要步骤如下#xff1a;
步骤 1…在 Spring Boot 中Async 注解用于实现异步方法调用允许方法在单独的线程中执行从而避免阻塞主线程提升应用的并发处理能力。
1. 基本用法
在 Spring Boot 中使用 Async 很简单主要步骤如下
步骤 1启用异步支持
首先需要在 Spring Boot 应用程序的启动类或配置类上加上 EnableAsync 注解以启用异步方法的支持。
SpringBootApplication
EnableAsync
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class, args);}
}步骤 2定义异步方法
然后在需要异步执行的方法上加上 Async 注解。注意异步方法需要返回 void 或 Future 类型如 CompletableFuture。
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import java.util.concurrent.CompletableFuture;Service
public class AsyncService {Asyncpublic void asyncMethod() {// 模拟耗时操作try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(异步方法执行完成);}Asyncpublic CompletableFutureString asyncMethodWithReturn() {try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}return CompletableFuture.completedFuture(异步方法带返回值执行完成);}
}步骤 3调用异步方法
当调用 Async 注解的方法时方法将会在独立的线程中执行不会阻塞调用它的线程。
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.CompletableFuture;RestController
public class AsyncController {Autowiredprivate AsyncService asyncService;GetMapping(/async)public String callAsyncMethod() {asyncService.asyncMethod();return 调用了异步方法;}GetMapping(/async-with-return)public CompletableFutureString callAsyncMethodWithReturn() {return asyncService.asyncMethodWithReturn();}
}2. 自定义线程池
默认情况下Spring 使用 SimpleAsyncTaskExecutor 来处理异步任务但你可以自定义线程池来管理这些任务。
自定义线程池配置
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.Executor;Configuration
EnableAsync
public class AsyncConfig {Bean(name asyncExecutor)public Executor asyncExecutor() {ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor();executor.setCorePoolSize(5);executor.setMaxPoolSize(10);executor.setQueueCapacity(25);executor.setThreadNamePrefix(AsyncThread-);executor.initialize();return executor;}
}然后在异步方法上指定使用这个线程池
Async(asyncExecutor)
public void asyncMethod() {// 方法实现
}3. 异步方法的限制
异步方法不能是 private 方法因为 Spring 需要通过代理对象来处理异步调用。异步方法必须通过代理对象调用不能直接在同一个类内部调用否则 Async 不会生效。
4. 异步方法异常处理
对于返回 Future 或 CompletableFuture 的异步方法可以通过 .exceptionally() 或 .handle() 方法处理异常
Async
public CompletableFutureString asyncMethodWithException() {return CompletableFuture.supplyAsync(() - {if (true) {throw new RuntimeException(异常发生);}return 成功;}).exceptionally(ex - 处理异常: ex.getMessage());
}对于 void 类型的异步方法可以使用 AsyncUncaughtExceptionHandler 处理未捕获的异常
import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;import java.lang.reflect.Method;Configuration
public class AsyncExceptionHandler implements AsyncConfigurer {Overridepublic AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {return new AsyncUncaughtExceptionHandler() {Overridepublic void handleUncaughtException(Throwable ex, Method method, Object... params) {System.out.println(异步方法出现未捕获异常: ex.getMessage());}};}
}总结
Async 注解为 Spring Boot 提供了非常简洁的异步调用支持能有效提升应用的并发处理能力。通过自定义线程池和异常处理机制还可以更好地控制异步任务的执行与监控。
