응답이 200이고 응답 body에 대한 처리만 하고 싶은 경우 retrieve.
이 외에 응답 코드가 4xx, 5xx 등 특정 코드에 따라 다른 결과를 주고 싶거나 응답 헤더를 사용하고 싶은 경우는 exchange를 사용하자.
(참고 : [spring] webClient error 처리)
평소에 4xx, 5xx 일 때 에러는 신경안쓰고 body에 대해서만 고려해서 retrieve를 많이 사용했었다.
coroutine으로 전환하면서 awaitRetrieve 를 쓰려고 했는데 없었다.
그러나 package org.springframework.web.reactive.function.client.WebClientExtension 에 awaitExchange 함수는 있다. (참고)
suspend fun RequestHeadersSpec<out RequestHeadersSpec<*>>.awaitExchange(): ClientResponse =
exchange().awaitSingle()
spring-webflux:5.2.1 기준.
그래서 awaitExchange로 awaitRetrieve Extension을 만들어서 이를 사용했다.
suspend inline fun <reified T : Any> WebClient.RequestHeadersSpec<out WebClient.RequestHeadersSpec<*>>.awaitRetrieve(): T {
return this.awaitExchange().also {
if (it.statusCode().isError) {
throw it.createException().awaitFirst()
}
}.awaitBody()
}
status를 보고 error(4xx, 5xx)인 경우 적절한 WebClientResponseException를 만들어서 예외를 던진다.
예를 들어 internal error인 경우 WebClientResponseException.InternalServerError 예외를 던진다.
webClient에서 만들어주는 에러말고 커스텀 에러를 던지고 싶다면 4번째 줄에 throw it.createException().awaitFirst() 을 수정하면된다.
val response = WebClient.create().get()
.(생략)
.awaitRetrieve<CustomResponseBody>()
사용은 위와 같이.
CustomResponseBody가 우리가 기대하는 응답 body이다.
'Back-End (web)' 카테고리의 다른 글
[Spring] GatewayFilterFactory add Order (0) | 2020.07.02 |
---|---|
[Spring] GatewayFilterFactory Unit Test (0) | 2020.07.02 |
[JUnit5] @ParameterizedTest (0) | 2019.12.15 |
[IntellJ] Kotlin 코드를 java 코드로 확인하기 (0) | 2019.12.09 |
[MockK] JPA repository.save param assert (1) | 2019.12.09 |
댓글