女朋友也能看懂的Zookeeper分布式锁原理
前言
关于分布式锁,在互联网行业的使用场景还是比较多的,比如电商的库存扣减,秒杀活动,集群定时任务执行等需要进程互斥的场景。而实现分布式锁的手段也很多,大家比较常见的就是redis跟zookeeper,今天我们主要介绍的是基于zookeeper实现的分布式锁。
这篇文章主要借用Curator框架对zk分布式锁的实现思路,大家理解了以后完全可以自己手动实现一遍,但是在工作中还是建议使用成熟的开源框架,很多坑别人已经帮我们踩好了,除非万不得已,需要高度定制符合自己项目的需求的时候,才开始自行封装吧。
正文
zookeeper简单介绍
既然是基于zookeeper的分布式锁,首先肯定要对这个zookeeper有一定了解,这里就不过多的进行讲解,只对其跟分布式锁有关联的特性做一个简单的介绍,更多详细的功能特性大家可以参阅官方文档。
zookeeper维护着类似文件系统的数据结构,它总共有四种类型的节点
PERSISTENT:持久化的节点。一旦创建后,即使客户端与zk断开了连接,该节点依然存在。
PERSISTENT_SEQUENTIAL:持久化顺序编号节点。比PERSISTENT节点多了节点自动按照顺序编号。
EPHEMERAL:临时节点。当客户端与zk断开连接之后,该节点就被删除。
EPHEMERAL_SEQUENTIAL:临时顺序编号节点。比EPHEMERAL节点多了节点自动按照顺序编号。(分布式锁实现使用该节点类型)
Curator实现分布式锁原理
好,当我们简单了解了zk的节点类型以后,现在正式的分析Curator分布式锁的实现原理。这里我们定义了一个“/curator_lock”锁节点用来存放相关客户端创建的临时顺序节点。
假设两个客户端ClientA跟ClientB同时去争夺一个锁,此时ClientA先行一步到达zk,那么它将会在我们的zk上创建一个“/curator_lock/xxxxx-0000000000”的临时顺序节点。
接着它会获取到“/curator_lock/”锁节点下的所有子节点,因为这些节点是有序的,这时候会判断它所创建的节点是否排在第一位(也就是序号最小),由于ClientA是第一个创建节点的的客户端,必然是排在第一位,所以它也就拿到了锁。我们用zkCli查看节点信息如下。
[zk: localhost:2182(CONNECTED) 4] ls /curator_lock [_c_f3f38067-8bff-47ef-9628-e638cfaad77e-lock-0000000000]
这个时候ClientB也来了,按照同样的步骤,先是在“/curator_lock/”下创建一个临时顺序节点“/curator_lock/xxxxx-0000000001”,这个节点的序号是递增的,接着也是获得该节点下的所有子节点,并比对自己当前生成的节点序号是否在这些子节点中是最小的,由于此时序号最小的节点是ClientA创建的,并且还没释放掉,所以ClientB自己就拿不到锁。
[zk: localhost:2182(CONNECTED) 4] ls /curator_lock [_c_2a8198e4-2039-4a3c-8606-39c65790d637-lock-0000000001, _c_f3f38067-8bff-47ef-9628-e638cfaad77e-lock-0000000000]
既然ClientB拿不到锁,也不会放弃,它会对自己的前一个节点加上监听器(zk提供的api实现),只要监听到前一个节点被删除了,也就是释放了锁,就会马上重新执行获取锁的操作。
当后面的ClientC,ClientD...过来的时候也是如此,变化的只是节点上的编号,它会根据Client连接的数量而不断增加。
可能大家还会担心,万一我的获取到锁的客户端宕机了怎么办,会不会不释放锁?其实上面已经解答了这个问题,由于Curator使用的是临时顺序节点来实现的分布式锁,只要客户端与zk连接断开,该节点也就消失了,相当于释放了锁。
下面代码展示了Curator的基本使用方法,仅作为参考实例,请勿在生产环境使用的这么随意。
CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2182",5000,10000,new ExponentialBackoffRetry(1000, 3));client.start();InterProcessMutex interProcessMutex = new InterProcessMutex(client, "/curator_lock");//加锁 interProcessMutex.acquire();//业务逻辑//释放锁 interProcessMutex.release();client.close();
总结
我们在搞懂了原理之后,就可以抛弃Curator,自己动手实现一个分布式锁了,相信有一定经验的工程师实现基本的功能都是没问题的,但是要做到生产级别,可能还是要在细节上下功夫,比如说一些异常处理,性能优化等因素要考虑。
该文章首发于微信公众号《深夜里的程序猿》,转载请注明出处,侵权必究。
转载于:https://www.cnblogs.com/coding-night/p/10681246.html
女朋友也能看懂的Zookeeper分布式锁原理相关推荐
- zookeeper 分布式锁原理
zookeeper 分布式锁原理: 1 大家也许都很熟悉了多个线程或者多个进程间的共享锁的实现方式了,但是在分布式场景中我们会面临多个Server之间的锁的问题,实现的复杂度比较高.利用基于googl ...
- Zookeeper分布式锁原理
1.分布式锁介绍 单机应用开发,涉及并发同步的时候,我们往往采用synchronized 或者Lock的方式来解决多线程间的代码同步问题,这时多线程的运行都是在同一个JVM之下,没有任何问题. 但当我 ...
- zookeeper 分布式锁_关于redis分布式锁,zookeeper分布式锁原理的一些学习与思考
编辑:业余草来源:https://www.xttblog.com/?p=4946 首先分布式锁和我们平常讲到的锁原理基本一样,目的就是确保,在多个线程并发时,只有一个线程在同一刻操作这个业务或者说方法 ...
- 关于redis分布式锁,zookeeper分布式锁原理的一些学习与思考
编辑:业余草 来源:https://www.xttblog.com/?p=4946 首先分布式锁和我们平常讲到的锁原理基本一样,目的就是确保,在多个线程并发时,只有一个线程在同一刻操作这个业务或者说方 ...
- zookeeper分布式锁原理及实现
前言 本文介绍下 zookeeper方式 实现分布式锁 原理简介 zookeeper实现分布式锁的原理就是多个节点同时在一个指定的节点下面创建临时会话顺序节点,谁创建的节点序号最小,谁就获得了锁,并且 ...
- Apache Curator之分布式锁原理(二)
本文主要讲解如下内容: 为什么要使用分布式锁? 分布式锁特性! 分布式锁的实现方式有哪些? Curator分布式锁原理 Curator分布式锁实现类UML及相关类的介绍 基于Redis,数据库实现分布 ...
- Zookeeper分布式锁的使用
由于公司引入了dubbo+zookeeper框架,里面不可避免的引入的zookeeper分布式锁,所以自己大致了解了一下.由于是自己研究,有不正确的地方还请大佬批评指正. 首先先介绍一下自己对zook ...
- 架构系列---利用zookeeper 分布式锁解决缓存重建冲突实战
上一篇 分布式缓存重建并发冲突问题以及zookeeper分布式锁解决方案, 主要讲解了分布式缓存重建冲突原因及利用zookeeper分布式锁解决缓存重建冲突问题,本篇接着上篇,实现上篇思路,带你利用z ...
- 《从Paxos到zookeeper分布式一致性原理与实践》笔记
<从Paxos到zookeeper分布式一致性原理与实践>笔记 文章目录 <从Paxos到zookeeper分布式一致性原理与实践>笔记 一.概念 二.一致性协调 2.1 2P ...
- 《从Paxos到zookeeper分布式一致性原理与实践》
<从Paxos到zookeeper分布式一致性原理与实践> 一.概念 ACID: Automaticy.consistency.isolation. Durability CAP: con ...
最新文章
- ACL 2022丨香港大学华为诺亚方舟新工作:生成式预训练语言模型的量化压缩
- C++ sizeof 操作符的用法总结
- sql server 的 money类型
- 工作日志——k8s pvpvc
- mysql8 修改密码_最新版本mysql8.0.18windows x64部署手册
- Meterpreter重要命令与使用
- Error:scalac: Error: scala.collection.immutable.$colon$colon.tl$1()Lscala/collection/immutable/List;
- bitmap 转byte[]后读取_闲谈redis的bitmap
- 计算机视觉论文-2021-07-02
- 巧用Android网络通信技术,在网络上直接传输对象
- select支持手动输入
- wps设置页码,从某一页重新开始编号
- 计算机技术应用节课,矢志不渝追求卓越,上好每一节课—记滁州应用技术学校黄鹂...
- [SHELL]: ln 命令详解
- RAC 网络心跳 磁盘心跳 本地心跳 控制文件磁盘心跳
- java计算机毕业设计在线辅导答疑系统源码+mysql数据库+系统+lw文档+部署
- 【opencv学习】【图像直方图和均衡化】
- CocoStudio UI 编辑器的使用
- 大数据时代,数据实时同步解决方案的思考—最全的数据同步总结
- 单代号网络图计算例题_单代号网络图究竟是什么?用什么软件画?