Как организовать пул потоков с помощью веб-клиента Spring Flux и Spring Flux? - PullRequest
Новая
       7

Как организовать пул потоков с помощью веб-клиента Spring Flux и Spring Flux?

0 голосов
/ 19 декабря 2018

Рассмотрим простой контроллер 

import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.reactive.function.client.WebClient;

@RestController
public class DtoController {

    private final WebClient client = WebClient.create("http://localhost:8081");

    @GetMapping("/booking")
    public Mono<MyDto> getDto() {
        return carsClient.get().uri("/myUrl")
                .retrieve()
                .bodyToMono(MyDto.class);
    }

}

Документация говорит о том, что в весеннем веб-потоке существует один поток ввода-вывода и N рабочих (N - количество ядер ЦП).И рабочие потоки повторно используются между вызовами Mono / Flux.

Но когда я запускаю это приложение, я вижу, что в дополнение к Spring Flux Spring веб-клиент также создает IO-поток и N рабочих.Итак, я получил: 

"Attach Listener"@11 046: RUNNING
"DestroyJavaVM"@9 089 in group "main": RUNNING
"Finalizer"@11 048: WAIT
"ObjectCleanerThread"@6 732 in group "main": WAIT
"reactor-http-nio-1"@6 711 in group "main": RUNNING
"reactor-http-nio-2"@6 713 in group "main": RUNNING
"reactor-http-nio-3"@6 715 in group "main": RUNNING
"reactor-http-nio-4"@6 714 in group "main": RUNNING
"Reference Handler"@11 049: WAIT
"RMI Scheduler(0)"@1 798: WAIT
"RMI TCP Accept-0"@1 288: RUNNING
"RMI TCP Accept-0"@1 445: RUNNING
"RMI TCP Accept-59098"@1 355: RUNNING
"Signal Dispatcher"@11 047: RUNNING
"SimplePauseDetectorThread_0"@6 329: SLEEPING
"Thread-15"@6 328: WAIT
"XNIO-1 Accept"@8 573 in group "main": RUNNING
"XNIO-1 I/O-1"@8 518 in group "main": RUNNING
"XNIO-1 I/O-2"@8 537 in group "main": RUNNING
"XNIO-1 I/O-3"@8 547 in group "main": RUNNING
"XNIO-1 I/O-4"@8 552 in group "main": RUNNING

Потоки с префиксом reactor-http-nio соответствуют приложению Spring, а XNIO - клиенту веб-потока.

Есть ли способ повторного использования рабочих между веб-клиентом иприложение?И это хорошая идея, чтобы повторно использовать эти темы?

1 Ответ

0 голосов
/ 19 декабря 2018

Ваше серверное приложение работает поверх Reactor Netty или, возможно, Undertow?Потоки XNIO обычно связаны с Undertow.Вы можете убедиться в этом, просмотрев журналы во время запуска приложения.

Если это так, то это ожидаемое поведение, поскольку Reactor Netty и Undertow не разделяют ресурсы клиента и сервера.

В последних версиях Spring Boot клиентские и серверные ресурсы автоматически распределяются, когда это возможно для Jetty и Reactor Netty .

В качестве примечания, если вы используете Spring Boot,вам следует попытаться создать WebClient экземпляров из WebClient.Builder, которые вы можете ввести в любое место вашего приложения.Это предоставит вам ожидаемые значения по умолчанию и пользовательскую конфигурацию.

...