SpringBoot webClient

이제 webClient 적용을 피할수 없게 되었다.

 

webFlux, reactor 관련해서 좀더 자세히 공부를 해야겠다.

 

https://happycloud-lee.tistory.com/220

Spring WebClient 쉽게 이해하기

 

https://docs.spring.io/spring-framework/docs/current/reference/html/web-reactive.html#webflux-client

Web on Reactive Stack

 

WebClient client = WebClient.create(); // DefaultWebClientBuilder

@Override
public WebClient build() {
    ClientHttpConnector connectorToUse =
            (this.connector != null ? this.connector : initConnector());

    ExchangeFunction exchange = (this.exchangeFunction == null ?
            ExchangeFunctions.create(connectorToUse, initExchangeStrategies()) :
            this.exchangeFunction);

    ExchangeFunction filteredExchange = (this.filters != null ? this.filters.stream()
            .reduce(ExchangeFilterFunction::andThen)
            .map(filter -> filter.apply(exchange))
            .orElse(exchange) : exchange);

    HttpHeaders defaultHeaders = copyDefaultHeaders();

    MultiValueMap<String, String> defaultCookies = copyDefaultCookies();

    return new DefaultWebClient(filteredExchange, initUriBuilderFactory(),
            defaultHeaders,
            defaultCookies,
            this.defaultRequest, new DefaultWebClientBuilder(this));
}

DefaultWebClient(ExchangeFunction exchangeFunction, UriBuilderFactory uriBuilderFactory,
			@Nullable HttpHeaders defaultHeaders, @Nullable MultiValueMap<String, String> defaultCookies,
			@Nullable Consumer<RequestHeadersSpec<?>> defaultRequest, DefaultWebClientBuilder builder) {
    this.exchangeFunction = exchangeFunction;
    this.uriBuilderFactory = uriBuilderFactory;
    this.defaultHeaders = defaultHeaders;
    this.defaultCookies = defaultCookies;
    this.defaultRequest = defaultRequest;
    this.builder = builder;
}

https://github.com/reactor/reactor-netty

GitHub - reactor/reactor-netty: TCP/HTTP/UDP/QUIC client/server with Reactor over Netty

httpClient 구현체가 netty-http로 바뀌었다.

 

//DefaultWebClientBuilder.java
private ClientHttpConnector initConnector() {
   if (reactorClientPresent) {
      return new ReactorClientHttpConnector();
   }
   else if (jettyClientPresent) {
      return new JettyClientHttpConnector();
   }
   else if (httpComponentsClientPresent) {
      return new HttpComponentsClientHttpConnector();
   }
   throw new IllegalStateException("No suitable default ClientHttpConnector found");
}

@Override
public WebClient build() {
    ClientHttpConnector connectorToUse =
            (this.connector != null ? this.connector : initConnector());

    ExchangeFunction exchange = (this.exchangeFunction == null ?
            ExchangeFunctions.create(connectorToUse, initExchangeStrategies()) :
            this.exchangeFunction);

    ExchangeFunction filteredExchange = (this.filters != null ? this.filters.stream()
            .reduce(ExchangeFilterFunction::andThen)
            .map(filter -> filter.apply(exchange))
            .orElse(exchange) : exchange);

    HttpHeaders defaultHeaders = copyDefaultHeaders();

    MultiValueMap<String, String> defaultCookies = copyDefaultCookies();

    return new DefaultWebClient(filteredExchange, initUriBuilderFactory(),
            defaultHeaders,
            defaultCookies,
            this.defaultRequest, new DefaultWebClientBuilder(this));
}

 

httpClient.create()에서 pool을 따로 안 만들어주면 모든 요청이 하나의 이벤트 루프 큐로 들어가는것 주의