spring cloud stream
1.RabbitMQ 설치하기
Windows에 rabbitmq를 설치한는 과정부터 시작하도록 하겠습니다.rabbitmq를 설치하기 위해서는 Erlang/OTP를 설치해야 합니다.rabbitmq 버전 별 요구되는 Erlang/OTP 버전을 선택하여 설치합니다.https://www.rabbit
2.Kafka 설치하기
Kafka는 고성능 분산 이벤트 스트리밍 플랫폼으로 데이터 파이프라인, 이벤트 pub-sub 등 다양한 목적으로 사용됩니다.spring cloud stream을 이용한 이벤트 처리를 위해서 다양한 메시지 브로커가 사용될 수 있는데, kafka도 그 중 하나입니다.이번
3.Spring cloud stream 적용해보기
spring cloud stream은 확장성있는 event driven 마이크로서비스를 스프링 애플리케이션에서 친숙하게 도입할 수 있게 하는 프레임워크입니다.https://spring.io/projects/spring-cloud-stream/크게 바인더와 바인
4.Annotation 방식으로 구현하기
앞서 구성도에서 확인하였던 Producer와 Receiver 서비스 간 메시지 전송 기능을 구현하도록 하겠습니다.spring initializer로 Producer와 Receiver 서비스를 생성합니다.https://start.spring.ioSpring Bo
5.Functional 방식으로 구현하기
Annotation 방식은 Spring에서 흔히 사용되는 방식이기 때문에 친숙한 편이지만, spring cloud stream 3버전부터 Annotation 방식의 구현은 deprecated 되었습니다.대신 StreamBridge와 Supplier, Consumer,
6.Test code 작성해보기
spring cloud stream으로 테스트 코드를 작성해 봅니다.spring cloud stream 3.2.x 버전대까지는 spring-cloud-stream-test-support를 사용하고 4.0 이상부터는 spring-cloud-stream-test-binde
7.Kafka로 전환해보기
spring cloud stream의 RabbitMQ 바인더를 이용해서 RabbitMQ를 통해 메시지를 주고 받았지만, 서비스가 많이 커져서 더 파워풀한 성능을 내는 Kafka 클러스터로 전환해야 할 때가 올 수도 있을 것입니다.지난 과정에 두 가지 경로로 메시지가 두
8.Message Payload Validator 구성과 DLQ 적용
메시지를 주고 받는 경우 데이터의 타입이 적절하지 않을 수도 있을 것입니다. Spring web을 이용했던 경험이 있다면 Jakarta나 Javax의 Annotation을 이용해서 데이터 클래스의 필드에 조건을 걸어 두고, REST API의 핸들러 메소드의 파라미터에