更新实战缓存代码

Author: Jackson0714

passjava-question/pom.xml

@@ -9,7 +9,7 @@
         <relativePath/> <!-- lookup parent from repository -->
     </parent>
     <groupId>com.jackson0714.passjava</groupId>
-    <artifactId>passjava-question</artifactId>
+    <artifactId>passjava-question</artifactId>mysql-connector-java
     <version>0.0.1-SNAPSHOT</version>
     <name>passjava-question</name>
     <description>佳必过-题目服务</description>
@@ -25,6 +25,10 @@
             <artifactId>passjava-common</artifactId>
             <version>0.0.1-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
         <!--
         <dependency>
             <groupId>com.aliyun.oss</groupId>

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

@@ -1,16 +1,16 @@
 package com.jackson0714.passjava.question.controller;
 
+import com.alibaba.fastjson.JSON;
 import com.jackson0714.common.utils.PageUtils;
 import com.jackson0714.common.utils.R;
 import com.jackson0714.passjava.question.entity.TypeEntity;
 import com.jackson0714.passjava.question.service.ITypeService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.core.ValueOperations;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 
 /**
@@ -29,19 +29,54 @@ public class TypeAppController {
     @Autowired
     private ITypeService ITypeService;
 
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
     /**
-     * 查询
+     * 查询题目类型列表
+     *
+     * @author：公众号：悟空聊架构
+     * @website：www.passjava.cn
      */
     @RequestMapping("/list")
-    //@RequiresPermissions("question:type:list")
     public R list(){
         List<TypeEntity> typeEntityListCache = (List<TypeEntity>) cache.get("typeEntityList");
-        List<TypeEntity> typeEntityList = null;
+        // 如果缓存中没有数据
+        if (typeEntityListCache == null) {
+            System.out.println("The cache is empty");
+            // 从数据库中查询数据
+            List<TypeEntity> typeEntityList = ITypeService.list();
+            // 将数据放入缓存中
+            typeEntityListCache = typeEntityList;
+            cache.put("typeEntityList", typeEntityListCache);
+        }
+        return R.ok().put("typeEntityList", typeEntityListCache);
+    }
+
+    /**
+     * 查询题目类型列表
+     *
+     * @author：公众号：悟空聊架构
+     * @website：www.passjava.cn
+     */
+    @RequestMapping("/list-by-redis")
+    public R listByRedis(){
+
+        // 初始化 redis 组件
+        ValueOperations<String, String> ops = stringRedisTemplate.opsForValue();
+
+        // 查询数据
+        String typeEntityListCache = ops.get("typeEntityList");
+        // 如果缓存中没有数据
         if (typeEntityListCache == null) {
             System.out.println("The cache is empty");
-            typeEntityList = ITypeService.list();
-            cache.put("typeEntityList", typeEntityList);
+            // 从数据库中查询数据
+            List<TypeEntity> typeEntityListFromDb = ITypeService.list();
+            // 将数据放入缓存中
+            String s = JSON.toJSONString(typeEntityListFromDb);
+            ops.set("typeEntityList", s);
         }
+        List<TypeEntity> typeEntityList = (List<TypeEntity>) JSON.parseObject(typeEntityListCache);
         return R.ok().put("typeEntityList", typeEntityList);
     }
 }

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

@@ -54,15 +54,16 @@ public PageUtils queryPage(Map<String, Object> params) {
     @Override
     public boolean saveQuestion(QuestionEntity question) {
         boolean saveResult = save(question);
-        saveEs(question);
+        //saveEs(question);
 
         return true;
     }
 
     @Override
     public boolean updateQuestion(QuestionEntity question) {
         updateById(question);
-        saveEs(question);
+        //saveEs(question);
+
         return true;
     }
 

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

@@ -1,4 +1,4 @@
-#spring:
+#=spring:
 #  datasource:
 #      driver-class-name: com.mysql.cj.jdbc.Driver
 #      url: jdbc:mysql://129.211.188.xxxx:xxxx/passjava_qms?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
@@ -38,3 +38,13 @@ logging:
 spring:
   jackson:
     date-format: yyyy-MM-dd HH:mm:ss
+
+  redis:
+    host: 127.0.0.1
+    port: 6379
+
+#  datasource:
+#    driver-class-name: com.mysql.cj.jdbc.Driver
+#    url: jdbc:mysql://127.0.0.1:3306/passjava_qms?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT
+#    username: root
+#    password: huangz01

passjava-question/src/test/java/com/jackson0714/passjava/question/PassjavaQuestionApplicationTests.java

@@ -6,15 +6,32 @@
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.core.ValueOperations;
 
 import java.util.List;
+import java.util.UUID;
 
 @SpringBootTest
 class PassjavaQuestionApplicationTests {
 
     @Autowired
     ITypeService ITypeService;
 
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Test
+    public void TestStringRedisTemplate() {
+        // 初始化 redis 组件
+        ValueOperations<String, String> ops = stringRedisTemplate.opsForValue();
+        // 存储数据
+        ops.set("悟空", "悟空聊架构_" + UUID.randomUUID().toString());
+        // 查询数据
+        String wukong = ops.get("悟空");
+        System.out.println(wukong);
+    }
+
     // 创建题目类型
     @Test
     void testCreateType() {