Flux

[webflux] PublishOn, SubscribeOn

WebFlux를 사용하는데 있어서, publisher와 subscriber 모델의 개념을 이해하는데까지 시간이 많이 소요가 되었다. mvc로 개발할 때는 메서드 호출만 하면 결과값이 return이 되었다. webflux를 사용해 비동기식으로 개발을 할 때는 메서드만 호출해서는 원하는 결과를 얻기가 힘들다. webflux에서는 subscribe(구독) 을 해야 동작을 한다. PublishOn 신호 처리 스케줄링으로 onNext, onComplete, onError 가 지정된 Scheduler 의 스레드에서 신호 처리 스레드 설정 다음 PublishOn을 만날 때까지 같은 스레드에서 동작 안만나면 동작 끝내고 마침 SubscribeOn 시퀀스를 실행할 스레드를 결정 PublishOn을 만날 때까지 같은 스레..

[Java] Java 8 Streams - Reactor map() 과 flatMap() 차이

map / flatMap 은 언제 사용해야 하나 map / flatmap 둘다 스트림의 중간에 값을 변환해주는 역할을 한다. map은 1 : 1로 반환을 보증하고 flatMap은 1 : N을 변환할 수 있다. Mono와 달리 Flux 는 비동기로 병렬 동작하는 publisher 를 사용하는 경우 성능상 이점이 많기 때문에 되도록 flatMap 을 사용하는게 좋다. reactive한 개발을 하면 사용하는 모든 method의 반환은 publisher 형태가 된다. 이렇게 반환된 결과값을 사용해야 하는 경우에는 map 보다 flatMap 을 사용할 때 자연스럽게 이어진다. 이러한 경우 때문에 Mono -> Mono 의 경우에도 flatMap을 사용하게 된다. 동기 처리 부분은 map 비동기 처리부분은 flat..

Spring WebFlux

WebFlux 란 WebFlux 는 Spring 5에서 새롭게 추가된 모듈이다. 클라이언트, 서버에서 reactive 스타일의 어플리케이션 개발을 도와주는 모듈이며 Non-blocking 에 reactive streams 의 BackPressure을 지원하며 Netty, Servlet3.1+ 컨테이너와 같은 서버에서 실행된다. 위의 그림은 각각의 기능들과 공통점에 대해 나와있다. 위는 전반적인 WebFlux의 구조이다. WebFlux 를 사용하기 전에 WebFlux 가 왜 생겨났는지 궁금했다. WebFlux 가 생긴 이유 적은 수의 스레드와 최소한의 하드웨어 자원으로 동시성을 처리하고 리소스를 확장하기 위해서 만들어졌다. 이는 새로운 공통 API 가 생긴 이유가 됐으며, tomcat 이 아닌 netty와..