feat: redis caching

f-lab-clone · Nov 14, 2023 · 17ce6cb · 17ce6cb
1 parent f3d28fe
commit 17ce6cb
Show file tree

Hide file tree

Showing 11 changed files with 100 additions and 39 deletions.
diff --git a/Dockerfile b/Dockerfile
@@ -17,4 +17,4 @@ COPY --from=builder snapshot-dependencies/ ./
 COPY --from=builder spring-boot-loader/ ./
 COPY --from=builder application/ ./
 
-ENTRYPOINT ["java","org.springframework.boot.loader.JarLauncher"]
+ENTRYPOINT ["java","org.springframework.boot.loader.JarLaungcher"]
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -53,6 +53,7 @@ dependencies {
     implementation("org.springframework.boot:spring-boot-starter-web")
     implementation("org.springframework.boot:spring-boot-starter-jdbc")
     implementation("org.springframework.boot:spring-boot-starter-cache")
+    implementation("org.springframework.boot:spring-boot-starter-data-redis")
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
     implementation("org.jetbrains.kotlin:kotlin-reflect")
     implementation("com.ninja-squad:springmockk:4.0.2")

diff --git a/docker-compose.yml b/docker-compose.yml
@@ -60,7 +60,7 @@ services:
       JWT_ISSUER: minjun
       QUEUE_SERVER_URL : http://localhost
       SPRING_PROFILES_ACTIVE: local
-      REDIS_HOST: redis
+      REDIS_HOST: localhost
       REDIS_PORT: 6379
 
     depends_on:

diff --git a/src/integrationTest/resources/application.yml b/src/integrationTest/resources/application.yml
@@ -7,6 +7,8 @@ management:
       enabled: 'true'
 
 spring:
+  cache:
+    type: redis
   jpa:
     generate-ddl: 'true'
     hibernate:
@@ -16,6 +18,9 @@ spring:
     web:
       pageable:
         one-indexed-parameters: true
+    redis:
+      host: localhost
+      port: 6379
 
 ticketing:
   jwt:
@@ -26,3 +31,4 @@ ticketing:
   queue:
     server:
       url: http://localhost:8082/ticket
+
diff --git a/src/main/kotlin/com/group4/ticketingservice/config/CacheConfig.kt b/src/main/kotlin/com/group4/ticketingservice/config/CacheConfig.kt
@@ -1,33 +1,43 @@
 package com.group4.ticketingservice.config
 
+import com.fasterxml.jackson.databind.DeserializationFeature
+import com.fasterxml.jackson.databind.ObjectMapper
+import com.fasterxml.jackson.databind.SerializationFeature
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule
 import org.springframework.cache.CacheManager
-import org.springframework.cache.annotation.CacheEvict
 import org.springframework.cache.annotation.EnableCaching
-import org.springframework.cache.concurrent.ConcurrentMapCache
-import org.springframework.cache.support.SimpleCacheManager
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
-import org.springframework.scheduling.annotation.Scheduled
+import org.springframework.data.redis.cache.RedisCacheConfiguration
+import org.springframework.data.redis.cache.RedisCacheManager.RedisCacheManagerBuilder
+import org.springframework.data.redis.connection.RedisConnectionFactory
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer
+import org.springframework.data.redis.serializer.RedisSerializationContext
+import java.time.Duration
 
 @Configuration
 @EnableCaching
-class CacheConfig {
+class CacheConfig(
+    private val redisConnectionFactory: RedisConnectionFactory
+) {
     companion object {
         private const val EVENT_CACHE = "getEvents"
     }
 
     @Bean
     fun cacheManager(): CacheManager {
-        val simpleCacheManager = SimpleCacheManager()
-        simpleCacheManager.setCaches(
-            listOf(
-                ConcurrentMapCache(EVENT_CACHE)
-            )
-        )
-        return simpleCacheManager
-    }
+        val objectMapper = ObjectMapper()
+            .findAndRegisterModules()
+            .enable(SerializationFeature.INDENT_OUTPUT)
+            .disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS)
+            .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
+            .registerModules(JavaTimeModule())
 
-    @CacheEvict(allEntries = true, value = [EVENT_CACHE])
-    @Scheduled(fixedDelay = 10 * 60 * 1000, initialDelay = 500)
-    fun cacheEvict() {}
+        val builder = RedisCacheManagerBuilder.fromConnectionFactory(redisConnectionFactory)
+        val configuration: RedisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
+            .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(GenericJackson2JsonRedisSerializer(objectMapper)))
+            .entryTtl(Duration.ofMinutes(30))
+        builder.cacheDefaults(configuration)
+        return builder.build()
+    }
 }
diff --git a/src/main/kotlin/com/group4/ticketingservice/config/RedisConfig.kt b/src/main/kotlin/com/group4/ticketingservice/config/RedisConfig.kt
@@ -0,0 +1,24 @@
+package com.group4.ticketingservice.config
+
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.data.redis.connection.RedisConnectionFactory
+import org.springframework.data.redis.connection.RedisStandaloneConfiguration
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory
+
+@Configuration
+class RedisConfig {
+    @Value("\${spring.data.redis.host}")
+    private val host: String? = null
+
+    @Value("\${spring.data.redis.port}")
+    private val port = 0
+
+    @Bean
+    fun redisConnectionFactory(): RedisConnectionFactory {
+        return LettuceConnectionFactory(
+            RedisStandaloneConfiguration(host!!, port)
+        )
+    }
+}
diff --git a/src/main/kotlin/com/group4/ticketingservice/controller/EventController.kt b/src/main/kotlin/com/group4/ticketingservice/controller/EventController.kt
@@ -2,14 +2,12 @@ package com.group4.ticketingservice.controller
 
 import com.group4.ticketingservice.dto.EventCreateRequest
 import com.group4.ticketingservice.dto.EventResponse
