// 僅僅加鎖
// 讀取 stock=15
Boolean ret = stringRedisTemplate.opsForValue().setIfAbsent("lock_key", "1"); // jedis.setnx(k,v)
// TODO 業(yè)務(wù)代碼 stock--
stringRedisTemplate.delete("lock_key");

// 加鎖，且設(shè)置鎖過期時間
// 讀取 stock = 15
Boolean result = stringRedisTemplate.opsForValue().setIfAbsent("key", "1", 10, TimeUnit.SECONDS);
// TODO 業(yè)務(wù)代碼 stock--
stringRedisTemplate.delete(key);

// 加鎖，且（給每個線程）設(shè)置鎖過期時間, 刪除鎖時判斷是否當(dāng)前線程
// 讀取  stock = 15
String uuid = UUID.getUuid; 
Boolean result = stringRedisTemplate.opsForValue().setIfAbsent("key", uuid, 10, TimeUnit.SECONDS);
// TODO 業(yè)務(wù)代碼  stock--  15 -> 14
// 判斷是否當(dāng)前線程
if (uuid.equals(stringRedisTemplate.opsForValue().get(key)) {
    // 極端場景下：（執(zhí)行時間定格在9.99秒）突然卡頓 10ms or redis服務(wù)宕機?。?！
    // 此時剛好鎖過期，自動刪除
    // 其他線程獲取鎖，然后會把上個線程的鎖刪除，又會出現(xiàn)bug
	stringRedisTemplate.delete(key);
}

@Autowire
public Redisson redisson;
   
 public void stock () {
     String key = "key";
     RLock lock = redisson.getLock(key);
     try {
         lock.lock();
         // TODO: 業(yè)務(wù)代碼 
     } catch(Exception e) {
         lock.unlock();
     }
 }

//模擬一個商品減庫存的原子操作
//lua腳本命令執(zhí)行方式：redis-cli --eval /tmp/test.lua , 10
jedis.set("product_stock_10016", "15");  // 初始化商品10016的庫存
String script = " local count = redis.call('get', KEYS[1]) " +
                " local a = tonumber(count) " +
                " local b = tonumber(ARGV[1]) " +
                " if a >= b then " +
                "   redis.call('set', KEYS[1], a-b) " +
                // 模擬語法報錯回滾操作
                "   bb == 0 " +
                "   return 1 " +
                " end " +
                " return 0 ";
Object obj = jedis.eval(script, Arrays.asList("product_stock_10016"), Arrays.asList("10"));
System.out.println(obj);

public void lockInterruptibly(long leaseTime, TimeUnit unit) throws InterruptedException {
   long threadId = Thread.currentThread().getId();
   Long ttl = this.tryAcquire(leaseTime, unit, threadId);
   if (ttl != null) {
       RFuture<RedissonLockEntry> future = this.subscribe(threadId);
        this.commandExecutor.syncSubscription(future);
       try {
           while(true) {
               ttl = this.tryAcquire(leaseTime, unit, threadId);
               if (ttl == null) {
                   return;
                }
               if (ttl >= 0L) {
                   this.getEntry(threadId).getLatch().tryAcquire(ttl, TimeUnit.MILLISECONDS);
               } else {
                   this.getEntry(threadId).getLatch().acquire();
               }
           }
       } finally {
           this.unsubscribe(future, threadId);
       }
   }
}