add spring cache

Author: Jackson0714

passjava-portal/src/views/modules/question/question-add-or-update.vue

@@ -188,7 +188,7 @@ export default {
           this.$http({
             url: this.$http.adornUrl(
               `/question/v1/admin/question/${
-                !this.dataForm.id ? "save" : "update"
+                !this.dataForm.id ? "create" : "update"
               }`
             ),
             method: "post",

passjava-question/pom.xml

@@ -37,6 +37,10 @@
             <version>3.15.5</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-cache</artifactId>
+        </dependency>
         <!--
         <dependency>
             <groupId>com.aliyun.oss</groupId>

passjava-question/src/main/java/com/jackson0714/passjava/question/PassjavaQuestionApplication.java

@@ -3,18 +3,18 @@
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.context.annotation.ComponentScan;
 
+@EnableCaching
 @EnableFeignClients(basePackages = "com.jackson0714.passjava.question.feign")
 @EnableDiscoveryClient
 @MapperScan("com.jackson0714.passjava.question.dao")
 @SpringBootApplication
 public class PassjavaQuestionApplication {
-
     public static void main(String[] args) {
         SpringApplication.run(PassjavaQuestionApplication.class, args);
     }
-
 }

passjava-question/src/main/java/com/jackson0714/passjava/question/config/MyCacheConfig.java

@@ -0,0 +1,52 @@
+package com.jackson0714.passjava.question.config;
+
+import org.redisson.api.redisnode.RedisSentinel;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.cache.CacheProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+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.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+/**
+ * @Author: 公众号 | 悟空聊架构
+ * @Date: 2021/6/25 15:27
+ * @Site: www.passjava.cn
+ * @Github: https://github.com/Jackson0714/PassJava-Platform
+ */
+
+@EnableConfigurationProperties(CacheProperties.class)
+@Configuration
+@EnableCaching
+public class MyCacheConfig {
+
+    @Autowired
+    CacheProperties cacheProperties;
+
+    @Bean
+    RedisCacheConfiguration redisCacheConfiguration(CacheProperties cacheProperties) {
+        RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig();
+        config = config.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()));
+        config = config.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));
+        CacheProperties.Redis redisProperties = cacheProperties.getRedis();
+
+        if (redisProperties.getTimeToLive() != null) {
+            config = config.entryTtl(redisProperties.getTimeToLive());
+        }
+        if (redisProperties.getKeyPrefix() != null) {
+            config = config.prefixKeysWith(redisProperties.getKeyPrefix());
+        }
+        if (!redisProperties.isCacheNullValues()) {
+            config = config.disableCachingNullValues();
+        }
+        if (!redisProperties.isUseKeyPrefix()) {
+            config = config.disableKeyPrefix();
+        }
+
+        return config;
+    }
+}

passjava-question/src/main/java/com/jackson0714/passjava/question/config/MyRedissonConfig.java

@@ -22,7 +22,7 @@ public RedissonClient redisson() throws IOException {
         // 集群模式
         // config.useClusterServers().addNodeAddress("127.0.0.1:7004", "127.0.0.1:7001");
         // 2.根据 Config 创建出 RedissonClient 示例。
-        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
+        config.useSingleServer().setAddress("redis://192.168.56.10:6379");
         return Redisson.create(config);
     }
 }

passjava-question/src/main/java/com/jackson0714/passjava/question/controller/QuestionController.java

@@ -1,9 +1,11 @@
 package com.jackson0714.passjava.question.controller;
 
-import java.util.Arrays;
-import java.util.Map;
+import java.util.*;
 
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.CachePut;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -24,11 +26,12 @@
  * 
  *
  * @author jackson0714
- * @email jackson0585@163.com
+ * @公众号：悟空聊架构
  * @date 2020-04-25 22:34:04
  */
 @RestController
 @RequestMapping("question/v1/admin/question")
