bodyToFlux()
-
Reactive StreamingSpring Reactive Web Application/Spring WebFlux 2023. 9. 21. 22:00
Spring WebFlux는 SSE(Server-Sent Events)를 이용해 데이터를 Streaming 할 수 있습니다. SSE는 Spring 4.2 버전부터 지원되었으며, Spring 5 버전부터 Reactor의 Publisher 타입인 Flux를 이용해 조금 더 편리한 방법으로 SSE를 사용할 수 있게 되었습니다. Note. SSE(Server-Sent Events) 클라이언트가 HTTP 연결을 통해 서버로부터 전송되는 업데이트 데이터를 지속적으로 수신할 수 있는 단방향 서버 푸시 기술입니다. SSE는 주로 클라이언트 측에서 서버로부터 전송되는 이벤트 스트림을 자동으로 수신하기 위해 사용됩니다. 다음은 Streaming으로 처리될 데이터를 데이터베이스에서 조회하는 BookService 클래스의 코..
-
WebClientSpring Reactive Web Application/Spring WebFlux 2023. 9. 16. 10:00
WebClient WebClient는 Spring 5부터 지원하는 Non-Blocking HTTP request를 위한 리액티브 웹 클라이언트로서 함수형 기반의 향상된 API를 제공합니다. WebClient는 내부적으로 HTTP 클라이언트 라이브러리에게 HTTP request를 위임하며, 기본 HTTP 클라이언트 라이브러리는 Reactor Netty입니다. WebClient는 Non-Blocking과 Blocking HTTP request를 모두 지원합니다. 다음은 WebClient를 사용한 예제 코드입니다. import lombok.extern.slf4j.Slf4j; import org.springframework.boot.ApplicationArguments; import org.springframe..