我正在使用 Spring WebFlux,我需要執行非同步任務作為方法的一部分,該方法不應阻止對使用者的主要回應。具體來說,我想在完成主任務後呼叫非同步方法,但不延遲回應。
這是我想要實現的目標的簡化版本:
public Mono<ResponseDTO> publishPackage(RequestDTO requestDTO) { return publishPackageService.doSomething(requestDTO) .flatMap(responseDTO -> doSomethingInAsync(requestDTO, responseDTO) .thenReturn(responseDTO) ); } // Method that simulates an asynchronous task with a 5-second delay public Mono<Void> doSomethingInAsync(RequestDTO requestDTO, ResponseDTO responseDTO) { return Mono.delay(Duration.ofSeconds(5)) .then(); // Converts the delayed Mono<Long> to Mono<Void> }
此呼叫完成後,我想非同步執行 doSomethingInAsync(requestDTO, responseDTO)。
doSomethingInAsync 方法應該是非阻塞的,並且不會延遲主要反應。
問題:
doSomethingInAsync 方法正在執行,但它似乎可能會阻止回應或未按預期非同步運作。如何確保 doSomethingInAsync 非同步運作並且不會阻止對使用者的回應?
詳情:
publishPackageService.doSomething(requestDTO):回傳一個 Mono。
doSomethingInAsync(requestDTO, responseDTO):是一個非同步方法,我想在不阻塞回應的情況下運行它。
問題:
如何確保 doSomethingInAsync 在背景運作而不阻塞回應?
以上是如何在 Spring WebFlux 中執行非同步任務而不阻塞主回應?的詳細內容。更多資訊請關注PHP中文網其他相關文章!