스프링 웹 플럭스 | [10분 테코톡] 🐅호돌의 Spring Webflux 22 개의 정답

번역] 스프링 웹플럭스 레퍼런스 (Web on Reactive Stack)

Web on Reactive Stack

1. 스프링 웹플럭스(Spring WebFlux)

1.1. 개요

1.1.1. “리액티브” 의 정의(Define “Reactive”)

1.1.2. 리액티브 API(Reactive API)

1.1.3. 프로그래밍 모델(Programming Models)

어노테이티드 컨트롤러: 스프링 MVC와 일치하며, spring-web 모듈과 동일한 어노테이션을 기반으로 구성되었다. 스프링 MVC와 웹플럭스 컨트롤러는 리액티브(리액터, RxJava) 반환 타입을 지원하며, 결과적으로 이 둘을 구분하기가 쉽지 않게 되었다. 주목할만한 차이점은 웹플럭스는 리액티브 @RequestBody 아규먼트를 지원한다는 것이다.

함수형 엔드포인트: 람다 기반의 경량 함수형 프로그래밍 모델. 소형 라이브러리, 혹은 요청을 라우팅하고 핸들링하기 위해 어플리케이션이 사용할 수 있는 유틸리티의 모음이라고 할 수 있다. 어노테이티드 컨트롤러와의 큰 차이점은, 어플리케이션이 요청 핸들링의 시작부터 끝까지 책임지느냐 vs 어노테이션을 통해 의사를 표시하고 콜백을 받느냐이다.

1.1.4. 적용 영역(Applicability)

잘 작동 중인 기존 스프링 MVC 어플리케이션이 있다면, 변경할 필요가 없다. 명령형 프로그래밍은 작성하고 이해하고 디버깅 하기에 가장 쉬운 방법이며, 라이브러리 선택에 있어 최대한의 선택지를 가지게 된다. 대부분 블로킹 방식이기 때문에.

이미 논 블로킹 웹 스택을 찾고 있다면, 스프링 웹플럭스는 다른 웹 스택과 동일한 실행 모델이라는 이점과 함께, 서버에 있어서의 선택지(네티, 톰캣, 제티, 언더토, 서블릿 3.1+ 컨테이너), 프로그래밍 모델에 있어서의 선택지(어노테이티드 컨트롤러, 함수형 웹 엔드포인트), 리액티브 라이브러리에 있어서의 선택지(리액터, RxJava 또는 그 외)를 제공한다.

자바 8 람다 또는 코틀린과 함께 사용할 경량 함수형 웹 프레임워크를 원한다면, 스프링 웹플럭스 함수형 웹 엔드포인트를 사용할 수 있다. 또한 더 작은 어플리케이션이나, 더 훌륭한 명료성과 제어(control)라는 이점을 보다 적은 복잡도로 제공하는 마이크로서비스에도 스프링 웹플럭스는 좋은 선택지가 된다.

마이크로서비스 아케텍처에서 스프링 MVC 또는 스프링 웹플럭스 컨트롤러 또는 스프링 웹플럭스 함수형 엔드포인트 각각으로 만들어진 서로 다른 어플리케이션을 혼합하여 사용할 수 있다. 이 두 프레임워크에가 동일한 어노테이션 기반 프로그래밍 모델을 지원한다는 점은 올바른 도구를 적재적소에 사용하는 동시에 기존 지식을 재사용하기 쉽게 만들어준다.

어플리케이션을 평가하는 간단한 방법은 어플리케이션의 의존성을 확인하는 것이다. 블로킹 영속성 API(JPA, JDBC) 또는 네트워킹 API를 사용하고 있다면, 스프링 MVC는 적어도 공통 아키텍처에 있어서는 최고의 선택이 된다. 스프링 MVC는 기술적으로 개별 쓰레드에 대해 리액터와 RxJava를 사용하여 블로킹 호출을 수행하는 것이 가능하지만, 논 블로킹 웹 스택을 최대한 활용하지는 못한다.

기존 스프링 MVC어플리케이션이 원격 서비스 호출(remoting)을 수행한다면, 리액티브 WebClient(이하 웹클라이언트)를 사용해보라. 스프링 MVC 컨트롤러 메서드로부터 리액티브 타입(Reactor, RxJava, 기타 등)을 반환값으로 직접 얻을 수 있다. 호출 당, 혹은 호출 간 상호 작용의 지연이 클수록, 더욱 드라마틱한 이점을 얻을 수 있다. 스프링 MVC 컨트롤러는 다른 리액티브 컴포넌트를 똑같이 호출할 수 있다.

팀의 규모가 크다면, 논 블로킹, 함수형, 선언적 프로그래밍으로의 전환에 따르는 학습 곡선이 가파르다는 점을 유념해야 한다. 전체를 바꾸지 않고 시작하는 실용적인 방법은 리액티브 웹클라이언트를 사용하는 것이다. 이걸 넘어서면 작은 것부터 시작해보고, 이로부터 얻은 장점을 측정해보라. 대부분의 어플리케이션의 경우 이 전환이 필수적이지는 않다고 본다. 얻고자 하는 장점이 무엇인지 불확실하다면, 논 블로킹 I/O가 어떻게 작동하는지, 그리고 이것의 효과가 무엇인지 배우는 것에서 시작하도록 한다(예로, 싱글 쓰레드 Node.js의 동시성 처리가 있다).