-import com.group4.ticketingservice.entity.Event
 import com.group4.ticketingservice.service.EventService
 import io.swagger.v3.oas.annotations.Hidden
 import jakarta.servlet.http.HttpServletRequest
 import jakarta.validation.Valid
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.cache.annotation.Cacheable
-import org.springframework.data.domain.Page
 import org.springframework.data.domain.Pageable
 import org.springframework.data.domain.Sort
 import org.springframework.data.web.PageableDefault
@@ -83,12 +81,16 @@ class EventController @Autowired constructor(
     }
 
     @GetMapping
-    @Cacheable(value = ["getEvents"], key = "#pageable.pageNumber+'-'+#pageable.pageSize+'-'+#pageable.sort.toString()+'-'+#name")
+    @Cacheable(
+        value = ["getEvents"],
+        key = "#pageable.pageNumber+'-'+#pageable.pageSize+'-'+#pageable.sort.toString()+'-'+#name",
+        cacheManager = "cacheManager"
+    )
     fun getEvents(
         request: HttpServletRequest,
         @RequestParam(required = false) name: String?,
         @PageableDefault(size = 10, sort = ["id"], direction = Sort.Direction.DESC) pageable: Pageable
-    ): ResponseEntity<Page<Event>> {
+    ): Any {
         val page = eventService.getEvents(name, pageable)
         print(pageable.sort.toString())
         val headers = HttpHeaders()

diff --git a/src/main/kotlin/com/group4/ticketingservice/service/EventService.kt b/src/main/kotlin/com/group4/ticketingservice/service/EventService.kt
@@ -1,5 +1,6 @@
 package com.group4.ticketingservice.service
 
+import com.group4.ticketingservice.dto.EventResponse
 import com.group4.ticketingservice.dto.EventSpecifications
 import com.group4.ticketingservice.entity.Event
 import com.group4.ticketingservice.repository.EventRepository
@@ -36,8 +37,20 @@ class EventService(
         return eventRepository.findById(id).orElse(null)
     }
 
-    fun getEvents(name: String?, pageable: Pageable): Page<Event> {
+    fun getEvents(name: String?, pageable: Pageable): Page<EventResponse> {
         val specification = EventSpecifications.withName(name)
-        return PageImpl(eventRepository.findAllBy(specification, pageable))
+        return PageImpl(
+            eventRepository.findAllBy(specification, pageable).map {
+                EventResponse(
+                    id = it.id!!,
+                    name = it.name,
+                    startDate = it.startDate,
+                    endDate = it.endDate,
+                    reservationStartTime = it.reservationStartTime,
+                    reservationEndTime = it.reservationEndTime,
+                    maxAttendees = it.maxAttendees
+                )
+            }
+        )
     }
 }
diff --git a/src/main/kotlin/com/group4/ticketingservice/utils/ResponseAdvice.kt b/src/main/kotlin/com/group4/ticketingservice/utils/ResponseAdvice.kt
@@ -2,10 +2,8 @@ package com.group4.ticketingservice.utils
 
 import com.group4.ticketingservice.controller.HealthController
 import com.group4.ticketingservice.dto.ErrorResponseDTO
-import com.group4.ticketingservice.dto.EventResponse
 import com.group4.ticketingservice.dto.ReservationResponse
 import com.group4.ticketingservice.dto.SuccessResponseDTO
-import com.group4.ticketingservice.entity.Event
 import com.group4.ticketingservice.entity.Reservation
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.core.MethodParameter
@@ -56,6 +54,13 @@ class ResponseAdvice<T>(
                 path = response.headers.getFirst("Content-Location")
             ) as T?
         }
+        if (body is LinkedHashMap<*, *>) { // cached data
+            val b = body["body"] as LinkedHashMap<String, Any>
+            return SuccessResponseDTO(
+                data = b["content"],
+                path = request.uri.path
+            ) as T?
+        }
 
         if (body is ErrorResponseDTO) {
             return body
@@ -96,18 +101,6 @@ class ResponseAdvice<T>(
 
         if (data.isEmpty()) {
             data = listOf()
-        } else if (data[0] is Event) {
-            data = (page.content as List<Event>).map {
-                EventResponse(
-                    id = it.id!!,
-                    name = it.name,
-                    startDate = it.startDate,
-                    endDate = it.endDate,
-                    reservationStartTime = it.reservationStartTime,
-                    reservationEndTime = it.reservationEndTime,
-                    maxAttendees = it.maxAttendees
-                )
-            }
         } else if (data[0] is Reservation) {
             data = (page.content as List<Reservation>).map {
                 ReservationResponse(

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
@@ -11,6 +11,8 @@ spring:
     resources:
       add-mappings: 'false'
 
+  cache:
+    type: redis
 
   mvc:
     log-resolved-exception: 'false'
@@ -20,6 +22,10 @@ spring:
     web:
       pageable:
         one-indexed-parameters: true
+    redis:
+      host: ${REDIS_HOST}
+      port: ${REDIS_PORT}
+
 
 
   datasource:

diff --git a/src/test/resources/application.yml b/src/test/resources/application.yml
@@ -1,4 +1,6 @@
 spring:
+  cache:
+    type: redis
   security:
     user:
       name: user
@@ -8,6 +10,9 @@ spring:
     web:
       pageable:
         one-indexed-parameters: true
+    redis:
+      host: localhost
+      port: 6379
 
 ticketing:
   jwt:
@@ -16,4 +21,5 @@ ticketing:
     issuer: minjun
   queue:
     server:
-      url: http://localhost:8082/ticket
+      url: http://localhost:8082/ticket
+