doocs/advanced-java
1
0
Fork 0
mirror of https://github.com/doocs/advanced-java.git synced 2025-04-01 12:30:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

docs: update distributed-lock-redis-vs-zookeeper.md

Browse Source
This commit is contained in:
yanglbme 2022-09-28 10:51:23 +08:00
parent a9123c980d
commit 0a52be9d0d
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
docs/distributed-system/distributed-lock-redis-vs-zookeeper.md
View File

@ -253,32 +253,32 @@ public class ZooKeeperDistributedLock implements Watcher {
public boolean tryLock() { public boolean tryLock() {
try { try {
// 传入进去的locksRoot + “/” + productId // 传入进去的locksRoot + “/” + productId
// 假设productId代表了一个商品id，比如说1 // 假设productId代表了一个商品id，比如说1
// locksRoot = locks // locksRoot = locks
// /locks/10000000000，/locks/10000000001，/locks/10000000002 // /locks/10000000000，/locks/10000000001，/locks/10000000002
lockNode = zk.create(locksRoot + "/" + productId, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL); lockNode = zk.create(locksRoot + "/" + productId, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
// 看看刚创建的节点是不是最小的节点 // 看看刚创建的节点是不是最小的节点
// locks：10000000000，10000000001，10000000002 // locks：10000000000，10000000001，10000000002
List<String> locks = zk.getChildren(locksRoot, false); List<String> locks = zk.getChildren(locksRoot, false);
Collections.sort(locks); Collections.sort(locks);
if(lockNode.equals(locksRoot+"/"+ locks.get(0))){ if (lockNode.equals(locksRoot + "/" + locks.get(0))) {
//如果是最小的节点,则表示取得锁 // 如果是最小的节点,则表示取得锁
return true; return true;
} }
//如果不是最小的节点，找到比自己小1的节点 // 如果不是最小的节点，找到比自己小1的节点
int previousLockIndex = -1; int previousLockIndex = -1;
for(int i = 0; i < locks.size(); i++) { for (int i = 0; i < locks.size(); i++) {
if(lockNode.equals(locksRoot + “/” + locks.get(i))) { if (lockNode.equals(locksRoot + “ /”+locks.get(i))){
previousLockIndex = i - 1; previousLockIndex = i - 1;
break; break;
} }
} }
this.waitNode = locks.get(previousLockIndex); this.waitNode = locks.get(previousLockIndex);
} catch (KeeperException e) { } catch (KeeperException e) {
throw new LockException(e); throw new LockException(e);
} catch (InterruptedException e) { } catch (InterruptedException e) {