添加更新 block 缓存的方法

book-server/src/main/java/com/book/server/controller/BookController.java

@@ -6,6 +6,7 @@ import com.book.dao.cpsshard.entity.UserRecentlyRead;
 import com.book.server.common.entity.Result;
 import com.book.server.common.entity.ResultCode;
 import com.book.dao.VO.*;
+import com.book.server.service.BlockCacheGuava;
 import com.book.server.service.BookService;
 import com.book.server.service.CacheService;
 import lombok.extern.slf4j.Slf4j;
@@ -91,17 +92,6 @@ public class BookController extends BaseController {
         return Result.byObject(list);
     }
 
-    /**
-     * 更新block缓存
-     *
-     * @return
-     */
-    //@GetMapping("/resetBlockCache")
-    //@CacheEvict(value = "block", allEntries = true)
-    //public Result resetBlockCache() {
-    //    return Result.byObject("OK");
-    //}
-
 
     /**
      * 导入书库
@@ -193,6 +183,7 @@ public class BookController extends BaseController {
 
     @Autowired
     private CacheService cacheService;
+
     /**
      * 自定义书籍上传
      *
@@ -236,4 +227,18 @@ public class BookController extends BaseController {
     public Result updateBookContent(@RequestBody BookContentVO bookContentVO) {
         return Result.byObject(bookService.updateBookContent(bookContentVO));
     }
+
+    @Autowired
+    private BlockCacheGuava blockCacheGuava;
+
+    /**
+     * 更新 block 缓存
+     *
+     * @return
+     */
+    @GetMapping("/updateBlockCache")
+    public Result updateBlockCache() {
+        blockCacheGuava.clearCache();
+        return Result.success();
+    }
 }

book-server/src/main/java/com/book/server/service/BlockCacheGuava.java

@@ -1,7 +1,6 @@
 package com.book.server.service;
 
 import com.book.dao.VO.BlockRes;
-import com.google.common.cache.Cache;
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;
 import com.google.common.cache.LoadingCache;
@@ -28,7 +27,7 @@ public class BlockCacheGuava {
                 .build(new CacheLoader<Integer, List<BlockRes>>() {
                     @Override
                     public List<BlockRes> load(Integer key) throws Exception {
-                        return cacheService.getBlockByPageIdCache(key);
+                        return cacheService.getBlockByPageId(key);
                     }
                 });
     }
@@ -36,4 +35,9 @@ public class BlockCacheGuava {
     public List<BlockRes> getBlockRes(Integer key) throws ExecutionException {
         return blockResCache.get(key);
     }
+
+    public void clearCache() {
+        blockResCache.refresh(1);
+        blockResCache.refresh(2);
+    }
 }

book-server/src/main/java/com/book/server/service/CacheService.java

@@ -76,7 +76,7 @@ public class CacheService {
                 queryVO.getPage() * queryVO.getSize(), queryVO.getSize());
     }
 
-    public ArrayList<BlockRes> getBlockByPageIdCache(Integer pageId) {
+    public ArrayList<BlockRes> getBlockByPageId(Integer pageId) {
         //没有缓存
         ArrayList<BlockRes> list = new ArrayList<>();
         // 获取板块