Merge pull request #86 from Block-Guard/refactor/add-redis

[Refactor] Redis 추가

Author: chaeyuuu

build.gradle

@@ -30,6 +30,10 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-actuator'
 	implementation 'org.springframework.boot:spring-boot-starter-mail'
 
+	implementation 'org.springframework.boot:spring-boot-starter'
+	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+	implementation 'com.fasterxml.jackson.core:jackson-databind'
+
 	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.7.0'
 	implementation 'org.springframework.boot:spring-boot-starter-validation'
 	compileOnly 'org.projectlombok:lombok'

src/main/java/com/blockguard/server/domain/admin/api/AdminApi.java

@@ -13,6 +13,7 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;

src/main/java/com/blockguard/server/domain/news/application/NewsService.java

@@ -10,6 +10,7 @@
 import com.blockguard.server.global.exception.BusinessExceptionHandler;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
@@ -24,6 +25,7 @@
 public class NewsService {
     private final NewsRepository newsRepository;
 
+    @Cacheable(value = "news:list:v2", key = "'list:' + #page + ':' + #size + ':' + #sort + ':' + #category")
     public NewsPageResponse getNewsList(int page, int size, String sort, String category) {
         Pageable pageable = PageRequest.of(page - 1, size, getSort(sort));
         Page<NewsArticle> newsPage;

src/main/java/com/blockguard/server/domain/news/dto/response/NewsArticleResponse.java

@@ -4,13 +4,15 @@
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 
 import java.time.Duration;
 import java.time.LocalDateTime;
 
 @Getter
 @Builder(toBuilder = true)
 @AllArgsConstructor
+@NoArgsConstructor
 public class NewsArticleResponse {
     private Long id;
     private String title;

src/main/java/com/blockguard/server/domain/news/dto/response/NewsPageResponse.java

@@ -3,12 +3,14 @@
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 
 import java.util.List;
 
 @Getter
 @Builder
 @AllArgsConstructor
+@NoArgsConstructor
 public class NewsPageResponse {
     private List<NewsArticleResponse> news;
     private PageableInfo pageableInfo;

src/main/java/com/blockguard/server/domain/news/dto/response/PageableInfo.java

@@ -3,9 +3,11 @@
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 
 @Getter
 @AllArgsConstructor
+@NoArgsConstructor
 @Builder
 public class PageableInfo {
     private int page;

src/main/java/com/blockguard/server/domain/news/scheduler/NewsSaveScheduler.java

@@ -4,6 +4,7 @@
 import com.blockguard.server.infra.crawler.DaumNewsCrawler;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -37,7 +38,7 @@ public class NewsSaveScheduler {
             Map.entry(Category.ETC, List.of("몸캠"))
     );
 
-    @Async
+    @CacheEvict(value = "news:list:v2", allEntries = true)
     public void crawlingForAdmin() {
         crawlByCategories(EnumSet.of(
                 Category.VOICE_PHISHING,
@@ -46,7 +47,7 @@ public void crawlingForAdmin() {
         ));
     }
 
-    @Async
+    @CacheEvict(value = "news:list:v2", allEntries = true)
     // @Scheduled(cron = "0 0 4 * * *")
     public void saveNewsArticles() {
         crawlAll();

src/main/java/com/blockguard/server/global/config/RedisConfig.java

@@ -0,0 +1,53 @@
+package com.blockguard.server.global.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+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.lettuce.LettuceConnectionFactory;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+import java.time.Duration;
+import java.util.HashMap;
+import java.util.Map;
+
+@EnableCaching
+@Configuration
+public class RedisConfig {
+    @Value("${spring.data.redis.host}")
+    private String host;
+
+    @Value("${spring.data.redis.port}")
+    private int port;
+
+    @Bean
+    public RedisConnectionFactory redisConnectionFactory() {
+        return new LettuceConnectionFactory(host, port);
+    }
+
+    @Bean
+    public CacheManager cacheManager(RedisConnectionFactory cf) {
+        RedisCacheConfiguration defaultConfig = RedisCacheConfiguration.defaultCacheConfig()
+                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
+                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()))
+                .entryTtl(Duration.ofMinutes(30));
+
+        Map<String, RedisCacheConfiguration> cacheConfigs = new HashMap<>();
+        cacheConfigs.put("news:list:v2", defaultConfig.entryTtl(Duration.ofHours(24))); // 뉴스는 하루 TTL
+
+
+        return RedisCacheManager.
+                RedisCacheManagerBuilder.
+                fromConnectionFactory(cf)
+                .cacheDefaults(defaultConfig)
+                .withInitialCacheConfigurations(cacheConfigs)
+                .build();
+
+    }
+}