SpringBoot异步处理全过程

更新时间：2025年06月25日 09:05:47 作者：北辰alk

这篇文章主要介绍了SpringBoot异步处理全过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

Spring Boot 提供了强大的异步处理能力，可以帮助开发者轻松实现非阻塞式编程，提高系统吞吐量和响应速度。

以下是实现异步处理的完整方案：

一、基于注解的异步方法

1. 启用异步支持

@Configuration
@EnableAsync  // 核心注解，启用异步处理
public class AsyncConfig {
    
    // 可选：自定义线程池
    @Bean(name = "taskExecutor")
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);       // 核心线程数
        executor.setMaxPoolSize(10);       // 最大线程数
        executor.setQueueCapacity(100);    // 队列容量
        executor.setThreadNamePrefix("Async-"); // 线程名前缀
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}

2. 标记异步方法

@Service
public class EmailService {

    // 使用默认线程池
    @Async
    public CompletableFuture<String> sendEmailAsync(String to, String content) {
        // 模拟耗时操作
        Thread.sleep(1000);
        System.out.println("邮件发送至: " + to + "，线程: " + Thread.currentThread().getName());
        return CompletableFuture.completedFuture("success");
    }

    // 使用指定线程池
    @Async("taskExecutor")
    public void processInBackground(Order order) {
        // 后台处理逻辑
        System.out.println("处理订单: " + order.getId());
    }
}

3. 调用异步方法

@RestController
@RequestMapping("/api")
public class NotificationController {

    @Autowired
    private EmailService emailService;

    @GetMapping("/send")
    public ResponseEntity<String> sendNotification() {
        // 非阻塞调用
        CompletableFuture<String> future = emailService.sendEmailAsync("user@example.com", "Hello");
        
        // 可以继续执行其他逻辑
        System.out.println("请求已接收，邮件发送中...");
        
        return ResponseEntity.ok("请求已处理");
    }
}

二、响应式异步处理

1. 添加WebFlux支持

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

2. 响应式控制器

@RestController
@RequestMapping("/reactive")
public class ReactiveController {

    @GetMapping("/data")
    public Mono<String> getData() {
        return Mono.fromCallable(() -> {
            // 模拟耗时操作
            Thread.sleep(500);
            return "响应式数据";
        }).subscribeOn(Schedulers.boundedElastic()); // 指定异步调度器
    }
}

三、事件驱动的异步处理

1. 定义异步事件

public class OrderProcessedEvent extends ApplicationEvent {
    private final Order order;
    
    public OrderProcessedEvent(Object source, Order order) {
        super(source);
        this.order = order;
    }
    
    public Order getOrder() {
        return order;
    }
}

2. 异步事件监听

@Component
public class OrderEventListener {
    
    @Async
    @EventListener
    public void handleOrderEvent(OrderProcessedEvent event) {
        System.out.println("异步处理订单事件: " + event.getOrder().getId());
        // 执行耗时操作
    }
}

3. 发布事件

@Service
public class OrderService {
    
    private final ApplicationEventPublisher eventPublisher;
    
    public OrderService(ApplicationEventPublisher eventPublisher) {
        this.eventPublisher = eventPublisher;
    }
    
    public void processOrder(Order order) {
        // 业务逻辑...
        eventPublisher.publishEvent(new OrderProcessedEvent(this, order));
    }
}

四、异步RestTemplate

1. 配置AsyncRestTemplate

@Bean
public AsyncRestTemplate asyncRestTemplate() {
    return new AsyncRestTemplate(
        new ConcurrentTaskExecutor(Executors.newFixedThreadPool(10))
    );
}

2. 使用示例

@Service
public class ApiService {
    
    @Autowired
    private AsyncRestTemplate asyncRestTemplate;
    
    public ListenableFuture<ResponseEntity<String>> fetchDataAsync(String url) {
        return asyncRestTemplate.getForEntity(url, String.class);
    }
}

五、Spring WebClient (非阻塞HTTP客户端)

1. 配置WebClient

@Bean
public WebClient webClient() {
    return WebClient.builder()
            .baseUrl("https://api.example.com")
            .clientConnector(new ReactorClientHttpConnector(
                HttpClient.create().followRedirect(true)
            ))
            .build();
}

2. 使用示例

@Service
public class ApiConsumerService {
    
    @Autowired
    private WebClient webClient;
    
    public Mono<User> getUserAsync(String userId) {
        return webClient.get()
                .uri("/users/{id}", userId)
                .retrieve()
                .bodyToMono(User.class);
    }
}

六、事务边界处理

1. 异步事务处理

@Transactional
@Async
public CompletableFuture<Void> processWithTransaction(Order order) {
    // 业务逻辑
    orderRepository.save(order);
    return CompletableFuture.completedFuture(null);
}

2. 事务事件监听

@Async
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void handleAfterCommit(OrderEvent event) {
    // 事务提交后异步执行
    System.out.println("事务提交后处理: " + event.getOrderId());
}

七、异步异常处理

1. 自定义异常处理器

