Adds Spring Cloud AWS for caching

Author: Murtuza Ranapurwala

spring-boot/caching-with-elasticache-redis/build.gradle

@@ -24,12 +24,21 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.springframework.boot:spring-boot-starter-cache'
     implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+    implementation 'io.awspring.cloud:spring-cloud-starter-aws'
+//    implementation 'com.amazonaws:aws-java-sdk-cloudformation'
+    implementation 'com.amazonaws:aws-java-sdk-elasticache'
     compileOnly 'org.projectlombok:lombok'
     runtimeOnly 'com.h2database:h2'
     annotationProcessor 'org.projectlombok:lombok'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
 }
 
+dependencyManagement {
+    imports {
+        mavenBom 'io.awspring.cloud:spring-cloud-aws-dependencies:2.3.1'
+    }
+}
+
 test {
     useJUnitPlatform()
 }

spring-boot/caching-with-elasticache-redis/src/main/java/io/reflectoring/springcloudredis/configuration/EnableCache.java

@@ -1,33 +1,10 @@
 package io.reflectoring.springcloudredis.configuration;
 
-import io.lettuce.core.ReadFrom;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.cache.annotation.EnableCaching;
-import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisStaticMasterReplicaConfiguration;
-import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
-import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
 
 @Configuration
 @EnableCaching
 public class EnableCache {
-    public static final int PORT = 6379;
-
-    @Value("${spring.redis.primary}")
-    private String primaryEndpoint;
-
-    @Value("${spring.redis.reader}")
-    private String readerEndpoint;
-
-    @Bean
-    public LettuceConnectionFactory redisConnectionFactory() {
-        LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
-                .readFrom(ReadFrom.REPLICA_PREFERRED)
-                .build();
-        var staticMasterReplicaConfiguration = new RedisStaticMasterReplicaConfiguration(this.primaryEndpoint, PORT);
-        staticMasterReplicaConfiguration.addNode(readerEndpoint, PORT);
-        return new LettuceConnectionFactory(staticMasterReplicaConfiguration, clientConfig);
-    }
 
 }

spring-boot/caching-with-elasticache-redis/src/main/java/io/reflectoring/springcloudredis/controller/UserController.java

@@ -0,0 +1,24 @@
+package io.reflectoring.springcloudredis.controller;
+
+import io.reflectoring.springcloudredis.entity.User;
+import io.reflectoring.springcloudredis.service.UserService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Slf4j(topic = "PRODUCT_CONTROLLER")
+@RestController
+@RequestMapping("/user")
+@AllArgsConstructor
+public class UserController {
+
+    private final UserService userService;
+
+    @GetMapping("/{id}")
+    public User getUser(@PathVariable String id) {
+        return userService.getUser(id);
+    }
+}

spring-boot/caching-with-elasticache-redis/src/main/java/io/reflectoring/springcloudredis/entity/User.java

@@ -0,0 +1,20 @@
+package io.reflectoring.springcloudredis.entity;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import java.io.Serializable;
+
+@Entity
+@Getter
+@Setter
+public class User implements Serializable {
+    @Id
+    private String id;
+
+    private String firstName;
+
+    private String lastName;
+}

spring-boot/caching-with-elasticache-redis/src/main/java/io/reflectoring/springcloudredis/repository/UserRepository.java

@@ -0,0 +1,9 @@
+package io.reflectoring.springcloudredis.repository;
+
+import io.reflectoring.springcloudredis.entity.User;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface UserRepository extends JpaRepository<User, String> {
+}

spring-boot/caching-with-elasticache-redis/src/main/java/io/reflectoring/springcloudredis/service/ProductService.java

@@ -15,7 +15,7 @@
 
 @Service
 @AllArgsConstructor
-@CacheConfig(cacheNames = "product")
+@CacheConfig(cacheNames = "product-cache")
 public class ProductService {
     private final ProductRepository repository;
 

spring-boot/caching-with-elasticache-redis/src/main/java/io/reflectoring/springcloudredis/service/UserService.java

@@ -0,0 +1,22 @@
+package io.reflectoring.springcloudredis.service;
+
+import io.reflectoring.springcloudredis.entity.User;
+import io.reflectoring.springcloudredis.repository.UserRepository;
+import lombok.AllArgsConstructor;
+import org.springframework.cache.annotation.CacheConfig;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Service;
+
+@Service
+@AllArgsConstructor
+@CacheConfig(cacheNames = "product-cache")
+public class UserService {
+
+    private final UserRepository repository;
+
+    @Cacheable
+    public User getUser(String id){
+        return repository.findById(id).orElseThrow(()->
+                new RuntimeException("No such user found with id"));
+    }
+}

spring-boot/caching-with-elasticache-redis/src/main/resources/application.yaml

@@ -3,22 +3,22 @@ spring:
     initialization-mode: always
   application:
     name: spring-cloud-redis
-  cache:
-    type: redis
-    redis:
-      time-to-live: 60000
-  redis:
-    primary: spring-redis-cluster.xxx.ng.0001.use2.cache.amazonaws.com
-    reader: spring-redis-cluster-ro.xxx.ng.0001.use2.cache.amazonaws.com
   jpa:
     show-sql: true
     generate-ddl: true
     hibernate:
       ddl-auto: create-drop
-#  redis:
-#    cluster:
-#      nodes: spring-redis-cluster.xxx.clustercfg.use2.cache.amazonaws.com:6379
-#    lettuce:
-#      cluster:
-#        refresh:
-#          period: PT10M
+#cloud:
+#  aws:
+#    stack:
+#      name: spring-cache-2
+cloud:
+  aws:
+    elasticache:
+      clusters:
+        -
+          name: product-cache
+          expiration: 100
+        -
+          name: user-cache
+          expiration: 6000

spring-boot/caching-with-elasticache-redis/src/main/resources/data.sql

@@ -27,3 +27,13 @@ insert into product
 (id, name, price, manufacturing_date,  weight, height, width,  category)
 values
 ('prod_6', 'zara jacket green color', 1500, now(),  1.3, 10.4, 29.5,  'MEN_FASHION');
+
+insert into user
+(id, first_name, last_name)
+values
+('user_1', 'john', 'doe');
+
+insert into user
+(id, first_name, last_name)
+values
+('user_2', 'richard', 'mayor');