1.1.5. 서버(Servers)

1.1.6. 퍼포먼스(Performance)

1.1.7. 동시성 모델(Concurrency Model)

순수 스프링 웹플럭스 서버(예로, 데이터 접근이나 다른 선택적인 의존성이 존재하지 않는)에서는, 서버를 위한 쓰레드 하나, 요청을 처리하기 위한 쓰레드 여럿을 예상할 수 있다(보통 CPU 코어의 수가 쓰레드의 수가 된다). 그러나 서블릿 컨테이너의 경우, 서블릿 블로킹 I/O와 서블릿 3.1 논 블로킹 I/O를 모두 지원하기 위해 더 많은 수의 쓰레드가 사용될 수 있다(톰캣에서는 10개).

이벤트 루프 방식의 리액티브 웹클라이언트 연산자. 적고 고정된 수의 요청 처리 쓰레드가 사용된다(예로, 리액터 네티 커넥터와 사용되는 reactor-http-nio-). 리액터 네티가 클라이언트와 서버 모두에서 쓰인다면, 이 둘은 기본적으로 이벤트 루프 자원을 공유한다.

리액터와 RxJava는 Schedulers(이하 스케쥴러)라는 쓰레드 풀 추상화를 제공하여 publishOn 연산자와 함께 사용하며 다른 쓰레드 풀으로 처리를 전환한다. 스케쥴러는 특정한 동시성 전략을 제안한다. -예로, “parallel”(CPU 바운드 동작에는 제한된 수의 쓰레드 사용), 또는 “elastic”(I/O 바운드 동작에는 큰 수의 쓰레드 사용). 이러한 쓰레드를 본다는 것은 프로그램 코드가 특정 스케쥴러 전략을 사용하고 있음을 의미한다.

데이터 접근 라이브러리와 써드파티 의존성은 각자 스스로의 쓰레드를 생성하고 사용할 수 있다.

1.2. 리액티브 코어(Reactive Core)

서버의 요청 처리에 대해서는 두 가지 레벨의 지원이 있다. HttpHandler: HTTP 요청 핸들링을 위한 논 블로킹 I/O와 리액티브 스트림 기반의 기본 핸들러. 리액터 네티, 언더토, 톰캣, 제티, 서블릿 3.1+ 컨테이너를 지원하는 어댑터와 함께 작동한다. WebHandler API: 요청 처리를 위한 좀 더 고수준의, 다용도 웹 API. 어노테이티드 컨트롤러와 함수형 엔드포인트와 같은 구체적인 프로그래밍 모델 위에 존재한다.

클라이언트 사이드에는 논 블로킹 I/O, 리액티브 스트림 백프레셔로 HTTP 요청을 수행하기 위한 기본 ClientHttpConnector 계약이 있다. 리액터 네티 및 리액티브 제티 HttpClient를 위한 어댑터를 사용해 작동한다. 여기에는 더 고수준의 웹클라이언트가 사용된다.

클라이언트와 서버는 HTTP 요청과 응답 컨텐츠를 시리얼라이징/디시리얼라이징하기 위해 코덱을 사용한다.

1.2.1. HttpHandler

서버 사용되는 서버 API 리액티브 스트림 지원 네티 네티 API 리액터 네티 언더토 언더토 API spring-web: 언더토 to 리액티브 스트림 브릿지 톰캣 서블릿3.1 논 블로킹 I/O; byte[]에 대응하여 ByteBuffer를 읽고 쓰는 톰캣 API spring-web: 서블릿3.1 논 블로킹 I/O to 리액티브 스트림 브릿지 제티 서블릿3.1 논 블로킹 I/O; byte[]에 대응하여 ByteBuffer를 읽고 쓰는 제티 API spring-web: 서블릿3.1 논 블로킹 I/O to 리액티브 스트림 브릿지 서블릿3.1 컨테이너 서블릿3.1 논 블로킹 I/O spring-web: 서블릿3.1 논 블로킹 I/O to 리액티브 스트림 브릿지

서버 그룹 아티팩트 리액터 네티 io.projectreactor.netty reactor-netty 언더토 io.undertow undertow-core 톰캣 org.apache.tomcat.embed tomcat-embed-core 제티 org.eclipse.jetty jetty-server, jetty-servlet

Java HttpHandler handler = … ReactorHttpHandlerAdapter adapter = new ReactorHttpHandlerAdapter(handler); HttpServer.create().host(host).port(port).handle(adapter).bind().block();

Kotlin val handler: HttpHandler = … val adapter = ReactorHttpHandlerAdapter(handler) HttpServer.create().host(host).port(port).handle(adapter).bind().block()

Java HttpHandler handler = … UndertowHttpHandlerAdapter adapter = new UndertowHttpHandlerAdapter(handler); Undertow server = Undertow.builder().addHttpListener(port, host).setHandler(adapter).build(); server.start();

