꾸준한 연습장

개요 마이크로서비스를 공부하면서 예제 프로젝트를 진행하였는데, 부모 프로젝트에서 모듈을 생성하면 아래와 같이 형상 관리가 모듈별로 이루어지는 문제가 있었다.    심지어 둘 이상의 모듈을 수정한 다음 push하면 각각의 모듈에서 형상 관리가 이루어지므로 다음과 같이 더욱 지저분하게 보였다.   아직 모듈이 하나이고 브랜치들의 Merge 작업이 없기 때문에 이정도이지, 나중으로 가면 더 심각해질 문제였다. 필자는 IntelliJ에 내장된 Git GUI를 애용하기 때문에 더 용납할 수 없었다.물론 서브모듈별로 Git이 관리되는 것 자체가 문제라고 할 수는 없지만, 단순한 학습용 프로젝트이기 때문에 이렇게 관리되는 것을 원치 않았다.  해결 방법 원인은 어찌보면 당연하게도 모듈이 별도의 Git 저장소로 관리되..

개요  재고시스템으로 알아보는 동시성이슈 해결방법 강의 | 최상용 - 인프런최상용 | 동시성 이슈란 무엇인지 알아보고 처리하는 방법들을 학습합니다., 동시성 이슈 처리도 자신있게! 간단한 재고 시스템으로 차근차근 배워보세요. 백엔드 개발자라면 꼭 알아야 할 동www.inflearn.com 해당 게시글은 위 인프런 강의를 수강한 내용을 바탕으로 작성되었습니다. 개발 환경Java 17SpringBoot 3.3.4GradleMySQL, JPA 목표예제 프로젝트를 통해 멀티스레드 환경에서 발생할 수 있는 동시성 이슈를 효과적으로 예방/해결할 수 있는 방법을 학습한다. 선수 과목Spring, JPA  동시성 이슈 발생 우선 동시성 이슈가 발생하는 것을 확인할 수 있는 예제 코드를 작성해 보자. Entity@Ent..

개요 Java17, Gradle을 사용하는 SpringBoot 프로젝트를 새로 생성 후, Lombok을 추가하여 코드를 작성했다. 그리고 간단한 테스트 코드를 작성하여 실행하려는데 아래와 같이 cannot find symbol 에러가 발생했다.  분명 Dependency도 잘 추가했고, @Getter 등 Lombok 관련 코드도 클라이언트 코드에서 문제 없이 작성이 가능했는데 말이다. 위 에러는 SpringBootApplication을 실행할 때에도 위 Lombok 관련 코드가 포함된다면 동일하게 발생했다.  원인 두괄식으로 설명하자면, build.gradle에 implementation으로 Lombok의 의존성은 추가했지만, annotationProcessor로는 Lombok을 추가하지 않았기 때문이었..

