🌐 Spring WebClient 응답 Body 소비 및 재사용 이슈 분석

✅ 개요

Spring WebClient에서 bodyToMono() / bodyToFlux()는 응답 본문을 한 번만 소비할 수 있는 1회성 스트림입니다.

---

⚠️ 주요 문제 요약

• bodyToMono()를 두 번 호출하면 → 두 번째는 빈 결과 또는 오류
• 필터에서 body를 소비하면 이후 체인에서 body가 비어 있음
• ClientResponse를 복제해도 body는 기본값(empty) 으로 설정됨

---

📌 문제 원인

리액티브 스트림은 "데이터는 한 번만 구독 가능" 원칙을 따름.
→ 이미 한 번 읽은 스트림은 다른 구독자에게 재전송 불가.

---

📎 사례 요약

사례	설명
응답 Body 두 번 읽기 시도	❌ 실패 (한 번만 소비 가능)
필터에서 body 로깅 후 재사용	❌ body 소진됨
ClientResponse 재생성	⚠️ body 비어 있음 (기본값: empty)

---

💡 해결 방법

✔️ 1. 같은 체인 안에서 처리 통합

webClient.post()
    .retrieve()
    .bodyToMono(String::class.java)
    .doOnNext { logger.info("응답 바디: $it") }
    .map { objectMapper.readValue<MyDto>(it) }

✔️ 2. 본문을 변수에 저장해서 재사용

response.bodyToMono(String::class.java).flatMap { body ->
    val parsed = objectMapper.readValue<MyDto>(body)
    Mono.just(parsed)
}

✔️ 3. .cache() 또는 .share() 사용

val cachedBody = response.bodyToMono(String::class.java).cache()
// 여러 구독자에게 동일한 데이터 전달 가능

주의: cache()는 에러도 캐시하므로 주의 필요.

✔️ 4. 응답을 ResponseEntity로 받기

webClient.post()
    .retrieve()
    .toEntity(String::class.java)
    .flatMap { entity ->
        val body = entity.body
        ...
    }

✔️ 5. 필요 없을 때는 명시적으로 소비 또는 해제

// 내용 무시하고 소비
response.bodyToMono(Void::class.java)

// 또는 Spring 5.2+일 경우
response.releaseBody()

---

🧪 ClientResponse 재사용 시 주의사항

response.bodyToMono(String::class.java).flatMap { body ->
    val newResponse = response.mutate()
        .body(Mono.just(body)) // ✅ body 재주입 필수
        .build()
    Mono.just(newResponse)
}

ClientResponse.from() 또는 .mutate()로 복제할 때 body는 기본적으로 empty
반드시 .body(...)로 명시적으로 다시 설정해줘야 함

---

📝 요약

• 응답 Body는 반드시 한 번만 소비 가능
• 재사용하려면: 캐싱하거나 문자열로 읽어 변수 저장
• 필터에서 응답 본문 로그를 찍으려면 → 같은 체인에서 .doOnNext 사용
• 본문이 필요 없더라도 반드시 .bodyToMono(Void::class) 혹은 .releaseBody() 호출
• ClientResponse를 복제할 땐 반드시 .body(...)로 재지정해야 함

---

필요하다면 이 템플릿을 Notion 공유용으로 PDF 또는 템플릿 링크로 정리해주는 것도 가능하니 말씀 주세요.