zookeeper java 锁_Java实现分布式锁-基于Zookeeper(3)

ゝ一世哀愁。 2022-11-06 00:52 131阅读 0赞

import lombok.extern.slf4j.Slf4j;

import org.apache.zookeeper.\*;

import org.apache.zookeeper.data.Stat;

import java.io.IOException;

import java.util.Collections;

import java.util.List;

@Slf4j

public class ZkLock implements AutoCloseable, Watcher \{

private ZooKeeper zooKeeper;

private String znode;

public ZkLock() throws IOException \{

this.zooKeeper = new ZooKeeper("localhost:2181",

10000,this);

\}

public boolean getLock(String businessCode) \{

try \{

//创建业务 根节点

Stat stat = zooKeeper.exists("/" + businessCode, false);

if (stat==null)\{

zooKeeper.create("/" + businessCode,businessCode.getBytes(),

ZooDefs.Ids.OPEN\_ACL\_UNSAFE,

CreateMode.PERSISTENT);

\}

//创建瞬时有序节点 /order/order\_00000001

znode = zooKeeper.create("/" + businessCode + "/" + businessCode + "\_", businessCode.getBytes(),

ZooDefs.Ids.OPEN\_ACL\_UNSAFE,

CreateMode.EPHEMERAL\_SEQUENTIAL);

//获取业务节点下 所有的子节点

List childrenNodes = zooKeeper.getChildren("/" + businessCode, false);

//子节点排序

Collections.sort(childrenNodes);

//获取序号最小的(第一个)子节点

String firstNode = childrenNodes.get(0);

//如果创建的节点是第一个子节点，则获得锁

if (znode.endsWith(firstNode))\{

return true;

\}

//不是第一个子节点，则监听前一个节点

String lastNode = firstNode;

for (String node:childrenNodes)\{

if (znode.endsWith(node))\{

zooKeeper.exists("/"+businessCode+"/"+lastNode,true);

break;

\}else \{

lastNode = node;

\}

\}

synchronized (this)\{

wait();

\}

return true;

\} catch (Exception e) \{

e.printStackTrace();

\}

return false;

\}

@Override

public void close() throws Exception \{

zooKeeper.delete(znode,-1);

zooKeeper.close();

log.info("我已经释放了锁！");

\}

@Override

public void process(WatchedEvent event) \{

if (event.getType() == Event.EventType.NodeDeleted)\{

synchronized (this)\{

notify();

\}

\}

\}

\}

复制代码

发表评论取消回复

表情：

评论列表（有 0 条评论，131人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java Zookeeper - 分布式锁

前言本文来介绍下如何实现Zookeeper分布式锁，代码优化下就可以用了分布式锁分布式锁是通过互诉等手段，来实现分布式系统之间同步访问共享资源，以保证数据的

小灰灰/ 2023年07月01日 09:00/ 0 赞/ 48 阅读

相关基于zookeeper实现分布式锁

前言在分布式锁的实现中，zookeeper也是一种不错的选择，了解zookeeper的同学应该知道，zookeeper不仅可以作为集群的部署的中间件的服务协调器，器本身

ゝ一纸荒年。/ 2022年12月11日 06:24/ 0 赞/ 166 阅读

相关 zookeeper java 锁_Java实现分布式锁-基于Zookeeper(3)

import lombok.extern.slf4j.Slf4j; import org.apache.zookeeper.\; import org.apache.zoo

ゝ一世哀愁。/ 2022年11月06日 00:52/ 0 赞/ 132 阅读

相关 zookeeper学习（七）基于zookeeper实现分布式锁

一、分布式锁介绍分布式锁主要用于在分布式环境中保护跨进程、跨主机、跨网络的共享资源实现互斥访问，以达到保证数据的一致性。二、架构介绍

淡淡的烟草味﹌/ 2022年05月30日 09:52/ 0 赞/ 140 阅读

相关基于zookeeper实现分布式锁

一、分布式锁介绍分布式锁主要用于在分布式环境中保护跨进程、跨主机、跨网络的共享资源实现互斥访问，以达到保证数据的一致性。

傷城~/ 2022年05月27日 11:21/ 0 赞/ 202 阅读

相关 Java：使用ZooKeeper实现分布式锁

本文提供了使用ZooKeeper实现分布式锁的一个实现。与网上其它实现方式的主要区别在于，可以使用同一个客户端创建针对多个不同路径的锁。 1、锁管理器锁管理器内部包含一个

喜欢ヅ旅行/ 2022年03月01日 02:56/ 0 赞/ 156 阅读

相关 zookeeper 分布式锁(3)

分布式协调场景集群的缓存失效，让一个请求更新缓存即可，怎么做？![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_a

ゞ浴缸里的玫瑰/ 2022年01月31日 06:53/ 0 赞/ 153 阅读

相关基于Zookeeper实现分布式锁

实现分布式锁目前有三种流行方案，分别为基于数据库、Redis、Zookeeper的方案，其中前两种方案网络上有很多资料可以参考，本文不做展开。我们来看下使用Zookeeper如

港控/mmm°/ 2021年12月11日 09:45/ 0 赞/ 245 阅读

相关基于zookeeper实现分布式锁

基于zookeeper实现分布式锁分布式锁设计 demo源码欢迎查看Eetal的第二十七篇博客–基于zookeeper实现分布式锁

比眉伴天荒/ 2021年11月09日 15:14/ 0 赞/ 331 阅读

相关基于 Zookeeper 的分布式锁实现

点击上方 [Java后端][Java]，选择设为星标优质文章，及时送达 ![format_png][] 作者 | 田小波链接 | http://www.tianx

傷城~/ 2021年08月19日 15:06/ 0 赞/ 412 阅读