Chapter 07 리액티브 마이크로서비스 개발

MinJunKweon commented 2 years ago

느낀점

LOG-INFO commented 2 years ago

이벤트 드리븐 개념도 알겠고 추구하는 이유도 알겠는데, 트래킹이 너무 어려울 수 있을 것 같음
- 장점
- 긴 IO작업 시간동안 기다리지 않고 다른 작업을 할 수 있음
- 유연성, 확장성, 탄력성
- 그런데 C언어의 go to문 같다는 생각이 계속 듦
- 실제로 어제 겪은 일 중에 이상한 곳에서 메시지 오는데 찾기 어려웠던 경험이 있음
- 그냥 비동기 API 쓰는게 낫지 않을까 싶었음
Spring Cloud Stream 사용방식이 3.1에서 많이 바뀜
- EnableBinding, Input, StreamListener deprecated 됨
- Functional 방식으로 바뀌었는데 그럼 Source를 어케 해야할 지 모르겠음. 일단 그냥 KafkaTemplate, @EventListener 사용
여기서 나온 Consumer Group, Retry&DLQ, 순서보장&파티션 문제는 최근 프로젝트 진행하면서 매우 중요하게 다루고 있음
시간이 없어서 테스트코드쪽은 보지 못했다... 주말에 봐야지...

2rohyun commented 2 years ago

매우 유익하고 알찬 챕터였다...! 시간이 많이 없어 깊게 읽지 못했는데, 주말에라도 하나 하나 코드 살펴가며 따라치면서 습득해보아야겠다.
비동기, 동기, 논블로킹, 스트림, 메시징, 이벤트 기반 등등.. 뒤죽박죽 얽혀있는 개념이 그래도 50%는 이해된 느낌? (아직도 잘 모르겠음..) 그래도 논블로킹 동기 API, 이벤트 기반 비동기에 대한 차이는 와닿게 알 수 있었다.
생소한 개념에 대해 프로덕션 코드 뿐아니라 테스트 코드는 어떻게 짜는지 잘 설명해놔서 너무 좋았다. 꼭 다시 복습하면서 따라 쳐봐야지..

이번에 회사에서도 Aggregate 및 Reformatting 을 하는 프로젝트를 하나 땄는데, 거기서는 각기 다른 서버에서 요청할 때 CompletableFuture를 사용했음. CompletableFuture와 Mono, Flux를 사용하는 논블로킹 동기 방식이 어떤 차이가 있을까?
https://brunch.co.kr/@springboot/267 여기에 Sync, Async, Blocking, Non-Blocking 에 대해 설명 잘되어있는 듯.

minkukjo commented 2 years ago

지각해서 죄송합니다.
Webflux의 Asynchronous + Non Blocking 모델을 가히 훌륭하다고 생각함. 그러나 여전히 어렵고 동작을 이해하기 쉽지 않음. ( 차라리 WebClient + 코루틴 기반 I/O가 제공된다면 덜 복잡할지도..? )
기존의 JPA는 Webflux와 그다지 궁합이 좋지 않았지만, 하이버네이트가 이런걸 만들고 있음.
조만간 대용량 트래픽을 처리하는 JVM + 스프링 기반의 회사에서 웹플럭스의 시대가 올지도 모르겠다고 생각하고는 있음. 그러나 아직은 잘 모르겠다?
이벤트 기반의 비동기 서비스가 핵심인 것 같다. 현재 아키텍처 국룰은 EDD가 메타인 듯.

스터디 시간에 @2rohyun 님의 안건에 대해서 의견을 냈는데 지금 생각해보니 조금 더 자세히 말씀드렸으면 좋았겠다고 생각해서 끄적여봄. (좋은 안건 감사합니다 도현님)
CompletableFuture는 자바에서 비동기를 구현하기 위한 클래스임.
내부적으로 자바 7에서 처음 등장한 ForJoinPool을 사용하며 각 요청에 대한 개별 스레드가 만들어지게 되고 각 스레드는 응답이 올 때 까지 블락킹되어있음.
Mono/Flux의 경우 백프레셔를 사용해서 데이터가 존재할 때만 스레드가 동작하게 만듦으로써 비동기/논블라킹으로 동작하게 함. ( 더 적은 스레드로 더 효율적으로 일할 수 있음 )