update

Author: kimmking

08cache/cache/pom.xml

@@ -49,6 +49,18 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-cache</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-redis</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>io.lettuce</groupId>
+			<artifactId>lettuce-core</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-pool2</artifactId>
+		</dependency>
 		<dependency>
 			<groupId>net.sf.ehcache</groupId>
 			<artifactId>ehcache</artifactId>

08cache/cache/src/main/java/io/kimmking/cache/CacheApplication.java

@@ -3,9 +3,11 @@
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
 
 @SpringBootApplication(scanBasePackages = "io.kimmking.cache")
 @MapperScan("io.kimmking.cache.mapper")
+@EnableCaching
 public class CacheApplication {
 
 	public static void main(String[] args) {

08cache/cache/src/main/java/io/kimmking/cache/CacheConfig.java

@@ -0,0 +1,83 @@
+package io.kimmking.cache;
+
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.annotation.CachingConfigurerSupport;
+import org.springframework.cache.interceptor.*;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+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.core.RedisTemplate;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+import javax.annotation.Resource;
+
+import static org.springframework.data.redis.cache.RedisCacheConfiguration.defaultCacheConfig;
+
+@Configuration
+public class CacheConfig extends CachingConfigurerSupport {
+
+    @Resource
+    private RedisConnectionFactory factory;
+
+    /**
+     * 自定义生成redis-key
+     *
+     * @return
+     */
+    @Override
+    @Bean
+    public KeyGenerator keyGenerator() {
+        return (o, method, objects) -> {
+            StringBuilder sb = new StringBuilder();
+            sb.append(o.getClass().getName()).append(".");
+            sb.append(method.getName()).append(".");
+            for (Object obj : objects) {
+                sb.append(obj.toString());
+            }
+            //System.out.println("keyGenerator=" + sb.toString());
+            return sb.toString();
+        };
+    }
+
+    @Bean
+    public RedisTemplate<Object, Object> redisTemplate() {
+        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setConnectionFactory(factory);
+
+        GenericJackson2JsonRedisSerializer genericJackson2JsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
+
+        redisTemplate.setKeySerializer(genericJackson2JsonRedisSerializer);
+        redisTemplate.setValueSerializer(genericJackson2JsonRedisSerializer);
+
+        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
+        redisTemplate.setHashValueSerializer(genericJackson2JsonRedisSerializer);
+        return redisTemplate;
+    }
+
+    @Bean
+    @Override
+    public CacheResolver cacheResolver() {
+        return new SimpleCacheResolver(cacheManager());
+    }
+
+    @Bean
+    @Override
+    public CacheErrorHandler errorHandler() {
+        // 用于捕获从Cache中进行CRUD时的异常的回调处理器。
+        return new SimpleCacheErrorHandler();
+    }
+
+    @Bean
+    @Override
+    public CacheManager cacheManager() {
+        RedisCacheConfiguration cacheConfiguration =
+                defaultCacheConfig()
+                        .disableCachingNullValues()
+                        .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));
+        return RedisCacheManager.builder(factory).cacheDefaults(cacheConfiguration).build();
+    }
+}

08cache/cache/src/main/java/io/kimmking/cache/entity/User.java

@@ -4,10 +4,12 @@
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
+import java.io.Serializable;
+
 @Data
 @NoArgsConstructor
 @AllArgsConstructor
-public class User {
+public class User implements Serializable {
     private Integer id;
     private String  name;
     private Integer age;

08cache/cache/src/main/java/io/kimmking/cache/service/UserServiceImpl.java

@@ -15,13 +15,13 @@ public class UserServiceImpl implements UserService {
     UserMapper userMapper;
 
     // 开启spring cache
-    @Cacheable(key="#id",value="userCache")
+    @Cacheable //(key="#id",value="userCache")
     public User find(int id) {
         return userMapper.find(id);
     }
 
     // 开启spring cache
-    @Cacheable(key="LIST",value="userCache")
+    @Cacheable //(key="methodName",value="userCache")
     public List<User> list(){
         return userMapper.list();
     }

08cache/cache/src/main/resources/application.yml

@@ -7,6 +7,18 @@ spring:
     password:
     url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC
     driver-class-name: com.mysql.jdbc.Driver
+#  cache:
+#    type: redis
+  redis:
+    host: localhost
+    lettuce:
+      pool:
+        max-active: 32
+        max-wait: 10ms
+
+#    type: ehcache
+#    ehcache:
+#      config: ehcache.xml
 
 mybatis:
   mapper-locations: classpath:mapper/*Mapper.xml

08cache/cache/src/main/resources/mapper/UserMapper.xml

@@ -3,9 +3,9 @@
 <mapper namespace="io.kimmking.cache.mapper.UserMapper">
 
 <!--    开启mybatis cache  -->
-    <cache type="org.mybatis.caches.ehcache.LoggingEhcache">
-        <property name="memoryStoreEvictionPolicy" value="LRU"/>
-    </cache>
+<!--    <cache type="org.mybatis.caches.ehcache.LoggingEhcache">-->
+<!--        <property name="memoryStoreEvictionPolicy" value="LRU"/>-->
+<!--    </cache>-->
 
     <resultMap id="BaseResultMap" type="io.kimmking.cache.entity.User">
         <result column="id" jdbcType="INTEGER" property="id" />