🧣 SpringBoot + Redis 사용하기

현재 프로젝트

• 휴맥스모빌리티 주차장 서비스 개발
• SpringBoot + MySQL + Docker + AWS EC2(Amazon Linux 2)
• 주차장 검색 시 올라가는 카운트를 통해 인기도 출력
  - 기존 MySQL의 search_count를 -> Redis로 이관하기 위한 작업 진행

1. Redis 설치

📍 [Redis] Redis 설치 및 간단한 사용 방법 (Mac)

• Mac Os의 Homebrew를 통한 설치를 진행했습니다.
  $ brew install redis
  

• 설치가 완료되면 다음의 명령어로 redis를 실행합니다.
  $ brew services start redis
  

• redis-cli을 통해 실행할 수 있습니다.
  $ redis-cli
  

---

2. Redis 기본 명령어

https://wlswoo.tistory.com/44
-> 여기보고 정리해두기

---

3. Redis 적용 테스트

• 우선 제 브랜치로 돌아와서 테스트를 해보기로 했습니다.
  그런데 checkout 하니, resources/application.yml이 없...어졌..습니다😮
  엄청 당황했는데 그냥 제가 저장안하고 다른 브랜치로 넘어갔다가 와서 그런 것 같아서, 그냥 만들었습니다..!

  다시 만드니까 알아서 ignore 처리가 바로 되어서 안심하고 commit했습니다.

• 깃은 정말 다 알았다고 생각하는 순간 처음 보는 문제를 발생시키는 것 같아요😅
  깃 공부하기(메모)
  
  .
  .

• 다시 돌아와서 변경한 부분을 말씀드려볼게요.

1️⃣ 의존성 추가

Spring Boot 내에 Redis를 지원해주는 spring-boot-starter-data-redis라는 라이브러리가 있어서 사용하기로 결정했습니다.

📁 bulid.gradle

...
	// Redis
	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
...

2️⃣ host 및 port 지정해주기

Redis를 설치하고, 아무 설정을 하지 않았을 경우

• 기본 host : localhost(ec2의 경우 해당 IP)
• port : 6379
• password : 없음(설정에서 추가해준 경우에만 적용)

이렇게 설정이 되어 있습니다.
이 설정은 application.yml에 추가해주시면 됩니다.

⏰ 반드시 spring: 바로 아래 indentation에 작성해주어야 합니다. ⏰

📁 application.yml

spring:
  redis:
    host: localhost
    port: 6379
    ...

3️⃣ RedisConfig 적용(선택)

spring-boot-starter-data-redis에 자체적으로 RedisTemplete을 자동 주입해주지만, 약간의 오류가 있어 추가해주었습니다.
오류가 발생하지 않는다면 추가하지 않아도 됩니다!
📁 config/RedisConfig.java

package com.humax.parking.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.StringRedisTemplate;

@Configuration
public class RedisConfig {

    @Bean
    public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory connectionFactory) {
        return new StringRedisTemplate(connectionFactory);
    }
}

4️⃣ UserService 수정

기존의 MySQL에서의 search_count를 Redis로 옮겨주고, MySQL에는 주기적으로 갱신만 해주도록 변경했습니다.
📁 service/UserService.java
🙌 기존

private void updateSearchCount(List<ParkingEntity> parkingEntities){
        for(ParkingEntity parkingEntity : parkingEntities){
            parkingEntity.setSearchCount(parkingEntity.getSearchCount()+1);
        }
    }

🙌 변경후

...
private final StringRedisTemplate stringRedisTemplate;

private static final String SEARCH_COUNT_KEY_PREFIX = "search_count:";
    ...
    
private void updateSearchCount(List<ParkingEntity> parkingEntities) {
        for (ParkingEntity parkingEntity : parkingEntities) {
            String key = SEARCH_COUNT_KEY_PREFIX + parkingEntity.getParkingId();
            stringRedisTemplate.opsForValue().increment(key);
            // 로그 추가
            System.out.println("추가된 주차장 parking_id: " + parkingEntity.getParkingId());
        }
    }

• RedisTemplate 사용을 위해 선언을 해주었습니다.
• 또한, SEARCH_COUNT_KEY_PREFIX로 search_count를 명시할 수 있도록 했습니다.
• Redis에 SEARCH_COUNT_KEY_PREFIX를 통해 카운트의 KEY 값을 넣어주고, 실제로 검색된 후 key값이 increment 되도록 코드를 작성했습니다.
• 로그를 넣어주어 실제로 호출이 되는지도 바로 확인할 수 있도록 했습니다.
  
  

5️⃣ 결과 확인 방법

search_count의 동작 로직은 다음과 같습니다.
1. 사용자가 가까운 주차장을 반경, 위도와 경도로 조회합니다.
(반드시 소셜로그인이 되어 있는 유저여야만 합니다)

URI
localhost:8080/api/v1/user/search

Body(JSON)

{ 
	"distance": 2000,
    "lon":"37.5170112",
    "lat":"126.9019532"
}

2. 실제 적용되었음을 로그와 redis 조회, 그리고 MySQL 갱신 여부를 통해 확인합니다.
   
   

6️⃣ 결과 확인!

📩 가까운 주차장 조회

📩 프로젝트 로그가 출력되었는지 확인

📩 Redis 확인
GET search_count:{parking_id}

• crossCheck : 조회되지 않은 주차장의 count 확인 ✅
  
  
  

📩 MySQL 확인
일반적으로 이 쿼리가 종료된 즉시, MySQL에서 적용이 되어야 하지만 바로 적용되지 않는 문제 발생

---

4. MySQL Batch 작업

• 주기적으로 MySQL에 search_count가 갱신될 수 있도록 배치 작업을 시도해봤습니다.
  📁 service에 redis 패키지 생성/GSearchCountUpdateTask.java

package com.humax.parking.service.redis;

import com.humax.parking.service.UserService;
import java.util.ArrayList;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;

@SpringBootApplication
@EnableScheduling
public class SearchCountUpdateTask {

    private final UserService userService;

    public SearchCountUpdateTask(UserService userService) {
        this.userService = userService;
    }

    @Scheduled(fixedDelay = 60000) // 1분마다 실행 (밀리초 단위) -> 추후 실제 배치 작업 시 1시간으로 변갱
    public void updateSearchCount() {
        try {
            // 여기서 userService의 메소드를 호출하여 MySQL의 검색 횟수를 갱신
            userService.updateSearchCount(new ArrayList<>());
            System.out.println("갱신 완료");
        } catch (Exception e) {
            // 예외 처리
            e.printStackTrace();
        }
    }
}

📁 UserService.java 수정

public void updateSearchCount(List<ParkingEntity> parkingEntities) {
        for (ParkingEntity parkingEntity : parkingEntities) {
            String key = SEARCH_COUNT_KEY_PREFIX + parkingEntity.getParkingId();
            stringRedisTemplate.opsForValue().increment(key);
            // 로그 추가
            System.out.println("추가된 주차장 parking_id: " + parkingEntity.getParkingId());
        }
    }

결과

• 테스트용이라 1분에 한번씩 MySQL에 갱신이 되도록 했습니다.

• 하지만 실제 MySQL에서 값이 아직 반영되지 않는 문제가 있습니다.
  
  

• 배치 작업을 하지 않는 것으로 결론.

---

다음 편 : 🧣 SpringBoot + Redis - 메인 화면 인기 주차장 띄우기