[#249] 크루 랭킹의 캐시 저장소 변경, 캐싱 스케줄러의 중복 실행 방지

build.gradle

@@ -36,6 +36,7 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-cache'
     implementation "com.github.ben-manes.caffeine:caffeine:3.1.8"
     implementation 'org.hibernate:hibernate-spatial:6.3.1.Final'
+    implementation 'org.redisson:redisson-spring-boot-starter:3.23.4'
 
     implementation group: 'org.flywaydb', name: 'flyway-mysql', version: '9.10.2'
     implementation 'org.springframework.boot:spring-boot-starter-webflux'

src/main/java/kr/pickple/back/common/config/CacheConfig.java

@@ -4,17 +4,25 @@
 import java.util.List;
 import java.util.concurrent.TimeUnit;
 
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
 import org.springframework.cache.CacheManager;
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.cache.caffeine.CaffeineCache;
 import org.springframework.cache.support.SimpleCacheManager;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.data.redis.cache.RedisCacheConfiguration;
+import org.springframework.data.redis.cache.RedisCacheManager;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
 import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -34,6 +42,7 @@ public class CacheConfig {
     private final RedisProperties redisProperties;
 
     @Bean
+    @Primary
     public CacheManager caffeineCacheManager() {
         final List<CaffeineCache> caches = Arrays.stream(CacheType.values())
                 .map(cacheType ->
@@ -52,6 +61,32 @@ public CacheManager caffeineCacheManager() {
         return cacheManager;
     }
 
+    @Bean
+    public CacheManager redisCacheManager() {
+        RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
+                .serializeKeysWith(RedisSerializationContext.SerializationPair
+                        .fromSerializer(new StringRedisSerializer()))
+                .serializeValuesWith(RedisSerializationContext.SerializationPair
+                        .fromSerializer(new Jackson2JsonRedisSerializer(Object.class)));
+
+        return RedisCacheManager.RedisCacheManagerBuilder
+                .fromConnectionFactory(redisConnectionFactory())
+                .cacheDefaults(redisCacheConfiguration)
+                .build();
+    }
+
+    @Bean
+    public RedissonClient redissonClient() {
+        Config redisConfig = new Config();
+        redisConfig.useSingleServer()
+                .setAddress(String.format("redis://%s:%d", redisProperties.getHost(), redisProperties.getPort()))
+                .setPassword(redisProperties.getPassword())
+                .setConnectionMinimumIdleSize(2)
+                .setConnectionPoolSize(4);
+
+        return Redisson.create(redisConfig);
+    }
+
     @Bean
     public RedisConnectionFactory redisConnectionFactory() {
         final RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();

src/main/java/kr/pickple/back/ranking/service/RankingScheduler.java

@@ -1,5 +1,7 @@
 package kr.pickple.back.ranking.service;
 
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
@@ -10,9 +12,17 @@
 public class RankingScheduler {
 
     private final RankingService rankingService;
+    private final RedissonClient redissonClient;
 
     @Scheduled(cron = "0 0 */6 * * *")
     public void refreshRankingCache() {
-        rankingService.putCrewRankingCache();
+        RLock lock = redissonClient.getLock("refreshCrewRankingCacheLock");
+        if (lock.tryLock()) {
+            try {
+                rankingService.putCrewRankingCache();
+            } finally {
+                lock.unlock();
+            }
+        }
     }
 }

src/main/java/kr/pickple/back/ranking/service/RankingService.java

@@ -18,12 +18,12 @@ public class RankingService {
 
     private final RankingJdbcRepository rankingJdbcRepository;
 
-    @Cacheable(cacheManager = "caffeineCacheManager", cacheNames = "ranking", key = "'crew'")
+    @Cacheable(cacheManager = "redisCacheManager", cacheNames = "ranking", key = "'crew'")
     public List<CrewRankingResponse> findCrewRanking() {
         return putCrewRankingCache();
     }
 
-    @CachePut(cacheManager = "caffeineCacheManager", cacheNames = "ranking", key = "'crew'")
+    @CachePut(cacheManager = "redisCacheManager", cacheNames = "ranking", key = "'crew'")
     public List<CrewRankingResponse> putCrewRankingCache() {
         final List<CrewRankingResponse> crewRankings = rankingJdbcRepository.getCrewRankings();