Spring Boot 3.1.2 自定义线程池异常捕获 - 全局异常处理

在 Spring Boot 中，可以通过实现 AsyncUncaughtExceptionHandler 接口来捕获自定义线程池中的异常。

首先，创建一个类来实现 AsyncUncaughtExceptionHandler 接口，并重写 handleUncaughtException 方法来处理异常，例如：

public class CustomAsyncExceptionHandler implements AsyncUncaughtExceptionHandler {

    @Override
    public void handleUncaughtException(Throwable throwable, Method method, Object... obj) {
        // 处理异常逻辑
        System.out.println('捕获到异常：' + throwable.getMessage());
        // 可以根据需要进行日志记录、发送邮件等操作
    }
}

然后，在 Spring Boot 的配置类中配置自定义的线程池和异常处理器，例如：

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 配置线程池参数
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(100);
        executor.setQueueCapacity(10);
        executor.setThreadNamePrefix("CustomExecutor-");
        executor.initialize();
        return executor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new CustomAsyncExceptionHandler();
    }
}

最后，在需要异步执行的方法上添加 @Async 注解，例如：

@Service
public class MyService {

    @Async
    public void asyncMethod() {
        // 异步执行的方法逻辑
        throw new RuntimeException('自定义异常');
    }
}

当异步方法中抛出异常时，异常会被 CustomAsyncExceptionHandler 捕获并进行处理。你可以根据实际需求，在 handleUncaughtException 方法中添加逻辑来处理异常，比如记录日志、发送邮件等。