add different lock, add sleep, update readme

yennanliu · Feb 17, 2024 · 948273a · 948273a
1 parent a03165c
commit 948273a
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 4 deletions.
diff --git a/springBank/README.md b/springBank/README.md
@@ -121,9 +121,14 @@ docker-compose restart
 
 #---------------------------  
 # Macbook apple M1 chip
-#---------------------------  
+#--------------------------- 
+
+# run 
 docker-compose -f docker-compose-m1.yml up
 
+# rebuild (use updated java code) and run
+docker-compose -f docker-compose-m1.yml up --build
+
 # restart
 docker-compose -f docker-compose-m1.yml restart
 ```

diff --git a/...ank/springBankApp/src/main/java/com/yen/springBankApp/service/BalanceServiceRedisson.java b/...ank/springBankApp/src/main/java/com/yen/springBankApp/service/BalanceServiceRedisson.java
@@ -6,6 +6,7 @@
 import com.yen.springBankApp.repository.BalanceRepository;
 import lombok.extern.slf4j.Slf4j;
 import org.redisson.api.RLock;
+import org.redisson.api.RReadWriteLock;
 import org.redisson.api.RedissonClient;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.StringRedisTemplate;
@@ -84,12 +85,17 @@ public void deductBalance(DeductBalanceDto deductBalanceDto) {
         log.info(">>> (BalanceServiceRedisson) deductBalance start ...");
 
         // get lock
-        RLock lock = redissonClient.getLock("lock");
+        //RLock lock = redissonClient.getLock("lock");
+        RReadWriteLock rwLock = redissonClient.getReadWriteLock("rwLock");
 
         // lock
-        lock.lock();
+        //lock.lock();
+        rwLock.writeLock();
 
         try{
+            // sleep 10 sec
+            Thread.sleep(10000);
+
             // 1) get stock amount
             // set up "balance" as String type in Redis, with value = 5000
             // https://github.com/yennanliu/SpringPlayground/blob/main/springBank/doc/pic/redis_key_setting.png
@@ -111,7 +117,8 @@ public void deductBalance(DeductBalanceDto deductBalanceDto) {
             e.printStackTrace();
         }finally {
             // unlock
-            lock.unlock();
+            //lock.unlock();
+            rwLock.writeLock().unlock();
         }
     }
 
@@ -168,6 +175,9 @@ public void transferMysql(DeductBalanceDto deductBalanceDto) {
         try{
             // V2 : Mysql
             if (balanceRepository.findById(1).isPresent() && balanceRepository.findById(2).isPresent()){
+
+                Thread.sleep(10000);
+
                 Balance balance1 = balanceRepository.findById(1).get();
                 Balance balance2 = balanceRepository.findById(2).get();
                 // update to DB