+
 public class QuestionController {
     @Autowired
     private IQuestionService IQuestionService;
@@ -50,17 +53,31 @@ public R list(@RequestParam Map<String, Object> params){
      * 信息
      */
     @RequestMapping("/info/{id}")
-    //@RequiresPermissions("question:question:info")
+    @Cacheable({"hot"})
     public R info(@PathVariable("id") Long id) {
-		QuestionEntity question = IQuestionService.getById(id);
+		QuestionEntity question = IQuestionService.info(id);
         return R.ok().put("question", question);
     }
 
+    /**
+     * 测试方法的返回结果是否被缓存了
+     */
+    @RequestMapping("/test")
+    @Cacheable(value = "hot", key = "#root.method.name")
+    public int test() {
+        return 222;
+    }
+
+    @RequestMapping("/test2")
+    @Cacheable(value = "hot", key = "#root.method.name")
+    public int test2() {
+        return 456;
+    }
+
     /**
      * 保存
      */
     @RequestMapping("/save")
-    //@RequiresPermissions("question:question:save")
     public R save(@Valid @RequestBody QuestionEntity question){
 		IQuestionService.saveQuestion(question);
 
@@ -82,22 +99,32 @@ public R update(@RequestBody QuestionEntity question){
      * 删除
      */
     @RequestMapping("/delete")
-    //@RequiresPermissions("question:question:delete")
+    @CacheEvict(value = "hot")
     public R delete(@RequestBody Long[] ids){
 		IQuestionService.removeByIds(Arrays.asList(ids));
-
         return R.ok();
     }
 
-    /**
-     * 测试
-     * @return
-     */
-    @RequestMapping("/test")
-    //@RequiresPermissions("question:question:delete")
-    public String test(){
+    @RequestMapping("/create")
+    @CachePut(value = "hot", key = "#result.id")
+    // mock create
+    public QuestionEntity create(@Valid @RequestBody QuestionEntity question){
+        return IQuestionService.createQuestion(question);
+    }
 
-        return "test";
+    @RequestMapping("/remove/{id}")
+    @CacheEvict(value = "hot")
+    public R remove(@PathVariable("id") Long id){
+        IQuestionService.removeById(id);
+        return R.ok();
     }
 
+    @RequestMapping("/condition/{id}")
+    @Cacheable(value = "hot", unless = "#result.message.containss('NoCache')")
+    public R condition(@PathVariable("id") Long id) {
+        QuestionEntity question = IQuestionService.info(id);
+        HashMap<String, Object> map = new HashMap<String, Object>();
+
+        return R.ok().put("question", question).put("message", "NoCache");
+    }
 }

passjava-question/src/main/java/com/jackson0714/passjava/question/feign/SearchFeignService.java

@@ -3,7 +3,9 @@
 import com.jackson0714.common.to.es.QuestionEsModel;
 import com.jackson0714.common.utils.R;
 import org.apache.ibatis.annotations.Mapper;
+import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.stereotype.Service;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 

passjava-question/src/main/java/com/jackson0714/passjava/question/service/IQuestionService.java

@@ -2,7 +2,9 @@
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.jackson0714.common.utils.PageUtils;
+import com.jackson0714.common.utils.R;
 import com.jackson0714.passjava.question.entity.QuestionEntity;
+import org.springframework.web.bind.annotation.PathVariable;
 
 import java.util.Map;
 
@@ -17,8 +19,12 @@ public interface IQuestionService extends IService<QuestionEntity> {
 
     PageUtils queryPage(Map<String, Object> params);
 
+    QuestionEntity info(Long id);
+
     boolean saveQuestion(QuestionEntity question);
 
     boolean updateQuestion(QuestionEntity question);
+
+    QuestionEntity createQuestion(QuestionEntity question);
 }
 

passjava-question/src/main/java/com/jackson0714/passjava/question/service/impl/QuestionServiceImpl.java

@@ -1,5 +1,6 @@
 package com.jackson0714.passjava.question.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.jackson0714.common.to.es.QuestionEsModel;
 import com.jackson0714.common.utils.R;
 import com.jackson0714.passjava.question.entity.TypeEntity;
@@ -8,6 +9,7 @@
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 import java.util.Map;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -51,6 +53,12 @@ public PageUtils queryPage(Map<String, Object> params) {
         return new PageUtils(page);
     }
 
+    @Override
+    @Cacheable({"question", "hot"})
+    public QuestionEntity info(Long id) {
+        return getById(id);
+    }
+
     @Override
     public boolean saveQuestion(QuestionEntity question) {
         boolean saveResult = save(question);
@@ -67,6 +75,13 @@ public boolean updateQuestion(QuestionEntity question) {
         return true;
     }
 
+    @Override
+    public QuestionEntity createQuestion(QuestionEntity question) {
+        // Mock 返回 id
+        question.setId(123L);
+        return question;
+    }
+
     private boolean saveEs(QuestionEntity question) {
         // 1.创建 ES model
         QuestionEsModel esModel = new QuestionEsModel();

passjava-question/src/main/resources/application.properties

@@ -8,4 +8,17 @@ spring.zipkin.discovery-client-enabled=false
 # \u8BBE\u7F6E\u4F7F\u7528 http \u7684\u65B9\u5F0F\u4F20\u8F93\u6570\u636E\uFF0C\u4E5F\u53EF\u4EE5\u7528 RabbitMQ \u6216 Kafka\u3002
 spring.zipkin.sender.type=web
 # \u8BBE\u7F6E\u91C7\u6837\u7387\u4E3A 100 %\uFF0C\u9ED8\u8BA4\u4E3A 0.1\uFF0810%\uFF09
-spring.sleuth.sampler.probability=1
+spring.sleuth.sampler.probability=1 
+
+# \u4F7F\u7528 Redis \u4F5C\u4E3A\u7F13\u5B58\u7EC4\u4EF6
+spring.cache.type=redis
+# \u7F13\u5B58\u8FC7\u671F\u65F6\u95F4\u4E3A 3600s
+spring.cache.redis.time-to-live=3600000
+# \u7F13\u5B58\u7684\u952E\u7684\u540D\u5B57\u524D\u7F00
+spring.cache.redis.key-prefix=passjava_
+# \u662F\u5426\u4F7F\u7528\u7F13\u5B58\u524D\u7F00
+spring.cache.redis.use-key-prefix=true
+# \u662F\u5426\u7F13\u5B58\u63A7\u5236\uFF0C\u9632\u6B62\u7F13\u5B58\u7A7F\u900F
+spring.cache.redis.cache-null-values=true
+
+