修改配置格式并增加redis的json序列化

Author: ms100

README.md

@@ -298,8 +298,9 @@ spring:
   cache:
     redis:
       time-to-live: PT15M  #默认缓存15分钟
-      cache-name-time-to-live: #缓存key的缓存时间
-        maps:
+      cache-as-multi:
+        serialize-to-json: true #使用 RedisSerializer.json() 序列化
+        cache-name-time-to-live-map: #cacheName对应的缓存时间
           foo: PT15S  #foo缓存15秒
           demo: PT5M  #demo缓存5分钟
 ```

cache-as-multi-sample/src/main/java/io/github/ms100/cacheasmultisample/cache/DogController.java

@@ -0,0 +1,37 @@
+package io.github.ms100.cacheasmultisample.cache;
+
+import io.github.ms100.cacheasmultisample.cache.service.Dog;
+import io.github.ms100.cacheasmultisample.cache.service.DogService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/dog")
+public class DogController {
+
+    private final DogService dogService;
+
+    @RequestMapping("/getDog")
+    public Dog getDog(@RequestParam("id") Long dogId) {
+        return dogService.getDog(dogId);
+    }
+
+
+    @RequestMapping("/getDogs")
+    public Map<Long, Dog> getDogs(@RequestParam("ids") Long[] dogIds) {
+        return dogService.getDogs(Arrays.asList(dogIds));
+    }
+
+    @RequestMapping("/getDogList")
+    public List<Dog> getDogList(@RequestParam("ids") Long[] dogIds) {
+        return dogService.getDogList(Arrays.asList(dogIds));
+    }
+
+}

cache-as-multi-sample/src/main/java/io/github/ms100/cacheasmultisample/cache/service/Dog.java

@@ -0,0 +1,9 @@
+package io.github.ms100.cacheasmultisample.cache.service;
+
+import lombok.Data;
+
+@Data
+public class Dog {
+    private Long id;
+    private String name;
+}

cache-as-multi-sample/src/main/java/io/github/ms100/cacheasmultisample/cache/service/DogService.java

@@ -0,0 +1,16 @@
+package io.github.ms100.cacheasmultisample.cache.service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author zhumengshuai
+ */
+public interface DogService {
+    Dog getDog(Long dogId);
+
+    Map<Long, Dog> getDogs(List<Long> dogIds);
+
+    List<Dog> getDogList(List<Long> dogIds);
+
+}

cache-as-multi-sample/src/main/java/io/github/ms100/cacheasmultisample/cache/service/DogServiceImpl.java

@@ -0,0 +1,58 @@
+package io.github.ms100.cacheasmultisample.cache.service;
+
+import io.github.ms100.cacheasmulti.cache.annotation.CacheAsMulti;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.CacheConfig;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+@CacheConfig(cacheNames = "dog")
+class DogServiceImpl implements DogService {
+
+    @Override
+    @Cacheable
+    public Dog getDog(Long dogId) {
+        log.info("getDog: {}", dogId);
+        return createDog(dogId);
+    }
+
+    @Override
+    @Cacheable
+    public Map<Long, Dog> getDogs(@CacheAsMulti List<Long> dogIds) {
+        log.info("getDogs: {}", dogIds);
+        Map<Long, Dog> res = new HashMap<>();
+        for (Long dogId : dogIds) {
+            res.put(dogId, createDog(dogId));
+        }
+        return res;
+    }
+
+    @Override
+    @Cacheable
+    public List<Dog> getDogList(@CacheAsMulti List<Long> dogIds) {
+        log.info("getDogList: {}", dogIds);
+        List<Dog> res = new ArrayList<>();
+        for (Long dogId : dogIds) {
+            res.add(createDog(dogId));
+        }
+        return res;
+    }
+
+    private Dog createDog(Long id) {
+        Dog dog = new Dog();
+        dog.setId(id);
+        dog.setName("name" + id);
+
+        return dog;
+    }
+
+}

cache-as-multi-sample/src/main/resources/application.yaml

@@ -7,14 +7,17 @@ spring:
   redis:
     host: 127.0.0.1
     port: 6379
+    password: 123456
   cache:
     redis:
       time-to-live: PT15M
-      cache-name-time-to-live:
-        maps:
+      cache-as-multi:
+        serialize-to-json: true
+        cache-name-time-to-live-map:
           foo: PT15S
           demo: PT5M
           newBar: PT1M
+          dog: PT1M
 
 server:
   tomcat:

cache-as-multi/pom.xml

@@ -5,7 +5,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>io.github.ms100</groupId>
   <artifactId>cache-as-multi</artifactId>
-  <version>1.0.0</version>
+  <version>1.1.0</version>
 
   <name>cache-as-multi</name>
   <url>http://https://github.com/ms100/cache-as-multi</url>
@@ -53,6 +53,11 @@
       <artifactId>spring-boot-starter-data-redis</artifactId>
       <optional>true</optional>
     </dependency>
+    <dependency>
+      <groupId>com.fasterxml.jackson.core</groupId>
+      <artifactId>jackson-databind</artifactId>
+      <optional>true</optional>
+    </dependency>
     <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-configuration-processor</artifactId>

cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/config/EnhancedCacheAutoConfiguration.java

@@ -3,7 +3,7 @@
 import io.github.ms100.cacheasmulti.cache.convert.EnhancedCacheConversionService;
 import io.github.ms100.cacheasmulti.cache.convert.converter.EnhancedCacheConverter;
 import io.github.ms100.cacheasmulti.jcache.config.EnhancedJCacheConfiguration;
-import io.github.ms100.cacheasmulti.support.RedisCacheNameTimeToLiveCustomizer;
+import io.github.ms100.cacheasmulti.support.RedisCacheCustomizer;
 import io.github.ms100.cacheasmulti.support.TypeMethodKeyGenerator;
 import org.springframework.beans.factory.config.BeanDefinition;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
@@ -63,8 +63,8 @@ public TypeMethodKeyGenerator typeMethodKeyGenerator() {
     @Bean
     @ConditionalOnClass(name = "org.springframework.data.redis.cache.RedisCacheManager")
     @ConditionalOnMissingBean
-    @ConfigurationProperties(prefix = "spring.cache.redis.cache-name-time-to-live")
-    public RedisCacheNameTimeToLiveCustomizer redisCacheNameTimeToLiveCustomizer() {
-        return new RedisCacheNameTimeToLiveCustomizer();
+    @ConfigurationProperties(prefix = "spring.cache.redis.cache-as-multi")
+    public RedisCacheCustomizer redisCacheCustomizer() {
+        return new RedisCacheCustomizer();
     }
 }

cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/support/RedisCacheCustomizer.java

@@ -0,0 +1,48 @@
+package io.github.ms100.cacheasmulti.support;
+
+import lombok.Setter;
+import org.springframework.boot.autoconfigure.cache.RedisCacheManagerBuilderCustomizer;
+import org.springframework.data.redis.cache.RedisCacheConfiguration;
+import org.springframework.data.redis.cache.RedisCacheManager;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
+import org.springframework.data.redis.serializer.RedisSerializer;
+
+import java.time.Duration;
+import java.util.Collections;
+import java.util.Map;
+
+/**
+ * @author zhumengshuai
+ */
+public class RedisCacheCustomizer implements RedisCacheManagerBuilderCustomizer {
+    /**
+     * 使用 RedisSerializer.json 序列化
+     */
+    @Setter
+    private boolean serializeToJson = false;
+    /**
+     * CacheName 对应的 TTL(PT 时间格式)
+     */
+    @Setter
+    private Map<String, Duration> cacheNameTimeToLiveMap = Collections.emptyMap();
+
+    @Override
+    public void customize(RedisCacheManager.RedisCacheManagerBuilder builder) {
+        //用一个假的 cacheName 获取到默认的 RedisCacheConfiguration
+        builder.initialCacheNames(Collections.singleton("*"));
+        RedisCacheConfiguration defaultCacheConfiguration = builder.getCacheConfigurationFor("*")
+                .orElseThrow(NullPointerException::new);
+
+        if (serializeToJson) {
+            defaultCacheConfiguration = defaultCacheConfiguration.serializeValuesWith(
+                    RedisSerializationContext.SerializationPair.fromSerializer(RedisSerializer.json()));
+            builder.cacheDefaults(defaultCacheConfiguration);
+        }
+        RedisCacheConfiguration finalDefaultCacheConfiguration = defaultCacheConfiguration;
+        cacheNameTimeToLiveMap.forEach((cacheName, ttl) -> {
+            RedisCacheConfiguration configuration = finalDefaultCacheConfiguration.entryTtl(ttl);
+            builder.withCacheConfiguration(cacheName, configuration);
+        });
+    }
+
+}