[수미수의 개발 브로구]

Flux 병합 처리  Flux 사용 시 병합 처리는 여러 스트림을 동시에 처리하는 각각의 스트림에서 생성된 데이터를 결합하여 하나의 스트림으로 방출 하는데 사용된다. Flux 에서는 여러 병합 연산자가 있으며, merge(), mergeSequential(), concat(), zip() 등을 사용 할 수 있다.merge()  merge() 는 여러 스트림을 병렬로 처리하여 즉시 데이터를 방출 하며, 각 스트림의 데이터를 순서에 상관 없이 결합한다. 여러 스트림의 데이터를 빠르게 처리하고 순서가 중요하지 않을 때 사용 한다.Merge data from Publisher sequences emitted by the passed Publisher into an interleaved merged sequenc..

들어가기 전 지난 글에서는 Spring WebFlux가 무엇이며, Spring MVC 와의 차이점 그리고 왜 Spring WebFlux를 써야하는지에 대해서 알아 보았습니다. Spring WebFlux 가 동작 할때 기본적으로 사용되는 서버는 Netty를 사용하고 있으며, Reative 스타일의 어플리케이션 개발을 지원하기 위해 Reactor 프로젝트를 사용하고 있습니다. 이번 글에서는 Netty 서버가 무엇인지 간략하게 알아보고, Reactive Stream Publisher 구현체인 Mono 와 Flux 에대해서 간단히 알아보도록 하겠습니다. 네티란 Netty is an NIO client server framework which enables quick and easy development of n..

들어가기 전 올해 개발 프로젝트를 진행하면서, 모놀리식 시스템에서 MSA 로 전환 하는 업무를 맡았다. 도메인 분리부터 시작하여 각각의 프로젝트를 생성하고 서비스들간 API를 이용하여 통신하는 아키텍처 모습을 가졌으며, 그중 특정 도메인의 서비스의 경우 여러 서비스들로 부터 요청을 받는 구조가 되어 해당 도메인을 MVC 기반의 Spring Boot 로 개발 중 비동기/논블럭킹의 Spring WebFlux 로 전환하였다. Spring WebFlux 의 경우 러닝커브도 높은편이고, 개발 사고 방식이 일반적인 방식이 아닌 함수형 프로그래밍 형태로 개발해야 했으며, 결론 부터 말하자면 생각보다 많은 어려움이 있었다. 팀원들과 기초공사 부터 시작해서 한단계 한단계 살을 붙여나가 현재는 Spring WebFlux ..