'Spring/Spring WebFlux' 카테고리의 글 목록 (2 Page)

[📕 Reactive] 1. Reactive 시스템과 Reactive 프로그래밍

2024.12.16

Reactor, Spring WebFlux의 기초 개념을 꼼꼼하게 다지고자 "스프링으로 시작하는 리액티브 프로그래밍" 책을 정독하고 정리하려고 한다. 1. 리액티브 시스템이란?리액티브 시스템 = 반응을 잘하는 시스템 👉 비동기 메시지 기반의 통신을 기반으로 클라이언트의 요청에 즉각적으로 응답함으로써 지연 시간을 최소화하는 것을 의미✳️ 특징선언형 프로그래밍실행할 동작을 구체적으로 명시하지 않고, 목표만 선언여러 가지 동작을 각각 별도의 코드로 분리하지 않고, 각 동작에 대해서 메서드 체인을 형성해 한 문장으로 된 코드로 구성Data streams와 propagation of change데이터가 발생할 때마다 이것을 변화하는 이벤트로 봄이벤트를 발생키면서 데이터를 계속적으로 전달 🔷 명령형 프로..

Spring/Spring WebFlux

[WebFlux] Reactor 연산자 정리

2024.07.17

flatMapManyflatMapManyMono에서 여러 개 요소를 생성할 때 사용 👉 Mono에서 반환된 결과를 여러 개의 요소로 변환하여 Flux로 처리할 때 유용 fromIterableIterable 타입의 데이터(list, set, map 등의 컬렉션)를 Flux로 변환 👉 컬렉션 내의 요소들을 리액티브 스트림으로 변환하여 비동기적으로 처리 map, mapNotNullmap은 onNext 이벤트를 받아서 값을 변경하고 아래로 전달 Flux.range(1, 5) .map(value -> value * 2) .doOnNext(value -> { log.info("doOnNext: " + value); }) .subscribe();mapNotNull은 변경된 값이 nu..

Spring/Spring WebFlux

[WebFlux] flatMap과 map의 차이

2024.07.17

Webflux를 사용할 때마다 flatMap과 map이 항상 헷갈리므로 정리. 두 메서드는 Reactive Stream API 일부로 Reactor 라이브러리의 Mono와 Flux에서 사용되며 비동기 스트림 처리 역할을 수행한다. 단, flatMap이 비동기 작업에 더 적합 ! flatMap()입력 스트림의 각 요소에 대해 비동기적으로 함수를 적용 👉 1:N 변환원본 요소를 변환하여 새로운 Mono 또는 Flux 반환반환된 스트림은 flatten(평탄화)되어 단일 Mono 또는 Flux로 합쳐짐@GetMapping("/user/{id}")public Mono getUser(@PathVariable String id) { return userRepository.findById(id) // ret..

Spring/Spring WebFlux

[WebFlux] Reactive Streams

2024.07.03

Reactive Programming✳️ 전통적인 콜백 기반 API나 Future와 같은 JDK의 비동기 코드 작성 방식에 비해 더 유연하고 효율적1. 비동기 처리의 간소화 : 비동기 작업을 스트림의 형태로 처리하므로 데이터의 흐름을 통해 각 단계를 연결하고 데이터가 준비되는 즉시 처리 가능2. 선언적 API 제공 : Reactor, RxJava와 같은 라이브러리는 map, filter, reduce와 같은 함수형 프로그래밍 스타일의 연산자를 제공하여 데이터 변환하고 조작하는 과정을 간결하게 표현3. backPressure 지원 : 데이터 소비자가 데이터 생산자의 속도를 제어할 수 있도록 함 4. 복잡성 감소와 가독성 향상 : 연산자 체이닝을 통해 코드의 가독성 높이고 각 단계의 작업을 분리하여 개발자가..

Spring/Spring WebFlux

[WebFlux] 비동기/동기, non-blocking/blocking, CompletableFuture

2024.07.03

팀에서 IoT를 비동기적으로 처리하기 위해 WebFlux를 사용하고 있다.WebFlux에 대해 얕게만 알고 사용했기 때문에 이번 기회에 공부해보기로 한다. ✴️ Sync(동기)와 Async(비동기)🔶 Sync : 클라이언트에서 메서드 호출 → 메서드 제공하는 곳에서 기능을 모두 수행해 결과값이 결정되면 그때 반환 👉 요청한 작업에 대해 완료 여부를 신경 써서 작업을 순차적으로 수행할지 아닌지 결정🔶 Async : 결과값이 결정되기 전에 일단 반환 (순서 보장 X)👉 요청한 작업에 대해 완료 여부를 따지지 않고 자신의 다음 작업을 그대로 수행 ✴️ Blocking과 Non-Blocking🔷 Blocking : 요청한 작업이 끝날 때까지 다른 작업하지 않고 기다림🔷 Non-Blocking : 요..

Spring/Spring WebFlux

[WebFlux] Spring WebFlux란?

2024.01.13

Spring WebFlux는 Reactive Stream API를 사용하여 non-blocking, asynchronous를 지원하는 비동기 스프링 웹 프레임워크이다. 이는 대량의 웹 트래픽 (I/O가 많은 웹 서비스 로직)에서 MVC와 대비하여 효율적이고 높은 성능을 보여주기 때문에 활용되고 있다. 매번 WebFlux의 성능이 좋다고는 할 수 없음!더보기👉 그러면 주로 어디에서 활용되나...?마이크로서비스에서 다양한 동시 요청을 수행하는 gateway server실시간 데이터 스트리밍을 위한 웹소켓대량의 I/O를 처리하는 실시간 채팅 서비스 Spring MVC vs Spring WebFluxSpring 공식 페이지에 나와있는 표를 통해 둘의 차이점을 알 수 있다.WebFlux는 비동기/논블로킹이..

[📕 Reactive] 1. Reactive 시스템과 Reactive 프로그래밍

[WebFlux] Reactor 연산자 정리

[WebFlux] flatMap과 map의 차이

[WebFlux] Reactive Streams

[WebFlux] 비동기/동기, non-blocking/blocking, CompletableFuture

[WebFlux] Spring WebFlux란?

티스토리툴바