feat: add redis for spring cache

Author: easepan

src/main/java/org/code4everything/boot/cache/AbstractCache.java

@@ -0,0 +1,69 @@
+package org.code4everything.boot.cache;
+
+import org.code4everything.boot.config.BootConfig;
+import org.code4everything.boot.web.mvc.exception.ExceptionFactory;
+import org.springframework.cache.Cache;
+import org.springframework.cache.support.SimpleValueWrapper;
+import org.springframework.http.HttpStatus;
+
+import java.util.Objects;
+import java.util.concurrent.Callable;
+
+/**
+ * @author pantao
+ * @since 2019/6/14
+ **/
+public abstract class AbstractCache implements Cache {
+
+    private final String name;
+
+    private final Object nativeCache;
+
+    public AbstractCache(String name, Object nativeCache) {
+        this.name = name;
+        this.nativeCache = nativeCache;
+    }
+
+    @Override
+    public String getName() {
+        return name;
+    }
+
+    @Override
+    public Object getNativeCache() {
+        return nativeCache;
+    }
+
+    @Override
+    public ValueWrapper putIfAbsent(Object key, Object value) {
+        ValueWrapper wrapper = get(key);
+        if (Objects.isNull(wrapper)) {
+            put(key, value);
+        }
+        return wrapper;
+    }
+
+    protected ValueWrapper wrapValueIfNotNull(Object value) {
+        return Objects.isNull(value) ? null : new SimpleValueWrapper(value);
+    }
+
+    @SuppressWarnings("unchecked")
+    protected <T> T convert2(Object value, Class<T> type) {
+        return Objects.isNull(value) ? null : (T) value;
+    }
+
+    @SuppressWarnings("unchecked")
+    protected <T> T convert2(Object value, Callable<T> valueLoader) {
+        if (Objects.isNull(value)) {
+            try {
+                return valueLoader.call();
+            } catch (Exception e) {
+                if (BootConfig.isDebug()) {
+                    throw ExceptionFactory.exception(HttpStatus.INTERNAL_SERVER_ERROR, "value loader error");
+                }
+                return null;
+            }
+        }
+        return (T) value;
+    }
+}

src/main/java/org/code4everything/boot/cache/redis/RedisCache.java

@@ -0,0 +1,74 @@
+package org.code4everything.boot.cache.redis;
+
+import org.code4everything.boot.cache.AbstractCache;
+import org.springframework.data.redis.core.RedisTemplate;
+
+import java.util.Date;
+import java.util.concurrent.Callable;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Redis缓存
+ *
+ * @author pantao
+ * @since 2019/6/14
+ **/
+public class RedisCache extends AbstractCache {
+
+    private final RedisTemplate<String, Object> redisTemplate;
+
+    private final String keyPrefix;
+
+    private final long timeout;
+
+    public RedisCache(String name, RedisTemplate<String, Object> redisTemplate) {
+        this(name, redisTemplate, Long.MAX_VALUE, name);
+    }
+
+    public RedisCache(String name, RedisTemplate<String, Object> redisTemplate, long timeout) {
+        this(name, redisTemplate, timeout, name);
+    }
+
+    public RedisCache(String name, RedisTemplate<String, Object> redisTemplate, long timeout, String keyPrefix) {
+        super(name, redisTemplate);
+        this.keyPrefix = keyPrefix + ":";
+        this.timeout = timeout;
+        this.redisTemplate = redisTemplate;
+    }
+
+    @Override
+    public ValueWrapper get(Object key) {
+        return wrapValueIfNotNull(redisTemplate.opsForValue().get(keyPrefix + key));
+    }
+
+    @Override
+    public <T> T get(Object key, Class<T> type) {
+        return convert2(redisTemplate.opsForValue().get(keyPrefix + key), type);
+    }
+
+    @Override
+    public <T> T get(Object key, Callable<T> valueLoader) {
+        return convert2(redisTemplate.opsForValue().get(keyPrefix + key), valueLoader);
+    }
+
+    @Override
+    public void put(Object key, Object value) {
+        String newKey = keyPrefix + key;
+        redisTemplate.opsForValue().set(newKey, value);
+        redisTemplate.expire(newKey, timeout, TimeUnit.SECONDS);
+    }
+
+    @Override
+    public void evict(Object key) {
+        redisTemplate.delete(keyPrefix + key);
+    }
+
+    @Override
+    public void clear() {
+        redisTemplate.delete(redisTemplate.keys(keyPrefix + "*"));
+    }
+
+    public void expireAt(String key, Date date) {
+        redisTemplate.expireAt(keyPrefix + key, date);
+    }
+}