Kotlin val handler: HttpHandler = … val adapter = UndertowHttpHandlerAdapter(handler) val server = Undertow.builder().addHttpListener(port, host).setHandler(adapter).build() server.start()

Java HttpHandler handler = … Servlet servlet = new TomcatHttpHandlerAdapter(handler); Tomcat server = new Tomcat(); File base = new File(System.getProperty(“java.io.tmpdir”)); Context rootContext = server.addContext(“”, base.getAbsolutePath()); Tomcat.addServlet(rootContext, “main”, servlet); rootContext.addServletMappingDecoded(“/”, “main”); server.setHost(host); server.setPort(port); server.start();

Kotlin val handler: HttpHandler = … val servlet = TomcatHttpHandlerAdapter(handler) val server = Tomcat() val base = File(System.getProperty(“java.io.tmpdir”)) val rootContext = server.addContext(“”, base.absolutePath) Tomcat.addServlet(rootContext, “main”, servlet) rootContext.addServletMappingDecoded(“/”, “main”) server.host = host server.setPort(port) server.start()

Java HttpHandler handler = … Servlet servlet = new JettyHttpHandlerAdapter(handler); Server server = new Server(); ServletContextHandler contextHandler = new ServletContextHandler(server, “”); contextHandler.addServlet(new ServletHolder(servlet), “/”); contextHandler.start(); ServerConnector connector = new ServerConnector(server); connector.setHost(host); connector.setPort(port); server.addConnector(connector); server.start();

Kotlin val handler: HttpHandler = … val servlet = JettyHttpHandlerAdapter(handler) val server = Server() val contextHandler = ServletContextHandler(server, “”) contextHandler.addServlet(ServletHolder(servlet), “/”) contextHandler.start(); val connector = ServerConnector(server) connector.host = host connector.port = port server.addConnector(connector) server.start()

1.2.2. WebHandler API

사용자 세션(세션 어트리뷰트)

리퀘스트 어트리뷰트

요청에 대한 리졸빙된 Locale or Principal

파싱되고 캐싱된 폼 데이터 접근

멀티파트 데이터 추상화

기타 등등..

스페셜 빈 타입

빈 이름 빈 타입 카운트 설명 WebExceptionHandler 0..N WebFilter 인스턴스들과 타겟 WebHandler에서 발생한 익셉션에 대한 핸들링을 제공한다. 자세한 내용은 Exceptions를 참조한다. WebFilter 0..N 인터셉터 스타일 로직을 적용하여 타겟 WebHandler의 전/후 동작을 담당한다. 자세한 내용은 Filters를 참조한다. webHandler WebHandler 1 요청을 처리한다. webSessionManager WebSessionManager 0..N ServerWebExchange의 메서드를 통해 노출된 WebSession 인스턴스를 관리한다. 디폴트는 DefaultWebSessionManager. serverCodecConfigurer ServerCodecConfigurer 0..1 HttpMessageReader로 접근하여 ServerWebExchange의 메서드를 통해 노출된 폼 데이터와 멀티파트 데이터를 파싱하는 컴포넌트. 디폴트는 ServerCodecConfiguter.create() localeContextResolver LocaleContextResolver 0..1 ServerWebExchange의 메서드를 통해 노출된 LocaleContext에 대한 리졸버. 디폴트는 AcceptHeaderLocaleContextResolver. forwardedHeaderTransformer ForwardedHeaderTransformer 0..1 포워드 타입 헤더를 처리하기 위한 컴포넌트. 각 헤더는 추출과 제거 or 제거 only. 디폴트는 사용하지 않음.

폼 데이터

Java Mono> getFormData();

Kotlin suspend fun getFormData(): MultiValueMap

멀티파트 데이터

Java Mono> getMultipartData();

Kotlin suspend fun getMultipartData(): MultiValueMap

스프링 웹 플럭스 | [10분 테코톡] 🐅호돌의 Spring Webflux 인기 답변 업데이트

당신은 주제를 찾고 있습니까 “스프링 웹 플럭스 – [10분 테코톡] 🐅호돌의 Spring Webflux“? 다음 카테고리의 웹사이트 you.xosotanphat.com 에서 귀하의 모든 질문에 답변해 드립니다: https://you.xosotanphat.com/blog. 바로 아래에서 답을 찾을 수 있습니다. 작성자 우아한Tech 이(가) 작성한 기사에는 조회수 9,798회 및 좋아요 133개 개의 좋아요가 있습니다.

여기에서 이 주제에 대한 비디오를 시청하십시오. 주의 깊게 살펴보고 읽고 있는 내용에 대한 피드백을 제공하세요!

🙋‍♀️ 우아한테크코스의 크루들이 진행하는 10분 테크토크입니다. 🙋‍♂️

’10분 테코톡’이란 우아한테크코스 과정을 진행하며 크루(수강생)들이 동료들과 학습한 내용을 공유하고 이야기하는 시간입니다. 서로가 성장하기 위해 지식을 나누고 대화하며 생각해보는 시간으로 자기 주도적인 성장을 지향하는 우아한테크코스의 문화 중 하나입니다.

🌕우아한테크코스란 🌕

