李锋镝的博客

  • 首页
  • 时间轴
  • 说说
  • 读书观影
  • 系列
  • AI工具集
  • 论坛
  • 友圈
    • 友链
    • 朋友圈
    • 游客中心
  • 留言
    • 留言
    • 走心评论
  • 关于
    • 关于本站
    • Now
    • 每日心情
    • 网站地图
    • 网站统计
    • 赞助
  • 星球穿梭
  • 🚇开往
静亦定 动亦定
惟坚韧者始能遂其志
  1. 首页
  2. 转载
  3. 技术
  4. 正文

分布式锁-Zookeeper实现分布式锁

2019年11月11日 254 0 0
本文最后更新于 2019年11月11日,距今已 2552 天,其中的信息可能已经发生变化,请注意甄别。

如何用Zookeeper实现分布式锁?

在学习分布式锁之前,需要首先了解一下Zookeeper的[临时顺序节点]。

什么是临时顺序节点?

让我们来回顾一下Zookeeper节点的概念:

自动草稿

Zookeeper的数据存储结构就像一棵树,这棵树由节点组成,这种节点叫做Znode。

Znode分为四种类型:

1.持久节点 (PERSISTENT)

默认的节点类型。创建节点的客户端与zookeeper断开连接后,该节点依旧存在 。

2.持久节点顺序节点(PERSISTENT_SEQUENTIAL)

所谓顺序节点,就是在创建节点时,Zookeeper根据创建的时间顺序给该节点名称进行编号:

自动草稿

3.临时节点(EPHEMERAL) 

和持久节点相反,当创建节点的客户端与zookeeper断开连接后,临时节点会被删除。

自动草稿
自动草稿
自动草稿

4.临时顺序节点(EPHEMERAL_SEQUENTIAL) 
顾名思义,临时顺序节点结合和临时节点和顺序节点的特点:在创建节点时,Zookeeper根据创建的时间顺序给该节点名称进行编号;当创建节点的客户端与Zookeeper断开连接后,临时节点会被删除。

那临时顺序节点和Zookeeper的分布式锁有什么关系呢?

Zookeeper分布式锁的原理

Zookeeper分布式锁恰恰应用了临时顺序节点。具体如何实现呢?让我们来看一看详细步骤:

获取锁

首先,在Zookeeper当中创建一个持久节点ParentLock。当第一个客户端想要获得锁时,需要在ParentLock这个节点下面创建一个临时顺序节点 Lock1。

自动草稿

之后,Client1查找ParentLock下面所有的临时顺序节点并排序,判断自己所创建的节点Lock1是不是顺序最靠前的一个。如果是第一个节点,则成功获得锁。

自动草稿

这时候,如果再有一个客户端 Client2 前来获取锁,则在ParentLock下载再创建一个临时顺序节点Lock2。

自动草稿

Client2查找ParentLock下面所有的临时顺序节点并排序,判断自己所创建的节点Lock2是不是顺序最靠前的一个,结果发现节点Lock2并不是最小的。

于是,Client2向排序仅比它靠前的节点Lock1注册Watcher,用于监听Lock1节点是否存在。这意味着Client2抢锁失败,进入了等待状态。

自动草稿

这时候,如果又有一个客户端Client3前来获取锁,则在ParentLock下载再创建一个临时顺序节点Lock3。

自动草稿

Client3查找ParentLock下面所有的临时顺序节点并排序,判断自己所创建的节点Lock3是不是顺序最靠前的一个,结果同样发现节点Lock3并不是最小的。

于是,Client3向排序仅比它靠前的节点Lock2注册Watcher,用于监听Lock2节点是否存在。这意味着Client3同样抢锁失败,进入了等待状态。

自动草稿

这样一来,Client1得到了锁,Client2监听了Lock1,Client3监听了Lock2。这恰恰形成了一个等待队列,很像是Java当中ReentrantLock所依赖的AQS(AbstractQueuedSynchronizer)。

