快捷導(dǎo)航

Spring中DeferredResult異步處理

更新時(shí)間：2023年12月06日 09:29:53 作者：檀越劍指大廠

DeferredResult是Spring中處理異步請(qǐng)求的強(qiáng)大工具,可以幫助改善應(yīng)用程序的性能和用戶體驗(yàn),本文就來(lái)介紹一下Spring中DeferredResult異步處理,感興趣的可以了解一下

一.簡(jiǎn)單介紹

1.DeferredResult 簡(jiǎn)介

DeferredResult 是 Spring Framework 中用于異步處理請(qǐng)求的一種機(jī)制。它允許將處理結(jié)果推遲到稍后的時(shí)間點(diǎn)，通常用于處理需要較長(zhǎng)時(shí)間完成的操作，例如異步任務(wù)、長(zhǎng)時(shí)間計(jì)算或外部服務(wù)調(diào)用。

2.功能和特性

異步處理： DeferredResult 允許將請(qǐng)求的處理推遲到稍后的時(shí)間，允許應(yīng)用程序異步地處理請(qǐng)求。
非阻塞： 使用 DeferredResult 不會(huì)阻塞容器線程，這有助于提高應(yīng)用程序的吞吐量。
長(zhǎng)輪詢(xún)： 可以使用 DeferredResult 實(shí)現(xiàn)長(zhǎng)輪詢(xún)（long polling）模式，其中客戶端發(fā)送請(qǐng)求并在服務(wù)器端保持掛起狀態(tài)，直到有數(shù)據(jù)可用。

二.使用方式

1.Controller 中的方法

Controller 中的方法： 在控制器方法中，返回類(lèi)型可以是 DeferredResult<T>，其中 T 是要返回的數(shù)據(jù)類(lèi)型。

@GetMapping("/async-operation")
public DeferredResult<String> asyncOperation() {
    DeferredResult<String> deferredResult = new DeferredResult<>();

    // 在某個(gè)異步任務(wù)完成后，將結(jié)果設(shè)置到 DeferredResult 中
    asyncService.performAsyncOperation()
                .whenComplete((result, throwable) -> deferredResult.setResult(result));

    return deferredResult;
}

2.異步任務(wù)完成后設(shè)置結(jié)果

異步任務(wù)完成后設(shè)置結(jié)果： 在異步任務(wù)完成后，通過(guò) DeferredResult.setResult(result) 將結(jié)果設(shè)置到 DeferredResult 對(duì)象中。

public CompletableFuture<String> performAsyncOperation() {
    // 異步任務(wù)邏輯
    return CompletableFuture.supplyAsync(() -> "Async operation result");
}

3.自定義線程池

線程池:

public class ThreadPoolUntil {
    private static final int THREAD_POOL_SIZE = 10;
    private static ExecutorService executorService = Executors.newFixedThreadPool(THREAD_POOL_SIZE);

    public static void executeTask(Runnable task) {
        executorService.submit(task);
    }

    public static void shutdown() {
        executorService.shutdown();
    }
}

controller:

@ApiOperation(value = "首頁(yè)-合計(jì)列表", nickname = "首頁(yè)-合計(jì)列表")
@PostMapping("/totalList")
public DeferredResult<Payload<List<TotalListDayDTO>>> totalList(@RequestBody TotalListQuery totalListQuery
        , @RequestHeader(value = "brandDetailNo") String brandDetailNo) {
      totalListQuery.setBrandDetailNo(brandDetailNo);
      DeferredResult<Payload<List<TotalListDayDTO>>> deferredResult = new DeferredResult<>(10000L);
      // 設(shè)置超時(shí)處理
      deferredResult.onTimeout(() -> deferredResult.setErrorResult(new Payload("504", "請(qǐng)求超時(shí)")));
      // 設(shè)置錯(cuò)誤處理
      deferredResult.onError((Throwable t) -> deferredResult.setErrorResult(new Payload("500", "系統(tǒng)錯(cuò)誤")));
      // 創(chuàng)建任務(wù)
      Runnable task = () -> deferredResult.setResult(new Payload(skuDataBusinessService.totalList(totalListQuery)));
      ThreadPoolUntil.executeTask(task);
      return deferredResult;
}

三.原理分析

1.Servlet 異步支持

Servlet 3.0+ 異步支持： DeferredResult 的實(shí)現(xiàn)依賴(lài)于 Servlet 3.0+ 的異步支持。在處理請(qǐng)求時(shí)，容器會(huì)將請(qǐng)求轉(zhuǎn)交給異步處理，允許處理線程在異步操作完成前釋放。

2.DeferredResult 中介

DeferredResult 作為中介： DeferredResult 充當(dāng)控制器方法和異步任務(wù)之間的中介，使得控制器方法可以在異步任務(wù)完成后設(shè)置結(jié)果。

四.注意事項(xiàng)

1.超時(shí)處理

超時(shí)處理： 可以設(shè)置 DeferredResult 的超時(shí)時(shí)間，如果異步操作在超時(shí)時(shí)間內(nèi)未完成，可以通過(guò)設(shè)置超時(shí)處理邏輯來(lái)處理。

deferredResult.setTimeout(5000); // 設(shè)置超時(shí)時(shí)間為5秒
deferredResult.onTimeout(() -> {
    // 處理超時(shí)邏輯
    deferredResult.setErrorResult("Operation timed out");
});

2.異常處理

異常處理： 需要在異步任務(wù)中捕獲可能的異常，并在 DeferredResult 中設(shè)置錯(cuò)誤結(jié)果。

asyncService.performAsyncOperation()
            .whenComplete((result, throwable) -> {
                if (throwable != null) {
                    deferredResult.setErrorResult("An error occurred: " + throwable.getMessage());
                } else {
                    deferredResult.setResult(result);
                }
            });