우아한테크코스는 일반 사용자용 서비스를 개발하는 회사가 필요로 하는 역량을 가진 프로그래머를 양성하기 위한 교육입니다. 우리의 목표는 자기 주도적으로 학습하고 성장하고 싶은 개발자를 위한 교육을 만드는 것입니다.

(R2DBC는 곧 글을 써볼 예정이다.) 태그목록. 글뷰관련 태그목록. spring스프링StreamsreactiveredisWebflux웹플럭스백프레셔 …

+ 여기에 표시

Source: hyunsoori.tistory.com

Date Published: 4/28/2022

View: 5170

이에 따라 비동기 처리를 이용한 웹 애플리케이션이 필요해졌다. 그 해결책으로 스프링 5와 스프링 부트 2는 리액티브 프로그래밍인 웹플럭스를 이용해 웹 프로그램을 …

+ 여기에 더 보기

Source: 12bme.tistory.com

Date Published: 7/7/2022

View: 316

그동안 스프링 웹플럭스를 사용하면서 나름대로 이게 왜 사용되고 어떤 방식으로 동작되는지에 대해서 누구도 간결하게 설명해주지 않아서 한번 …

+ 여기를 클릭

Source: velog.io

Date Published: 4/29/2022

View: 6065

1. 스프링 웹플럭스(Spring WebFlux). 스프링 프레임워크의 오리지널 웹 프레임워크인 스프링 웹 MVC는 서블릿 API와 서블릿 컨테이너를 위한 것이었다.

+ 여기에 보기

Source: parkcheolu.tistory.com

Date Published: 8/24/2021

View: 8933

비동기-논블로킹 프로그래밍. 전통적 웹 방식 (스프링 MVC). 전통적 웹 방식은 1개 요청당 1개의 스레드를 사용하는 Thread per Request 모델 …

+ 여기를 클릭

Source: devsh.tistory.com

Date Published: 1/2/2022

View: 5538

아무튼, 웹플럭스를 사용하려면 가능한 STS 툴을 사용해서 하도록하자. 여기서는 STS를 사용하였다. (버전 : 4.2.0). 먼저 스프링부트 프로젝트를 만들어 …

+ 더 읽기

Source: lts0606.tistory.com

Date Published: 1/1/2022

View: 4902

스프링웹플럭스란 Project Reactor의 웹의 스트리밍 처리를 한다. SpringBoot2(Spring5) 부터 사용가능 하며 Reactive Stack, Servlet Stack 둘중 하나를 …

+ 여기에 더 보기

Source: hanseungwan24.tistory.com

Date Published: 11/23/2022

View: 1799

Reactor is the reactive library of choice for Spring WebFlux. It proves the Mono and Flux API types to work on data sequences of 0..1 ( Mono ) …

+ 여기에 보기

Source: docs.spring.io

Date Published: 10/28/2022

View: 5003

주제와 관련된 더 많은 사진을 참조하십시오 [10분 테코톡] 🐅호돌의 Spring Webflux. 댓글에서 더 많은 관련 이미지를 보거나 필요한 경우 더 많은 관련 기사를 볼 수 있습니다.

@Configuration public class RedisConfigurer { @Bean public LettuceConnectionFactory redisConnectionFactory() { LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder() .commandTimeout(Duration.ofSeconds(2)) .shutdownTimeout(Duration.ZERO) .build(); return new LettuceConnectionFactory(new RedisStandaloneConfiguration(“localhost”, 6379), clientConfig); } @Bean public ReactiveRedisTemplate personRedisTemplate( ReactiveRedisConnectionFactory connectionFactory) { Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Person.class); RedisSerializationContextBuilder builder = RedisSerializationContext.newSerializationContext(new StringRedisSerializer()); RedisSerializationContext serializationContext = builder.value(serializer).build(); return new ReactiveRedisTemplate<>(connectionFactory, serializationContext); } }

Reactive Streams is an initiative to provide a standard for asynchronous stream processing with non-blocking back pressure.

