2.2. retrieve()
retrieve() 메서드는 응답 본문(response body)를 가져와서 디코딩하는 가장 간단한 방법이다. 다음 예제는 이를 수행하는 방법이다:
Java:
WebClient client = WebClient.create("https://example.org");
Mono<Person> result = client.get()
.uri("/persons/{id}", id).accept(MediaType.APPLICATION_JSON)
.retrieve()
.bodyToMono(Person.class);
Kotlin:
val client = WebClient.create("https://example.org")
val result = client.get()
.uri("/persons/{id}", id).accept(MediaType.APPLICATION_JSON)
.retrieve()
.awaitBody<Person>()
또한 응답으로부터 디코딩된 객체 스트림을 얻을 수도 있다.
Java:
Flux<Quote> result = client.get()
.uri("/quotes").accept(MediaType.TEXT_EVENT_STREAM)
.retrieve()
.bodyToFlux(Quote.class);
Kotlin:
val result = client.get()
.uri("/quotes").accept(MediaType.TEXT_EVENT_STREAM)
.retrieve()
.bodyToFlow<Quote>()
기본적으로 4xx 또는 5xx 상태 코드(status code)로 응답하면 WebClientResponseException 혹은 WebClientResponseException.BadRequest, WebClientResponseException.NotFound 등과 같은 각 HTTP 상태에 맞는 예외를 던진다. 또한 onStatus 메서드를 사용하여 결과 예외를 커스터마이징할 수 있다. 다음은 그 예제다:
Java:
Mono<Person> result = client.get()
.uri("/persons/{id}", id).accept(MediaType.APPLICATION_JSON)
.retrieve()
.onStatus(HttpStatus::is4xxClientError, response -> ...)
.onStatus(HttpStatus::is5xxServerError, response -> ...)
.bodyToMono(Person.class);
Kotlin:
val result = client.get()
.uri("/persons/{id}", id).accept(MediaType.APPLICATION_JSON)
.retrieve()
.onStatus(HttpStatus::is4xxClientError) { ... }
.onStatus(HttpStatus::is5xxServerError) { ... }
.awaitBody<Person>()
onStatus가 사용되는 경우, 응답에 내용(body가)이 있을 것으로 예상되면 onStatus 콜백에서 이를 소비해야 한다. 그렇지 않으면 리소스 반환을 위해서 응답 내용(body가)이 자동으로 비워진다.
목차 가이드
