使用ZooKeeper实现Java跨JVM的分布式锁(读写锁)

╰+攻爆jí腚メ 2022-06-07 02:29 150阅读 0赞

一、[使用ZooKeeper实现Java跨JVM的分布式锁][ZooKeeper_Java_JVM]

二、[使用ZooKeeper实现Java跨JVM的分布式锁(优化构思)][ZooKeeper_Java_JVM 1]

三、[使用ZooKeeper实现Java跨JVM的分布式锁(读写锁)][ZooKeeper_Java_JVM 2]

**zookeeper技术学习，更多知识请访问[https://www.itkc8.com][https_www.itkc8.com]**

**读写锁：**

本文在前面俩片的基础之上介绍如何 使用ZooKeeper实现Java跨JVM的分布式锁(读写锁)。

简单介绍一下读写锁，在使用读写锁时， 多个客户端（线程）可以同时获取 “读锁”， 但是“写入锁”是排它的，只能单独获取。

1、假设A,B线程获取到 “读锁”， 这时C线程就不能获取 “写锁”。

2、假设C线程获取了“写锁”，那么A,B线程就不能获取“读锁”。

这在某种情况下会大幅度提高系统的性能，在单JVM进程内 Java已经提供了这种锁的机制，可以参考ReentrantReadWriteLock这个类。

**基于ZK的分布式读写锁：**

本文主要介绍ZK的分布式读写锁，还是基于Curator客户端实现。

**\[java\]** [view plain][] [copy][view plain]

1.  **package** com.framework.code.demo.zook.lock;  
2.    
3.  **import** org.apache.curator.RetryPolicy;  
4.  **import** org.apache.curator.framework.CuratorFramework;  
5.  **import** org.apache.curator.framework.CuratorFrameworkFactory;  
6.  **import** org.apache.curator.framework.recipes.locks.InterProcessMutex;  
7.  **import** org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock;  
8.  **import** org.apache.curator.retry.ExponentialBackoffRetry;  
9.    
10. **public** **class** ReadWriteLock \{  
11.   
12.     /\*\* 
13.      \* @param args 
14.      \* @throws Exception  
15.      \*/  
16.     **public** **static** **void** main(String\[\] args) **throws** Exception \{  
17.         RetryPolicy retryPolicy = **new** ExponentialBackoffRetry(1000,3);  
18.         CuratorFramework client = CuratorFrameworkFactory  
19.                 .newClient("192.168.1.103:2181", retryPolicy);  
20.         client.start();  
21.           
22.         InterProcessReadWriteLock readWriteLock = **new** InterProcessReadWriteLock(client, "/read-write-lock");  
23.           
24.         //读锁  
25.         **final** InterProcessMutex readLock = readWriteLock.readLock();  
26.         //写锁  
27.         **final** InterProcessMutex writeLock = readWriteLock.writeLock();  
28.           
29.         **try** \{  
30.             readLock.acquire();  
31.             System.out.println(Thread.currentThread() + "获取到读锁");  
32.               
33.             **new** Thread(**new** Runnable() \{  
34.                 @Override  
35.                 **public** **void** run() \{  
36.                     **try** \{  
37.                         //在读锁没释放之前不能读取写锁。  
38.                         writeLock.acquire();  
39.                         System.out.println(Thread.currentThread() + "获取到写锁");  
40.                     \} **catch** (Exception e) \{  
41.                         e.printStackTrace();  
42.                     \} **finally** \{  
43.                         **try** \{  
44.                             writeLock.release();  
45.                         \} **catch** (Exception e) \{  
46.                             e.printStackTrace();  
47.                         \}  
48.                     \}  
49.                 \}  
50.             \}).start();  
51.             //停顿3000毫秒不释放锁，这时其它线程可以获取读锁，却不能获取写锁。  
52.             Thread.sleep(3000);  
53.         \} **catch** (Exception e) \{  
54.             e.printStackTrace();  
55.         \} **finally** \{  
56.             readLock.release();  
57.         \}  
58.           
59.         Thread.sleep(1000000);  
60.         client.close();  
61.     \}  
62.   
63. \}

![Center][]

**实现原理：**

实现原理与之前介绍的锁的原理基本类似，这里主要说明一下不同之处。

1、写入锁在申请锁时写入的节点名称是这样的   xxxx-\_\_WRIT\_\_00000000xxx 例如：   \_c\_9b6e456b-94fe-47e7-b968-34027c094b7d-\_\_WRIT\_\_0000000006

2、读取锁在申请锁时写入的节点名称是这样的  xxxx-\_\_READ\_\_00000000xxx 例如：    \_c\_9b6e456b90-9c33-6294665cf525--b6448-\_\_READ\_\_0000000005

区别就是写入锁的字符串包含WRIT，读取所包含READ

**获取锁的区别：**

1、写入锁在获取锁时的处理与前面文章介绍的原理一直，就是判断自己前面还有没有节点，如果没有就可以获取到锁，如果有就等待前面的节点释放锁。

2、读取锁在获取锁时的处理是，判断自己前面还有没有写入锁的节点，也就是前面的节点是否包含WRIT，如果有那么等待前面的节点释放锁。

读取所自己前面有 其它 读取锁节点 无所谓，它仍然可以获取到锁，这也就是读取所可以多客户端共享的原因。

**zookeeper技术学习，更多知识请访问[https://www.itkc8.com][https_www.itkc8.com]**

[ZooKeeper_Java_JVM]: http://blog.csdn.net/nimasike/article/details/51567653
[ZooKeeper_Java_JVM 1]: http://blog.csdn.net/nimasike/article/details/51578163
[ZooKeeper_Java_JVM 2]: http://blog.csdn.net/nimasike/article/details/51581755
[https_www.itkc8.com]: https://www.itkc8.com
[view plain]: http://blog.csdn.net/nimasike/article/details/51581755#
[Center]: /images/20220607/6a2d37aee8554c938bff3772bb235185.png