조회수 시스템을 리팩토링하며 시간복잡도, 공간복잡도 줄인 경험

Redis 키 수 = 게시글 수 × 1 (각 게시글마다 Set 키 1개)
Set 내 데이터 = 게시글별 누적 조회자 수
총 메모리 = O(게시글 수 + 총 조회 건수)

// 사용자가 게시글 조회할 때마다 실행
String key = RedisKey.getViewedMembersKey(articleId);
redisTemplate.opsForSet().add(key, String.valueOf(memberId));
redisTemplate.expire(key, DUPLICATE_PREVENTION_TTL, TimeUnit.SECONDS); // TTL 갱신

// 전체 게시글을 스캔하여 조회수 변경 여부 확인
@Scheduled(fixedRate = SYNC_INTERVAL)
public void syncAllViewCounts() {
List<Article> allArticles = articleRepository.findAll(); // O(N) 전체 조회

    for (Article article : allArticles) {
        String redisValue = redisTemplate.opsForValue()
            .get(RedisKey.getArticleViewKey(article.getId()));

        if (redisValue != null) {
            // DB 업데이트 수행
        }
    }
}

public void increaseViewCount(Long articleId, Long memberId) {
String key = RedisKey.getViewedMembersKey(articleId);
Long added = redisTemplate.opsForSet().add(key, String.valueOf(memberId));

    // 중복 조회인 경우 즉시 종료 (TTL 갱신 방지)
    if (added != RedisConstants.REDIS_SET_ADD_SUCCESS) {
        return;
    }

    // TTL은 최초 1회만 설정
    redisTemplate.expire(key, RedisConstants.DUPLICATE_PREVENTION_TTL, TimeUnit.SECONDS);

    redisTemplate.opsForValue().increment(RedisKey.getArticleViewKey(articleId));
    redisTemplate.opsForSet().add(RedisKey.articlesSaveDbKey(), articleId.toString());
}

// 조회수 증가 시 동기화 대상으로 등록
redisTemplate.opsForSet().add(RedisKey.articlesSaveDbKey(), articleId.toString());

// 동기화 시 변경된 게시글만 처리
@Transactional
public void bulkUpdateViewCounts() {
Set<String> articleIds = redisTemplate.opsForSet().members(RedisKey.articlesSaveDbKey());
if (articleIds == null) return;

    List<ViewCountUpdateDto> updateList = new ArrayList<>();

    // 변경된 게시글에 대해서만 처리 O(K)
    for (String articleIdStr : articleIds) {
        Long articleId = Long.parseLong(articleIdStr);
        String viewCountValue = redisTemplate.opsForValue()
                .get(RedisKey.getArticleViewKey(articleId));

        if (viewCountValue != null) {
            updateList.add(new ViewCountUpdateDto(articleId, Long.parseLong(viewCountValue)));
        }
    }

    batchUpdater.batchUpdate(updateList); // 배치 처리
    clearCache(articleIds); // 처리 완료 후 캐시 정리
}

@Component
public class ArticleViewBatchUpdater {

    private static final int BATCH_SIZE = 500;

    public void batchUpdate(List<ViewCountUpdateDto> updateList) {
        String sql = """
            UPDATE article
            SET view_count = view_count + :viewCount
            WHERE id = :articleId
            """;

        // 500개씩 배치 처리
        for (int i = 0; i < updateList.size(); i += BATCH_SIZE) {
            List<ViewCountUpdateDto> batch = updateList.subList(
                i, Math.min(i + BATCH_SIZE, updateList.size())
            );

            namedJdbcTemplate.batchUpdate(sql, createParameterSources(batch));
        }
    }
}

@Scheduled(fixedRate = RedisConstants.RANKING_REFRESH_INTERVAL)
public void updateRedisTopArticles() {
// DB에서 정확한 조회수 기준으로 정렬
List<Article> topArticles = articleRepository.findTopByViews(
PageRequest.of(0, RedisConstants.TOP_LIMIT));

    String key = RedisKey.getTopArticleListKey();
    redisTemplate.delete(key);

    // 정렬된 결과만 Redis List에 저장
    for (Article article : topArticles) {
        redisTemplate.opsForList().rightPush(key, article.getIdAsString());
    }
}

// API 조회는 O(1)
public List<ArticleListResponse> getTopRankedArticles() {
List<Long> topIds = getTopArticleIds(); // O(1) Redis List 조회
// ... DB에서 게시글 정보 조회
}