refactor: 많이 조회한 게시글 키워드 구조 변경

src/main/java/in/koreatech/koin/domain/community/article/model/ArticleSearchKeyword.java

@@ -59,7 +59,11 @@ public void resetWeight() {
         this.weight = 1.0;
     }
 
-    public void incrementTotalSearch() {
-        this.totalSearch++;
+    public void updateLastSearchedAt(LocalDateTime now) {
+        this.lastSearchedAt = now;
+    }
+
+    public void increaseTotalSearchBy(int count) {
+        this.totalSearch += count;
     }
 }

src/main/java/in/koreatech/koin/domain/community/article/model/ArticleSearchKeywordIpMap.java

@@ -51,6 +51,13 @@ public void incrementSearchCount() {
         this.searchCount++;
     }
 
+    public void incrementSearchCountBy(Integer additionalCount) {
+        if (additionalCount == null || additionalCount <= 0) {
+            return;
+        }
+        this.searchCount += additionalCount;
+    }
+
     public void resetSearchCount() {
         this.searchCount = 0;
     }

src/main/java/in/koreatech/koin/domain/community/article/model/KeywordRankingManager.java

@@ -0,0 +1,46 @@
+package in.koreatech.koin.domain.community.article.model;
+
+import in.koreatech.koin.domain.community.article.model.redis.PopularKeywordTracker;
+import in.koreatech.koin.domain.community.article.repository.ArticleSearchKeywordRepository;
+import lombok.RequiredArgsConstructor;
+
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class KeywordRankingManager {
+
+    private final PopularKeywordTracker popularKeywordTracker;
+    private final ArticleSearchKeywordRepository keywordRepository;
+
+    public List<String> getTopKeywords(int count) {
+        List<String> primaryKeywords = new ArrayList<>(popularKeywordTracker.getTopKeywords(count));
+
+        if (primaryKeywords.size() < count) {
+            int remainingCount = count - primaryKeywords.size();
+            List<String> secondaryKeywords = getBackupKeywords(remainingCount);
+            secondaryKeywords.stream()
+                .filter(keyword -> !primaryKeywords.contains(keyword))
+                .forEach(primaryKeywords::add);
+        }
+
+        return primaryKeywords;
+    }
+
+    private List<String> getBackupKeywords(int count) {
+        LocalDateTime fromDate = LocalDateTime.now().minusWeeks(1);
+        Pageable pageable = PageRequest.of(0, count);
+
+        List<String> topKeywords = keywordRepository.findTopKeywords(fromDate, pageable);
+        if (topKeywords.isEmpty()) {
+            topKeywords = keywordRepository.findTopKeywordsByLatest(pageable);
+        }
+        return topKeywords;
+    }
+}

src/main/java/in/koreatech/koin/domain/community/article/model/redis/PopularKeywordTracker.java

@@ -0,0 +1,62 @@
+package in.koreatech.koin.domain.community.article.model.redis;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+import org.springframework.data.redis.core.ZSetOperations.TypedTuple;
+
+import java.util.Set;
+import java.util.stream.Collectors;
+
+@Component
+@RequiredArgsConstructor
+public class PopularKeywordTracker {
+
+    private static final double FIXED_WEIGHT_AFTER_FIVE_SEARCHES = 0.0625;
+    private static final int MAX_SEARCH_COUNT_FOR_WEIGHT = 10;
+
+    private static final String KEYWORD_SET = "popular_keywords";
+    private static final String IP_SEARCH_COUNT_PREFIX = "search:count:ip:";
+
+    private final RedisTemplate<String, Object> redisTemplate;
+
+    public void updateKeywordWeight(String ipAddress, String keyword) {
+        if (keyword == null || keyword.isBlank() || ipAddress == null || ipAddress.isBlank()) {
+            return;
+        }
+
+        String ipSearchCountKey = IP_SEARCH_COUNT_PREFIX + ipAddress;
+
+        Long currentIpCount = redisTemplate.opsForHash().increment(ipSearchCountKey, keyword, 1);
+
+        double additionalWeight = calculateWeight(currentIpCount);
+
+        if (additionalWeight > 0) {
+            redisTemplate.opsForZSet().incrementScore(KEYWORD_SET, keyword, additionalWeight);
+        }
+    }
+
+    private double calculateWeight(Long currentCount) {
+        if (currentCount <= 5) {
+            return 1.0 / Math.pow(2, currentCount - 1);
+        } else if (currentCount <= MAX_SEARCH_COUNT_FOR_WEIGHT) {
+            return FIXED_WEIGHT_AFTER_FIVE_SEARCHES;
+        }
+        return 0.0;
+    }
+
+    public Set<String> getTopKeywords(int limit) {
+        Set<TypedTuple<Object>> keywordTuples = redisTemplate.opsForZSet()
+            .reverseRangeWithScores(KEYWORD_SET, 0, limit - 1);
+
+        if (keywordTuples == null || keywordTuples.isEmpty()) {
+            return Set.of();
+        }
+
+        return keywordTuples.stream()
+            .map(TypedTuple::getValue)
+            .map(String::valueOf)
+            .collect(Collectors.toSet());
+    }
+}

