SpringBoot異步處理全過程
更新時間：2025年06月25日 09:05:47 作者：北辰alk
這篇文章主要介紹了SpringBoot異步處理全過程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
Spring Boot 提供了強大的異步處理能力，可以幫助開發(fā)者輕松實現(xiàn)非阻塞式編程，提高系統(tǒng)吞吐量和響應(yīng)速度。
以下是實現(xiàn)異步處理的完整方案：
一、基于注解的異步方法
1. 啟用異步支持
@Configuration
@EnableAsync // 核心注解，啟用異步處理
public class AsyncConfig {
// 可選：自定義線程池
@Bean(name = "taskExecutor")
public Executor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5); // 核心線程數(shù)
executor.setMaxPoolSize(10); // 最大線程數(shù)
executor.setQueueCapacity(100); // 隊列容量
executor.setThreadNamePrefix("Async-"); // 線程名前綴
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
executor.initialize();
return executor;
}
}
2. 標(biāo)記異步方法
@Service
public class EmailService {
// 使用默認線程池
@Async
public CompletableFuture<String> sendEmailAsync(String to, String content) {
// 模擬耗時操作
Thread.sleep(1000);
System.out.println("郵件發(fā)送至: " + to + "，線程: " + Thread.currentThread().getName());
return CompletableFuture.completedFuture("success");
}
// 使用指定線程池
@Async("taskExecutor")
public void processInBackground(Order order) {
// 后臺處理邏輯
System.out.println("處理訂單: " + order.getId());
}
}
3. 調(diào)用異步方法
@RestController
@RequestMapping("/api")
public class NotificationController {
@Autowired
private EmailService emailService;
@GetMapping("/send")
public ResponseEntity<String> sendNotification() {
// 非阻塞調(diào)用
CompletableFuture<String> future = emailService.sendEmailAsync("user@example.com", "Hello");
// 可以繼續(xù)執(zhí)行其他邏輯
System.out.println("請求已接收，郵件發(fā)送中...");
return ResponseEntity.ok("請求已處理");
}
}
二、響應(yīng)式異步處理
1. 添加WebFlux支持
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
2. 響應(yīng)式控制器
@RestController
@RequestMapping("/reactive")
public class ReactiveController {
@GetMapping("/data")
public Mono<String> getData() {
return Mono.fromCallable(() -> {
// 模擬耗時操作
Thread.sleep(500);
return "響應(yīng)式數(shù)據(jù)";
}).subscribeOn(Schedulers.boundedElastic()); // 指定異步調(diào)度器
}
}
三、事件驅(qū)動的異步處理
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. 異步事件監(jiān)聽
@Component
public class OrderEventListener {
@Async
@EventListener
public void handleOrderEvent(OrderProcessedEvent event) {
System.out.println("異步處理訂單事件: " + event.getOrder().getId());
// 執(zhí)行耗時操作
}
}
3. 發(fā)布事件
@Service
public class OrderService {
private final ApplicationEventPublisher eventPublisher;
public OrderService(ApplicationEventPublisher eventPublisher) {
this.eventPublisher = eventPublisher;
}
public void processOrder(Order order) {
// 業(yè)務(wù)邏輯...
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);
}
}
六、事務(wù)邊界處理
1. 異步事務(wù)處理
@Transactional
@Async
public CompletableFuture<Void> processWithTransaction(Order order) {
// 業(yè)務(wù)邏輯
orderRepository.save(order);
return CompletableFuture.completedFuture(null);
}
2. 事務(wù)事件監(jiān)聽
@Async
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void handleAfterCommit(OrderEvent event) {
// 事務(wù)提交后異步執(zhí)行
System.out.println("事務(wù)提交后處理: " + event.getOrderId());
}
七、異步異常處理
1. 自定義異常處理器
@Configuration
public class AsyncExceptionConfig implements AsyncConfigurer {
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return (ex, method, params) -> {
System.err.println("異步方法異常: " + method.getName());
ex.printStackTrace();
// 可以發(fā)送通知或記錄日志
};
}
}
2. 異常處理示例
@Async
public CompletableFuture<String> riskyOperation() {
if (Math.random() > 0.5) {
throw new RuntimeException("隨機錯誤");
}
return CompletableFuture.completedFuture("成功");
}
// 調(diào)用處處理異常
riskyOperation().exceptionally(ex -> {
System.out.println("處理異常: " + ex.getMessage());
return "fallback";
});
八、性能監(jiān)控與指標(biāo)
1. 監(jiān)控異步任務(wù)
@Async
@Timed(value = "async.email", description = "郵件發(fā)送耗時")
public void sendEmailWithMetrics(String to) {
// 發(fā)送郵件邏輯
}
2. 線程池指標(biāo)
@Bean
@ExportMeterRegistry
public ExecutorServiceMetrics executorServiceMetrics(MeterRegistry registry) {
return new ExecutorServiceMetrics(
Executors.newFixedThreadPool(5),
"async.executor",
Collections.emptyList()
);
}
九、最佳實踐
線程池配置：
- 根據(jù)業(yè)務(wù)類型隔離線程池(IO密集型 vs CPU密集型)
- 合理設(shè)置隊列容量和拒絕策略
資源清理：
@PreDestroy
public void cleanup() {
((ThreadPoolTaskExecutor) executor).shutdown();
}
上下文傳遞：
@Bean
public Executor contextAwareExecutor() {
return new DelegatingSecurityContextExecutorService(
Executors.newFixedThreadPool(5)
);
}
調(diào)試技巧：
- 設(shè)置線程名前綴便于日志追蹤
- 使用MDC傳遞請求上下文
避免陷阱：
- 異步方法不能自調(diào)用
- 避免在異步方法中使用ThreadLocal
- 注意事務(wù)邊界問題
十、完整示例
電商訂單處理系統(tǒng)
@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的異步處理能力為構(gòu)建高性能應(yīng)用提供了強大支持，合理使用可以顯著提升系統(tǒng)吞吐量。開發(fā)者應(yīng)根據(jù)具體業(yè)務(wù)場景選擇合適的異步模式，并注意線程安全、資源管理和異常處理等問題。
總結(jié)
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要為大家詳細介紹了spring boot和mybatis集成分頁插件，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-04-04
這篇文章主要介紹了springboot如何引入外部yml配置文件，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-08-08
這篇文章主要為大家介紹了druid連接池的參數(shù)配置示例全面解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-09-09
這篇文章主要介紹了java讀取properties文件的方法,實例分析了java讀取在項目中與不在項目中properties文件的相關(guān)技巧,需要的朋友可以參考下2015-06-06
CommonMark和Flexmark是兩種用于解析Markdown文檔的Java庫,CommonMark提供了一種簡潔和一致的Markdown格式語法規(guī)范,但不支持目錄解析,而Flexmark是一個基于CommonMark的擴展庫,不僅遵循了CommonMark規(guī)范,還提供了更多靈活的API和擴展功能2024-10-10
java商城項目實戰(zhàn)之購物車功能實現(xiàn)
這篇文章主要為大家詳細介紹了java商城項目實戰(zhàn)之購物車功能實現(xiàn)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-04-04
SpringBoot實現(xiàn)大模型流式Streaming響應(yīng)的示例代碼
這篇文章主要為大家詳細介紹了SpringBoot實現(xiàn)大模型流式Streaming響應(yīng)的相關(guān)知識,文中的示例代碼講解詳細,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2026-01-01
RabbitMQ支持消息的過期時間,在消息發(fā)送時可以進行指定。 RabbitMQ支持隊列的過期時間,從消息入隊列開始計算,只要超過了隊列的超時時間配置,那么消息會自動的清除2021-09-09
SpringBoot整合數(shù)據(jù)庫訪問層的實戰(zhàn)
本文主要介紹了SpringBoot整合數(shù)據(jù)庫訪問層的實戰(zhàn)，主要包含JdbcTemplate和mybatis框架的整合應(yīng)用，具有一定的參考價值，感興趣的可以了解一下2022-03-03
這篇文章主要介紹了Java線程Thread之interrupt中斷解析，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-01-01