欲引入Redisson框架实现分布式锁

rainbowshine521 · May 25, 2020 · be7cbe2 · be7cbe2
1 parent 8f1ed88
commit be7cbe2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/novel-front/src/main/java/com/java2nb/novel/core/listener/BookVisitAddListener.java b/novel-front/src/main/java/com/java2nb/novel/core/listener/BookVisitAddListener.java
@@ -50,6 +50,8 @@ public void updateDb(Long bookId, Channel channel, Message message) {
 
         log.debug("收到更新数据库消息：" + bookId);
         Thread.sleep(1000 * 2);
+        //TODO 操作共享资源visitCount，集群环境下有线程安全问题，引入Redisson框架实现分布式锁
+        //目前visitCount不重要，数据可丢失，暂不实现分布式锁
         Integer visitCount = (Integer) cacheService.getObject(CacheKey.BOOK_ADD_VISIT_COUNT+bookId);
         if(visitCount == null){
             visitCount = 0 ;

diff --git a/novel-front/src/main/java/com/java2nb/novel/core/schedule/BookToEsSchedule.java b/novel-front/src/main/java/com/java2nb/novel/core/schedule/BookToEsSchedule.java
@@ -48,6 +48,8 @@ public class BookToEsSchedule {
      */
     @Scheduled(fixedRate = 1000 * 60)
     public void saveToEs() {
+        //TODO 引入Redisson框架实现分布式锁
+        //可以重复更新，只是效率可能略有降低，所以暂不实现分布式锁
         if (cacheService.get(CacheKey.ES_TRANS_LOCK) == null) {
             cacheService.set(CacheKey.ES_TRANS_LOCK, "1", 60 * 20);
             try {