Zookeeper：分布式锁 - 版本历史

Eijux：/* InterProcessSemaphoreV2：信号量 */

2021-10-01T09:58:07Z

InterProcessSemaphoreV2：信号量

←上一版本		2021年10月1日 (五) 17:58的版本
第708行：		第708行：

	=== InterProcessSemaphoreV2：信号量 ===		=== InterProcessSemaphoreV2：信号量 ===
	~~示例：~~		<pre>
			跟Java并信号量没有什么不同，curator实现的信号量也是基于令牌桶算法，当一个线程要执行的时候就去桶里面获取令牌，如果有足够的令牌就执行，如果没有就阻塞，当线程执行完毕也要将令牌放回桶里。
			</pre>

			示例：“设置了信号量为1，如果其中一个线程取走了，那么下一个线程将阻塞直接信号量被返回到桶里面”
	: <syntaxhighlight lang="Java" highlight="">		: <syntaxhighlight lang="Java" highlight="">
	@Test		@Test

Eijux：/* InterProcessSemaphoreMutex：分布式排它锁 */

2021-10-01T09:53:39Z

InterProcessSemaphoreMutex：分布式排它锁

←上一版本		2021年10月1日 (五) 17:53的版本
第527行：		第527行：
	=== InterProcessSemaphoreMutex：分布式排它锁 ===		=== InterProcessSemaphoreMutex：分布式排它锁 ===
	*（注意，不可重入的锁很容易在一些情况导致死锁）		*（注意，不可重入的锁很容易在一些情况导致死锁）


	示例：		示例：

Eijux：/* InterProcessReadWriteLock：分布式读写锁 */

2021-10-01T09:53:21Z

InterProcessReadWriteLock：分布式读写锁

←上一版本		2021年10月1日 (五) 17:53的版本
第584行：		第584行：
	=== InterProcessReadWriteLock：分布式读写锁 ===		=== InterProcessReadWriteLock：分布式读写锁 ===
	* 读锁和读锁不互斥，只要有写锁就互斥。		* 读锁和读锁不互斥，只要有写锁就互斥。


	示例：		示例：

Eijux：/* InterProcessSemaphoreV2：信号量 */

2021-10-01T09:53:03Z

InterProcessSemaphoreV2：信号量

←上一版本		2021年10月1日 (五) 17:53的版本
第768行：		第768行：
	1释放读信号量===============		1释放读信号量===============
	</syntaxhighlight>		</syntaxhighlight>


	* 当然可以一次获取多个信号量：		* 当然可以一次获取多个信号量：

Eijux：/* curator 提供的分布式锁 */

2021-10-01T09:51:52Z

curator 提供的分布式锁

←上一版本		2021年10月1日 (五) 17:51的版本
第437行：		第437行：
	curator 的几种锁方案：		curator 的几种锁方案：
	# '''InterProcessMutex'''：分布式可重入排它锁		# '''InterProcessMutex'''：分布式可重入排它锁
	#: <syntaxhighlight lang="Java" highlight="">		# '''InterProcessSemaphoreMutex'''：分布式排它锁
			# '''InterProcessReadWriteLock'''：分布式读写锁
			# '''InterProcessMultiLock'''：多重锁，将多个锁作为单个实体管理的容器


			curator 还提供了信号量：
			: '''InterProcessSemaphoreV2'''：
			<pre>
			InterProcessSemaphoreV2 实现了一个跨 jvm 的信号量。

			主要工作原理是：
			acquire时创建一个临时顺序节点，如果创建成功且临时节点数小于等于 maxLeases 则说明信号量获取成功，否则 wait 等待，等待目录发生变化或计数改变时唤醒。

			整个 acquire 过程持 InterProcessMutex 而互斥，因为其中带有等待，性能不会太高。实际使用时等待时间最好不要太长。
			</pre>

			=== InterProcessMutex：分布式可重入排它锁 ===
			示例：
			: <syntaxhighlight lang="Java" highlight="">
	@Test		@Test
	public void sharedReentrantLock() throws Exception {		public void sharedReentrantLock() throws Exception {
第496行：		第514行：
	}		}
	</syntaxhighlight>		</syntaxhighlight>
	#: <syntaxhighlight lang="xml" highlight="">		: <syntaxhighlight lang="xml" highlight="">
	1获取锁===============		1获取锁===============
	1再次获取锁===============		1再次获取锁===============
