layering cache Spring boot demo

xiaolyuh123 · xiaolyuh123 · commit 36c50606ba15 · 2018-08-19T19:39:50.000+08:00
diff --git a/spring-boot-student-cache-redis-caffeine/src/main/java/com/xiaolyuh/cache/listener/RedisMessageListener.java b/spring-boot-student-cache-redis-caffeine/src/main/java/com/xiaolyuh/cache/listener/RedisMessageListener.java
@@ -22,7 +22,7 @@
  */
 @Component
 public class RedisMessageListener extends MessageListenerAdapter {
-    private static final Logger log = LoggerFactory.getLogger(RedisPublisher.class);
+    private static final Logger logger = LoggerFactory.getLogger(RedisPublisher.class);
 
     @Autowired
     CacheManager cacheManager;
@@ -31,7 +31,7 @@ public class RedisMessageListener extends MessageListenerAdapter {
     public void onMessage(Message message, byte[] pattern) {
         super.onMessage(message, pattern);
         ChannelTopicEnum channelTopic = ChannelTopicEnum.getChannelTopicEnum(new String(message.getChannel()));
-        log.info("redis消息订阅者接收到频道【{}】发布的消息。消息内容：{}", channelTopic.getChannelTopicStr(), message.toString().getBytes());
+        logger.info("redis消息订阅者接收到频道【{}】发布的消息。消息内容：{}", channelTopic.getChannelTopicStr(), message.toString().getBytes());
         // 解析订阅发布的信息，获取缓存的名称和缓存的key
         String ms = new String(message.getBody());
         @SuppressWarnings("unchecked")
@@ -48,17 +48,17 @@ public void onMessage(Message message, byte[] pattern) {
                 case REDIS_CACHE_DELETE_TOPIC:
                     // 获取一级缓存，并删除一级缓存数据
                     ((LayeringCache) cache).getFirstCache().evict(key);
-                    log.info("删除一级缓存{}数据,key:{}", cacheName, key.toString().getBytes());
+                    logger.info("删除一级缓存{}数据,key:{}", cacheName, key.toString().getBytes());
                     break;
 
                 case REDIS_CACHE_CLEAR_TOPIC:
                     // 获取一级缓存，并删除一级缓存数据
                     ((LayeringCache) cache).getFirstCache().clear();
-                    log.info("清除一级缓存{}数据", cacheName);
+                    logger.info("清除一级缓存{}数据", cacheName);
                     break;
 
                 default:
-                    log.info("接收到没有定义的订阅消息频道数据");
+                    logger.info("接收到没有定义的订阅消息频道数据");
                     break;
             }
 
diff --git a/spring-boot-student-cache/src/main/java/com/xiaolyuh/SpringBootStudentCacheApplication.java b/spring-boot-student-cache/src/main/java/com/xiaolyuh/SpringBootStudentCacheApplication.java
@@ -5,10 +5,11 @@
 import org.springframework.cache.annotation.EnableCaching;
 
 @SpringBootApplication
-@EnableCaching// 开启缓存，需要显示的指定
+// 开启缓存，需要显示的指定
+@EnableCaching
 public class SpringBootStudentCacheApplication {
 
-	public static void main(String[] args) {
-		SpringApplication.run(SpringBootStudentCacheApplication.class, args);
-	}
+    public static void main(String[] args) {
+        SpringApplication.run(SpringBootStudentCacheApplication.class, args);
+    }
 }
diff --git a/spring-boot-student-layering-cache/pom.xml b/spring-boot-student-layering-cache/pom.xml
@@ -55,8 +55,8 @@
 
         <dependency>
             <groupId>com.xiaolyuh</groupId>
-            <artifactId>layering-cache-aspectj</artifactId>
-            <version>1.0.0</version>
+            <artifactId>layering-cache-starter</artifactId>
+            <version>1.0.0-SNAPSHOT</version>
         </dependency>
 
     </dependencies>
diff --git a/spring-boot-student-layering-cache/src/main/java/com/xiaolyuh/SpringBootStudentLayeringCacheApplication.java b/spring-boot-student-layering-cache/src/main/java/com/xiaolyuh/SpringBootStudentLayeringCacheApplication.java
@@ -3,7 +3,7 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.boot.autoconfigure.cache.CacheAutoConfiguration;
 
 @SpringBootApplication
 public class SpringBootStudentLayeringCacheApplication {
diff --git a/spring-boot-student-layering-cache/src/main/java/com/xiaolyuh/config/RedisConfig.java b/spring-boot-student-layering-cache/src/main/java/com/xiaolyuh/config/RedisConfig.java
@@ -8,6 +8,8 @@
 import com.xiaolyuh.serializer.StringRedisSerializer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+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.Jackson2JsonRedisSerializer;
@@ -56,5 +58,11 @@ public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisC
         return redisTemplate;
     }
 
+    @Bean
+    @Primary
+    public RedisCacheManager cacheManager(RedisTemplate<String, Object> redisTemplate) {
+        RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);
+        return cacheManager;
+    }
 
 }
diff --git a/spring-boot-student-layering-cache/src/main/java/com/xiaolyuh/entity/Person.java b/spring-boot-student-layering-cache/src/main/java/com/xiaolyuh/entity/Person.java
@@ -4,71 +4,72 @@
 import javax.persistence.GeneratedValue;
 import javax.persistence.Id;
 import javax.persistence.NamedQuery;
+import java.io.Serializable;
 
 @Entity // @Entity注解指明这是一个和数据库表映射的实体类。
 @NamedQuery(name = "Person.withNameAndAddressNamedQuery", query = "select p from Person p where p.name=?1 and address=?2")
-public class Person {
-	@Id // @Id注解指明这个属性映射为数据库的主键。
-	@GeneratedValue // @GeneratedValue注解默认使用主键生成方式为自增，hibernate会为我们自动生成一个名为HIBERNATE_SEQUENCE的序列。
-	private Long id;
+public class Person implements Serializable {
+    @Id // @Id注解指明这个属性映射为数据库的主键。
+    @GeneratedValue // @GeneratedValue注解默认使用主键生成方式为自增，hibernate会为我们自动生成一个名为HIBERNATE_SEQUENCE的序列。
+    private Long id;
 
-	private String name;
+    private String name;
 
-	private Integer age;
+    private Integer age;
 
-	private String address;
+    private String address;
 
-	public Person() {
-		super();
-	}
+    public Person() {
+        super();
+    }
 
-	public Person(Long id, String name, Integer age, String address) {
-		this.id = id;
-		this.name = name;
-		this.age = age;
-		this.address = address;
-	}
+    public Person(Long id, String name, Integer age, String address) {
+        this.id = id;
+        this.name = name;
+        this.age = age;
+        this.address = address;
+    }
 
-	public Person(String name, Integer age) {
-		this.name = name;
-		this.age = age;
-	}
+    public Person(String name, Integer age) {
+        this.name = name;
+        this.age = age;
+    }
 
-	public Long getId() {
-		return id;
-	}
+    public Long getId() {
+        return id;
+    }
 
-	public void setId(Long id) {
-		this.id = id;
-	}
+    public void setId(Long id) {
+        this.id = id;
+    }
 
-	public String getName() {
-		return name;
-	}
+    public String getName() {
+        return name;
+    }
 
-	public void setName(String name) {
-		this.name = name;
-	}
+    public void setName(String name) {
+        this.name = name;
+    }
 
-	public Integer getAge() {
-		return age;
-	}
+    public Integer getAge() {
+        return age;
+    }
 
-	public void setAge(Integer age) {
-		this.age = age;
-	}
+    public void setAge(Integer age) {
+        this.age = age;
+    }
 
-	public String getAddress() {
-		return address;
-	}
+    public String getAddress() {
+        return address;
+    }
 
-	public void setAddress(String address) {
-		this.address = address;
-	}
+    public void setAddress(String address) {
+        this.address = address;
+    }
 
-	@Override
-	public String toString() {
-		return "Person [id=" + id + ", name=" + name + ", age=" + age + ", address=" + address + "]";
-	}
+    @Override
+    public String toString() {
+        return "Person [id=" + id + ", name=" + name + ", age=" + age + ", address=" + address + "]";
+    }
 
 }
diff --git a/spring-boot-student-layering-cache/src/main/java/com/xiaolyuh/service/impl/PersonServiceImpl.java b/spring-boot-student-layering-cache/src/main/java/com/xiaolyuh/service/impl/PersonServiceImpl.java
@@ -39,7 +39,7 @@ public void removeAll() {
     @Override
     @Cacheable(value = "'people' + ':' + #person.id", key = "#person.id",
             firstCache = @FirstCache(expireTime = 4, timeUnit = TimeUnit.SECONDS),
-            secondaryCache = @SecondaryCache(expiration = 10, preloadTime = 3, forceRefresh = true, timeUnit = TimeUnit.SECONDS))
+            secondaryCache = @SecondaryCache(expiration = 100, preloadTime = 3, forceRefresh = true, timeUnit = TimeUnit.SECONDS))
     public Person findOne(Person person) {
         Person p = personRepository.findOne(person.getId());
         System.out.println("为id、key为:" + p.getId() + "数据做了缓存");
