Redis 配置测试

Author: itwanger

codingmore-admin/src/test/java/com/codingmore/CacheDemoService.java

@@ -0,0 +1,14 @@
+package com.codingmore;
+
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.cache.annotation.Caching;
+
+/**
+ * 微信搜索「沉默王二」，回复 Java
+ *
+ * @author 沉默王二
+ * @date 6/16/22
+ */
+public interface CacheDemoService {
+    Object getFromDB(Integer id);
+}

codingmore-admin/src/test/java/com/codingmore/CacheDemoServiceImpl.java

@@ -0,0 +1,25 @@
+package com.codingmore;
+
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.cache.annotation.Caching;
+import org.springframework.stereotype.Service;
+
+/**
+ * 微信搜索「沉默王二」，回复 Java
+ *
+ * @author 沉默王二
+ * @date 6/16/22
+ */
+@Service
+public class CacheDemoServiceImpl implements CacheDemoService {
+
+
+    @Caching(cacheable = {
+            @Cacheable(cacheNames = "demoCache", key = "#id + 0"),
+    })
+    @Override
+    public Object getFromDB(Integer id) {
+        System.out.println("模拟去db查询~~~" + id);
+        return "hello cache...";
+    }
+}

codingmore-admin/src/test/java/com/codingmore/CodingmoreRedisApplicationTests.java

@@ -0,0 +1,44 @@
+package com.codingmore;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.cache.Cache;
+import org.springframework.data.redis.cache.RedisCacheManager;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.StringRedisTemplate;
+
+import javax.annotation.Resource;
+
+/**
+ * 微信搜索「沉默王二」，回复 Java
+ *
+ * @author 沉默王二
+ * @date 6/16/22
+ */
+@SpringBootTest
+class CodingmoreRedisApplicationTests {
+    @Resource
+    private RedisTemplate redisTemplate;
+
+    @Resource
+    private StringRedisTemplate stringRedisTemplate;
+
+    @Autowired
+    private CacheDemoService cacheDemoService;
+
+    @Autowired
+    private RedisCacheManager cacheManager;
+
+    @Test
+    public void testRedis() {
+        cacheDemoService.getFromDB(3);
+
+        System.out.println("----------验证缓存是否生效----------");
+        Cache cache = cacheManager.getCache("demoCache");
+        System.out.println(cache.get(1, String.class));
+
+    }
+
+}
+

codingmore-admin/src/test/resources/application.yml

@@ -1,3 +1,4 @@
+# Spring Boot 配置
 spring:
   profiles:
     active: dev #默认为开发环境
@@ -9,9 +10,11 @@ spring:
     date-format: yyyy-MM-dd HH:mm:ss
     time-zone: GMT+8
 
+# 端口号
 server:
-  port: 8080
+  port: 9002
 