获得锁的过程大致就是这样,那么Zookeeper如何释放锁呢?

释放锁的过程很简单,只需要释放对应的子节点就好。

释放锁

释放锁分为两种情况:

1.任务完成,客户端显示释放

当任务完成时,Client1会显示调用删除节点Lock1的指令。

自动草稿

2.任务执行过程中,客户端崩溃

获得锁的Client1在任务执行过程中,如果Duang的一声崩溃,则会断开与Zookeeper服务端的链接。根据临时节点的特性,相关联的节点Lock1会随之自动删除。

自动草稿

由于Client2一直监听着Lock1的存在状态,当Lock1节点被删除,Client2会立刻收到通知。这时候Client2会再次查询ParentLock下面的所有节点,确认自己创建的节点Lock2是不是目前最小的节点。如果是最小,则Client2顺理成章获得了锁。

自动草稿

同理,如果Client2也因为任务完成或者节点崩溃而删除了节点Lock2,那么Client3就会接到通知。

自动草稿

最终,Client3成功得到了锁。

自动草稿

使用Zookeeper实现分布式锁的大致流程就是这样。那么使用Zookeeper实现的分布式锁和Redis实现的分布式锁相比有什么优势和劣势呢?

下面总结一下他们各自的优劣。

分布式锁 优点 缺点
Zookeeper 1.有封装好的框架,容易实现

2.有等待锁的队列,大大提升抢锁效率。

添加和删除节点性能较低
Redis Set和Del指令性能较高 1.实现复杂,需要考虑超时,原子性,误删等情形。

2.没有等待锁的队列,只能在客户端自旋来等待,效率低下。

有人说Zookeeper实现的分布式锁支持可重入,Redis实现的分布式锁不支持可重入,这是错误的观点。两者都可以在客户端实现可重入逻辑。

关于Zookeeper分布式锁的内容就介绍到这里啦。

原文链接:https://blog.csdn.net/kongmin_123/article/details/82081953

参考链接

1
  1. 1blog.csdn.netblog.csdn.net
本作品采用 知识共享署名-非商业性使用-相同方式共享 4.0 国际许可协议 进行许可
分享到

分布式锁-Zookeeper实现分布式锁

也可使用浏览器菜单中的「分享」功能

微信扫一扫分享

标签: JAVA Zookeeper 分布式 分布式锁
最后更新:2019年11月11日

岁月同一天 11 月 6 日

回望过去的今天,你在写什么

  • AI
    1 年前 2025年11月6日
    AI能写代码,却造不出软件:软件工程的核心竞争力从未改变

    “我用AI拼了个Demo,就差上线了,能帮我变成产品吗?” 最近越来越多非技术从业者带着这样的需求找上门——他们可能是律…

  • 代码人生
    1 年前 2025年11月6日
    西蒙学习法实战指南:6个月攻克新领域,从入门到能用的高效路径

    作为IT从业者,我们每天都面临新技术的冲击——今天是AI大模型,明天是云原生,后天是低代码开发。有限的时间与无限的学习需…

  • AI
    1 年前 2025年11月6日
    从Token到计费:大模型背后的文本编码逻辑与商业本质

    你是否有过这样的困惑?——给大模型发一段500字的中文需求,却被扣除了800多个Token;同样一篇文章,在GPT-4中…

  • 6 年前 2020年11月6日
    8条经验轻松上手IDEA插件开发

    IDEA作为我们(后端Java开发者)必不可少的IDE,以其智能的代码提示、多样的框架支持、简洁的开发界面等特性,被业界…

  • 其他
    7 年前 2019年11月6日
    架构师究竟比高级开发厉害在哪?

    目前我在互联网公司里干了1年多,接触了多位技术和业务的架构师,由于我正在升级到架构师,所以能直观地感受到高级开发和架构的…

  • 转载
    7 年前 2019年11月6日
    如何在面试中介绍自己的项目经验

    在面试时,经过寒暄后,一般面试官会让介绍项目经验 。常见的问法是,说下你最近的(或最拿得出手的)一个项目。 根据我们的面…

