Browse Source

更新缓存问题

tianyunperfect 3 years ago
parent
commit
ffaa7dfcae

+ 6 - 3
book-server/src/main/java/com/book/server/controller/BookController.java

@@ -1,5 +1,6 @@
 package com.book.server.controller;
 package com.book.server.controller;
 
 
+import com.book.dao.cps.mapper.BookMapper;
 import com.book.dao.cps.pojo.Book;
 import com.book.dao.cps.pojo.Book;
 import com.book.dao.cps.pojo.SearchKeyword;
 import com.book.dao.cps.pojo.SearchKeyword;
 import com.book.dao.cpsshard.entity.UserRecentlyRead;
 import com.book.dao.cpsshard.entity.UserRecentlyRead;
@@ -193,6 +194,9 @@ public class BookController extends BaseController {
         return false;
         return false;
     }
     }
 
 
+    @Autowired
+    private BookMapper bookMapper;
+
     /**
     /**
      * 自定义书籍上传
      * 自定义书籍上传
      *
      *
@@ -204,12 +208,11 @@ public class BookController extends BaseController {
     @PostMapping("/upload-8F80F0A4-E084-44C6-8659-61612C9D9D44")
     @PostMapping("/upload-8F80F0A4-E084-44C6-8659-61612C9D9D44")
     public Result uploadFile(@RequestParam("file") MultipartFile file, Long bookId, HttpSession session) throws IOException {
     public Result uploadFile(@RequestParam("file") MultipartFile file, Long bookId, HttpSession session) throws IOException {
 
 
-
         if (file.isEmpty() || bookId == null || !cacheService.isUploadBook(bookId)) {
         if (file.isEmpty() || bookId == null || !cacheService.isUploadBook(bookId)) {
             return Result.failure(ResultCode.PARAMERROR);
             return Result.failure(ResultCode.PARAMERROR);
         }
         }
         //判断 ID 是否存在
         //判断 ID 是否存在
-        Book bookById = cacheService.getBookById(bookId);
+        Book bookById = bookMapper.selectByPrimaryKey(bookId);
         if (bookById != null) {
         if (bookById != null) {
             return Result.failure(ResultCode.IDEXIST);
             return Result.failure(ResultCode.IDEXIST);
         }
         }
@@ -267,7 +270,7 @@ public class BookController extends BaseController {
     private BlockCacheGuava blockCacheGuava;
     private BlockCacheGuava blockCacheGuava;
 
 
     /**
     /**
-     * 更新 block 缓存
+     * 后台-更新缓存
      *
      *
      * @return
      * @return
      */
      */

+ 19 - 10
book-server/src/main/java/com/book/server/service/BlockCacheGuava.java

@@ -1,6 +1,7 @@
 package com.book.server.service;
 package com.book.server.service;
 
 
 import com.book.dao.VO.BlockRes;
 import com.book.dao.VO.BlockRes;
+import com.book.server.utils.RedisUtil;
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;
 import com.google.common.cache.CacheLoader;
 import com.google.common.cache.LoadingCache;
 import com.google.common.cache.LoadingCache;
@@ -36,18 +37,26 @@ public class BlockCacheGuava {
         return blockResCache.get(key);
         return blockResCache.get(key);
     }
     }
 
 
+    @Autowired
+    private RedisUtil redisUtil;
+
     public void clearCache() {
     public void clearCache() {
         blockResCache.refresh(1);
         blockResCache.refresh(1);
         blockResCache.refresh(2);
         blockResCache.refresh(2);
-        cacheService.deleteSmartRecommandCache("1");
-        cacheService.deleteSmartRecommandCache("2");
-        cacheService.deleteTopRecommendCache("1");
-        cacheService.deleteTopRecommendCache("2");
-        cacheService.deleteSearchKeywordsCache("1");
-        cacheService.deleteSearchKeywordsCache("2");
-        cacheService.deleteRecommendFromCache("1",0,10);
-        cacheService.deleteRecommendFromCache("1",1,10);
-        cacheService.deleteRecommendFromCache("2",0,10);
-        cacheService.deleteRecommendFromCache("2",1,10);
+        redisUtil.removePattern("smartRecommand*");
+        redisUtil.removePattern("topRecommend*");
+        redisUtil.removePattern("searchKeyword*");
+        redisUtil.removePattern("recommend*");
+        redisUtil.removePattern("book*");
+        redisUtil.removePattern("user*");
+        redisUtil.removePattern("category*");
+        redisUtil.removePattern("chapters*");
+        redisUtil.removePattern("defaultFreeChapterNum");
+        redisUtil.removePattern("freeCoin*");
+        redisUtil.removePattern("userReadConfig*");
+        redisUtil.removePattern("edit_book*");
+        redisUtil.removePattern("bookContent*");
+
+
     }
     }
 }
 }

+ 0 - 3
book-server/src/main/java/com/book/server/service/CacheService.java

@@ -197,9 +197,6 @@ public class CacheService {
         return bookService.getFreeCoin(id);
         return bookService.getFreeCoin(id);
     }
     }
 
 
-    @CacheFind(key = "user", delete = true)
-    public void deleteUserByIdCache(Long id) {
-    }
 
 
     @CacheFind(key = "user", update = true)
     @CacheFind(key = "user", update = true)
     public User updateUserByIdCache(Long id) {
     public User updateUserByIdCache(Long id) {