컨슈머 서버 질문드립니다

안녕하세요. 수강자님 서비스가 복잡해질수록 발행하는 이벤트도 다양해지고 받는 쪽, 컨슈머도 이에 비례해서 증가하기 마련입니다. 싱글 도메인에 단순 비동기라면 적은 수의 메시지로도 문제가 없겠지만 복잡한 메시징 전송이나 상태 전송, 메시지의 컨펌 등 여러 레이어에 걸쳐 처리해야 할 경우 엠큐의 효과가 극대화 됩니다.브로드캐스팅 뿐 아니라 pub sub도 여러 도메인에서 활용 가능하므로 사용하기 나름입니다감사합니다

소스코드를 찾아가며 공부하는 시간이 더 많아야한다고하셨는데

안녕하세요. 수강자님 소스는 보통 사용하는 라이브러리를 뜯어보거나 Git에서 학습하고자 하는 소스들의 예제들을 찾아서 실행하며 로컬에서 분석해보시는걸 추천드립니다. 스프링의 경우 굉장히 다양한 유형별 소스가 Git에 많이 나와있고, 예제 단위로 정리한 repository도 많으므로 본인의 학습 목표에 따라 공식문서 뿐만 아니라 다른 라이브러리, 소스들을 찾아서 분석해보는걸 추전 드려요

DLQ 관련 질문

안녕하세요. 수강자님 auto 모드일때 미처리 (에러든 예외든) 된 상태는 unacked 가 맞습니다. DLQ도 어쨋든 큐이기 때문에 단순히 DLQ로 이동한 것만으로는 처리가 됐다고 보기 어렵고 컨슈머가 재 처리 해주어야 합니다. 다시 정상 처리 되었다면 ack 가 되어야 합니다.ack가 되지 않았다면 정상적으로 처리가 안됐다는 뜻이므로 consumer를 다시 점검해야 합니다.실제 처리 한건지 안한건지 코드에서 로그 등으로 확인해보고 MANUAL 모드에서 직접 채널에 basicAck, basicNack 으로 확인해시면 좀 더 이해가 빨리 되실겁니다. 감사합니다.

알림은 왜 pub sub 구조로 설계하나요?

안녕하세요. 수강자님 알림의 경우 단순 큐로도 구성이 가능한데, 굳이 pub/sub으로 하는 이유는 느슨한 연결을 통한 확장성 때문에 보통 pub/sub의 형태로 구현합니다.단순 알림 기능 이후에 여러가지 채널로 알림을 확장하기 용이합니다. 단일 컨슈머 호출일 경우 기능이 제한적이기 때문에 추가적인 확장시 로직 변화가 pub/sub에 비해서 큽니다.큐가 하나만 생성되고, 리스너도 하나만 붙어서 한 번에 하나의 컨슈머만 메시지를 처리하는 경우보다 여러 subscriber를 두고 각각의 독립된 sub가 각자의 부여된 역할을 처리하는 것이 확장성 확보가 되고 기능추가, 상호 영향도에서 장점이 있습니다. 답변이 되었길 바랍니다. 감사합니다.

Receiver를 여러개 하려면 어떻게하나요?

안녕하세요. 수강자님 컨슈머를 여러개 등록하는 방식은 여러가지 방식으로 접근할 수 있지만, 대표적으로는 크게 두가지 방식으로 나눌수 있습니다.일단 제일 편한건 워커노드를 여러대 설치하는 것이고, 두번째는 컨슈머를 통일한 애플리케이션에서 기동할 때 여러개 생성하는 방식이 있는데 이 방식에는 SimpleRabbitListenerContainerFactory 를 활용하거나 @RabbitListener를 활용하는 방식으로 처리할 수 있습니다. (사진)보시는 바와같이 SimpleRabbitListenerContainerFactory의 setConcurrentConsumers(동시 처리 수); 와 같이 지정해서 애플리케이션 기동시 동시처리 컨슈머를 생성할 수 있고, setMaxConcurrentConsumers로 최대치의 스케일을 설정할 수 있습니다.이렇게 하면 동일 큐에 여러 스레드가 붙어서 병렬로 소비할 수 있습니다. 두번째는 @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME, containerFactory = "rabbitListenerContainerFactory")여기에 queues 에 원하는 큐 이름들을 설정하는 방법입니다.여러개의 큐 를 하나의 리스너에 바인딩 해서 queues = {"queue1", "queue2"}이런 형태로 설정해주실 수 있습니다.리스너를 여러개 두고 여러 큐, 여러 리스너를 등록해서 사용하시면 됩니다. 답변이 되었길 바랍니다. 감사합니다.

깃허브 step11 브랜치

안녕하세요. 수강자님 slack에 메시지 보내는 예제는 인터넷에 많이 있습니다. 해당 코드는 깃이나 인터넷 자료를 보시고, application.yml에 api-token과 channel-id 만 넣으시면 알림은 보내는데 문제 없을거에요.강의를 안만든 이유는 인터넷에 이미 관련 코드들이 많아서 강의로 설명할만한 주제는 아니라서 그렇습니다.지피티나 다른 llm 도구를 사용하셔도 금방 테스트 하실 수 있을거에요.감사합니다.

