Spring （59）如何在Spring中实现异步处理

在Spring中实现异步处理通常涉及到@Async注解。这个注解允许你以异步的方式执行方法，即方法的调用将立即返回，而实际的执行将在不同的线程上异步进行。

使用`@Async`的步骤：

启用异步支持：在配置类上使用@EnableAsync注解，这会告诉Spring搜索@Async注解方法并运行它们在后台线程池中。

@Configuration
@EnableAsync
public class AsyncConfig {@Bean(name = "taskExecutor")public Executor taskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(2);executor.setMaxPoolSize(5);executor.setQueueCapacity(100);executor.setThreadNamePrefix("AsyncThread-");executor.initialize();return executor;}
}

在这个配置中，我们定义了一个线程池执行器ThreadPoolTaskExecutor，它决定了异步任务将如何被执行。

定义异步方法：在你想要异步执行的方法上添加@Async注解。

@Service
public class AsyncService {@Async("taskExecutor")public CompletableFuture<String> performAsyncTask(String param) {// 模拟长时间运行的任务try {Thread.sleep(5000);} catch (InterruptedException e) {Thread.currentThread().interrupt();}String result = "Task executed with " + param;return CompletableFuture.completedFuture(result);}
}

@Async注解可以指定一个特定的Executor的bean名称来使用。如果不指定，将使用默认的执行器。

调用异步方法：从其他的Spring管理的bean中调用异步方法。异步方法会立即返回一个Future对象，你可以使用这个对象来获取异步操作的结果。

@RestController
public class AsyncController {private final AsyncService asyncService;@Autowiredpublic AsyncController(AsyncService asyncService) {this.asyncService = asyncService;}@GetMapping("/startAsyncTask")public ResponseEntity<String> startAsyncTask(@RequestParam String param) {CompletableFuture<String> completableFuture = asyncService.performAsyncTask(param);return new ResponseEntity<>("Task is being executed!", HttpStatus.ACCEPTED);}// 这里的实现是简化的，实际情况下可能需要更复杂的逻辑来处理异步任务的结果。
}

异常处理

使用@Async时，你不能直接从调用方法中通过常规的try-catch块捕获异常。因为异常是在异步执行的线程中产生的，所以要管理异常，你需要在返回的Future上使用try-catch块。

CompletableFuture<String> future = asyncService.performAsyncTask("testParam");
future.whenComplete((res, ex) -> {if (ex != null) {// 处理异常情况System.out.println("Exception occurred: " + ex.getMessage());} else {// 使用结果System.out.println("Result: " + res);}
});