import org.springframework.beans.factory.annotation.Value; import org.springframework.core.ParameterizedTypeReference; import org.springframework.stereotype.Component; import org.springframework.web.reactive.function.client.WebClient; import org.springframework.web.reactive.function.server.*; import reactor.core.publisher.Mono; import java.util.List; import java.util.Optional; @Component public class ClientDemoHandler { private static final String GITHUB_BASE_URL = “https://api.github.com”; public Mono handle1(ServerRequest req) { WebClient webClient = WebClient.create(GITHUB_BASE_URL); // 쿼리 스트링에 user가 포함되어 있는지 체크 Optional userName = req.queryParam(“user”); if (!userName.isPresent()) { return ServerResponse.ok().body(Mono.just(“user is Required”), String.class); } // 비동기 호출(비블록) Mono > values = webClient.get() .uri(“users/” + userName.get() + “/repos”) .retrieve() .bodyToMono(new ParameterizedTypeReference >(){}); return ServerResponse.ok().body(values, new ParameterizedTypeReference >(){}) } public RouterFunction routerule() { return RouterFunctions.route(RequestPredicates.GET(“/func/sample9”), this::handle1); } }

public Mono handle1(ServerRequest req) { WebClient webClient = WebClient.create(GITHUB_BASE_URL); // 쿼리 스트링에 user가 포함되어 있는지 체크 Optional userName = req.queryParam(“user”); if (!userName.isPresent()) { return ServerResponse.ok().body(Mono.just(“user is Required”), String.class); } // 비동기 호출(비블록) Mono > values = webClient.get() .uri(“users/” + userName.get() + “/repos”) .retrieve() .bodyToMono(new ParameterizedTypeReference >(){}); return ServerResponse.ok().body(values, new ParameterizedTypeReference >(){}) }

RequestPredicates의 GET 메서드를 이용해 RequestPredicates 구현 클래스의 인스턴스를 생성한다. 경로(/hello)에 GET 요청이 있고, accept 헤더가 TEXT/PLAIN인 액세스 조건을 나타낸다. 이 조건을 만족할때, greetingHandler 클래스의 hello() 메서드를 호출한다.

Java HttpHandler handler = … Servlet servlet = new JettyHttpHandlerAdapter(handler); Server server = new Server(); ServletContextHandler contextHandler = new ServletContextHandler(server, “”); contextHandler.addServlet(new ServletHolder(servlet), “/”); contextHandler.start(); ServerConnector connector = new ServerConnector(server); connector.setHost(host); connector.setPort(port); server.addConnector(connector); server.start();

Java HttpHandler handler = … Servlet servlet = new TomcatHttpHandlerAdapter(handler); Tomcat server = new Tomcat(); File base = new File(System.getProperty(“java.io.tmpdir”)); Context rootContext = server.addContext(“”, base.getAbsolutePath()); Tomcat.addServlet(rootContext, “main”, servlet); rootContext.addServletMappingDecoded(“/”, “main”); server.setHost(host); server.setPort(port); server.start();

서버 사용되는 서버 API 리액티브 스트림 지원 네티 네티 API 리액터 네티 언더토 언더토 API spring-web: 언더토 to 리액티브 스트림 브릿지 톰캣 서블릿3.1 논 블로킹 I/O; byte[]에 대응하여 ByteBuffer를 읽고 쓰는 톰캣 API spring-web: 서블릿3.1 논 블로킹 I/O to 리액티브 스트림 브릿지 제티 서블릿3.1 논 블로킹 I/O; byte[]에 대응하여 ByteBuffer를 읽고 쓰는 제티 API spring-web: 서블릿3.1 논 블로킹 I/O to 리액티브 스트림 브릿지 서블릿3.1 컨테이너 서블릿3.1 논 블로킹 I/O spring-web: 서블릿3.1 논 블로킹 I/O to 리액티브 스트림 브릿지

import org.springframework.context.annotation.Configuration; import org.springframework.context.ApplicationContext; import org.thymeleaf.spring5.ISpringWebFluxTemplateEngine; import org.thymeleaf.spring5.SpringWebFluxTemplateEngine; import org.thymeleaf.spring5.templateresolver.SpringResourceTemplateResolver; import org.thymeleaf.spring5.view.reactive.ThymeleafReactiveViewResolver; import org.thymeleaf.templatemode.TemplateMode; import org.thymeleaf.templateresolver.ITemplateResolver; import org.springframework.web.reactive.config.ViewResolverRegistry; import org.springframework.web.reactive.config.WebFluxConfigurer; import java.util.HashMap; import org.springframework.context.ApplicationContextAware; import org.springframework.beans.BeansException; import org.springframework.context.annotation.Bean; import org.springframework.http.MediaType; import org.springframework.web.reactive.function.server.RequestPredicates; import org.springframework.web.reactive.function.server.RouterFunction; import org.springframework.web.reactive.function.server.RouterFunctions; import org.springframework.web.reactive.function.server.ServerResponse; @Configuration public class RoutsConfig implements ApplicationContextAware, WebFluxConfigurer { ApplicationContext context; @Bean public RouterFunction route(FirstHandler handler) { return RouterFunctions.route( RequestPredicates.GET(“/hello”).and(RequestPredicates.accept(MediaType.TEXT_PLAIN)), handler::hello); } @Bean public RouterFunction index() { // /요청에 대한 페이지 정의 return RouterFunctions.route(RequestPredicates.GET(“/”).and(RequestPredicates.accept(MediaType.TEXT_HTML)), req -> ServerResponse.ok().render(“index”, new HashMap ())); } @Bean public ITemplateResolver thymeleafTemplateResolver() { final SpringResourceTemplateResolver resolver = new SpringResourceTemplateResolver(); resolver.setApplicationContext(this.context); resolver.setPrefix(“classpath:static/”); resolver.setSuffix(“.html”); resolver.setTemplateMode(TemplateMode.HTML); resolver.setCacheable(false); resolver.setCheckExistence(false); return resolver; } @Bean public ISpringWebFluxTemplateEngine thymeleafTemplateEngine() { SpringWebFluxTemplateEngine templateEngine = new SpringWebFluxTemplateEngine(); templateEngine.setTemplateResolver(thymeleafTemplateResolver()); return templateEngine; } @Bean public ThymeleafReactiveViewResolver thymeleafReactiveViewResolver() { ThymeleafReactiveViewResolver viewResolver = new ThymeleafReactiveViewResolver(); viewResolver.setTemplateEngine(thymeleafTemplateEngine()); return viewResolver; } @Override public void configureViewResolvers(ViewResolverRegistry registry) { registry.viewResolver(thymeleafReactiveViewResolver()); } @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { } }

ServerWebExchange Access to the full ServerWebExchange — container for the HTTP request and response, request and session attributes, checkNotModified methods, and others.

ServerHttpRequest , ServerHttpResponse Access to the HTTP request or response.

WebSession Access to the session. This does not force the start of a new session unless attributes are added. Supports reactive types.

java.security.Principal The currently authenticated user — possibly a specific Principal implementation class if known. Supports reactive types.

org.springframework.http.HttpMethod The HTTP method of the request.

java.util.Locale The current request locale, determined by the most specific LocaleResolver available — in effect, the configured LocaleResolver / LocaleContextResolver .

java.util.TimeZone + java.time.ZoneId The time zone associated with the current request, as determined by a LocaleContextResolver .

@PathVariable For access to URI template variables. See URI Patterns.

@MatrixVariable For access to name-value pairs in URI path segments. See Matrix Variables.

@RequestParam For access to Servlet request parameters. Parameter values are converted to the declared method argument type. See @RequestParam . Note that use of @RequestParam is optional — for example, to set its attributes. See “Any other argument” later in this table.

@RequestHeader For access to request headers. Header values are converted to the declared method argument type. See @RequestHeader .

@CookieValue For access to cookies. Cookie values are converted to the declared method argument type. See @CookieValue .

@RequestBody For access to the HTTP request body. Body content is converted to the declared method argument type by using HttpMessageReader instances. Supports reactive types. See @RequestBody .

HttpEntity For access to request headers and body. The body is converted with HttpMessageReader instances. Supports reactive types. See HttpEntity .

@RequestPart For access to a part in a multipart/form-data request. Supports reactive types. See Multipart Content and Multipart Data.

java.util.Map , org.springframework.ui.Model , and org.springframework.ui.ModelMap . For access to the model that is used in HTML controllers and is exposed to templates as part of view rendering.

@ModelAttribute For access to an existing attribute in the model (instantiated if not present) with data binding and validation applied. See @ModelAttribute as well as Model and DataBinder . Note that use of @ModelAttribute is optional — for example, to set its attributes. See “Any other argument” later in this table.

Errors , BindingResult For access to errors from validation and data binding for a command object, i.e. a @ModelAttribute argument. An Errors , or BindingResult argument must be declared immediately after the validated method argument.

SessionStatus + class-level @SessionAttributes For marking form processing complete, which triggers cleanup of session attributes declared through a class-level @SessionAttributes annotation. See @SessionAttributes for more details.

UriComponentsBuilder For preparing a URL relative to the current request’s host, port, scheme, and context path. See URI Links.

@SessionAttribute For access to any session attribute — in contrast to model attributes stored in the session as a result of a class-level @SessionAttributes declaration. See @SessionAttribute for more details.

@RequestAttribute For access to request attributes. See @RequestAttribute for more details.

Spring Webflux 1 (웹플럭스 적용기, 설치)

Spring webflux와 관련된 일반적인 설명, 소개 및 배경은 구글링을 하면 잘 나온다.

무슨 반응형 프로그래밍..함수형 프로그래밍 등등 여러 내용이 나오는데..

머리보다 몸이 먼저인 사람에게는 참 어렵고 쉽지않는 내용이다.

아무튼, 요놈의 웹플럭스는 Spring5 부터 사용 가능한 최근에 나온 프레임워크이며 Java8에서 나온 각종 함수형 코딩방법, rxjava같은 반응형 방법등을 사용하여…..

동작 원리가 이해하기 어렵다면 기능구현을 먼저 해 보고나서 뒤돌아가 원리를 찾아보는 것도 나쁘지 않다고 생각한다.

아무튼, 웹플럭스를 사용하려면 가능한 STS 툴을 사용해서 하도록하자.

여기서는 STS를 사용하였다. (버전 : 4.2.0)

먼저 스프링부트 프로젝트를 만들어준다.

요기 스타터 프로젝트를 만들면 참 편리하게 몸통(?)이 만들어진다.

프로젝트를 만들고 난 뒤에 웹플럭스에 필요한 라이브러리를 추가한다.

* 기존 라이브러리는 전부 제거합니다!!

* 또한 스프링 부트에서 기본으로 만들어주는 ServlceServletInitializer 클래스도 제거합니다!

-> SpringBootServletInitializer 클래스를 상속받는 클래스 입니다.

-> 메인 메소드를 포함하지 않는 configure 메소드를 오버라이드 한 클래스를 의미 합니다.

* 메이븐

org.springframework.boot spring-boot-starter-webflux

* Gradle

// https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-webflux compile group: ‘org.springframework.boot’, name: ‘spring-boot-starter-webflux’, version: ‘2.2.5.RELEASE’

프로젝트가 생성되면 메인메소드는 그냥 그대로 두면 된다.

메인메소드가 존재하는 클래스를 제외하고 나머지 클래스는 삭제하자.

웹플럭스에서 주로 만나게될 녀석은 바로 RouterFunction 라는 인터페이스이다.

사용자의 요청에 대한 처리 절차를 함수형 방법으로 나열했다고 생각하면 될 것 같다.

첫번째로 일반 요청에 따라 Json형식으로 응답하는 기능을 만들어보자.

import java.util.HashMap; import org.springframework.http.MediaType; import org.springframework.stereotype.Component; import org.springframework.web.reactive.function.BodyInserters; import org.springframework.web.reactive.function.server.ServerRequest; import org.springframework.web.reactive.function.server.ServerResponse; import reactor.core.publisher.Mono; @Component public class FirstHandler { private HashMap result = new HashMap<>(); private Mono> mapper = Mono.just(result); public Mono hello(ServerRequest request) { result.put(“number”, 1234); result.put(“text”, “webFlux”); mapper.subscribe( (arg)->{//구독..? System.out.println(arg); }); return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(BodyInserters.fromProducer(mapper, HashMap.class)); } }

FirstHandler라는 클래스를 추가하였다.

컴포넌트 에노테이션을 붙여서 빈객체로 등록해 주었다.

뭔지는 잘 모르겠지만 Mono 라는 클래스를 리턴하는 hello 라는 메소드를 포함하고 있다.

메소드 내용은 짐작하긴 어렵지만 왠지 저 HashMap을 사용자의 요청이 존재하면 Json형태로 전달 할 것만 같다.

위 클래스는 MVC패턴으로 비교하면 Service의 역할을 하게 될 것 이다.

이제 사용자의 요청에 대한 응답에 대한 클래스를 만들어보자.

import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Bean; import org.springframework.http.MediaType; import org.springframework.web.reactive.function.server.RequestPredicates; import org.springframework.web.reactive.function.server.RouterFunction; import org.springframework.web.reactive.function.server.RouterFunctions; import org.springframework.web.reactive.function.server.ServerResponse; @Configuration public class RoutsConfig { @Bean public RouterFunction route(FirstHandler handler) { return RouterFunctions.route( RequestPredicates.GET(“/hello”).and(RequestPredicates.accept(MediaType.TEXT_PLAIN)), handler::hello); } }

방금 위에서 만든 FirstHandler라는 클래스를 RouterFunctions 인터페이스에 넣어 전달하였다.

GET이라는 메소드가 왠지 GET방식의 hello라는 요청에 대해서 동작 할 것 같고…

FirstHandler의 클래스의 내용이 실행될 것 같다.

사실 보는내용 그대로가 전부이다. GET을 통해서 get방식요청 hello에 대해서 응답하고,

뭔지는 모르겠지만 FirstHandler의 hello메소드를 리턴해주는 것이 전부이다.

위 클래스는 MVC 패턴으로 비교한다면 Controller 의 역할을 담당하게 될 것 이다.

그러면 한번 실행하여보자!!

오…FirstHandler클래스에 정의된 해쉬맵 데이터가 나왔다.

그리고 sts의 콘솔창도 살펴보자.

와..맵 데이터가 출력되었다.

여기까지의 프로젝트 구조는 아래사진처럼 되어있다.

프로젝트 구조 모습

여기까지 동작이 완료되었다면 우리가 알 수 있는 것은,

RoutsConfig클래스가 컨트롤러의 역할과 비슷한 행동을 하고, FirstHandler 클래스가 마치 서비스의 역할을 하는 것 같다라는 점 이다.

대부분의 샘플 코드나 예제가 구글링하면 json 방식으로 데이터를 리턴하는 것만 나와있다.

그러면 이제 웹페이지를 띄워보자.

applictaion.properties에서 아래 세팅을 하여보았다.

spring.mvc.view.prefix=classpath:/resources/static/ spring.mvc.view.suffix=.html

그리고 화면을 띄웠는데..

음…뷰를 못찼네??

프로퍼티를 요리조리 바꾸어보았지만 뭐 되는게 없었다.

사실, 웹플럭스는 뷰 리졸버가 자동으로 등록되지 않기 때문에 뷰 리졸버에 대해서는 따로 세팅을 해 주어야 한다.

권장하는 방법이 뷰와 관련되서는 프레임워크를 추가하여 사용하라고 되어 있다.

여기서는 thymeleaf라는 프레임워크를 사용 하였다.

* 메이븐

org.thymeleaf thymeleaf-spring5

* Gradle

// https://mvnrepository.com/artifact/org.thymeleaf/thymeleaf-spring5 compile group: ‘org.thymeleaf’, name: ‘thymeleaf-spring5’, version: ‘3.0.11.RELEASE’

RoutsConfig 클래스에 뷰와 관련된 내용을 수정하여보자.

import org.springframework.context.annotation.Configuration; import org.springframework.context.ApplicationContext; import org.thymeleaf.spring5.ISpringWebFluxTemplateEngine; import org.thymeleaf.spring5.SpringWebFluxTemplateEngine; import org.thymeleaf.spring5.templateresolver.SpringResourceTemplateResolver; import org.thymeleaf.spring5.view.reactive.ThymeleafReactiveViewResolver; import org.thymeleaf.templatemode.TemplateMode; import org.thymeleaf.templateresolver.ITemplateResolver; import org.springframework.web.reactive.config.ViewResolverRegistry; import org.springframework.web.reactive.config.WebFluxConfigurer; import java.util.HashMap; import org.springframework.context.ApplicationContextAware; import org.springframework.beans.BeansException; import org.springframework.context.annotation.Bean; import org.springframework.http.MediaType; import org.springframework.web.reactive.function.server.RequestPredicates; import org.springframework.web.reactive.function.server.RouterFunction; import org.springframework.web.reactive.function.server.RouterFunctions; import org.springframework.web.reactive.function.server.ServerResponse; @Configuration public class RoutsConfig implements ApplicationContextAware, WebFluxConfigurer { ApplicationContext context; @Bean public RouterFunction route(FirstHandler handler) { return RouterFunctions.route( RequestPredicates.GET(“/hello”).and(RequestPredicates.accept(MediaType.TEXT_PLAIN)), handler::hello); } @Bean public RouterFunction index() { // /요청에 대한 페이지 정의 return RouterFunctions.route(RequestPredicates.GET(“/”).and(RequestPredicates.accept(MediaType.TEXT_HTML)), req -> ServerResponse.ok().render(“index”, new HashMap())); } @Bean public ITemplateResolver thymeleafTemplateResolver() { final SpringResourceTemplateResolver resolver = new SpringResourceTemplateResolver(); resolver.setApplicationContext(this.context); resolver.setPrefix(“classpath:static/”); resolver.setSuffix(“.html”); resolver.setTemplateMode(TemplateMode.HTML); resolver.setCacheable(false); resolver.setCheckExistence(false); return resolver; } @Bean public ISpringWebFluxTemplateEngine thymeleafTemplateEngine() { SpringWebFluxTemplateEngine templateEngine = new SpringWebFluxTemplateEngine(); templateEngine.setTemplateResolver(thymeleafTemplateResolver()); return templateEngine; } @Bean public ThymeleafReactiveViewResolver thymeleafReactiveViewResolver() { ThymeleafReactiveViewResolver viewResolver = new ThymeleafReactiveViewResolver(); viewResolver.setTemplateEngine(thymeleafTemplateEngine()); return viewResolver; } @Override public void configureViewResolvers(ViewResolverRegistry registry) { registry.viewResolver(thymeleafReactiveViewResolver()); } @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { } }

아니 뷰 리졸버 세팅이 이렇게도 많은 코드라인을 차지하다니..

뭐..타일즈나 다른 프레임워크를 사용하여도 상관 없다.

여기서의 핵심은 두번째 index 메소드를 살펴보자.

첫번째 매소드와 마찬가지로 함수형 방법으로 무언가 나열되어 있지만 대략 알 수 있는 것은 index라는 페이지로 이동시켜 줄 것 같다라는 점 이다.

static 디렉토리에 index.html 파일을 만들어주자.

* index.html 파일 내용

hello

* index.html 파일 위치

html 파일 생성~

그리고나서 서버를 재 시작하고 접속하여보면,

헬로~

뷰 페이지가 정상적으로 나오는 것을 볼 수 있다.

정말 앞뒤 다 짜르고 단순하게 json으로 데이터를 받고, 뷰 페이지를 띄우는 것을 소개하였다.

개념이나 원리에 대해서는 다른 블로그나 포스팅이 더 나을수도 있다…ㅠ

그러면 화면도 띄웠고, json 형식의 데이터도 만나 보았으니 이제 웹플럭스가 뭔지 좀더 분석하여보자!!

아래 샘플코드를 첨부한다.

example.zip 0.06MB

* 악성코드나 바이러스 없습니다!!! >ㅁ< * 내용을 채우고 수정중입니다. * 튜토리얼이나 가이드 목적보다도 개념정리에 목적을 두고 쓰고있습니다. 틀린부분이나 누락된 부분은 꼭 알려주세요! 반응형

키워드에 대한 정보 스프링 웹 플럭스

다음은 Bing에서 스프링 웹 플럭스 주제에 대한 검색 결과입니다. 필요한 경우 더 읽을 수 있습니다.

이 기사는 인터넷의 다양한 출처에서 편집되었습니다. 이 기사가 유용했기를 바랍니다. 이 기사가 유용하다고 생각되면 공유하십시오. 매우 감사합니다!

사람들이 주제에 대해 자주 검색하는 키워드 [10분 테코톡] 🐅호돌의 Spring Webflux

• 동영상
• 공유
• 카메라폰
• 동영상폰
• 무료
• 올리기

YouTube에서 스프링 웹 플럭스 주제의 다른 동영상 보기

주제에 대한 기사를 시청해 주셔서 감사합니다 [10분 테코톡] 🐅호돌의 Spring Webflux | 스프링 웹 플럭스, 이 기사가 유용하다고 생각되면 공유하십시오, 매우 감사합니다.