src/main/java/in/koreatech/koin/domain/community/article/repository/ArticleSearchKeywordRepository.java

@@ -5,29 +5,32 @@
 import java.util.Optional;
 
 import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.Lock;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.Repository;
 
 import in.koreatech.koin.domain.community.article.model.ArticleSearchKeyword;
+import jakarta.persistence.LockModeType;
 
 public interface ArticleSearchKeywordRepository extends Repository<ArticleSearchKeyword, Integer> {
 
-    void save(ArticleSearchKeyword keyword);
+    ArticleSearchKeyword save(ArticleSearchKeyword keyword);
 
+    @Lock(LockModeType.PESSIMISTIC_WRITE)
     Optional<ArticleSearchKeyword> findByKeyword(String keywordStr);
 
     @Query("""
         SELECT k.keyword
         FROM ArticleSearchKeyword k
-        WHERE k.lastSearchedAt >= :oneWeekAgo
+        WHERE k.lastSearchedAt >= :fromDate
         ORDER BY k.weight DESC, k.lastSearchedAt DESC
         """)
-    List<String> findTopKeywords(LocalDateTime oneWeekAgo, Pageable pageable);
+    List<String> findTopKeywords(LocalDateTime fromDate, Pageable pageable);
 
     @Query("""
         SELECT k.keyword
         FROM ArticleSearchKeyword k
-        ORDER BY k.weight DESC, k.lastSearchedAt
+        ORDER BY k.totalSearch DESC, k.lastSearchedAt
         """)
     List<String> findTopKeywordsByLatest(Pageable pageable);
 

src/main/java/in/koreatech/koin/domain/community/article/scheduler/ArticleScheduler.java

@@ -3,7 +3,7 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import in.koreatech.koin.domain.community.article.service.ArticleService;
+import in.koreatech.koin.domain.community.article.service.ArticleSyncService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
@@ -12,32 +12,33 @@
 @RequiredArgsConstructor
 public class ArticleScheduler {
 
-    private final ArticleService articleService;
+    private final ArticleSyncService articleSyncService;
 
     @Scheduled(cron = "0 0 6 * * *")
     public void updateHotArticles() {
         try {
-            articleService.updateHotArticles();
+            articleSyncService.updateHotArticles();
         } catch (Exception e) {
             log.error("인기 게시글 업데이트 중에 오류가 발생했습니다.", e);
         }
     }
 
-    @Scheduled(cron = "0 0 0/6 * * *")
-    public void resetOldKeywordsAndIpMaps() {
+    @Scheduled(cron = "0 0 * * * *")
+    public void getBusNoticeArticle() {
         try {
-            articleService.resetWeightsAndCounts();
+            articleSyncService.updateBusNoticeArticle();
         } catch (Exception e) {
-            log.error("많이 검색한 키워드 초기화 중에 오류가 발생했습니다.", e);
+            log.error("버스 공지 게시글 조회 중에 오류가 발생했습니다.", e);
         }
     }
 
-    @Scheduled(cron = "0 0 * * * *")
-    public void getBusNoticeArticle() {
+    @Scheduled(cron = "0 0 */6 * * *")
+    public void synchronizeKeywords() {
         try {
-            articleService.updateBusNoticeArticle();
+            articleSyncService.resetWeightsAndCounts();
+            articleSyncService.synchronizeKeywords();
         } catch (Exception e) {
-            log.error("버스 공지 게시글 조회 중에 오류가 발생했습니다.", e);
+            log.error("Redis에서 MySQL로 키워드 동기화 중 오류가 발생했습니다.", e);
         }
     }
 }