Spring RestTemplate vs WebClient

Spring

Spring RestTemplate vs WebClient

joaa 2024. 2. 27. 10:25

🎈 RestTemplate vs Webclient

RestTemplate
thread-per-request 모델에 기반하는 Java Servlet API를 사용함.-> Synchronous & Blocking
클라이언트가 응답을 받을 때까지 thread가 블럭 상테임. 메모리와 CPU cycle을 소모하는 것으로 인한 block code의 단점이 발생함.

결과적으로 애플리케이션이 많은 스레드를 생성하고, 이것은 사용 가능한 메모리를 모두 점유하거나 스레드 풀을 소모할 수 있음.

WebClient
Spring Reactive 프레임워크가 제공하는 Asynchronous, non-blocking 방식을 사용함.

RestTemplate은 각 HTTP 요청마다 thread를 호출하고, WebClient는 HTTP 요청마다 "task"를 생성함. Reactive 프레임워크는 그 task들을 큐에 넣었다가 적절한 응답이 가능할 때 task를 실행함.

Reactive 프레임워크는 event-driven 아키텍쳐를 사용해서 Reactive Streams API를 통해 asynchronous logic을 짜는 방법을 제공함. 결과적으로 Reacitve한 접근은 synchronous/blocking 방법보다 적은 스레드와 시스템 자원을 사용하면서 더 많은 로직을 수행할 수 있음.

WebClient는 Srping WebFlux 라이브러리에 포함됨. 따라서 반응형(Mono 및 Flux)을 선언적 구성으로 사용하여 기능적이고 유창한 API를 사용하여 클라이언트 코드를 작성할 수도 있음.

Spring5.0 버전부터 RestTemplate의 대안으로 WebClient 사용을 권고함.

WebClient의 특징

Non-blocking I/O
Reactive Streams back pressure
High concurrency with fewer hardware resources
Functional-style, fluent API that takes advantage of Java 8 lambdas
Synchronous and asynchronous interactions
Streaming up to or streaming down from a server

예시를 통한 RestTemplate WebClient 비교

java
@GetMapping("/slow-service-tweets")
private List<Tweet> getAllTweets() {
    Thread.sleep(2000L); // delay
    return Arrays.asList(
      new Tweet("RestTemplate rules", "@user1"),
      new Tweet("WebClient is better", "@user2"),
      new Tweet("OK, both are useful", "@user1"));
}

RestTemplate를 사용했을 때

@GetMapping("/tweets-blocking")
public List<Tweet> getTweetsBlocking() {
    log.info("Starting BLOCKING Controller!");
    final String uri = getSlowServiceUri();

    RestTemplate restTemplate = new RestTemplate();
    ResponseEntity<List<Tweet>> response = restTemplate.exchange(
      uri, HttpMethod.GET, null,
      new ParameterizedTypeReference<List<Tweet>>(){});

    List<Tweet> result = response.getBody();
    result.forEach(tweet -> log.info(tweet.toString()));
    log.info("Exiting BLOCKING Controller!");
    return result;
}

결과

Starting BLOCKING Controller!
Tweet(text=RestTemplate rules, username=@user1)
Tweet(text=WebClient is better, username=@user2)
Tweet(text=OK, both are useful, username=@user1)
Exiting BLOCKING Controller!

WebClient를 사용했을 때

@GetMapping(value = "/tweets-non-blocking", 
            produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<Tweet> getTweetsNonBlocking() {
    log.info("Starting NON-BLOCKING Controller!");
    Flux<Tweet> tweetFlux = WebClient.create()
      .get()
      .uri(getSlowServiceUri())
      .retrieve()
      .bodyToFlux(Tweet.class);

    tweetFlux.subscribe(tweet -> log.info(tweet.toString()));
    log.info("Exiting NON-BLOCKING Controller!");
    return tweetFlux;
}

결과

Starting NON-BLOCKING Controller!
Exiting NON-BLOCKING Controller!
Tweet(text=RestTemplate rules, username=@user1)
Tweet(text=WebClient is better, username=@user2)
Tweet(text=OK, both are useful, username=@user1)