티스토리

Dreamchaser's Note

검색하기

블로그 홈

Dreamchaser's Note

dreamchaser3.tistory.com/m

드림체이서3 님의 블로그입니다.

구독자: 1

방명록 방문하기

주요 글 목록

RSocket Backpressure in Webflux 스프링 웹플럭스를 사용하여 리액티브 스트림즈 스펙에 부합하는 웹애플리케이션을 개발할 수 있다. 리액티브 스트림즈에서 가장 중요한 특징은 Backpressure인데, 스프링 웹플럭스(+ 리액터)를 사용하면 같은 애플리케이션 내부에서 이를 효과적으로 실현할 수 있다. 그러나, 만일 두 개의 서로 다른 웹애플리케이션이 네트워크를 통해 http 프로토콜로 통신을 한다면, backpressure가 어떻게 동작할까 하는 의문이 생기게 된다. 가령 다음과 같이 모두 스프링 웹플럭스로 만들어진 서비스A와 B가 있다고 하고, A가 B의 아래 api를 호출한다고 생각해보자. // Service B @GetMapping("/people") public Flux people() { .. 공감수 2 댓글수 0 2020. 2. 10.
Spring Webflux Cache 개요 스프링 웹플럭스와 Reactor를 사용하여 웹서버를 개발할 때 고민이 되는 부분이 있다. 바로 캐시이다. 기존 mvc 모델에서는 스프링 캐시를 사용하여 캐싱을 쉽게 할 수 있었지만, 웹플럭스 모델에서는 스프링 캐시를 이용하여 캐싱을 할 수 없다. 다음과 같이 @Cacheable 어노테이션을 이용하여 캐싱을 한다고 하면, mvc 모델 @Cacheable public List list() { // Integer List를 리턴 } 웹플럭스 모델 @Cacheable public Mono listMono() { // Mono 체인을 리턴 } mvc 모델에서는 캐시하고자 하는 값 자체를 캐싱할 수 있지만, 웹플럭스 모델에서는 위처럼 Mono 객체가 캐싱된다. 리액티브 스트림의 생명주기 글에서 다루었듯이, M.. 공감수 9 댓글수 1 2019. 10. 28.
Reactor - Reactive Streams 생명 주기 개요 Spring Webflux를 사용하여 리액티브 웹 서버를 만들기 위해서는 Webflux의 구조를 이해하는 것 만큼이나 Reactor의 구조를 이해하는 것이 중요하다. Reactor에서 reactive stream은 다음과 같은 3단계의 생명 주기를 가지고있다. 1. 조립 단계 (Assembly-time) 2. 구독 단계 (Subscription-time) 3. 런타임 단계 (Runtime) 각각의 단계에 대해서 자세히 알아보자. 조립 단계 (Assembly-time) Reactive stream의 생명 주기의 첫 번째 단계는 조립 단계이다. Reactor가 제공하는 체인형 api를 사용하여 Flux나 Mono를 만들수 있는데, 이는 언뜻 보면 빌더 패턴처럼 보인다. 그러나, 해당 api들은 각각 i.. 공감수 3 댓글수 0 2019. 10. 21.
Spring WebFlux - Config 개요 Spring Webflux Java Configuration은 어노테이션 기반의 컨트롤러 방식이나 functional endpoints 방식에서 요청을 처리하기 위한 bean들을 정의하고 웹 관련 설정을 커스터마이징할 수 있는 api를 제공한다. @EnableWebflux 라는 어노테이션으로 웹플럭스 설정을 활성화할 수 있다. @Configuration @EnableWebFlux public class WebConfig { } WebFlux config API를 오버라이딩하기 위해서는 아래와 같이 WebFluxConfigurer을 구현한다. @Configuration @EnableWebFlux public class WebConfig implements WebFluxConfigurer { // Im.. 공감수 0 댓글수 0 2019. 8. 29.
Spring Webflux - CORS 개요 Spring Webflux도 MVC와 동일하게 CORS(Cross-Origin Resource Sharing)를 지원한다. 보안 상의 이유로, 브라우저는 다른 도메인으로의 AJAX 호출을 금지한다. CORS는 도메인 간의 요청을 인증하는 것에 대한 W3C 규약으로, 대부분의 브라우저들이 이를 구현하고 있다. 여기서는 CORS 규약에 대한 자세한 설명은 하지 않고, webflux에서 관련 설정하는 법을 다루고자 한다. CORS에 대한 자세한 설명은 아래 참고 https://developer.mozilla.org/en-US/docs/Web/HTTP/CORS 설정 Local Configuration 어노테이션 컨트롤러 메소드에 @CrossOrigin 어노테이션을 사용하면 도메인 간 요청을 가능하게 할 수.. 공감수 1 댓글수 0 2019. 7. 31.
Spring Webflux - Functional Endpoints 개요 Spring WebFlux는 WebFlux.fn이라는 요청을 라우팅하고 처리하는 경량의 함수형 프로그래밍 모델을 포함하고 있다. 물론 Webflux는 기존 MVC처럼 어노테이션 기반의 프로그래밍 모델도 지원하기 때문에, 두 가지 모델 중 하나를 개인 선호에 따라 선택하여 쓸 수 있다. WebFlux.fn에는 다음과 같은 두 가지 핵심 클래스가 있다. - HandlerFunction : ServerRequest를 인자로 받아 Mono를 리턴한다. 어노테이션 기반 모델에서 @RequestMapping 메소드의 바디와 동일한 역할이다. - RouterFunction : ServerRequest를 인자로 받아 Mono를 리턴한다. router function이 매치가 되면, 그에 맞는 handler fuc.. 공감수 0 댓글수 0 2019. 7. 25.
Spring Webflux - DispatcherHandler 개요 스프링 webflux의 request 처리는 DispatcherHandler를 거쳐 적절한 handler에 요청 처리를 맡기는 형태이다. 스프링 MVC에서 DispatcherServlet의 역할을 DispatcherHandler가 한다고 생각하면 된다. WebHttpHandlerBuilder가 HttpHandler들을 체이닝하는데, DispatcherHandler도 함께 체이닝된다. 전반적인 request 처리 과정은 아래와 같다. 웹서버(netty, jetty 등)에서 handle → ServerManager.handle() → 체인된 HttpHandler들 → DispatcherHandler.handle() 의 과정으로 HttpHandler에서 리퀘스트가 처리된다. DispatcherHandle.. 공감수 1 댓글수 0 2019. 7. 18.
Spring WebClient 개요 Spring Webflux에는 reactive, non-blocking하게 HTTP 요청을 처리할 수 있도록 WebClient라는 모듈을 제공한다. 기존의 RestTemplate과 같은 역할 하지만, non-blocking하다라는 점에서 차이가 있다. 내부적으로 WebClient는 HTTP 클라이언트 라이브러리에 위임하는데, 디폴트로 Reactor Netty의 HttpClient를 사용한다. Reactor Netty 외에도, Jetty의 HttpClient를 지원하며, 다른 라이브러리도 ClientHttpConnector에 넣어주면 사용할 수 있다. 설정 WebClient를 생성하는 가장 간단한 방식은 아래와 같은 static 팩토리 메소드들을 사용하는 것이다. WebClient.create() W.. 공감수 2 댓글수 0 2019. 7. 10.
Spring Webflux + Reactor Spring 5 개요 스프링5는 내부적으로 스프링 부트2를 사용하며, web stack은 2가지로 구성되어 있다. 기존처럼 서블릿 구조를 사용하는 Spring MVC stack과 스프링5부터 새롭게 도입된 Reactive stack인 Spring Webflux 스택으로 이루어져 있다. 위 그림에서 볼 수 있듯이, Reactive stack인 경우에는 Reactor가 필수이고, Netty와 같은 비동기/non-blocking 모델의 네트워킹 프레임워크를 사용한다. 물론 Reactive stack에서도 Tomcat, Jetty와 같은 서블릿 기반의 컨테이너를 사용할 수 있지만, 이 경우에는 Servlet 3.1 non-blocking I/O를 사용한다. webflux도 비동기/non-blocking 모델이기.. 공감수 4 댓글수 0 2019. 5. 13.
Spring AMQP 개요 Spring AMQP는 AMQP 기반의 메세징 솔루션이다. 메세지를 주고 받는 것과 관련한 추상화된 template을 제공한다. 이를 이해하기 위해서, Message Queue, AMQP를 우선 살펴본다. Message Queue MOM(Message Oriented Middleware) 응용 스프트웨어 간의 메세지 교환을 비동기적으로 처리하기 위한 소프트웨어이다. Message Queue는 MOM을 구현하기 위해 주로 사용되는 방법이다. 이름에서 유추할 수 있듯이 메시징에 큐를 사용한다. sender와 receiver가 직접적으로 메시지를 교환하지 않고, 중간에 큐를 두어 비동기적으로 교환한다. publisher/subscriber model) 따라서, application과 분리가 가능하고, 메.. 공감수 0 댓글수 0 2019. 5. 13.
JDK Dynamic Proxy vs CGLib Proxy 개요 Spring AOP는 2가지 타입의 proxy를 제공한다. 바로 JDK Dynamic Proxy와 CGLib Proxy이다. Spring AOP의 ProxyFactoryBean이 proxy를 생성하는데, 경우에 따라 이 둘 중 하나를 선택해서 사용하는 방식이다. 각 Proxy가 어떻게 다르고 어떤 경우에 쓰이는지 살펴보자. JDK Dynamic Proxy JDK Dynamic Proxy는 interface 기반의 proxy이다. 이는 큰 단점인데, 왜냐하면 모든 target class가 interface를 구현하고 있어야하기 때문이다. 또한, JDK Dynamic Proxy는 Java reflecton을 사용해 method를 invoke한다. 이를 이해하기 위해 먼저 Java reflection을 .. 공감수 1 댓글수 0 2019. 5. 13.
Modern Hardware Architecture_focusing on cache 개요 좋은 성능을 내는 애플리케이션 개발을 위해서는 하드웨어 아키텍쳐를 이해할 필요가 있다. 모던 하드웨어라고 할 만한 현대의 하드웨어는 어떠한 구조로 이루어져 있는지 살펴보자. 구조 모던 하드웨어 아키텍처는 위와 같은 구조로 이루어져 있다. 1개 이상의 CPU L1 Cache L2 Cache L3 Cache Main Memory(RAM) Disk(HDD/SSD) Network Card L1, L2, L3의 의미는 Level 1, 2, 3 의 줄임말이다. 각 레벨 캐시를 조금 더 자세히 살펴보자. L1과 L2 Cache 각 CPU는 L1과 L2 메모리 캐시를 가지고 있다. L1 캐시는 일반적으로 작지만 읽는 속도가 매우 빠르다. L2 캐시는 일반적으로 더 크지만 읽는 속도가 L1 캐시보다 느리다. CPU.. 공감수 1 댓글수 0 2019. 5. 13.
Java equals() & hashcode() equals() public boolean equals(Object obj) 두 non-null object x, y에 대해 x.equals(y)는 x와 y가 "같은"지 체크한다. 여기서, "같다"라는 것은, 즉 true를 return하는 경우는 오직(if and only if) x, y가 같은 object를 참조하는 경우 뿐이다. hashCode() public int hashCode() 해당 object의 hash code value를 return한다. hashcode에는 아래와 같은 일반적인 규약이 있다. Whenever it is invoked on the same object more than once during an execution of a Java application, the hashC.. 공감수 0 댓글수 0 2019. 5. 13.
Java Lambda 개요 자바 람다식은 자바8부터 도입된 함수형 인터페이스를 구현한 코드를 간결하게 쓸 수 있게 해주는 문법이다. 여기서는 람다식의 문법 혹은 람다가 어떻게 도입되었는지, 얼마나 혁명적인지를 논의하기 보다는 람다식이 어떻게 컴파일되고 처리되는지 그 내부 구현을 기존 자바의 익명 클래스와 비교하면서 살펴본다. 내용 람다식의 특징 람다식이 어떻게 도입되었는지에 대한 설명은 생략하려 하나, 이후 논의를 위해서 특징적인 내용만 짚고 넘어가려 한다. 함수형 패러다임의 영향으로 자바에 람다식이 도입되기는 하였지만, 람다식은 자바의 새로운 함수 타입 체계는 아니다. 람다식은 단지 함수형 인터페이스(추상 메소드가 한 개만 존재하는 인터페이스)를 간결한 문법으로 구현할 수 있도록 한 것이다. '인터페이스'와 대등한 개념의 .. 공감수 3 댓글수 0 2019. 5. 12.
Java 11 Features 개요 자바 11이 출시되면서 새롭게 등장한 feature들을 정리해본다. (OpenJDK 기준) 출시일: 2018-09-25 특징 1. Nest-Based Access Control class Test { static class Nest1 { private int nest1Var; } static class Nest2 { private int nest2Var; } } 위와 같이 nested class의 경우, 'Test', 'Nest1', 'Nest2'는 모두 'nestmate'이다. 기존 JVM 상에서는 nestmate끼리 private 멤버 변수를 접근하려면 컴파일러가 중간에 bridge method를 만들어야 했다. 따라서, reflection을 사용하여 nestmate class의 private .. 공감수 0 댓글수 0 2019. 5. 12.
Java 10 Features 개요 자바 10에 새로 추가된 특징들을 알아본다. (OpenJDK 기준) * 출시일: 2018-03-20 특징 1. Local-Variable Type Inference 로컬 변수 타입을 'var'로 선언할 수 있게 되었다. 다음과 같은 케이스에만 적용된다. initializer와 함께 선언되는 로컬 변수 ex. var list = new ArrayList(); // infers ArrayList var stream = list.stream(); // infers Stream enhanced for-loop 내 index 변수 for(var user : users) { ... } traditional for-loop 내 로컬 변수 for(var i = 0; i 공감수 0 댓글수 0 2019. 5. 12.
Apache Kafka 소개 Kafka는 분산 messaging platform으로 publisher/subscriber model을 기반으로 동작한다. 분산 플랫폼이므로 실시간 대용량 로그 처리에 용이하다.producer가 특정 topic의 message들을 생성하면 Kafka cluster가 각 topic별로 분류하여 보관한다. 그리고 각 topic을 구독하고있는 consumer들이 해당 topic의 message들을 가져가는 형태이다. Topic Topic은 여러 partition들로 쪼개져 Kafka cluster의 각 서버에 저장된다. 이 때 각 partition별로 메세지의 순서가 보장된다. Replication(복제) 설정을 해두면, 마찬가지로 각 cluster의 각 서버에 partition별로 복제되어 저장되고,.. 공감수 0 댓글수 0 2019. 5. 12.

문의안내

티스토리
로그인
고객센터

티스토리는 카카오에서 사랑을 담아 만듭니다.