Invoking a Blocking API

• 리액터의 publishOn, subscribeOn을 이용해 호출을 다른 스레드를 이용해 처리할 수 있다

CallBlockingAction.java

• 지원하는 Schedulers.html

method	실행 적합
parallel()	병렬 non-blocking Runnable
single()	저지연 Runnable 단일 실행. 반환 Scheduler는 재사용된다.
boundedElastic()	실행 시간이 긴 여러 (블로킹) 작업 실행. 동시 실행 제한(bound) 존재 유저 스레드는 idle 60초를 넘으면 동적으로 삭제된다 기본 유저 스레드지만, 오버라이딩 메서드로 데몬 스레드 지정 가능 threadCap : 최대 스레드 수. 기본값은 (코어 수) * 10 queuedTaskCap : 최대 큐잉 작업 수. 초과하면 RejectedExecutionException 발생. Integer.MAX_VALUE으로 무제한 설정 가능 name : 스레드 이름 prefix
immediate()	호출자 스레드로 즉시 실행
fromExecutorService()	Backing ExecutorService 지정

지원하는 HTTP 서버들에 대한 최소한의 추상화

↓ interface HttpHandler

↓ Reactor Netty

org.springframework.web.server 패키지는 HttpHandler 규약 위에서, 컴포넌트 체인(N개 WebExceptionHandler, N개 WebFilter, 1개 WebHandler)을 이용해 요청을 처리한다

WebHttpHandlerBuilder를 이용해 체인을 구성할 수 있는데, 직접 builder에 등록하거나, 컴포넌트를 자동 감지한 ApplicationContext를 지정해주면 된다

WebHandler API는 웹앱 공통 기능들을 지원한다 : 유저 세션 with 속성, 요청 속성, 요청 Locale/Principal 결정, form data, multipart data 등

WebHttpHandlerBuilder 자동 감지 빈

Bean name	Bean type	Count	Description
<any>	WebExceptionHandler	0..N	예외 처리
<any>	WebFilter	0..N	전후 처리
webHandler	WebHandler	1	요청 처리
webSessionManager	WebSessionManager	0..1	WebSession 인스턴스 관리. ServerWebExchange로 획득 가능. 기본값 DefaultWebSessionManagerCookieAndSessionAction.java 실행 스크린샷 <이미지 - 최초 get 헤더> <이미지 - 최초 get body> <이미지 - 1번째 set> <이미지 - 2번째 set> <이미지 - 2번째 get 헤더> <이미지 - 2번째 get body> Redis를 이용해 세션을 관리하고 싶은 경우 : spring-session-data-redis 사용 고려samplesspring-session-reactive
serverCodecConfigurer	ServerCodecConfigurer	0..1	form, multipart 데이터를 파싱하는 HttpMessageReader 인스턴스에 접근. ServerWebExchange로 획득 가능. 기본값 ServerCodecConfigurer.create()
localeContextResolver	LocaleContextResolver	0..1	ServerWebExchange로 획득 가능. 기본값 AcceptHeaderLocaleContextResolver
forwardedHeaderTransformer	ForwardedHeaderTransformer	0..1	프록시가 추가한 forwarded 헤더 조작. 기본적으로 사용되지 않는다.

Form Data(application/x-www-form-urlencoded)

↓ ServerWebExchange

DefaultServerWebExchange는 설정된 HttpMessageReader 인스턴스를 이용해 form을 MultiValueMap으로 파싱한다. 기본적으로 ServerCodecConfigurer 빈이 FormHttpMessageReader 빈을 사용 설정한다

Multipart Data(multipart/form-data)

↓ ServerWebExchange

DefaultServerWebExchange는 설정된 HttpMessageReader<MultiValueMap<String, Part>> 인스턴스를 이용해 multipart를 MultiValueMap으로 파싱한다. 기본적으로 DefaultPartHttpMessageReader 빈이 이용된다

Jackson JSON

• Jackson 라이브러리가 존재하는 경우, JSON 및 binary JSON(Smile)이 지원된다
• Jackson2Decoder의 동작
1. Jackson의 비동기, 논블로킹 파서가 하나의 JSON 객체를 표현하는 TokenBuffer로 바이트 스트림을 모은다
2. 각 TokenBuffer는 Jackson의 ObjectMapper로 넘겨져 고수준 객체로 변환된다
3. single-value publisher(e.g. Mono)의 디코딩의 경우, TokenBuffer가 하나만 필요하다
4. multi-value publisher(e.g. Flux)의 디코딩의 경우, 각 TokenBuffer가 객체를 구성할 수 있게 되면 ObjectMapper로 전달된다. 입력 컨텐츠로 JSON 배열, line-delimited JSON(application/stream+json)이 가능하다
• Jackson2Encoder의 동작
1. single-value publisher(e.g. Mono)는 바로 ObjectMapper에서 직렬화한다
2. multi-value publisher를 application/json로 직렬화하는 경우, Flux#collectToList()의 반환 컬렉션을 직렬화한다
3. application/x-ndjson, application/stream+x-jackson-smile 같은 스트리밍 타입으로 multi-value publisher를 직렬화하는 경우, line-delimited JSON 포맷으로 각 값을 따로 write, flush한다
4. SSE의 경우, 이벤트가 발생할 때마다 Jackson2Encoder를 1회 호출하고 flush하여 저지연을 보장한다
• 커스텀 JsonSerializer 등록

↓ java

@JsonComponent public class EntityResponseSerializer<T> extends JsonSerializer<EntityResponse<T>> { @Override public void serialize(EntityResponse<T> value, JsonGenerator gen, SerializerProvider serializers) throws IOException { var v = value.entity(); if (v == null) gen.writeNull(); else if (v instanceof String) gen.writeString((String) v); else gen.writeObject(v); } }