چگونه یک کار ناهمزمان را در Spring WebFlux بدون مسدود کردن پاسخ اصلی اجرا کنیم؟

Summarize this content to 400 words in Persian Lang
من با Spring WebFlux کار می کنم و باید یک کار ناهمزمان را به عنوان بخشی از روشی انجام دهم که نباید پاسخ اصلی کاربر را مسدود کند. به طور خاص، من می خواهم یک متد ناهمزمان را پس از اتمام کار اصلی، اما بدون تاخیر در پاسخ، فراخوانی کنم.

در اینجا یک نسخه ساده از آنچه من در تلاش برای رسیدن به آن هستم:

public Mono 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 doSomethingInAsync(RequestDTO requestDTO, ResponseDTO responseDTO) {
return Mono.delay(Duration.ofSeconds(5))
.then(); // Converts the delayed Mono to Mono
}

وارد حالت تمام صفحه شوید

از حالت تمام صفحه خارج شوید

بعد از اتمام این فراخوانی می خواهم اجرا کنم doSomethingInAsync(requestDTO, responseDTO) به صورت ناهمزمانروش doSomethingInAsync باید غیر مسدود کننده باشد و پاسخ اصلی را به تاخیر نیندازد.مسئله:

را doSomethingInAsync متد در حال اجرا است، اما به نظر می‌رسد که ممکن است پاسخ را مسدود کند یا به صورت ناهمزمان اجرا نشود. چگونه می توانم اطمینان حاصل کنم doSomethingInAsync به صورت ناهمزمان اجرا می شود و پاسخ به کاربر را مسدود نمی کند؟

جزئیات:

publishPackageService.doSomething(requestDTO): یک مونو را برمی گرداند.doSomethingInAsync(requestDTO، answerDTO): یک روش ناهمزمان است که می‌خواهم بدون مسدود کردن پاسخ آن را اجرا کنم.

سوالات:

چگونه می توانم مطمئن شوم که doSomethingInAsync در پس زمینه بدون مسدود کردن پاسخ اجرا می شود؟

public Mono 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 doSomethingInAsync(RequestDTO requestDTO, ResponseDTO responseDTO) {
    return Mono.delay(Duration.ofSeconds(5))
        .then(); // Converts the delayed Mono to Mono
}