refactor: 중복알림 캐싱 추가

Author: jinwon1234

build.gradle

@@ -75,6 +75,10 @@ dependencies {
 
 	// firebase
 	implementation 'com.google.firebase:firebase-admin:9.2.0'
+
+	// cache
+	implementation 'org.springframework.boot:spring-boot-starter-cache'
+	implementation 'com.github.ben-manes.caffeine:caffeine'
 }
 
 

src/main/java/apptive/team5/alarm/service/AlarmDispatchService.java

@@ -6,20 +6,24 @@
 import apptive.team5.alarm.entity.Alarm;
 import apptive.team5.alarm.entity.AlarmMessage;
 import apptive.team5.alarm.event.AlarmCreatedEvent;
+import apptive.team5.config.CacheConfig;
 import apptive.team5.diary.domain.DiaryEntity;
 import apptive.team5.diary.service.DiaryLowService;
 import apptive.team5.subscribe.domain.Subscribe;
 import apptive.team5.subscribe.service.SubscribeLowService;
 import apptive.team5.user.domain.UserEntity;
 import apptive.team5.user.service.UserLowService;
 import lombok.RequiredArgsConstructor;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 
+import static apptive.team5.config.CacheConfig.*;
+
 @Service
 @Transactional
 @RequiredArgsConstructor
@@ -35,26 +39,26 @@ public class AlarmDispatchService {
     private final SubscribeLowService subscribeLowService;
 
     @Async("sendAlarm")
+    @Cacheable(value = LIKE_ALARM_CACHE, key = "'actor:' + #request.actorId() + ':' + 'diary:' + #request.diaryId()")
     public void saveAndDispatchForLike(DiaryLikeAlarmSendRequest request) {
 
         Long actorId = request.actorId();
         UserEntity actor = userLowService.findById(actorId);
         DiaryEntity diary = diaryLowService.findByIdWithUser(request.diaryId());
         UserEntity receiver = diary.getUser();
 
-        String title = AlarmMessage.LIKE_ALARM.getMessage();
         String content = actor.getUsername() + "님이 회원님의 킬링파트를 좋아합니다.";
         String deepLink = DIARY_DEEP_LINK_FORMAT.formatted(diary.getId());
 
         saveAndPublish(receiver, AlarmMessage.LIKE_ALARM, content, deepLink);
     }
 
     @Async("sendAlarm")
+    @Cacheable(value = SUBSCRIBE_ALARM_CACHE, key = "'subscriber:' + #request.subscriberId() + ':' + 'subscribedToUser:' + #request.subscribedToUserId()")
     public void saveAndDispatchForSubscribe(SubscribeAlarmSendRequest request) {
         UserEntity subscriber = userLowService.findById(request.subscriberId());
         UserEntity receiver = userLowService.findById(request.subscribedToUserId());
 
-        String title = AlarmMessage.SUBSCRIBE_ALARM.getMessage();
         String content = subscriber.getUsername() + "님이 회원님을 픽했어요.";
         String deepLink = SUBSCRIBE_DEEP_LINK_FORMAT.formatted(receiver.getId());
 

src/main/java/apptive/team5/config/CacheConfig.java

@@ -0,0 +1,42 @@
+package apptive.team5.config;
+
+import apptive.team5.alarm.entity.AlarmMessage;
+import com.github.benmanes.caffeine.cache.Caffeine;
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.cache.caffeine.CaffeineCacheManager;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.time.Duration;
+
+@Configuration
+@EnableCaching
+public class CacheConfig {
+
+    public static final String LIKE_ALARM_CACHE = "likeAlarm";
+    public static final String SUBSCRIBE_ALARM_CACHE = "subscribeAlarm";
+
+    @Bean
+    public CacheManager cacheManager() {
+        CaffeineCacheManager cacheManager = new CaffeineCacheManager();
+
+
+        cacheManager.registerCustomCache(
+                LIKE_ALARM_CACHE,
+                Caffeine.newBuilder()
+                        .expireAfterWrite(Duration.ofMinutes(5))
+                        .build()
+        );
+
+        cacheManager.registerCustomCache(
+                SUBSCRIBE_ALARM_CACHE,
+                Caffeine.newBuilder()
+                        .expireAfterWrite(Duration.ofMinutes(5))
+                        .build()
+        );
+
+        return cacheManager;
+
+    }
+}