src/main/java/org/code4everything/boot/cache/redis/RedisCacheCreator.java

@@ -0,0 +1,43 @@
+package org.code4everything.boot.cache.redis;
+
+import org.code4everything.boot.cache.CacheCreator;
+import org.code4everything.boot.module.redis.RedisTemplateUtils;
+
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * Redis缓存创建者
+ *
+ * @author pantao
+ * @since 2019/6/14
+ **/
+public class RedisCacheCreator implements CacheCreator {
+
+    private final long timeout;
+
+    private final Map<String, String> prefixMap;
+
+    public RedisCacheCreator() {
+        this(Long.MAX_VALUE, null);
+    }
+
+    public RedisCacheCreator(Map<String, String> prefixMap) {
+        this(Long.MAX_VALUE, prefixMap);
+    }
+
+    public RedisCacheCreator(long timeout) {
+        this(timeout, null);
+    }
+
+    public RedisCacheCreator(long timeout, Map<String, String> prefixMap) {
+        this.timeout = timeout;
+        this.prefixMap = prefixMap;
+    }
+
+    @Override
+    public RedisCache createCache(String cacheName) {
+        String prefix = Objects.isNull(prefixMap) ? cacheName : prefixMap.getOrDefault(cacheName, cacheName);
+        return new RedisCache(cacheName, RedisTemplateUtils.newTemplate(), timeout, prefix);
+    }
+}

src/main/java/org/code4everything/boot/cache/redis/RedisCacheManager.java

@@ -0,0 +1,41 @@
+package org.code4everything.boot.cache.redis;
+
+import cn.hutool.core.util.ObjectUtil;
+import org.code4everything.boot.cache.BootCacheManager;
+import org.springframework.cache.Cache;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Date;
+
+/**
+ * Redis缓存管理器
+ *
+ * @author pantao
+ * @since 2019/6/14
+ **/
+public class RedisCacheManager extends BootCacheManager {
+
+    public RedisCacheManager(RedisCacheCreator redisCacheCreator) {
+        this(redisCacheCreator, 16);
+    }
+
+    public RedisCacheManager(RedisCacheCreator redisCacheCreator, int capacity) {
+        super(redisCacheCreator, capacity);
+    }
+
+    public RedisCacheManager(Collection<RedisCache> caches, RedisCacheCreator redisCacheCreator) {
+        super(new ArrayList<>(caches), redisCacheCreator);
+    }
+
+    public RedisCacheManager(Collection<RedisCache> caches) {
+        this(caches, null);
+    }
+
+    public void expireAt(String cacheName, String key, Date date) {
+        Cache cache = getCache(cacheName);
+        if (ObjectUtil.isNotNull(cache)) {
+            ((RedisCache) cache).expireAt(key, date);
+        }
+    }
+}

src/test/java/org/code4everything/boot/common/JsonTest.java

@@ -0,0 +1,21 @@
+package org.code4everything.boot.common;
+
+import cn.hutool.core.lang.Console;
+import com.alibaba.fastjson.JSONObject;
+import com.google.common.collect.Lists;
+import org.junit.Test;
+
+import java.util.List;
+
+/**
+ * @author pantao
+ * @since 2019/6/14
+ **/
+public class JsonTest {
+
+    @Test
+    public void testJson() {
+        List<String> list = Lists.newArrayList("a", "b", "c");
+        Console.log(JSONObject.parse(JSONObject.toJSONString(list)));
+    }
+}