3

RestTemplate複数の残りのエンドポイントからデータを取得するために使用するコントローラーがあります。「RestTemplate」がブロックされているため、Web ページの読み込みに時間がかかっています。パフォーマンスを向上させるために、すべてを に置き換える予定RestTeamplateですSpring WebClient。私が現在持っている方法の1つは、RestTemplate以下のとおりです。

public List<MyObject> getMyObject(String input){
    URI uri = UriComponentsBuilder.fromUriString("/someurl")
            .path("123456")
            .build()
            .toUri();
    RequestEntity<?> request = RequestEntity.get(uri).build();
    ParameterizedTypeReference<List<MyObject>> responseType =   new ParameterizedTypeReference<List<MyObject>>() {};
    ResponseEntity<List<MyObject>> responseEntity = restTemplate.exchange(request, responseType); 

    MyObject      obj= responseEntity.getBody(); 

}

今、私は上記の方法を使用するように置き換えたいと思っていますWebClientが、私は初めてでWebClient、どこから始めればよいかわかりません. 任意の方向とヘルプをいただければ幸いです。

4

1 に答える 1

5

役立つように、restTemple を webClient に置き換える方法の例を示します。すでに pom.xml をセットアップしていることを願っています

構成クラスを作成しました。

@Slf4j
@Configuration
public class ApplicationConfig {

    /**
     * Web client web client.
     *
     * @return the web client
     */
    @Bean
    WebClient webClient() {
        return WebClient.builder()
            .filter(this.logRequest())
            .filter(this.logResponse())
            .build();
    }

    private ExchangeFilterFunction logRequest() {
        return ExchangeFilterFunction.ofRequestProcessor(clientRequest -> {
            log.info("WebClient request: {} {} {}", clientRequest.method(), clientRequest.url(), clientRequest.body());
            clientRequest.headers().forEach((name, values) -> values.forEach(value -> log.info("{}={}", name, value)));
            return Mono.just(clientRequest);
        });
    }

    private ExchangeFilterFunction logResponse() {
        return ExchangeFilterFunction.ofResponseProcessor(clientResponse -> {
            log.info("WebClient response status: {}", clientResponse.statusCode());
            return Mono.just(clientResponse);
        });
    }
}

さらに、WebClient を呼び出すサービス クラス

@Component
@RequiredArgsConstructor
public class MyObjectService {

    private final WebClient webClient;

    public Mono<List<Object>> getMyObject(String input) {
        URI uri = UriComponentsBuilder.fromUriString("/someurl")
            .path("123456")
            .build()
            .toUri();

        ParameterizedTypeReference<List<MyObject>> responseType = new ParameterizedTypeReference<List<MyObject>>() {
        };

        return this.webClient
            .get()
            .uri(uri)
            .exchange()
            .flatMap(response -> response.bodyToMono(responseType));
    }
}

これにより、 のノンブロッキング モノが得られます。List<MyObject>また、ボディをフラックスに抽出することもできますresponse.bodyToFlux(responseType)

これがあなたがより多くを探求するためのベースになることを願っています。

于 2019-04-09T07:32:01.350 に答える