Redis Cache System Build

This commit is contained in:
DanielLee
2025-12-08 11:20:45 +09:00
parent fcefaf416c
commit 14b97683ec
4 changed files with 429 additions and 1 deletions

View File

@@ -1,5 +1,6 @@
package com.kamco.cd.kamcoback.code;
import com.kamco.cd.kamcoback.code.config.CommonCodeCacheManager;
import com.kamco.cd.kamcoback.code.dto.CommonCodeDto;
import com.kamco.cd.kamcoback.code.service.CommonCodeService;
import com.kamco.cd.kamcoback.common.enums.DetectionClassification;
@@ -34,6 +35,7 @@ import org.springframework.web.bind.annotation.RestController;
public class CommonCodeApiController {
private final CommonCodeService commonCodeService;
private final CommonCodeCacheManager commonCodeCacheManager;
@Operation(summary = "목록 조회", description = "모든 공통코드 조회")
@ApiResponses(
@@ -243,4 +245,40 @@ public class CommonCodeApiController {
@RequestParam String code) {
return ApiResponseDto.okObject(commonCodeService.getCodeCheckDuplicate(parentId, code));
}
@Operation(summary = "캐시 갱신", description = "공통코드 캐시를 갱신합니다. 공통코드 설정 변경 후 호출해주세요.")
@ApiResponses(
value = {
@ApiResponse(
responseCode = "200",
description = "캐시 갱신 성공",
content =
@Content(
mediaType = "application/json",
schema = @Schema(implementation = String.class))),
@ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
})
@PostMapping("/cache/refresh")
public ApiResponseDto<String> refreshCommonCodeCache() {
commonCodeCacheManager.refreshCommonCodeCache();
return ApiResponseDto.ok("공통코드 캐시가 갱신되었습니다.");
}
@Operation(summary = "캐시 상태 확인", description = "Redis에 캐시된 공통코드 개수를 확인합니다.")
@ApiResponses(
value = {
@ApiResponse(
responseCode = "200",
description = "캐시 상태 조회 성공",
content =
@Content(
mediaType = "application/json",
schema = @Schema(implementation = Integer.class))),
@ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
})
@GetMapping("/cache/status")
public ApiResponseDto<Integer> getCommonCodeCacheStatus() {
int count = commonCodeCacheManager.getCachedCommonCodeCount();
return ApiResponseDto.ok(count);
}
}

View File

@@ -0,0 +1,108 @@
package com.kamco.cd.kamcoback.code.config;
import com.kamco.cd.kamcoback.code.dto.CommonCodeDto.Basic;
import com.kamco.cd.kamcoback.code.service.CommonCodeService;
import java.util.List;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.cache.CacheManager;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
/**
* 공통코드 캐시 관리 및 초기화 클래스
*
* <p>애플리케이션 시작 시 공통코드를 Redis 캐시에 미리 로드하고, 캐시 갱신을 관리합니다.
*/
@Slf4j
@Component
@RequiredArgsConstructor
public class CommonCodeCacheManager {
private final CommonCodeService commonCodeService;
private final CacheManager cacheManager;
public static final String COMMON_CODES_CACHE_NAME = "commonCodes";
/**
* 애플리케이션 시작 완료 후 공통코드를 Redis 캐시에 미리 로드
*
* <p>이 메서드는 Spring 애플리케이션이 완전히 시작된 후에 자동으로 실행되며, 공통코드 데이터를 Redis
* 캐시에 미리 로드하여 초기 조회 시 성능을 최적화합니다.
*/
@EventListener(ApplicationReadyEvent.class)
public void initializeCommonCodeCache() {
try {
log.info("=== 공통코드 캐시 초기화 시작 ===");
List<Basic> allCommonCodes = commonCodeService.getFindAll();
log.info("✓ 공통코드 {}개가 Redis 캐시에 로드되었습니다.", allCommonCodes.size());
allCommonCodes.forEach(
code ->
log.debug(
" - [{}] {} (ID: {})",
code.getCode(),
code.getName(),
code.getId()));
log.info("=== 공통코드 캐시 초기화 완료 ===");
} catch (Exception e) {
log.error("공통코드 캐시 초기화 중 오류 발생", e);
}
}
/**
* 공통코드 캐시 전체 초기화 (수동 갱신)
*
* <p>공통코드 설정이 변경되었을 때 호출하여 캐시를 강제로 갱신합니다.
*/
public void refreshCommonCodeCache() {
try {
log.info("공통코드 캐시 갱신 시작...");
// 기존 캐시 제거
clearCommonCodeCache();
// 새로운 데이터 로드
List<Basic> allCommonCodes = commonCodeService.getFindAll();
log.info("✓ 공통코드 캐시가 {}개 항목으로 갱신되었습니다.", allCommonCodes.size());
} catch (Exception e) {
log.error("공통코드 캐시 갱신 중 오류 발생", e);
}
}
/**
* 공통코드 캐시 초기화 (삭제)
*
* <p>공통코드 캐시를 비우고 다음 조회 시 DB에서 새로 로드하도록 합니다.
*/
public void clearCommonCodeCache() {
try {
var cache = cacheManager.getCache(COMMON_CODES_CACHE_NAME);
if (cache != null) {
cache.clear();
log.info("✓ 공통코드 캐시가 초기화되었습니다.");
}
} catch (Exception e) {
log.error("공통코드 캐시 초기화 중 오류 발생", e);
}
}
/**
* 캐시 상태 확인
*
* @return 캐시에 있는 공통코드 개수
*/
public int getCachedCommonCodeCount() {
try {
List<Basic> cachedCodes = commonCodeService.getFindAll();
return cachedCodes.size();
} catch (Exception e) {
log.warn("캐시 상태 확인 중 오류 발생", e);
return 0;
}
}
}