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

ゝ一世哀愁。 2022-11-06 00:52 174阅读 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 条评论，174人围观）

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

相关阅读

相关基于zookeeper实现分布式锁

引言在程序开发过程中不得不考虑的就是并发问题。在java中对于同一个jvm而言，jdk已经提供了lock和同步等。但是在分布式情况下，往往存在多个进程对一些资源产生竞争

淩亂°似流年/ 2023年10月18日 11:22/ 0 赞/ 57 阅读

相关基于 Zookeeper 实现分布式锁

文章目录前言声明前置知识分布式锁设计原则 Zookeeper 分布式锁实现 Curator框架实现分布式锁

ゞ浴缸里的玫瑰/ 2023年10月15日 23:09/ 0 赞/ 62 阅读

相关基于zookeeper实现分布式锁

　　关于zookeeper的基础知识及安装部署，这位文章已经讲的很清楚了，传送门[https://my.oschina.net/u/3796575/blog/1845035][

灰太狼/ 2023年08月17日 16:41/ 0 赞/ 50 阅读

相关 Java Zookeeper - 分布式锁

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

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

相关基于zookeeper实现分布式锁

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

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

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

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

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

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

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

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

相关基于zookeeper实现分布式锁

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

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

相关基于Zookeeper实现分布式锁

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

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

相关基于zookeeper实现分布式锁

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

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