+# MyBatis plus 的配置查询后写注释
 mybatis-plus:
   mapper-locations:
     - classpath:dao/*.xml
@@ -23,52 +26,35 @@ mybatis-plus:
     map-underscore-to-camel-case: true
     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
 
-ignored:
-  urls: #安全路径白名单
-    - /doc.html
-    - /swagger-ui/**
-    - /swagger/**
-    - /swagger-resources/**
-    - /**/v3/api-docs
-    - /**/*.js
-    - /**/*.css
-    - /**/*.png
-    - /**/*.ico
-    - /webjars/springfox-swagger-ui/**
-    - /actuator/**
-    - /druid/**
-    - /users/login
-    - /users/register
-    - /users/info
-    - /users/logout
-    - /minio/upload
+# 自定义类 ignoreConfig，URL 的白名单
+secure:
+  ignored:
+    urls: #安全路径白名单
+      - /doc.html
+      - /swagger-ui/**
+      - /swagger/**
+      - /swagger-resources/**
+      - /**/v3/api-docs
+      - /**/*.js
+      - /**/*.css
+      - /**/*.png
+      - /**/*.ico
+      - /webjars/springfox-swagger-ui/**
+      - /actuator/**
+      - /druid/**
+      - /users/login
+      - /users/register
+      - /users/info
+      - /users/logout
+      - /minio/upload
 
 # 登录认证 token filter
 jwt:
   tokenHeader: Authorization #JWT存储的请求头
-  secret: learn-admin-secret #JWT加解密使用的密钥
+  secret: codingmore-admin-secret #JWT加解密使用的密钥
   expiration: 604800 #JWT的超期限时间(60*60*24*7)
   tokenHead: 'Bearer '  #JWT负载中拿到开头
 
-
-  # oss
-aliyun:
-  oss:
-      # oss对外服务的访问域名
-    endpoint: oss-cn-beijing.aliyuncs.com
-      # 访问身份验证中用到用户标识
-    accessKeyId: LTAI5t924wYTNT9dQoAWGDKa
-      # 用户用于加密签名字符串和oss用来验证签名字符串的密钥
-    accessKeySecret: RYNmqo4yZdTXbPcuQVE4jK9ax0HRLM
-      # oss的存储空间
-    bucketName: itwanger-oss
-      # 上传文件大小(M)
-    maxSize: 3
-      # 上传文件夹路径前缀
-    dir:
-      prefix: codingmore/images/
-
-
 #异步线程配置
 async:
   executor:
@@ -81,4 +67,9 @@ async:
     #设置线程活跃时间（秒）
     keepAliveSeconds: 360
     #设置默认线程名称
-    threadNamePrefix: upload-image-thread-
+    threadNamePrefix: sync-thread-
+
+# 文章定时发布的最小间隔
+post:
+  schedule:
+    minInterval: 10

codingmore-mbg/src/main/java/com/codingmore/config/RedisConfig.java

@@ -5,6 +5,8 @@
 import com.fasterxml.jackson.annotation.PropertyAccessor;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.CacheManager;
 import org.springframework.cache.annotation.CachingConfigurerSupport;
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.context.annotation.Bean;
@@ -20,13 +22,16 @@
 import org.springframework.data.redis.serializer.StringRedisSerializer;
 
 import java.time.Duration;
+import java.util.HashMap;
+import java.util.Map;
 
 /**
  * Redis配置类
  * Created by zhanglei on 2020/3/2.
  */
 @EnableCaching
 @Configuration
+@Slf4j
 public class RedisConfig extends CachingConfigurerSupport {
 
     @Bean
@@ -67,12 +72,22 @@ public RedisSerializer<Object> redisSerializer() {
     }
 
     @Bean
-    public RedisCacheManager redisCacheManager(RedisConnectionFactory redisConnectionFactory) {
-        RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory);
-        //设置Redis缓存有效期为1天
-        RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
-                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer())).entryTtl(Duration.ofDays(1));
-        return new RedisCacheManager(redisCacheWriter, redisCacheConfiguration);
+    public CacheManager redisCacheManager(RedisConnectionFactory redisConnectionFactory) {
+        RedisCacheConfiguration defaultCacheConfig = RedisCacheConfiguration.defaultCacheConfig()
+                .entryTtl(Duration.ofDays(1)) // 默认没有特殊指定的
+                .computePrefixWith(cacheName -> "caching:" + cacheName);
+
+        // 针对不同cacheName，设置不同的过期时间
+        Map<String, RedisCacheConfiguration> initialCacheConfiguration = new HashMap<String, RedisCacheConfiguration>() {{
+            put("demoCache", RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofMillis(20*1000)));
+            // ...
+        }};
+
+        RedisCacheManager redisCacheManager = RedisCacheManager.builder(redisConnectionFactory)
+                .cacheDefaults(defaultCacheConfig) // 默认配置（强烈建议配置上）。  比如动态创建出来的都会走此默认配置
+                .withInitialCacheConfigurations(initialCacheConfiguration) // 不同cache的个性化配置
+                .build();
+        return redisCacheManager;
     }
 
 }