Spring WebClient

🔎 Spring WebClient

WebClient는 Spring 5에서 도입된 비동기적이고 논블로킹 방식의 HTTP 클라이언트입니다. RestTemplate의 현대적인 대안으로, 리액티브 프로그래밍 패러다임을 지원합니다.

💡 주요 특징:

비동기 및 동기 작업 모두 지원
함수형 프로그래밍 스타일의 API
스트리밍 지원
효율적인 리소스 관리

💡 WebClient 설정하기

2.1. 의존성 추가

pom.xml에 다음 의존성을 추가합니다:

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

2.2. WebClient Bean 생성

@Configuration
public class WebClientConfig {
    
    @Bean
    public WebClient webClient() {
        return WebClient.builder()
            .baseUrl("https://api.example.com")
            .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
            .build();
    }
}

💡 WebClient 기본 사용법

3.1. GET 요청

Mono<User> userMono = webClient.get()
    .uri("/users/{id}", 1)
    .retrieve()
    .bodyToMono(User.class);

userMono.subscribe(user -> System.out.println(user.getName()));

3.2. POST 요청

User newUser = new User("John Doe", "john@example.com");
Mono<User> createdUserMono = webClient.post()
    .uri("/users")
    .body(Mono.just(newUser), User.class)
    .retrieve()
    .bodyToMono(User.class);

createdUserMono.subscribe(user -> System.out.println("Created user ID: " + user.getId()));
  

3.3. PUT 요청

User updatedUser = new User("John Updated", "john@example.com");
Mono<Void> updateMono = webClient.put()
    .uri("/users/{id}", 1)
    .body(Mono.just(updatedUser), User.class)
    .retrieve()
    .bodyToMono(Void.class);

updateMono.subscribe(null, error -> System.err.println("Error updating user: " + error.getMessage()));
  

3.4. DELETE 요청

Mono<Void> deleteMono = webClient.delete()
    .uri("/users/{id}", 1)
    .retrieve()
    .bodyToMono(Void.class);

deleteMono.subscribe(null, error -> System.err.println("Error deleting user: " + error.getMessage()));

💡 WebClient 고급 기능

4.1. 헤더 설정

Mono<User> userMono = webClient.get()
    .uri("/users/{id}", 1)
    .header("Authorization", "Bearer " + token)
    .retrieve()
    .bodyToMono(User.class);
  

4.2. 에러 처리

Mono<User> userMono = webClient.get()
    .uri("/users/{id}", 1)
    .retrieve()
    .onStatus(HttpStatus::is4xxClientError, response -> 
        Mono.error(new RuntimeException("API not found")))
    .onStatus(HttpStatus::is5xxServerError, response -> 
        Mono.error(new RuntimeException("Server error")))
    .bodyToMono(User.class);

userMono.subscribe(
    user -> System.out.println(user.getName()),
    error -> System.err.println("Error: " + error.getMessage())
);

4.3. 응답 스트리밍

Flux<User> userFlux = webClient.get()
    .uri("/users")
    .retrieve()
    .bodyToFlux(User.class);

userFlux.subscribe(
    user -> System.out.println(user.getName()),
    error -> System.err.println("Error: " + error.getMessage()),
    () -> System.out.println("Completed")
);

4.4. 타임아웃 설정

Mono<User> userMono = webClient.get()
    .uri("/users/{id}", 1)
    .retrieve()
    .bodyToMono(User.class)
    .timeout(Duration.ofSeconds(5));

💡 WebClient vs RestTemplate

WebClient의 장점:

비동기 및 논블로킹 방식으로 효율적인 리소스 사용
함수형 프로그래밍 스타일로 가독성 향상
스트리밍 지원으로 대용량 데이터 처리에 유리
리액티브 프로그래밍과의 통합이 용이

RestTemplate의 장점:

동기식 프로그래밍에 익숙한 개발자에게 더 직관적
레거시 시스템과의 통합이 쉬움

💡 실제 사용 예제

GitHub API를 사용한 사용자 정보 조회:

WebClient client = WebClient.create("https://api.github.com");

Mono<GitHubUser> userMono = client.get()
    .uri("/users/{username}", "octocat")
    .retrieve()
    .bodyToMono(GitHubUser.class);

userMono.subscribe(
    user -> System.out.println("Name: " + user.getName() + ", Followers: " + user.getFollowers()),
    error -> System.err.println("Error: " + error.getMessage())
);

💡 성능 최적화 팁

커넥션 풀링: HttpClient 설정을 통해 커넥션 풀 사용
재시도 메커니즘 구현: Retry 연산자 사용
캐싱: Spring의 캐싱 추상화 활용