Conversation
Contributor
|
""" Walkthrough이 변경 사항은 이메일 전송 방식을 Spring Mail에서 AWS SES로 전환하고, 메일 로그에 실패 원인(caused) 정보를 추가하며, Redis 스트림의 recordId를 메일 처리 전반에 걸쳐 추적 및 삭제하도록 개선합니다. 또한, 메일 로그 상세 응답 DTO가 새로 도입되고, 스레드 풀 설정이 조정되었습니다. Changes
Sequence Diagram(s)sequenceDiagram
participant RedisStream as RedisStream
participant RedisReader as RedisStreamReader
participant Processor as MailMessageProcessor
participant Writer as MailWriter
participant SES as AWS SES
participant Redis as Redis
RedisStream->>RedisReader: 메시지 읽기
RedisReader->>Processor: subscriptionId, recordId 추출
Processor->>Writer: MailDto(subscription, quiz, recordId)
loop 각 MailDto
Writer->>SES: sendEmail(MailDto)
alt 성공/실패와 무관하게
Writer->>Redis: XDEL(quiz-email-stream, recordId)
end
end
Assessment against linked issues
Assessment against linked issues: Out-of-scope changes(없음) Possibly related PRs
Suggested reviewers
Poem
📜 Recent review detailsConfiguration used: CodeRabbit UI 📒 Files selected for processing (1)
🚧 Files skipped from review as they are similar to previous changes (1)
✨ Finishing Touches
Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out. 🪧 TipsChatThere are 3 ways to chat with CodeRabbit:
SupportNeed help? Create a ticket on our support page for assistance with any issues or questions. Note: Be mindful of the bot's finite context window. It's strongly recommended to break down tasks such as reading entire modules into smaller chunks. For a focused discussion, use review comments to chat about specific files and their changes, instead of using the PR comments. CodeRabbit Commands (Invoked using PR comments)
Other keywords and placeholders
CodeRabbit Configuration File (
|
crocusia
requested review from
HeeMang-Lee,
Kimyoonbeom,
Ksr-ccb,
jong-0126 and
wannabeing
and removed request for
Ksr-ccb and
wannabeing
HeeMang-Lee
approved these changes
Jun 23, 2025
![coderabbitai[bot]](https://avatars.githubusercontent.com/in/347564?s=60&v=4){kind=small}
Contributor
There was a problem hiding this comment.
Actionable comments posted: 6
🔭 Outside diff range comments (1)
cs25-batch/src/main/java/com/example/cs25batch/config/RedisConsumerGroupInitalizer.java (1)
23-25: 로거 사용으로 출력 개선
Spring Boot 환경에서는System.out.println대신 SLF4J 로거를 사용하여 로그 레벨과 포맷을 관리하는 것이 좋습니다.-import org.springframework.data.redis.RedisSystemException; +import org.springframework.data.redis.RedisSystemException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; @Component @RequiredArgsConstructor public class RedisConsumerGroupInitalizer implements InitializingBean { + private static final Logger log = LoggerFactory.getLogger(RedisConsumerGroupInitalizer.class); private final StringRedisTemplate redisTemplate; @@ -22,7 +24,7 @@ public class RedisConsumerGroupInitalizer implements InitializingBean { try { redisTemplate.opsForStream().createGroup(STREAM, ReadOffset.latest(), GROUP); } catch (RedisSystemException e) { - System.out.println("Redis Consumer Group 이미 존재: " + GROUP); + log.info("Redis Consumer Group 이미 존재: {}", GROUP); } } }
🧹 Nitpick comments (4)
cs25-batch/src/main/java/com/example/cs25batch/config/RedisConsumerGroupInitalizer.java (1)
12-12: 클래스명 오타 수정 제안
파일명과 일치하지 않는Initalizer는 올바른 철자인Initializer로 변경하는 것이 바람직합니다. IDE 및 Spring Component 스캔 시 혼동을 줄일 수 있습니다.cs25-batch/src/main/java/com/example/cs25batch/config/AwsSesConfig.java (1)
23-23: 하드코딩된 AWS 리전을 설정 가능하게 만드세요.현재 리전이 하드코딩되어 있어 다른 환경에서 유연성이 떨어집니다.
+@Value("${AWS_SES_REGION:ap-northeast-2}") +private String region; @Bean public SesV2Client amazonSesClient() { AwsBasicCredentials credentials = AwsBasicCredentials.create(accessKey, secretKey); return SesV2Client.builder() .credentialsProvider(StaticCredentialsProvider.create(credentials)) - .region(Region.AP_NORTHEAST_2) + .region(Region.of(region)) .build(); }cs25-batch/src/main/java/com/example/cs25batch/batch/component/processor/MailMessageProcessor.java (1)
25-25:recordId추출에 방어적 프로그래밍을 고려하세요.
RedisStreamReader의 변경사항과 일치하는 좋은 구현입니다. 하지만recordId에 대한 null 체크를 추가하는 것을 고려해보세요.-String recordId = message.get("recordId"); +String recordId = message.get("recordId"); +if (recordId == null) { + log.warn("RecordId is missing from message: {}", message); + // 또는 예외를 던지거나 기본값 설정 +}cs25-batch/src/main/java/com/example/cs25batch/batch/jobs/DailyMailSendJob.java (1)
128-131: 사용하지 않는 시간 측정 코드 제거로그가 주석 처리되었지만 시간 측정 변수는 여전히 할당되고 있습니다. 사용하지 않는 코드는 제거하는 것이 좋습니다.
-long searchStart = System.currentTimeMillis(); List<SubscriptionMailTargetDto> subscriptions = subscriptionService.getTodaySubscriptions(); -long searchEnd = System.currentTimeMillis(); //log.info("[1. 발송 리스트 조회] {}개, {}ms", subscriptions.size(), searchEnd - searchStart);
📜 Review details
Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro
📒 Files selected for processing (16)
cs25-batch/build.gradle(1 hunks)cs25-batch/src/main/java/com/example/cs25batch/Cs25BatchApplication.java(2 hunks)cs25-batch/src/main/java/com/example/cs25batch/aop/MailLogAspect.java(3 hunks)cs25-batch/src/main/java/com/example/cs25batch/batch/component/processor/MailMessageProcessor.java(2 hunks)cs25-batch/src/main/java/com/example/cs25batch/batch/component/reader/RedisStreamReader.java(1 hunks)cs25-batch/src/main/java/com/example/cs25batch/batch/component/writer/MailWriter.java(3 hunks)cs25-batch/src/main/java/com/example/cs25batch/batch/dto/MailDto.java(1 hunks)cs25-batch/src/main/java/com/example/cs25batch/batch/jobs/DailyMailSendJob.java(4 hunks)cs25-batch/src/main/java/com/example/cs25batch/batch/service/BatchMailService.java(2 hunks)cs25-batch/src/main/java/com/example/cs25batch/config/AwsSesConfig.java(1 hunks)cs25-batch/src/main/java/com/example/cs25batch/config/RedisConsumerGroupInitalizer.java(1 hunks)cs25-entity/src/main/java/com/example/cs25entity/domain/mail/entity/MailLog.java(2 hunks)cs25-service/src/main/java/com/example/cs25service/domain/mail/controller/MailLogController.java(2 hunks)cs25-service/src/main/java/com/example/cs25service/domain/mail/dto/MailLogDetailResponse.java(1 hunks)cs25-service/src/main/java/com/example/cs25service/domain/mail/dto/MailLogResponse.java(0 hunks)cs25-service/src/main/java/com/example/cs25service/domain/mail/service/MailLogService.java(2 hunks)
💤 Files with no reviewable changes (1)
- cs25-service/src/main/java/com/example/cs25service/domain/mail/dto/MailLogResponse.java
🧰 Additional context used
🧠 Learnings (1)
cs25-batch/src/main/java/com/example/cs25batch/batch/jobs/DailyMailSendJob.java (1)
Learnt from: crocusia
PR: NBC-finalProject/CS25-BE#141
File: cs25-batch/src/main/java/com/example/cs25batch/batch/jobs/DailyMailSendJob.java:187-195
Timestamp: 2025-06-23T01:34:30.721Z
Learning: DailyMailSendJob에서 taskExecutor bean은 mailConsumerWithAsyncStep에서만 사용되므로, ThreadShuttingJobListener로 해당 작업 완료 후 executor를 종료해도 다른 배치 작업들에 영향을 주지 않습니다.
🔇 Additional comments (11)
cs25-batch/build.gradle (1)
28-31: Maven Central에서 AWS SDK BOM의 실제 최신 버전을 다시 조회해보겠습니다.#!/bin/bash # 그룹 및 아티팩트 ID를 따옴표로 묶어서 AWS SDK BOM 최신 버전 조회 curl -s 'https://search.maven.org/solrsearch/select?q=g:%22software.amazon.awssdk%22%20AND%20a:%22bom%22&rows=1&wt=json' | jq '.response.docs[0]'cs25-batch/src/main/java/com/example/cs25batch/batch/component/reader/RedisStreamReader.java (1)
47-51: 필요한 데이터만 추출하는 개선된 접근 방식입니다.이전의 모든 키-값 쌍을 복사하는 방식에서 필요한 필드만 선별적으로 추출하는 방식으로 변경된 것이 좋습니다.
subscriptionId에 대한 null 체크와recordId추가가 적절하게 구현되었습니다.cs25-batch/src/main/java/com/example/cs25batch/batch/component/processor/MailMessageProcessor.java (1)
47-47:MailDto에recordId필드 추가가 적절히 구현되었습니다.
RedisStreamReader와 일관성 있게recordId를MailDto에 포함시키는 것이 올바르게 구현되었습니다.cs25-batch/src/main/java/com/example/cs25batch/Cs25BatchApplication.java (1)
17-19: 코드 포맷팅이 일관성 있게 개선되었습니다.들여쓰기와 정렬이 더 일관된 스타일로 개선되어 가독성이 향상되었습니다. 로직에는 변경사항이 없습니다.
Also applies to: 31-33, 38-38, 45-46
cs25-entity/src/main/java/com/example/cs25entity/domain/mail/entity/MailLog.java (1)
55-56: 생성자 업데이트가 올바르게 구현됨새로운
caused파라미터가 생성자와 필드 초기화에 올바르게 추가되었습니다.Also applies to: 62-62
cs25-service/src/main/java/com/example/cs25service/domain/mail/service/MailLogService.java (1)
6-6: 상세 응답 DTO로의 변경이 적절함
MailLogDetailResponse로의 변경이 새로운caused필드를 포함한 더 상세한 메일 로그 정보 제공이라는 PR 목표와 일치합니다.Also applies to: 38-40
cs25-batch/src/main/java/com/example/cs25batch/batch/component/writer/MailWriter.java (1)
19-19: Redis 의존성 추가가 적절함Redis 스트림 레코드 정리를 위한
StringRedisTemplate의존성 추가가 올바릅니다.cs25-batch/src/main/java/com/example/cs25batch/aop/MailLogAspect.java (1)
35-35: AWS 오류 세부사항 캡처 로직이 우수함
caused변수를 추가하여 AWS SES 오류 메시지를 캡처하고MailLog에 저장하는 로직이 잘 구현되었습니다.Also applies to: 42-42, 50-50
cs25-batch/src/main/java/com/example/cs25batch/batch/dto/MailDto.java (1)
12-14: 필드 캡슐화 및 recordId 추가가 적절함필드를
private으로 변경하여 캡슐화를 개선하고, Redis 스트림 레코드 추적을 위한recordId필드 추가가 올바르게 구현되었습니다.cs25-batch/src/main/java/com/example/cs25batch/batch/service/BatchMailService.java (1)
39-83: AWS SES 마이그레이션이 잘 구현되었습니다!Spring Mail에서 AWS SES v2로의 전환이 깔끔하게 처리되었고, 이메일 구성 요소들이 적절히 설정되었습니다.
cs25-batch/src/main/java/com/example/cs25batch/batch/jobs/DailyMailSendJob.java (1)
173-183: 스레드 풀 크기 감소에 대한 성능 영향 검토 필요스레드 풀 크기가 크게 감소했습니다 (코어: 5→2, 최대: 10→4). 이는 동시 처리 능력을 감소시킬 수 있습니다. 대신 큐 용량이 500으로 설정되어 대기열은 늘어났습니다.
이 변경이 메일 발송 성능에 미치는 영향을 테스트했는지 확인해 주세요.
cs25-entity/src/main/java/com/example/cs25entity/domain/mail/entity/MailLog.java
Show resolved
Hide resolved
cs25-batch/src/main/java/com/example/cs25batch/batch/component/writer/MailWriter.java
Show resolved
Hide resolved
cs25-service/src/main/java/com/example/cs25service/domain/mail/dto/MailLogDetailResponse.java
Show resolved
Hide resolved
...-service/src/main/java/com/example/cs25service/domain/mail/controller/MailLogController.java
Outdated
Show resolved
Hide resolved
Ksr-ccb
approved these changes
Jun 23, 2025
This was referenced Aug 25, 2025
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
3 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
🔎 작업 내용
(기존엔 Gmail-smtp 서버 사용)
AWS 사용 시, 왜 예외가 발생했는지 파악하기 편하도록
🧩 트러블 슈팅
RedisConsumerGroup을 사용할 필요가 없다고 생각했으나, 결국 비동기 Thread에서 어떤 메시지를 꺼낼지 식별하기 위해서는 해당 기능이 필요하였다.close #128
Summary by CodeRabbit
신규 기능
버그 수정
리팩터