거북이 developer

BlockHound Spring Webflux 는 예상치 못한 blocking 로직이 있을 경우 성능에 큰 영향을 미치기 때문에 이러한 로직이 있는지 탐지하고 수정할 수 있어야 한다. BlockHound 는 비지니스 로직이 수행될 때 blocking 로직이 있으면 exception 을 던져 blocking 로직을 파악할 수 있게 도와준다. 번역 gateway 에서는 아래와 같은 방식으로 blockhound 를 실행한다. Dependency 추가 io.projectreactor.tools blockhound 1.0.3.RELEASE Application class 에서 BlockHound 실행여부를 판단 @SpringBootApplication public class Application { static ..

Test Code StepVerifier Reactor 를 사용할 경우 주로 다루는 Mono/Flux 를 반환하는 리액티브 API 에 대한 테스트는 기존 Test Code 작성 방법으로는 테스트하기 힘들다. 아래와 같이 reactor-test 에 대한 dependency 를 추가해야 사용이 가능하다 io.projectreactor reactor-test test ◉ 일반적인 Test Code 작성시 발생할 수 있는 실수 1 @Test public void mono() { Mono mono = Mono.just(1) // (1) .subscribeOn(Schedulers.single()); // (2) Mono.subscribe(item -> assertThat(item).isEqualTo(1)); // ..

Monitoring Metrics Spring Boot Application 의 Metric 을 수집하는 방법중의 하나로 Spring Actuator 를 사용할 수 있다. Spring Actuator 의 dependency 를 추가한다. org.springframework.boot spring-boot-starter-actuator management.endpoints.web.exposure.include 에 metrics 값을 추가하면 /actuator/metrics API 가 활성화 된다. management: endpoints: web: exposure: include: ["metrics"] HTTP GET method 요청으로 /actuator/metrics/{metric name} 형태로 요청하..

Exception Handle Functional Level Handler 에서 함수 수행시 onErrorReturn, onErrorResume 을 정의하여 에러 핸들링 처리를 할 수 있다. onErrorReturn public Mono handleRequest(ServerRequest request) { return sayHello(request) .onErrorReturn("Request Fail! But Return Success Status!") .flatMap(s -> ServerResponse.ok() .contentType(MediaType.TEXT_PLAIN) .bodyValue(s)); } onErrorResume public Mono handleRequest(ServerRequest r..

Server Configuration @EnableWebFlux @EnableWebFlux 어노테이션을 정의할 경우 DelegatingWebFluxConfiguration 이 동작하는데 해당 Configuration 이 수행하는 기능은 다음과 같다. WebFlux Application 운영을 위한 default spring configuration 을 정의해준다. WebFluxConfigurer 를 정의한 configuration 이 있는지 탐지 및 customizing 된 내용 적용. @Configuration @EnableWebFlux public class WebConfig { // ... } 만약 @EnableWebFlux 를 사용하지 않고 직접 핸들링 하고 싶다면, DelegatingWebFlu..

WebClient 생성 create WebClient 는 간단하게 static 메서드로 생성이 가능하다. static method 로 생성할 경우 디폴트로 Reactor Netty HttpClient 를 사용하므로 reactor-netty 라이브러리에 대한 의존성이 필요하다. WebClient webClient1 = WebClient.create(); WebClient webClient2 = WebClient.create("http://naver.com"); builder 몇가지 옵션을 설정하려면 builder 를 사용하여 생성하는것을 권장한다. uriBuilderFactory: base URL 과 관련하여 UriBuilderFactory 를 커스텀하게 구현했을 경우. defaultUriVariables..

Filter Spring Webflux 에서는 MVC 의 Interceptor 와 비슷한 역할을 하는 HandlerFilterFunction 과 Servlet Filter 와 비슷한 역할을 하는 WebFilter Interface 를 제공하고 있다. HandlerFilterFunction 핸들러 펑션에 필터를 적용할 땐 RouterFunction Builder 를 사용하면 되는데, 다음과 같은 함수가 있다. before : Handler 함수 수행 전에 동작하는 함수를 등록하며 인자로 Function 를 받는다. after : Handler 함수가 수행 완료되면 동작하는 함수를 등록하며 인자로 BiFunction 를 받는다. filter : 인자로 HandlerFilterFunction 를 받으며, 필터..

HandlerFunction ServerRequest 를 받아 ServerResponse 를 리턴하는, MVC 의 Controller 와 유사한 로직을 구현하는 함수이다. ServerRequest와 ServerResponse는 자바 8 방식으로 HTTP 요청과 응답에 접근할 수 있는 불변(immutable) 인터페이스다. 요청, 응답 body 모두 리액티브 스트림 back pressure로 처리한다. request body는 리액터 Flux나 Mono로 표현한다. response body는 Flux와 Mono를 포함한 어떤 리액티브 스트림 Publisher든 상관없다. 자세한 정보는 Reactive Libraries 를 참고. ServerRequest ServerRequest로 HTTP 메소드, URI,..