相关文章
  • 【收藏】从面试官角度观察到的程序员技能瓶颈,同时给出突破瓶颈的建议2019年10月16日
  • Maven发布本地项目的jar包和源码到私有仓库(maven-source-plugin的简单使用)2020年5月25日
  • Java 序列化和反序列化为什么要实现 Serializable 接口?2022年8月4日
  • 深入理解Redis2019年11月22日
  • 为什么同样是分布式架构的Kafka需要Leader而Redis不需要?2021年3月22日

李锋镝

既然选择了远方,便只顾风雨兼程。

打赏 点赞
< 上一篇
下一篇 >
1234567891112131415161718192021222324252627282930313233343536373839404142434446474849505152535455575859606162636465666769727476777879808182858687909293949596979899
取消回复
…

文章评论

还没有评论,快来抢沙发吧~

去吃自助,不小心打坏一个盘子,服务员说要赔10块钱,我应允好,吃完去赔偿。走的时候跟收银前台说弄坏了一个盘子,服务员让我来赔10块钱。收银员纠结了下,给我10块钱说:“不好意思了先生,影响到你的用餐,我们深感抱歉!”拿着10块钱我有点懵逼。

听点儿音乐吧 朋友~
文章目录
最新 热点 随机
最新 热点 随机
给服务器加了WAF 又一个逆天改命的人:小小徐 AI的生成能力等于生产力吗? NGINX严重漏洞(CVE-2026-15176、CVE-2026-93479、CVE-2026-97205) Kratos-plus v1.1.27更新说明 php2shell远程执行漏洞修复(CVE-2026-109618 和 CVE-2026-109619)
给主题增加了游客中心功能心气没了,干什么都不得劲我觉得是时候公布我的导航网站了给服务器加了WAF游本昌去世关于主题加载速度优化的一点儿小演进
中国文学史上最霸气的诗句是哪一首?这首诗当仁不让 Redis的主从同步及Redis Cluster(集群)下的高可用 记一次Apollo配置中心+Spring配置自动刷新导致的内存泄露问题 Java设计模式-原型模式 记录一次K8s 部署 Sentinel Dashboard 无法通过 Metric 抓取数据问题 应用型负载均衡(ALB)和网络型负载均衡(NLB)区别
最近评论
fairy 发布于 38 分钟前(11月06日) 机器人快来我这里吧!
李锋镝 发布于 43 分钟前(11月06日) 都是机器人,防不住
李锋镝 发布于 43 分钟前(11月06日) 是的,太烦了
李锋镝 发布于 44 分钟前(11月06日) 可以同一台服务器
fairy 发布于 3 小时前(11月06日) 这流量,好厉害啊。我一年都没那么多
标签聚合
WordPress K8s AI 架构 分布式 ElasticSearch Claude 日常 JAVA MySQL SQL 数据库 JVM Redis AI编程 IDEA SpringBoot 多线程 Spring Theme
友情链接
  • 哥斯拉
  • 彬红茶日记
  • 韩小韩博客
  • 韩情脉脉
  • 皮皮社
  • 搬砖日记
  • 志文工作室
  • 刘永博客
  • 懋和道人
  • Serendipity
  • Honesty
  • 林羽凡
  • lijie blog
  • 九仞之行
  • Mr.Sun的博客
  • 瓦匠个人小站
  • 老张博客
  • sssr7844的博客
  • 知向前端

COPYRIGHT © 2016-2026 lifengdi.com. ALL RIGHTS RESERVED.

lifengdi.com 十年之约虫洞

Domain age badge for lifengdi.com

Theme Kratos-plus By Dylan Li

津ICP备2024022503号-3

京公网安备11011502039375号