第506行：		第524行：
	2再次释放锁===============		2再次释放锁===============
	</syntaxhighlight>		</syntaxhighlight>
	~~# '''InterProcessSemaphoreMutex'''：分布式排它锁~~
	#*（注意，不可重入的锁很容易在一些情况导致死锁）		=== InterProcessSemaphoreMutex：分布式排它锁 ===
	#: <syntaxhighlight lang="Java" highlight="">		*（注意，不可重入的锁很容易在一些情况导致死锁）


			示例：
			: <syntaxhighlight lang="Java" highlight="">
	@Test		@Test
	public void sharedLock() throws Exception {		public void sharedLock() throws Exception {
第553行：		第575行：
	}		}
	</syntaxhighlight>		</syntaxhighlight>
	#: <syntaxhighlight lang="xml" highlight="">		: <syntaxhighlight lang="xml" highlight="">
	1获取锁===============		1获取锁===============
	1释放锁===============		1释放锁===============
第559行：		第581行：
	2释放锁===============		2释放锁===============
	</syntaxhighlight>		</syntaxhighlight>
	~~# '''InterProcessReadWriteLock'''：分布式读写锁~~
	#* 读锁和读锁不互斥，只要有写锁就互斥。		=== InterProcessReadWriteLock：分布式读写锁 ===
	#: <syntaxhighlight lang="Java" highlight="">		* 读锁和读锁不互斥，只要有写锁就互斥。


			示例：
			: <syntaxhighlight lang="Java" highlight="">
	@Test		@Test
	public void sharedReentrantReadWriteLock() throws Exception {		public void sharedReentrantReadWriteLock() throws Exception {
第626行：		第652行：
	}		}
	</syntaxhighlight>		</syntaxhighlight>
	#: <syntaxhighlight lang="xml" highlight="">		: <syntaxhighlight lang="xml" highlight="">
	1获取读锁===============		1获取读锁===============
	1再次获取读锁===============		1再次获取读锁===============
第636行：		第662行：
	2再次释放读锁===============		2再次释放读锁===============
	</syntaxhighlight>		</syntaxhighlight>
	#: （如上所示，读锁不是互斥的）		: （如上所示，读锁不是互斥的）
	~~# '''InterProcessMultiLock'''：多重锁，将多个锁作为单个实体管理的容器~~
	#: <syntaxhighlight lang="Java" highlight="9">		=== InterProcessMultiLock：多重锁 ===
			示例：
			: <syntaxhighlight lang="Java" highlight="9">
	@Test		@Test
	public void multiLock() throws Exception {		public void multiLock() throws Exception {
第675行：		第703行：
	}		}
	</syntaxhighlight>		</syntaxhighlight>
	#: <syntaxhighlight lang="xml" highlight="">		: <syntaxhighlight lang="xml" highlight="">
	false		false
	true		true
第681行：		第709行：
	</syntaxhighlight>		</syntaxhighlight>

			=== InterProcessSemaphoreV2：信号量 ===
			示例：
	~~curator 还提供了信号量：~~
	~~: '''InterProcessSemaphoreV2'''：~~
	~~<pre>~~
	~~InterProcessSemaphoreV2 实现了一个跨 jvm 的信号量。~~

	~~主要工作原理是：~~
	acquire时创建一个临时顺序节点，如果创建成功且临时节点数小于等于 maxLeases 则说明信号量获取成功，否则 wait 等待，等待目录发生变化或计数改变时唤醒。

	~~整个 acquire 过程持 InterProcessMutex 而互斥，因为其中带有等待，性能不会太高。实际使用时等待时间最好不要太长。~~
	~~</pre>~~
	: <syntaxhighlight lang="Java" highlight="">		: <syntaxhighlight lang="Java" highlight="">
	@Test		@Test
第750行：		第768行：
	1释放读信号量===============		1释放读信号量===============
	</syntaxhighlight>		</syntaxhighlight>


	* 当然可以一次获取多个信号量：		* 当然可以一次获取多个信号量：

Eijux：/* curator 提供的分布式锁 */

2021-10-01T09:41:49Z

curator 提供的分布式锁

