redisson lock的使用

1.現(xiàn)在錯誤的用法:

RLock lock = redisson.getLock(String.format(LOCK_KEY, 2));
try {
if (lock.tryLock()) {
//處理
logger.info("aaaaaaaaaaaaaaaaaa");
} catch(Exception e) {
//處理異常
} finally {
if (lock.isLocked()) {
lock.unlock();
}
}
測試實例:
TwoThread.java

public class TwoThread implements Runnable {
private RedissonClient redisson;

public TwoThread(RedissonClient redisson) {
this.redisson = redisson;
}

private Logger logger = LogManager.getLogger(getClass());
private String REWARD_CARD_LOCK_KEY = "444:lock:%d";

public void run() {
RLock lock = redisson.getLock(String.format(REWARD_CARD_LOCK_KEY, 2));
logger.info("thread---{}, lock:{}",Thread.currentThread().getId(), lock);
try {
if (lock.tryLock()) {
logger.info("tryLock thread---{}, lock:{}",Thread.currentThread().getId(),lock);
logger.info("aaaaaaaaaaaaaaaaaa");
}
} finally {
boolean locked = lock.isLocked();
logger.info("thread---{},lock:{},locked:{}",Thread.currentThread().getId(),lock,locked);
if (locked) {
logger.info("thread unlock---{}, lock:{}",Thread.currentThread().getId(),lock);
lock.unlock();
}

}
}
測試類:

Thread one = new Thread(new TwoThread(redisson));
Thread two = new Thread(new TwoThread(redisson));
Thread three = new Thread(new TwoThread(redisson));
Thread four = new Thread(new TwoThread(redisson));
one.start();
two.start();
three.start();
four.start();
打印結果:

thread---111, lock:org.redisson.RedissonLock@1cb2393f
thread---112, lock:org.redisson.RedissonLock@70feb82b
thread---114, lock:org.redisson.RedissonLock@50384a5d
thread---113, lock:org.redisson.RedissonLock@42232129
thread---111,lock:org.redisson.RedissonLock@1cb2393f,locked:true
aaaaaaaaaaaaaaaaaa
thread---113,lock:org.redisson.RedissonLock@42232129,locked:true
thread---112,lock:org.redisson.RedissonLock@70feb82b,locked:true
thread unlock---111, lock:org.redisson.RedissonLock@1cb2393f
thread---114,lock:org.redisson.RedissonLock@50384a5d,locked:true
thread unlock---114, lock:org.redisson.RedissonLock@50384a5d
thread unlock---113, lock:org.redisson.RedissonLock@42232129
thread unlock---112, lock:org.redisson.RedissonLock@70feb82b
Exception in thread "Thread-20" Exception in thread "Thread-19" java.lang.IllegalMonitorStateException: attempt to unlock lock, not locked by current thread by node id: 54882863-3389-40e7-ba4d-58ecae0a7155 thread-id: 114
at org.redisson.RedissonLock.unlock(RedissonLock.java:367)
at xx.TwoThread.run(TwoThread.java:36)
at java.lang.Thread.run(Thread.java:745)
java.lang.IllegalMonitorStateException: attempt to unlock lock, not locked by current thread by node id: 54882863-3389-40e7-ba4d-58ecae0a7155 thread-id: 113
at org.redisson.RedissonLock.unlock(RedissonLock.java:367)
at xx.TwoThread.run(TwoThread.java:36)
at java.lang.Thread.run(Thread.java:745)
嘗試去解鎖,但是沒有被當前線程鎖住。

boolean locked = lock.isLocked()為什么一直返回true，查看源碼,只要這個鎖被任意一個線程鎖,就會返回true

/**
* Checks if this lock locked by any thread
*
* @return <code>true</code> if locked otherwise <code>false</code>
*/
boolean isLocked();
所以,在finally里面 沒有被鎖就解鎖,肯定會報錯的。

2.tryLock正確用法:

RLock lock = redisson.getLock(String.format(REWARD_CARD_LOCK_KEY, 2));
try {
//嘗試加鎖，最多等待10秒，上鎖以后10秒自動解鎖
if (lock.tryLock(10,10, TimeUnit.SECONDS)) {
try {
//處理
logger.info("tryLock thread---{}, lock:{}", Thread.currentThread().getId(), lock);
} catch (Exception e) {
} finally {
//解鎖
lock.unlock();
}
}
} catch (InterruptedException e) {
//處理
//保留中斷發(fā)生的證據(jù)，以便調用棧中更高層的代碼能知道中斷，并對中斷作出響應
Thread.currentThread().interrupt();
}
關于處理InterruptedException,文檔參考:

https://www.ibm.com/developerworks/cn/java/j-jtp05236.html

需要恢復中斷狀態(tài)場景的一個例子,方便理解:

http://www.rzrgm.cn/softidea/p/4413374.html
————————————————
版權聲明：本文為CSDN博主「qq_24664619」的原創(chuàng)文章，遵循CC 4.0 BY-SA版權協(xié)議，轉載請附上原文出處鏈接及本聲明。
原文鏈接：https://blog.csdn.net/qq_24664619/article/details/103879692