DLQ 재시도 로직 처리후 DLQ에 unacked 1건이 남는거에 대해서

안녕하세요. 수강자님 Spring에서 @RabbitListener는 기본적으로 AcknowledgeMode가 AUTO라서 정상적으로 종료된 경우에는 Spring 내부에서 ack가 처리 됩니다. 다만 여기서 Exception이 있고 내부적으로 커넥션이 잠시 잃어버렸다거나 리스너가 비정상이어서 여기에 진입한 경우 정상적으로 처리 하지 못하고 unacked 로 남기는 것으로 보입니다. 이 부분을 정밀하게 처리하려면 catch 구문에서 세부적인 exception 을 잡아 throw 하거나 ack mode를 MANUAL로 바꿔서 호출해주는 형태로 변경해주면 unacked 로 남는 경우는 없을것으로 보입니다. exception throw 관련 예외 클래스는 AmqpRejectAndDontRequeueException 를 살펴보시고 관련 예제를 한번 보시면 도움이 될것 같습니다. 도움이 되었기를 바랍니다. 감사합니다.

NotificationMessage가 필요한 이유 질문

안녕하세요. 수강자님 일반적으로 실무에서 다른 레이어(혹은 다른 서비스)에 전송할 때 자료형의 나열식의 구조 보다는 좀 더 구조화된 DTO 형태의 객체(MQ에서는 Payload 라고 하거나 xxxMessage 라고 칭합니다) 를 전송하는게 일반적인 케이스입니다. 단순히 문자열 "ABCD" 보다는 JSON 형태의 { title : "ABCD"} 와 같이 명시적으로 의미가 있는 형태로 필드를 정의해서 보내는것이 개발 스펙상 명확하고, MQ 뒷단에서 받는 이(개발자)가 다른이가 될 가능성이 있기 때문에 스키마 형태(필드:값) 의 데이터 값을 보내는 것이 테스트, 디버깅에도 유용하다고 할 수 있습니다.그래서 MQ나 다른 미들웨어들도 내부적으로는 JSON을 파싱하는 컨버터 등을 기본적으로 내재하거나, Spring에서 제공하는 Converter (Jackson2Json) 를 써서 변환하는 형태로 개발을 하게 됩니다. 즉, 타입 안정성, 변수의 의미나 구조의 명확성 때문에 가급적 객체(DTO, Message, Payload) 형태로 보내는 것을 추천합니다. 이런 구조에서는 직렬화/역직렬화 (다음 강좌에 설명을 하고 있습니다) 의 개념도 같이 공부해두면 도움이 되겠습니다. 감사합니다.

스탭4 질문드립니다

안녕하세요. 수강자님 step 4번 브랜치의 news.html 부분을 확인하면 아래와 같이 되어있습니다. // 서버에 선택한 뉴스 타입 전송 function sendNewsType(newsType) { // Send the selected news type to the server stompClient.send("/app/subscribe", {newsType: newsType}, ""); console.log(`Sent newsType to server: ${newsType}`); } // 이전 토픽에서 구독 취소, 새 토픽 구독 function subscribeToNews(newsType) { // 이전 구독된 내용이 존재하면 unsubscribe if (subscription) { subscription.unsubscribe(); console.log("Previous subscription cancelled."); } subscription = stompClient.subscribe(`/topic/${newsType}`, function (message) { addMessageToDiv(message.body); }); console.log(`Subscribed to /topic/${newsType}`); } 54라인과 65라인에 ${newsType} 변수를 통해 선택한 뉴스를 전송하고, 전송 받도록 할당했기 때문에 해당 변수를 통해 적합한 뉴스 카테고리를 송/수신 하게 됩니다. 참고 바랍니다.감사합니다.

생성자 질문드립니다

안녕하세요. 수강자님, 다음 강좌에서 부연설명이 나오는데, 클래스의 필드를 final 로 선언 하는 경우 (immutable object 유지) 기본 생성자가 없으면 역직렬화가 안된다고 이해하시면 될거 같습니다. final 뿐 아니라 특히 DTO 등으로 변환해야 할 경우 객체의 기본 생성자를 두는 것이 안전한 방법입니다. 따라서 final 로 클래스 필드를 선언하고 기본 생성자에서 초기화 한 뒤 인스턴스를 생성하는 것이 불변성을 유지하는데 더 좋은 코드라고 할 수 있습니다. 예제를 쉽게 만들어서 보여드릴려다 보니 초기에 소스에 setter를 추가해서 설명한게 오히려 혼동을 드렸네요. 해당 부분 수정해서 소스 업데이트 하도록 하겠습니다. 대체적으로 객체 일관성이나 스레드 안정성을 위해 객체의 필드는 setter로 접근해서 수정하는것 보다는 생성자나 특정 메서드를 통해서 (비즈니스 로직에 맞게) 설정할 수 있게 하는것을 추천드립니다. 좋은 질문 주셔서 감사드립니다.