如何使用ZooKeeper实现Java跨JVM的分布式读写锁

发布时间:2021-11-12 18:35:42 作者:柒染
来源:亿速云 阅读:142

这期内容当中小编将会给大家带来有关 如何使用ZooKeeper实现Java跨JVM的分布式读写锁,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。


读写锁:

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


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

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

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

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


基于ZK的分布式读写锁:

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

package com.framework.code.demo.zook.lock;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class ReadWriteLock {

	/**
	 * @param args
	 * @throws Exception 
	 */
	public static void main(String[] args) throws Exception {
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000,3);
		CuratorFramework client = CuratorFrameworkFactory
				.newClient("192.168.1.103:2181", retryPolicy);
		client.start();
		
		InterProcessReadWriteLock readWriteLock = new InterProcessReadWriteLock(client, "/read-write-lock");
		
		//读锁
		final InterProcessMutex readLock = readWriteLock.readLock();
		//写锁
		final InterProcessMutex writeLock = readWriteLock.writeLock();
		
		try {
			readLock.acquire();
			System.out.println(Thread.currentThread() + "获取到读锁");
			
			new Thread(new Runnable() {
				@Override
				public void run() {
					try {
						//在读锁没释放之前不能读取写锁。
						writeLock.acquire();
						System.out.println(Thread.currentThread() + "获取到写锁");
					} catch (Exception e) {
						e.printStackTrace();
					} finally {
						try {
							writeLock.release();
						} catch (Exception e) {
							e.printStackTrace();
						}
					}
				}
			}).start();
			//停顿3000毫秒不释放锁,这时其它线程可以获取读锁,却不能获取写锁。
			Thread.sleep(3000);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			readLock.release();
		}
		
		Thread.sleep(1000000);
		client.close();
	}

}


如何使用ZooKeeper实现Java跨JVM的分布式读写锁


实现原理:

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

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实现Java跨JVM的分布式读写锁了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注亿速云行业资讯频道。

推荐阅读:
  1. Java读写锁ReentrantReadWriteLock怎么使用
  2. zookeeper中怎么实现分布式排它锁

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

zookeeper java jvm

上一篇:storm和zookeeper中节点的关系是什么

下一篇:Django中的unittest应用是什么

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》