티스토리 뷰
프로젝트 리액터
프로젝트 리액터(Project Reactor)
는 리액티브 스트림의 구현체 중 하나로 스프링의 에코시스템 범주에 포함된 프레임워크이다. 리액티브 스트림 사양을 구현하고 있기 때문에 리액티브 스트림에서 사용하는 용어와 규칙을 그대로 사용한다. 리액터를 사용하면 애플리케이션에 리액티브 프로그래밍을 적용할 수 있고, 비동기-논블로킹을 적용할 수 있다. 여기에 함수형 프로그래밍의 접근 방식을 사용해서 비동기-논블로킹 코드의 난해함을 어느정도 해결한다.
Mono & Flux
- 리액터는 리액티브 스트림의
publisher
인터페이스를 구현하는모노(Mono)
와플럭스(Flux)
라는 두 가지 핵심 타입을 제공 - 모노(Mono)는 0..1개의
단일 요소 스트림
을 통지하는 발행자이다. - 플럭스(Flux)는 0..N개로 이루어진
다수 요소 스트림
을 통지하는 발행자이다. - 두 타입 모두 리액티브 스트림 데이터 처리 프로토콜대로 onComplete 또는 OnError 시그널이 발생할 때 까지 onNext를 사용해 구독자에게 데이터를 통지한다.
Mono 예제
import reactor.core.publisher.Mono
fun main() {
val mono = Mono.just("Hello World")
mono.subscribe(::println)
}
Mono.just(data: T)
는 객체를 인자로 받은 뒤 모노로 wrapping하는 팩토리 함수이다.
import reactor.core.publisher.Mono
fun main() {
val mono = Mono.just("Hello World")
println(mono)
}
- 모노와 플럭스 연산자는 모두
Lazy(게으른)
동작하여 subscribe를 호출하지 않으면 리액티브 사양대로 코드가 동작하지 않는다. - subscribe는
Terminal Operator(최종 연산자)
이다. - Java8의 스트림도 이와 유사하게
map
,flatMap
,filter
등은 중간 연산자이고,collect
,findFirst
,count
등이 최종 연산자이다.
Flux 예제
import reactor.core.publisher.Flux
data class Cellphone(
val name: String,
val price: Int,
val currency: Currency,
)
enum class Currency {
KRW, USD
}
fun main() {
val iPhone = Cellphone(name = "Iphone", price = 1000, currency = Currency.KRW)
val galaxy = Cellphone(name = "Galaxy", price = 500, currency = Currency.KRW)
val flux = Flux.just(iPhone, galaxy)
flux.subscribe(::println)
}
- Flux는 Mono와 다르게 다수의 요소를 통지할 수 있다.
스프링 MVC vs 스프링 WebFlux
스프링 MVC
- 스프링으로 개발된 대부분의 웹 애플리케이션은
서블릿 기반
의 스프링 MVC이다. - 스프링 MVC는 동시성 처리를 전통적 웹 방식인 하나의 스레드가 하나의 요청을 처리하는
Thread per Request Model
을 사용한다. - 대부분의 스프링 웹 애플리케이션이 스프링 MVC 기반이므로 안정성과 풍부한 라이브러리를 지원한다.
- JPA, JDBC와 같은 블로킹 API를 사용하는 경우에는 스프링 MVC를 사용하는 것이 낫다.
- Thread per Request Model은 DB, Network IO 등이 발생한 경우 결과를 받기까지 스레드가 블로킹 된다. (예: DB에서 query 결과를 받기까지 5초의 시간이 소요된다치면, 스레드는 5초동안 아무것도 하지 못함)
- 이런 문제를 해결하기 위해 스레드 풀을 사용해 동시성을 제어한다.
스프링 WebFlux
- 스프링 WebFlux는 전통적 웹 프레임워크인 스프링 MVC와 대비되는
리액티브 기반의 웹 스택 프레임워크
이다. - 기본적으로 프로젝트 리액터 기반이며, 리액티브 스트림의 다른 구현체인 RxJava나 코틀린 코루틴으로도 개발이 가능하다.
- 스프링 WebFlux는 비동기-논블로킹으로 동작하므로, 적은 수의 스레드로도 대량의 동시성을 제어할 수 있다.
- 함수형 엔드포인트와 애노테이션 컨트롤러 방식을 모두 지원한다.
- 이벤트 루프 동시성 모델
- 스프링 MVC에 비해 러닝커브가 많이 높은 편이다.
- 전 구간 비동기-논블로킹인 경우에 최적의 성능을 보여준다.
'Spring' 카테고리의 다른 글
[Spring] 스프링 트랜잭션 전파 옵션 REQUIRES_NEW에 대해 알아보자 (0) | 2022.11.22 |
---|---|
[Spring] 프록시 내부 호출 문제점 (0) | 2022.10.28 |
[Spring] 웹 서버(Web Server)와 웹 어플리케이션 서버(WAS)의 차이가 무엇일까? (1) | 2022.08.27 |
[Spring] 스프링 트라이앵글 - IoC/DI, AOP, PSA (0) | 2022.08.26 |
[Spring Security] JWT (Json Web Token) (0) | 2022.07.21 |
댓글
공지사항
최근에 올라온 글
최근에 달린 댓글
- Total
- Today
- Yesterday
링크
TAG
- 김영한
- 구현
- 알고리즘
- 리팩토링
- 인프런
- 자료구조
- mysql 8.0
- 백준
- 코테
- spring boot
- 데이터베이스
- 그리디
- 릿코드
- Algorithm
- Real MySQL
- 코틀린
- 노마드
- kotlin
- MySQL
- 북클럽
- 문자열
- 파이썬
- 정렬
- webflux
- 노마드코더
- Refactoring
- leetcode
- 스프링
- Spring
- 스프링 부트
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | 6 | 7 |
8 | 9 | 10 | 11 | 12 | 13 | 14 |
15 | 16 | 17 | 18 | 19 | 20 | 21 |
22 | 23 | 24 | 25 | 26 | 27 | 28 |
29 | 30 | 31 |
글 보관함