@Configuration
public class AsyncExceptionConfig implements AsyncConfigurer {
    
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return (ex, method, params) -> {
            System.err.println("异步方法异常: " + method.getName());
            ex.printStackTrace();
            // 可以发送通知或记录日志
        };
    }
}

2. 异常处理示例

@Async
public CompletableFuture<String> riskyOperation() {
    if (Math.random() > 0.5) {
        throw new RuntimeException("随机错误");
    }
    return CompletableFuture.completedFuture("成功");
}

// 调用处处理异常
riskyOperation().exceptionally(ex -> {
    System.out.println("处理异常: " + ex.getMessage());
    return "fallback";
});

八、性能监控与指标

1. 监控异步任务

@Async
@Timed(value = "async.email", description = "邮件发送耗时")
public void sendEmailWithMetrics(String to) {
    // 发送邮件逻辑
}

2. 线程池指标

@Bean
@ExportMeterRegistry
public ExecutorServiceMetrics executorServiceMetrics(MeterRegistry registry) {
    return new ExecutorServiceMetrics(
        Executors.newFixedThreadPool(5),
        "async.executor",
        Collections.emptyList()
    );
}

九、最佳实践

线程池配置：

根据业务类型隔离线程池(IO密集型 vs CPU密集型)
合理设置队列容量和拒绝策略

资源清理：

@PreDestroy
public void cleanup() {
    ((ThreadPoolTaskExecutor) executor).shutdown();
}

上下文传递：

@Bean
public Executor contextAwareExecutor() {
    return new DelegatingSecurityContextExecutorService(
        Executors.newFixedThreadPool(5)
    );
}

调试技巧：

设置线程名前缀便于日志追踪
使用MDC传递请求上下文

避免陷阱：

异步方法不能自调用
避免在异步方法中使用ThreadLocal
注意事务边界问题

十、完整示例

电商订单处理系统

@Slf4j
@Service
public class OrderProcessingService {

    @Async("orderTaskExecutor")
    @Transactional
    public CompletableFuture<OrderResult> processOrderAsync(Order order) {
        log.info("开始处理订单 {}", order.getId());
        
        // 1. 扣减库存
        inventoryService.reduceStock(order);
        
        // 2. 生成支付单
        Payment payment = paymentService.createPayment(order);
        
        // 3. 异步通知
        notificationService.sendOrderConfirmation(order);
        
        // 4. 记录审计日志
        auditService.logOrderProcessed(order);
        
        return CompletableFuture.completedFuture(
            new OrderResult(order.getId(), "SUCCESS")
        );
    }
}

@Configuration
@EnableAsync
public class AsyncConfig {
    
    @Bean(name = "orderTaskExecutor")
    public Executor orderTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(20);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("Order-Processor-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
    
    @Bean(name = "notificationTaskExecutor")
    public Executor notificationTaskExecutor() {
        // 单独线程池处理通知
        return new ThreadPoolTaskExecutor();
    }
}

Spring Boot的异步处理能力为构建高性能应用提供了强大支持，合理使用可以显著提升系统吞吐量。开发者应根据具体业务场景选择合适的异步模式，并注意线程安全、资源管理和异常处理等问题。

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

spring boot和mybatis集成分页插件
这篇文章主要为大家详细介绍了spring boot和mybatis集成分页插件，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-04-04
springboot如何引入外部yml配置文件
这篇文章主要介绍了springboot如何引入外部yml配置文件，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-08-08
druid连接池的参数配置示例全面解析
这篇文章主要为大家介绍了druid连接池的参数配置示例全面解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2023-09-09
java读取properties文件的方法实例分析
这篇文章主要介绍了java读取properties文件的方法,实例分析了java读取在项目中与不在项目中properties文件的相关技巧,需要的朋友可以参考下
2015-06-06
Java 解析Markdown文档格式的两种方式
CommonMark和Flexmark是两种用于解析Markdown文档的Java库,CommonMark提供了一种简洁和一致的Markdown格式语法规范,但不支持目录解析,而Flexmark是一个基于CommonMark的扩展库,不仅遵循了CommonMark规范,还提供了更多灵活的API和扩展功能
2024-10-10
java商城项目实战之购物车功能实现
这篇文章主要为大家详细介绍了java商城项目实战之购物车功能实现，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-04-04
SpringBoot实现大模型流式Streaming响应的示例代码
这篇文章主要为大家详细介绍了SpringBoot实现大模型流式Streaming响应的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下
2026-01-01
Java RabbitMQ 中的消息长期不消费会过期吗
RabbitMQ支持消息的过期时间,在消息发送时可以进行指定。 RabbitMQ支持队列的过期时间,从消息入队列开始计算,只要超过了队列的超时时间配置,那么消息会自动的清除
2021-09-09
SpringBoot整合数据库访问层的实战
本文主要介绍了SpringBoot整合数据库访问层的实战，主要包含JdbcTemplate和mybatis框架的整合应用，具有一定的参考价值，感兴趣的可以了解一下
2022-03-03
浅谈Java线程Thread之interrupt中断解析
这篇文章主要介绍了Java线程Thread之interrupt中断解析，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-01-01