Redis queue, Spring scheduler + ratelimit 트러블슈팅

원래 updateViewCount 코드의 문제: 그냥 async만 사용해서 비동기적으로 처리하고있다. 하지만 대량의 요청이 들어오면 서버 리소스가 낭비된다거나, 카운팅이 중복될 수 있다. 따라서 분산 처리를 효율적으로 할 필요가 있었다.

해결방법: redis queue와 spring scheduler를 이용해 요청이 있을 때 마다 redis queue에 담고, batch 처리를 통해 일정 시간마다 한번에 반영한다.

@Service
@AllArgsConstructor
public class BoardQueueService {

    private final RedisTemplate<String, Object> redisTemplate;

    public void addToQueue(Long boardId){
        redisTemplate.opsForList().rightPush("board:viewCountQueue", boardId);
    }

    public Long fetchFromQueue(){
        Object value = redisTemplate.opsForList().leftPop("board:viewCountQueue");
        if(value instanceof Integer){
            return ((Integer) value).longValue();
        }
        return (Long) value;
    }
}

@Service
@RequiredArgsConstructor
public class BoardViewCountBatch {

    private final BoardQueueService boardQueueService;
    private final BoardRepository boardRepository;
    private final BoardValidationService boardValidationService;
    private final BoardDomainService boardDomainService;

    @Scheduled(fixedDelay = 5000)
    public void processViewCountBatch(){
        Long boardId;

        while((boardId = boardQueueService.fetchFromQueue()) != null){
            Board board = boardValidationService.validateBoard(boardId);
            if(board != null){
                boardDomainService.countBoard(board);
                boardRepository.save(board);
            }
        }
    }
}

조회 요청 시 redis queue에 boardId를 저장하고, batch가 5초마다 redis queue에서 boardId를 가져온다.

가져온 boardId로 Board 엔티티를 조회해 조회수를 증가시킨다. batch로 db에 저장하기에 효율적이다.