feat: 이메일/카카오 알림 발송 재시도 로직 추가

Author: Woomin-Wang

build.gradle

@@ -43,8 +43,13 @@ dependencies {
 	implementation 'software.amazon.awssdk:s3:2.26.12'
 	runtimeOnly 'org.postgresql:postgresql'
 
+	// 헬스 체크
 	implementation 'org.springframework.boot:spring-boot-starter-actuator'
 
+	// 재시도
+	implementation 'org.springframework.retry:spring-retry:2.0.10'
+
+	// 롬복
 	compileOnly 'org.projectlombok:lombok'
 	annotationProcessor 'org.projectlombok:lombok'
 

src/main/java/io/wisoft/prepair/prepair_api/PrepairApiApplication.java

@@ -3,8 +3,10 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.retry.annotation.EnableRetry;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
+@EnableRetry
 @EnableJpaAuditing
 @EnableScheduling
 @SpringBootApplication

src/main/java/io/wisoft/prepair/prepair_api/external/notification/email/EmailService.java

@@ -1,41 +1,40 @@
 package io.wisoft.prepair.prepair_api.external.notification.email;
 
-import io.wisoft.prepair.prepair_api.common.exception.BusinessException;
-import io.wisoft.prepair.prepair_api.common.exception.ErrorCode;
 import jakarta.mail.MessagingException;
 import jakarta.mail.internet.MimeMessage;
 import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
 import org.springframework.mail.MailException;
 import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.retry.annotation.Backoff;
+import org.springframework.retry.annotation.Retryable;
 import org.springframework.stereotype.Service;
 
-@Slf4j
 @Service
 @RequiredArgsConstructor
 public class EmailService {
 
     private final EmailTemplateBuilder emailTemplateBuilder;
     private final JavaMailSender mailSender;
 
-    public void sendInterviewQuestion(String email, String nickname, String questionTag, String question) {
+    @Retryable(
+            value = {MessagingException.class, MailException.class},
+            maxAttempts = 3,
+            backoff = @Backoff(delay = 1000, multiplier = 2)
+    )
+    public void send(String email, String nickname, String questionTag, String question) throws MessagingException {
         String html = emailTemplateBuilder.buildInterviewQuestionHtml(nickname, questionTag, question);
-        send(email, "[PrePair] 오늘의 면접 질문이 도착했어요!", html);
+        sendMail(email, "[PrePair] 오늘의 면접 질문이 도착했어요!", html);
     }
 
-    private void send(String to, String subject, String html) {
-        try {
-            MimeMessage message = mailSender.createMimeMessage();
-            MimeMessageHelper helper = new MimeMessageHelper(message, false, "UTF-8");
+    private void sendMail(String to, String subject, String html) throws MessagingException {
+        MimeMessage message = mailSender.createMimeMessage();
+        MimeMessageHelper helper = new MimeMessageHelper(message, false, "UTF-8");
 
-            helper.setTo(to);
-            helper.setSubject(subject);
-            helper.setText(html, true);
+        helper.setTo(to);
+        helper.setSubject(subject);
+        helper.setText(html, true);
 
-            mailSender.send(message);
-        } catch (MessagingException | MailException e) {
-            throw new BusinessException(ErrorCode.EMAIL_SEND_FAILED);
-        }
+        mailSender.send(message);
     }
-}
+}

src/main/java/io/wisoft/prepair/prepair_api/external/notification/kakao/KakaoService.java

@@ -1,23 +1,29 @@
 package io.wisoft.prepair.prepair_api.external.notification.kakao;
 
 import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.MediaType;
+import org.springframework.retry.annotation.Backoff;
+import org.springframework.retry.annotation.Retryable;
 import org.springframework.stereotype.Service;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
-import org.springframework.web.client.HttpClientErrorException;
+import org.springframework.web.client.HttpServerErrorException;
+import org.springframework.web.client.ResourceAccessException;
 import org.springframework.web.client.RestClient;
 
-@Slf4j
 @Service
 @RequiredArgsConstructor
 public class KakaoService {
 
     private final RestClient restClient;
     private static final String URL = "https://kapi.kakao.com/v2/api/talk/memo/default/send";
 
-    public void sendInterviewQuestion(String kakaoAccessToken, String question, String questionTag) {
+    @Retryable(
+            value = {HttpServerErrorException.class, ResourceAccessException.class},
+            maxAttempts = 3,
+            backoff = @Backoff(delay = 1000, multiplier = 2)
+    )
+    public void send(String kakaoAccessToken, String question, String questionTag) {
         String templateJson = """
                 {
                   "object_type": "text",

src/main/java/io/wisoft/prepair/prepair_api/interview/question/service/QuestionNotificationService.java

@@ -32,7 +32,7 @@ public void notifyMember(MemberSchedulerInfo member, InterviewQuestion question)
 
     private void sendEmail(MemberSchedulerInfo member, InterviewQuestion question) {
         try {
-            emailService.sendInterviewQuestion(
+            emailService.send(
                     member.email(),
                     member.nickname(),
                     question.getQuestionTag(),
@@ -45,9 +45,13 @@ private void sendEmail(MemberSchedulerInfo member, InterviewQuestion question) {
     }
 
     private void sendKakao(MemberSchedulerInfo member, InterviewQuestion question) {
-        if (!isValidKakaoToken(member)) return;
+        if (member.kakaoAccessToken() == null || member.kakaoAccessToken().isBlank()) {
+            log.warn("멤버 스킵 | memberId={} | reason=no_kakao_token", member.id());
+            return;
+        }
+
         try {
-            kakaoService.sendInterviewQuestion(
+            kakaoService.send(
                     member.kakaoAccessToken(),
                     question.getQuestion(),
                     question.getQuestionTag()
@@ -59,13 +63,4 @@ private void sendKakao(MemberSchedulerInfo member, InterviewQuestion question) {
             log.error("카카오 발송 실패 | memberId={}", member.id(), e);
         }
     }
-
-    private boolean isValidKakaoToken(MemberSchedulerInfo member) {
-        if (member.kakaoAccessToken() == null || member.kakaoAccessToken().isBlank()) {
-            log.warn("멤버 스킵 | memberId={} | reason=no_kakao_token", member.id());
-            return false;
-        }
-        return true;
-    }
-
 }