update redis, h2 configuration

Author: codej99

src/main/java/com/redis/cluster/RedisClusterApplication.java

@@ -1,11 +1,20 @@
 package com.redis.cluster;
 
+import com.redis.cluster.common.CacheKey;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.context.annotation.Bean;
-import org.springframework.security.crypto.factory.PasswordEncoderFactories;
-import org.springframework.security.crypto.password.PasswordEncoder;
+import org.springframework.data.redis.cache.CacheKeyPrefix;
+import org.springframework.data.redis.cache.RedisCacheConfiguration;
+import org.springframework.data.redis.cache.RedisCacheManager;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+import java.time.Duration;
+import java.util.HashMap;
+import java.util.Map;
 
 @SpringBootApplication
 @EnableCaching
@@ -15,8 +24,21 @@ public static void main(String[] args) {
         SpringApplication.run(RedisClusterApplication.class, args);
     }
 
-    @Bean
-    public PasswordEncoder passwordEncoder() {
-        return PasswordEncoderFactories.createDelegatingPasswordEncoder();
+    // https://stackoverflow.com/questions/51660160/set-expire-key-at-specific-time-when-using-spring-caching-with-redis
+    @Bean(name = "cacheManager")
+    public RedisCacheManager cacheManager(RedisConnectionFactory connectionFactory) {
+
+        RedisCacheConfiguration configuration = RedisCacheConfiguration.defaultCacheConfig()
+                .disableCachingNullValues()
+                .entryTtl(Duration.ofSeconds(CacheKey.DEFAULT_EXPIRE_SEC))
+                .computePrefixWith(CacheKeyPrefix.simple())
+                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()));
+
+        Map<String, RedisCacheConfiguration> cacheConfigurations = new HashMap<>();
+        cacheConfigurations.put(CacheKey.USER_SINGLE, RedisCacheConfiguration.defaultCacheConfig()
+                .entryTtl(Duration.ofSeconds(CacheKey.USER_SINGLE_EXPIRE_SEC)));
+
+        return RedisCacheManager.RedisCacheManagerBuilder.fromConnectionFactory(connectionFactory).cacheDefaults(configuration)
+                .withInitialCacheConfigurations(cacheConfigurations).build();
     }
 }

src/main/java/com/redis/cluster/common/CacheKey.java

@@ -0,0 +1,11 @@
+package com.redis.cluster.common;
+
+public class CacheKey {
+
+    private CacheKey() {
+    }
+
+    public static final int DEFAULT_EXPIRE_SEC = 60;
+    public static final String USER_SINGLE = "user-single";
+    public static final int USER_SINGLE_EXPIRE_SEC = 180;
+}

src/main/java/com/redis/cluster/config/EmbededH2Config.java

@@ -0,0 +1,18 @@
+package com.redis.cluster.config;
+
+import org.h2.tools.Server;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+
+import java.sql.SQLException;
+
+@Configuration
+@Profile("local")
+public class EmbededH2Config {
+    @Bean
+    public Server h2TcpServer() throws SQLException {
+        return Server.createTcpServer()
+                .start();
+    }
+}

src/main/java/com/redis/cluster/controller/RedisController.java

@@ -1,45 +1,47 @@
 package com.redis.cluster.controller;
 
+import com.redis.cluster.common.CacheKey;
 import com.redis.cluster.entity.User;
 import com.redis.cluster.repo.UserJpaRepo;
 import lombok.RequiredArgsConstructor;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.core.ValueOperations;
-import org.springframework.security.crypto.password.PasswordEncoder;
+import org.springframework.cache.annotation.CachePut;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.ArrayList;
-import java.util.Collection;
 import java.util.Collections;
-import java.util.List;
 
 @RequiredArgsConstructor
 @RequestMapping("/redis")
 @RestController
 public class RedisController {
 
-    private final RedisTemplate<String, String> redisTemplate;
     private final UserJpaRepo userJpaRepo;
-    private final PasswordEncoder passwordEncoder;
-
-    @GetMapping("/ops/value")
-    public List<String> redisClusterTest() {
-        ValueOperations<String, String> valueOps = redisTemplate.opsForValue();
-        Collection<String> keys = new ArrayList<>();
-        for (int i = 0; i < 10; i++) {
-            keys.add("valueOps_" + i);
-            valueOps.set("valueOps_" + i, String.valueOf(i));
-        }
-        return valueOps.multiGet(keys);
+    private static final String UID = "strongdaddy@naver.com";
+
+    @Cacheable(value = CacheKey.USER_SINGLE, key = "#uid", unless = "#result == null")
+    @GetMapping("/user/{uid}")
+    public User findOne(@PathVariable String uid) {
+        return userJpaRepo.findByUid(uid).orElse(null);
     }
 
-    @PostMapping("/post/user")
-    public void redisClusterPostUser() {
+    @PostMapping("/user")
+    @ResponseBody
+    public User postUser() {
         userJpaRepo.save(User.builder()
-                .uid("strongdaddy@naver.com")
-                .password(passwordEncoder.encode("1234"))
+                .uid(UID)
+                .password("1234")
                 .name("strongdaddy")
                 .roles(Collections.singletonList("ROLE_USER"))
                 .build());
+
+        return userJpaRepo.findByUid(UID).orElse(null);
+    }
+
+    @CachePut(value = CacheKey.USER_SINGLE, key = "#user.uid")
+    @PutMapping("/user")
+    @ResponseBody
+    public User putUser(@RequestBody User user) {
+        userJpaRepo.save(user);
+        return userJpaRepo.findByUid(UID).orElse(null);
     }
 }