refactor: test redis

src/main/java/com/gm/wj/WjApplication.java

@@ -2,7 +2,9 @@ package com.gm.wj;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
 
+@EnableCaching
 @SpringBootApplication
 public class WjApplication {
 

src/main/java/com/gm/wj/config/RedisConfig.java

+package com.gm.wj.config;
+
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.PropertyAccessor;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.cache.annotation.CachingConfigurerSupport;
+import org.springframework.cache.annotation.EnableCaching;
+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.cache.RedisCacheWriter;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
+import org.springframework.data.redis.serializer.RedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+import java.time.Duration;
+
+/**
+ * @author Evan
+ * @date 2020/4/23 21:51
+ */
+@EnableCaching
+@Configuration
+public class RedisConfig extends CachingConfigurerSupport {
+    public static final String REDIS_KEY_DATABASE="wj";
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
+        RedisSerializer<Object> serializer = redisSerializer();
+        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setConnectionFactory(redisConnectionFactory);
+        redisTemplate.setKeySerializer(new StringRedisSerializer());
+        redisTemplate.setValueSerializer(serializer);
+        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
+        redisTemplate.setHashValueSerializer(serializer);
+        redisTemplate.afterPropertiesSet();
+        return redisTemplate;
+    }
+
+    @Bean
+    public RedisSerializer<Object> redisSerializer() {
+        //创建JSON序列化器
+        Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
+        ObjectMapper objectMapper = new ObjectMapper();
+        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
+        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
+        serializer.setObjectMapper(objectMapper);
+        return serializer;
+    }
+
+    @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);
+    }
+}

src/main/java/com/gm/wj/entity/Category.java

@@ -11,6 +11,8 @@ import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import lombok.Data;
 import lombok.ToString;
 
+import java.io.Serializable;
+
 /**
  * Category entity.
  *
@@ -22,7 +24,7 @@ import lombok.ToString;
 @Table(name = "category")
 @ToString
 @JsonIgnoreProperties({ "handler","hibernateLazyInitializer" })
-public class Category {
+public class Category{
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     @Column(name = "id")

src/main/java/com/gm/wj/service/BookService.java

 package com.gm.wj.service;
 
+import com.gm.wj.config.RedisConfig;
 import com.gm.wj.dao.BookDAO;
 import com.gm.wj.entity.Book;
 import com.gm.wj.entity.Category;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.stereotype.Service;
@@ -22,6 +24,7 @@ public class BookService {
     @Autowired
     CategoryService categoryService;
 
+//    @Cacheable(value = RedisConfig.REDIS_KEY_DATABASE)
     public List<Book> list() {
         Sort sort = new Sort(Sort.Direction.DESC, "id");
         return bookDAO.findAll(sort);

src/main/resources/application.properties

@@ -39,9 +39,8 @@ spring.redis.host=localhost
 spring.redis.port=6379
 # Redis 数据库索引（默认为 0）
 spring.redis.database=0
-# Redis 服务器连接端口
 # Redis 服务器连接密码（默认为空）
-spring.redis.password=123
+spring.redis.password=
 #连接池最大连接数（使用负值表示没有限制）
 spring.redis.lettuce.pool.max-active=8
 # 连接池最大阻塞等待时间（使用负值表示没有限制）
@@ -51,7 +50,7 @@ spring.redis.lettuce.pool.max-idle=8
 # 连接池中的最小空闲连接
 spring.redis.lettuce.pool.min-idle=0
 # 连接超时时间（毫秒）
-spring.redis.timeout=0
+spring.redis.timeout=2000
 # redis 只用作缓存，不作为 repository
 spring.data.redis.repositories.enabled=false