欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot異步處理全過程

 更新時(shí)間：2025年06月25日 09:05:47   作者：北辰alk  
這篇文章主要介紹了SpringBoot異步處理全過程,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

Spring Boot 提供了強(qiáng)大的異步處理能力，可以幫助開發(fā)者輕松實(shí)現(xiàn)非阻塞式編程，提高系統(tǒng)吞吐量和響應(yīng)速度。

以下是實(shí)現(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);    // 隊(duì)列容量
        executor.setThreadNamePrefix("Async-"); // 線程名前綴
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}

2. 標(biāo)記異步方法

@Service
public class EmailService {

    // 使用默認(rèn)線程池
    @Async
    public CompletableFuture<String> sendEmailAsync(String to, String content) {
        // 模擬耗時(shí)操作
        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(() -> {
            // 模擬耗時(shí)操作
            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í)行耗時(shí)操作
    }
}

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("隨機(jī)錯誤");
    }
    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ā)送耗時(shí)")
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()
    );
}

九、最佳實(shí)踐

線程池配置：

  • 根據(jù)業(yè)務(wù)類型隔離線程池(IO密集型 vs CPU密集型)
  • 合理設(shè)置隊(duì)列容量和拒絕策略

資源清理：

@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. 記錄審計(jì)日志
        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() {
        // 單獨(dú)線程池處理通知
        return new ThreadPoolTaskExecutor();
    }
}

Spring Boot的異步處理能力為構(gòu)建高性能應(yīng)用提供了強(qiáng)大支持，合理使用可以顯著提升系統(tǒng)吞吐量。開發(fā)者應(yīng)根據(jù)具體業(yè)務(wù)場景選擇合適的異步模式，并注意線程安全、資源管理和異常處理等問題。

總結(jié)

以上為個人經(jīng)驗(yàn)，希望能給大家一個參考，也希望大家多多支持腳本之家。

相關(guān)文章

  • Mybatis/MybatisPlus公共字段填充與配置邏輯刪除

    Mybatis/MybatisPlus公共字段填充與配置邏輯刪除

    MyBatis 和 MyBatis-Plus 都提供了相應(yīng)的機(jī)制來處理這些公共字段的填充和邏輯刪除,下面就來介紹一下,感興趣的可以了解一下
    2025-05-05
  • SpringBoot+MQTT+apollo實(shí)現(xiàn)訂閱發(fā)布功能的示例

    SpringBoot+MQTT+apollo實(shí)現(xiàn)訂閱發(fā)布功能的示例

    這篇文章主要介紹了SpringBoot+MQTT+apollo實(shí)現(xiàn)訂閱發(fā)布功能的示例，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-06-06
  • Java的Hibernate框架中的組合映射學(xué)習(xí)教程

    Java的Hibernate框架中的組合映射學(xué)習(xí)教程

    組合映射即是指主對象和子對象關(guān)聯(lián)且擁有相同的生命周期的映射關(guān)系,這里我們將舉一些數(shù)據(jù)操作的實(shí)例,來講解Java的Hibernate框架中的組合映射學(xué)習(xí)教程
    2016-07-07
  • Java 跨域問題的處理方式

    Java 跨域問題的處理方式

    這篇文章主要介紹了Java 跨域問題的處理方式，幫助大家更好的理解和使用Java，感興趣的朋友可以了解下
    2020-11-11
  • springBoot詳解集成Swagger流程

    springBoot詳解集成Swagger流程

    Swagger是一個規(guī)范和完整的框架，用于生成、描述、調(diào)用和可視化?Restful?風(fēng)格的?Web?服務(wù)?？傮w目標(biāo)是使客戶端和文件系統(tǒng)作為服務(wù)器以同樣的速度來更新。文件的方法、參數(shù)和模型緊密集成到服務(wù)器端的代碼，允許API來始終保持同步
    2022-06-06
  • SpringBoot使用Flyway進(jìn)行數(shù)據(jù)庫遷移的實(shí)現(xiàn)示例

    SpringBoot使用Flyway進(jìn)行數(shù)據(jù)庫遷移的實(shí)現(xiàn)示例

    Flyway是一個數(shù)據(jù)庫遷移工具,它提供遷移歷史和回滾的功能,本文主要介紹了如何使用Flyway來管理Spring Boot應(yīng)用程序中的SQL數(shù)據(jù)庫架構(gòu),感興趣的可以了解一下
    2023-08-08
  • JAVA 內(nèi)存溢出案例匯總

    JAVA 內(nèi)存溢出案例匯總

    這篇文章主要介紹了JAVA 內(nèi)存溢出案例的匯總，文中講解非常細(xì)致，幫助各位工作學(xué)習(xí)時(shí)避免內(nèi)存溢出，感興趣的朋友可以了解下
    2020-07-07
  • SpringSecurity自定義AuthenticationProvider無法@Autowire的解決

    SpringSecurity自定義AuthenticationProvider無法@Autowire的解決

    這篇文章主要介紹了SpringSecurity自定義AuthenticationProvider無法@Autowire的解決方案，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2021-12-12
  • SpringBoot+Vue使用Echarts的方式

    SpringBoot+Vue使用Echarts的方式

    這篇文章主要介紹了SpringBoot+Vue使用Echarts的方式,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2025-05-05
  • springcloud組件技術(shù)分享(推薦)

    springcloud組件技術(shù)分享(推薦)

    Spring Cloud 是一系列框架的有序集合，它利用 Spring Boot 的開發(fā)便利性簡化了分布式系統(tǒng)的開發(fā)，比如服務(wù)發(fā)現(xiàn)、服務(wù)網(wǎng)關(guān)、服務(wù)路由、鏈路追蹤等。這篇文章主要介紹了springcloud組件技術(shù)分享,需要的朋友可以參考下
    2020-10-10

最新評論