←上一版本		2021年10月1日 (五) 17:41的版本
第680行：		第680行：
	false		false
	</syntaxhighlight>		</syntaxhighlight>

Eijux：/* curator 提供的分布式锁 */

2021-10-01T09:40:55Z

curator 提供的分布式锁

显示更改

Eijux：/* 思路一：非公平排他锁 */

2021-10-01T09:13:30Z

思路一：非公平排他锁

←上一版本		2021年10月1日 (五) 17:13的版本
第33行：		第33行：

	* 竞争锁的线程不会进行排队，意味着此为“非公平锁”。		* 竞争锁的线程不会进行排队，意味着此为“非公平锁”。
	* 可能出现的问题：当锁被释放或者获得锁的线程宕机，所有监听“/~~exclusive_lock”子节点的线程都会作出反应，这样会给服务器带来巨大压力。（“羊群效应”）~~		* 可能出现的问题：当锁被释放或者获得锁的线程宕机，所有监听“/exclusive_lock”子节点的线程都会作出反应，这样会给服务器带来巨大压力。【“'''羊群效应'''”】

	=== 思路二：公平排他锁 ===		=== 思路二：公平排他锁 ===

Eijux：/* 示例 */

2021-09-30T17:07:48Z

示例

←上一版本		2021年10月1日 (五) 01:07的版本
第501行：		第501行：
	: 控制台每间隔一秒钟输出一条记录：		: 控制台每间隔一秒钟输出一条记录：
	: [[File:Zookeeper：分布式锁：curator：InterProcessMutex示例.png\|600px]]		: [[File:Zookeeper：分布式锁：curator：InterProcessMutex示例.png\|600px]]

			== 总结 ==
			ZooKeeper 分布式锁：
			* 优点：ZooKeeper 分布式锁（如 InterProcessMutex），能有效地解决分布式问题，不可重入问题，使用起来也较为简单。
			* 缺点：ZooKeeper 实现的分布式锁，性能并不太高（因为每次在创建锁和释放锁的过程中，都要动态创建、销毁暂时节点来实现锁功能）。
			*: 【ZooKeeper 中创建和删除节点只能通过 Leader（主）服务器来执行，然后 Leader 服务器还需要将数据同步到所有的Follower（从）服务器上】


			目前分布式锁，比较成熟、主流的方案有两种：
			# 基于 Redis 的分布式锁。适用于'''并发量很大'''、性能要求很高而可靠性问题可以通过其他方案去弥补的场景。
			# 基于 ZooKeeper 的分布式锁。适用于'''高可靠'''（高可用），而并发量不是太高的场景。

			总之，在高性能、高并发的应用场景下，不建议使用 ZooKeeper 的分布式锁。而由于 ZooKeeper 的高可用性，因此在并发量不是太高的应用场景中，还是推荐使用 ZooKeeper 的分布式锁。

Eijux：/* Zookeeper分布式锁的实现 */

2021-09-30T17:00:35Z

Zookeeper分布式锁的实现

显示更改

Zookeeper：分布式锁 - 版本历史

Eijux：​/* InterProcessSemaphoreV2：信号量 */

Eijux：​/* InterProcessSemaphoreMutex：分布式排它锁 */

Eijux：​/* InterProcessReadWriteLock：分布式读写锁 */

Eijux：​/* InterProcessSemaphoreV2：信号量 */

Eijux：​/* curator 提供的分布式锁 */

Eijux：​/* curator 提供的分布式锁 */

Eijux：​/* curator 提供的分布式锁 */

Eijux：​/* 思路一：非公平排他锁 */

Eijux：​/* 示例 */

Eijux：​/* Zookeeper分布式锁的实现 */

Eijux：/* InterProcessSemaphoreV2：信号量 */

Eijux：/* InterProcessSemaphoreMutex：分布式排它锁 */

Eijux：/* InterProcessReadWriteLock：分布式读写锁 */

Eijux：/* InterProcessSemaphoreV2：信号量 */

Eijux：/* curator 提供的分布式锁 */

Eijux：/* curator 提供的分布式锁 */

Eijux：/* curator 提供的分布式锁 */

Eijux：/* 思路一：非公平排他锁 */

Eijux：/* 示例 */

Eijux：/* Zookeeper分布式锁的实现 */