[Redis] Redis CacheAside 전략 간단히 적용해보기 @Cachable 어노테이션

(게시판 토이프로젝트)

 

일단 현재 내 service코드는

단순히 DB찔러서 갖고 오는 코드임.

@Service
public class BoardService {

    private BoardRepository boardRepository;

    public BoardService(BoardRepository boardRepository) {
        this.boardRepository = boardRepository;
    }

    public List<Board> getBoards(int page, int size) {
        Pageable pageable = PageRequest.of(page -1, size);
        Page<Board> pageOfBoards = boardRepository.findAllByOrderByCreatedAtDesc(pageable);
        return pageOfBoards.getContent();
    }
}

 

 

 

이제 프로젝트에 config폴더 만들고, 세팅해준다음에

Service쪽 코드 간단히 수정해서

 

Redis먼저 찔러보고, CacheMiss면 DB 찌르고 DB에 저장까지 하는 로직으로 해보겠음.

 

파일구조는 이렇게 

config폴더 만들고, 그 하위에 redis 설정하는 파일 두개 만들겠음.

 

 

RedisCacheConfig 파일

@Configuration
@EnableCaching // Spring Boot의 캐싱 설정을 활성화
public class RedisCacheConfig {
    @Bean
    public CacheManager boardCacheManager(RedisConnectionFactory redisConnectionFactory) {
        RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration
                .defaultCacheConfig()
                // Redis에 Key를 저장할 때 String으로 직렬화(변환)해서 저장
                .serializeKeysWith(
                        RedisSerializationContext.SerializationPair.fromSerializer(
                                new StringRedisSerializer()))
                // Redis에 Value를 저장할 때 Json으로 직렬화(변환)해서 저장
                .serializeValuesWith(
                        RedisSerializationContext.SerializationPair.fromSerializer(
                                new Jackson2JsonRedisSerializer<Object>(Object.class)
                        )
                )
                // 데이터의 만료기간(TTL) 설정 - 1분마다 데이터 갱신됐으면 좋겠다!
                .entryTtl(Duration.ofMinutes(1L));

        return RedisCacheManager
                .RedisCacheManagerBuilder
                .fromConnectionFactory(redisConnectionFactory)
                .cacheDefaults(redisCacheConfiguration)
                .build();
    }
}

 

 

 

RedisConfig파일

@Configuration
public class RedisConfig {

    @Value("${spring.data.redis.host}")
    private String host;

    @Value("${spring.data.redis.port}")
    private int port;


    @Bean
    public LettuceConnectionFactory redisConnectionFactory() {
        //Lettuce 라이브러리 이용해서 Redis 연결 관리하는 객체 생성
        // Redis 서버에 대한 정보(host, port)를 설정
        return  new LettuceConnectionFactory(new RedisStandaloneConfiguration(host, port));
    }

}

 

 

Redis 설정은 해놨고,

이제 Service쪽 코드 수정

@Service
public class BoardService {

    private BoardRepository boardRepository;

    public BoardService(BoardRepository boardRepository) {
        this.boardRepository = boardRepository;
    }

    // @Cacheable : CacheAside 전략 쓰겠다.
    // CacheAside 전략 : 일단 redis 캐시 먼저 뒤지고, 없으면 내부 로직 진행, return 값을 redis에 저장.
    // 키값 - boards:pages:2:size:10 - boards 에서 page가 2이고, size가 10개인 데이터
    @Cacheable(cacheNames = "getBoards", key = "'boards:pages:' + #page + ':size' + #size", cacheManager = "boardCacheManager")
    public List<Board> getBoards(int page, int size) {
        // Cache Miss 가 발생했을 때 진행되는 로직
        // redis에 없으니까 boardRepository(DB) 뒤지는거임
        Pageable pageable = PageRequest.of(page -1, size);
        Page<Board> pageOfBoards = boardRepository.findAllByOrderByCreatedAtDesc(pageable);
        return pageOfBoards.getContent();
    }
}

이렇게 바꿔주겠음.

 

@Cachable어노테이션:

- cacheNames : 캐시 데이터가 어디 저장될지 지정.

첨에 어노테이션 봤을 때 레디스 저장구조가 어떻게 생긴지 몰라서

이 속성이 왜 필요한가 했음.

 

어차피 key-value로 저장되는 레디스에서 key는 안겹쳐야하고.. 굳이 왜 필요한가 했는데

약간 RDBMS에서 table같은 역할로 이해하면 쉬울거같음.

 

지금 내가 짠 코드 처럼 하게 된다면 

내부에

getBoards {
    boards:pages:2:size:10 ->  [ Board 데이터 ... ]
    boards:pages:3:size:10 ->  [ Board 데이터 ... ]
}

이런 느낌으로 저장된다고 보면됨.

 

어차피 key값은 unique해야하니까 겹칠일은 없겠지만,

캐시 구조 관리나 제어 편리성때문에 꼭 필요함.

 

예를 들어 내가 boards 캐시만 지우고싶다면?

구조적으로 분리가 안되어있으면 까다로워짐.

아무튼 이런 이유로 저장소 이름 붙이기는 필수적.

 

- key : key값 이름 지정

내가 쓴 코드처럼 하게 되면 키값이

boards:pages:2:size:10 

이런식으로 저장됨.

예전에 포스팅했던, 계층적 구조를 잘 따르게 지음

 

 

- cacheManager : 어떤 cacheManager한테 맡길건지 지정

지정 안해주면 defaultCacheManager쓴다고 합니다.

위에서 config 디렉토리 하위에

boardCacheManager 만들어둔게 있는데, 그걸 갖다 쓰는거임.

 

 

---

이제 실행하고 api 호출해보면

 

로그에 이렇게 찍힘.

 

처음에 캐시 조회해 봤는데 없어서

No cache entry라고 뜨고,

DB를 조회함.

그리고 return값을 redis에 저장하는 로그.

 

 

redis-cli 켜서 확인해보면

잘 들어가 있음!!!

 

하나하나 확인해보면

내가 저번에 만개인가 십만개인가 랜덤 생성해놓은 데이터중에서 불러와짐.

 

1분이 지나기 전에 다시 api호출해보면

아까랑 달리 바로 조회.

 

 

 

 

 

ttl확인해보면

5초 남기고 캡쳐

ㅋㅋㅋ

 

 

 

~~~시간이 흐르고 1분이 지남~~~

 

다시 api호출해보면

다시 캐시 없다면서 DB조회하고 캐시에 저장함.