이메일 timeout으로 인한 비동기처리 및 유효성검증

비동기처리로 빠른 timeout오률를 해결합니다.

Author: minwoo1999

src/main/java/com/example/userservice/domain/mail/service/impl/MailSenderServiceImpl.java

@@ -16,6 +16,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.thymeleaf.context.Context;
@@ -44,6 +45,7 @@ public class MailSenderServiceImpl implements MailSenderService {
 
 
     @Override
+    @Async
     public void sendMail(SendMailDto sendMailDto) throws MessagingException {
         String email=sendMailDto.getEmail();
         Integer randomNumber=getVerificationNumber();
@@ -104,6 +106,8 @@ public void sendVerificationMail(VerificationMailDto verificationMailDto) throws
             emailRedisUtil.setListData(email,0,"signupVerifySuccess",60*20L);
         }else if(Objects.equals(verifyPurpose, MailPurpose.SUBSCRIBE.toString()) && userInputCode.equals(verificationCode)){
             emailRedisUtil.setListData(email,0,"subscriberVerifySuccess",60*20L);
+        }else{
+            throw new EmailNotValidException("인증이 유효하지 않습니다");
         }
     }
 
@@ -122,7 +126,7 @@ private void emailValidationCheck(String email, String verifyPurpose) {
         if(verifyPurpose.equals("SUBSCRIBE")){
             Optional<Subscriber> subscriber = subscriberRepository.findByEmail(email);
             if(subscriber.isPresent()){
-                throw new IllegalArgumentException("중복된 구독자입니다.");
+                throw new DuplicateAccountException("중복된 구독자입니다.");
             }
 
         }

src/main/java/com/example/userservice/domain/subscriber/entity/Subscriber.java

@@ -30,6 +30,15 @@ public class Subscriber extends BaseTimeEntity {
     @OneToMany(mappedBy = "subscriber", cascade = CascadeType.ALL, orphanRemoval = true)
     private List<Interest> interests = new ArrayList<>();
 
+    @Column(nullable = false, columnDefinition = "BOOLEAN DEFAULT FALSE")
+    private boolean sent; // 이메일 발송 여부 (true: 발송 완료, false: 미발송)
+
+
+    @PrePersist
+    public void prePersist() {
+        this.sent = false;
+    }
+
     public Subscriber(String email) {
         this.email = email;
     }

src/main/java/com/example/userservice/global/config/AsyncConfig.java

@@ -0,0 +1,9 @@
+package com.example.userservice.global.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig {
+}

src/main/java/com/example/userservice/global/exception/GlobalExceptionHandler.java

@@ -24,6 +24,27 @@
 @Slf4j
 public class GlobalExceptionHandler {
 
+
+    @ExceptionHandler(IllegalArgumentException.class)
+    protected ResponseEntity<?> illegalArgumentException(IllegalArgumentException ex) {
+        log.error("handleDuplicateAccountException :: ");
+
+        ErrorCode errorCode = ErrorCode.UnAuthorizedException;
+
+        ErrorResponse error = ErrorResponse.builder()
+                .status(errorCode.getStatus().value())
+                .message(ex.getMessage())
+                .code(errorCode.getCode())
+                .build();
+
+        CommonResponse response = CommonResponse.builder()
+                .success(false)
+                .error(error)
+                .build();
+
+        return new ResponseEntity<>(response, errorCode.getStatus());
+    }
+
     /**
      * 회원가입 시, 회원 계정 정보가 중복 되었을때
      */