[java/자바] WebClient 사용하기 - 비동기(subscribe) vs 동기(block) 사용의 차이점

WebClient는 Spring WebFlux에서 HTTP 요청을 비동기 방식으로 처리하는 강력한 도구이다. 비동기 처리는 주로 리액티브 프로그래밍에서 사용되며, 비동기 요청을 보내고 응답을 기다리는 동안 다른 작업을 병렬로 처리할 수 있게 한다.

 

* 동기와 비동기/ 블럭과 넌블럭 차이 이해하기

https://musma.github.io/2019/04/17/blocking-and-synchronous.html

동기와 비동기, 그리고 블럭과 넌블럭

 

 

하지만 WebClient를 사용방법에 따라, 비동기 방식을 동기 방식으로 변경하여 사용할 수 있다.

 

WebClient 비동기 요청 기본 구조

Mono<String> result =  webClient.post().uri("https://jsonplaceholder.typicode.com/posts")
                .headers(httpHeaders-> httpHeaders.addAll(headers))
                .bodyValue(body)
                .retrieve()
                .bodyToMono(String.class)
                .doOnSuccess(response -> {
                    System.out.println("응답 성공");
                    System.out.println("doOnSuccess : "+response);
                })
                .doOnError(error -> {
                    System.out. println("응답 실패");
                    System.out.println(error.getMessage());
                })
                .subscribe();

 

subscribe() VS Block()

1. subscribe()

• subscribe()는 비동기 요청을 시작하고, 그에 대한 응답을 비동기적으로 처리할 수 있게 한다.
• 이 메서드를 호출하면, 요청은 바로 시작되고, 응답을 처리할 콜백이 등록된다.
• subscribe()를 사용하면 메인 쓰레드는 비동기 작업을 기다리지 않고, 다른 작업을 처리할 수 있다.
•  아래 예제 코드를 실행하면, 코드 실행이 종료 된 후에 result가 콘솔에 찍히는 것을 확인 할 수 있다.

 public void webclient() {
        System.out.println("start");
        WebClient webClient = WebClient.builder().build();
        HttpHeaders headers = new HttpHeaders();
        headers.add("Content-Type","application/json");
        String body = "{\"title\": \"foo\",\"body\": \"bar\",\"userId\": 1}";
        System.out.println("header : " + new Gson().toJson(headers));
        System.out.println("body : " + body);
        
        Mono<Map> result = webClient.post().uri("https://jsonplaceholder.typicode.com/posts")
                .headers(httpHeaders-> httpHeaders.addAll(headers))
                .bodyValue(body)
                .retrieve()
                .bodyToMono(Map.class);

        result.subscribe(suc-> {
            System.out.println("result : " + new Gson().toJson(suc));
        }, error -> {
            System.out.println(error.getMessage());
        });

        System.out.println("end");

실행결과

 

2. block():

• block()은 비동기 작업을 동기적으로 만들어, 요청이 완료될 때까지 현재 쓰레드를 차단하고 기다린다.
• block()을 사용하면 메인 쓰레드는 응답을 받을 때까지 기다리므로, 비동기 방식의 장점을 잃게된다.
• 주로 테스트나 간단한 프로토타입에서 동기적 흐름이 필요할 때 사용됩니다.
• 아래 예제 코드를 실행하면, subscribe()를 사용했을 때와 콘솔에 찍힌 결과가 다르다는 것을 확인 할 수 있다.

public void webclient() {
        System.out.println("start");
        WebClient webClient = WebClient.builder().build();
        HttpHeaders headers = new HttpHeaders();
        headers.add("Content-Type","application/json");
        String body = "{\"title\": \"foo\",\"body\": \"bar\",\"userId\": 1}";
        System.out.println("header : " + new Gson().toJson(headers));
        System.out.println("body : " + body);

        Mono<Map> resultMono = webClient.post().uri("https://jsonplaceholder.typicode.com/posts")
                .headers(httpHeaders-> httpHeaders.addAll(headers))
                .bodyValue(body)
                .retrieve()
                .bodyToMono(Map.class);

        Map<String, Object> result = resultMono.doOnSuccess(suc -> System.out.println("result : " + new Gson().toJson(suc)))
                .doOnError(error ->  System.out.println("error : " + error.getMessage()))
                .block();

        System.out.println("end");

    }

 

결론

• subscribe()는 비동기 요청을 보내고 응답을 받으면서도 메인 쓰레드를 차단않으므로 이를 통해 다른 작업을 병렬로 처리할 수 있다.
• block()은 동기적 방식으로, 요청이 완료될 때까지 현재 쓰레드를 차단하므로 비동기 처리의 장점을 활용하지 못한다.