개요 동기식 또는 명령형 프로그래밍 방식은 Exception이 발생했을 때, StackTrace를 확인하거나 의심되는 코드에 Breakpoint를 걸어서 문제의 원인을 단계적으로 찾아갈 수 있어 상대적으로 디버깅이 쉽다. 하지만 Reactor 같은 선언형 프로그래밍 방식은 작업의 대부분이 비동기적으로 실행되기 때문에 디버깅이 쉽지 않다. 그래서 Reactor는 디버깅의 어려움을 최소화하기 위해 몇 가지 방법을 제공한다.   Debug Mode를 사용한 디버깅 Reactor에서는 Hooks.onOperatorDebug() 메서드를 사용하여 디버그 모드를 활성화할 수 있다. 우선, 디버그 모드가 아닐 때 에러 메시지가 어떻게 출력되는지 확인해보자. @Slf4jpublic class Example12_1 { ..

Context란? Reactor에서 Context는 Reactor 구성요소(Operator 등) 간에 전파되는 key/value 형태의 저장소이다. ServletContext, SecurityContext 등과 유사한 개념이다. Downstream에서 Upstream으로 Context가 전파되어 Operator 체인상의 각 Operator가 해당 Context 정보를 동일하게 이용할 수 있음ThreadLocal과 유사하지만, Thread와 매핑되는 것이 아닌 Subscriber와 매핑된다. 즉, 구독이 발생할 때마다 구독과 연결된 하나의 Context가 생성된다. 사용 예시@Slf4jpublic class Example11_1 { public static void main(String[] args) th..

스레드(Thread)의 개념 이해 Reactor에서 사용되는 Scheduler는 Reactor Sequence에서 사용되는 스레드를 관리해 주는 관리자 역할을 한다. 이 Scherduler에 대한 설명에 앞서, 스레드에 대한 개념을 간단히 살펴보자면 다음과 같다. 코어(Core)실제 CPU의 코어를 지칭한다. 일반적으로 이 코어의 개수가 많으면 더 많은 수의 명령을 병렬로 빠르게 처리할 수 있다.  물리적 스레드(Physical Thread) / 논리적 코어(Logical Core) 과거에는 한 코어 당 하나의 물리적 스레드가 존재하여 한 코어가 한 번에 하나의 스레드를 처리할 수 있었다. 인텔에서는 코어 하나로 두 스레드를 처리할 수 있는 기술인 하이퍼스레딩 개념을 도입하여 하나의 코어로 두 가지 스레..

개요  [Reactive Programming] 리액티브 스트림즈(Reactive Streams)리액티브 스트림즈(Reactive Streams)란? 리액티브 스트림즈란 데이터 스트림을 Non-Blocking이면서 비동기적으로 처리하기 위한 리액티브 라이브러리의 표준 사양이다. 그 구현체로는 RxJava, Reactor, Akkmy-coding-notes.tistory.com 위 리액티브 스트림즈를 설명한 게시글에서 Processor에 대해 언급한 적이 있다. Processor는 Publisher와 Subscriber의 기능을 모두 지니는 클래스인데, Reactor에서도 Processor 인터페이스의 구현 클래스인 FluxProcessor, MonoProcessor, EmitterProcessor 등을 ..

개요 만약 Publisher가 많은 데이터를 Emit 하는데 Publisher의 처리 속도가 현저히 느려 데이터가 계속해서 쌓인다면 오버플로우가 발생할 수도 있을 것이다. Backpressure는 우리말로 배압, 역압이라고 한다. 이름과 같이, Backpressure는 리액티브 프로그래밍에서 Publisher가 수많은 데이터를 Emit하는 상황에서 과부하가 걸리지 않도록 하는 역할을 한다.  Reactor에서의 Backpressure 처리 방식 Reactor에서의 Backpressure 처리 방식은 크게 두 가지가 있다. 1. 데이터 개수 제어Subscriber가 적절히 처리할 수 있는 수준의 데이터 개수를 Publisher에게 요청하는 방식이다. Subscriber를 상속한 BaseSubscriber를..

개요 컴퓨터 시스템에서 사용되는 Cold와 Hot의 의미는 보통 Cold는 어떤 변경점 등을 적용할 때 시스템을 새로 시작(재기동)해야 하고, Hot은 새로 시작할 필요가 없는 것을 의미한다. Reactor에서의 Cold Sequence와 Hot Sequence의 Cold, Hot 역시 이와 비슷한 의미를 내포하고 있다. 설명에 앞서 Sequence의 의미를 되짚어보자면, 위 게시글에서 설명한 것과 같이  Publisher가 emit하는 데이터의 연속적인 흐름을 정의해 놓은 것을 의미하며, 코드로는 Operator 체인 형태로 정의된다.  Cold Sequence Cold Sequence는 Subscriber가 구독할 때마다 데이터 흐름이 처음부터 다시 시작되는 Sequence이다. 이를 마블 다이어그램..

마블 다이어그램(Marble Diagram)이란? 마블 다이어그램이란 여러 도형을 사용하여 비동기적인 데이터 흐름을 시간의 흐름에 따라 시각적으로 표시한 다이어그램이다. 이는 비동기적으로 작동하는 Operator를 직관적으로 이해하기 유용하여, Operator의 API 문서를 확인하려 할 때 마블 다이어그램부터  먼저 확인하는 것이 좋다.  위는 Reactor Documentation에 있는 fluxOperator의 마블 다이어그램이다. 타임라인마블 다이어그램에서의 타임라인은 왼쪽에서 오른쪽으로 흐른다. 따라서 왼쪽에 있는 데이터(구슬)가 더 먼저 emit(통지)된 데이터에 해당한다. Source Flux구슬이 줄줄이 있는 맨 윗줄 라인은 Publisher가 통지하는 데이터의 타임라인으로, 위 그림에선 ..