Java ZooKeeper分布式锁实现图解

 更新时间:2022年03月01日 14:37:41   作者:GuochaoHN  
ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等

什么是分布式锁

1、在我们进行单机应用开发,涉及并发同步的时候,我们往往采用synchronized或者Lock的方式来解决多线程间的代码同步问题,这时多线程的运行都是在同一个JVM之下,没有任何问题。

2、但当我们的应用是分布式集群工作的情况下,属于多JVM下的工作环境(多台机器),跨JVM之间已经无法通过多线程的锁解决同步问题。那么就需要一种更加高级的锁机制,来处理种跨机器的进程之间的数据同步问题——这就是分布式锁。(多节点从分布式组件中获取锁)

例如以下实例:

各种抢票软件客户端通过zookeeper获取锁,最终只有一个客户端可以获得锁并且先与12306服务器进行数据通信,最终和12306数据库服务器通行。通信完毕之后释放锁,其他客户端获取锁之后执行同样的操作。(显然前提是这几个客户端都通过负载均衡后均与节点集群中同一个服务器进行通信)

3、其他分布式锁

zookeeper分布式锁原理

核心思想:当客户端要获取锁,则创建节点,使用完锁,则删除该节点。

1、客户端获取锁时,在lock节点下创建临时顺序节点。

2、然后获取lock下面的所有子节点,客户端获取到所有的子节点之后,如果发现自己创建的子节点序号最小,那么就认为该客户端获取到了锁。使用完锁后,将该节点删除。

注意:

创建临时节点的原因:

如果某个已经获取锁了的节点发生宕机,如果是持久化节点,那么锁就无法释放。如果是临时节点,在发生宕机后,连接断开会自动释放锁。

创建顺序节点的原因:

将节点按顺序编号,客户端通过节点编号判断自己是否是序号最小的节点,并且获得锁。

3、如果发现自己创建的节点并非lock所有子节点中最小的,说明自己还没有获取到锁,此时客户端需要找到比自己小的那个节点,同时对其注册事件监听器,监听删除事件。

4、如果发现比自己小的那个节点被删除,则客户端的 Watcher会收到相应通知,此时再次判断自己创建的节点是否是lock子节点中序号最小的,如果是则获取到了锁, 如果不是则重复以上步骤继续获取到比自己小的一个节点并注册监听。

到此这篇关于Java ZooKeeper分布式锁实现图解的文章就介绍到这了,更多相关Java ZooKeeper内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Springboot实现对配置文件中的明文密码加密详解

    Springboot实现对配置文件中的明文密码加密详解

    我们在SpringBoot项目当中,会把数据库的用户名密码等配置直接放在yaml或者properties文件中,这样维护数据库的密码等敏感信息显然是有一定风险的。所以本文为大家整理了对配置文件中的明文密码加密的方法,希望对大家有所帮助
    2023-03-03
  • Java中List集合的遍历实例详解

    Java中List集合的遍历实例详解

    这篇文章主要介绍了Java中List集合遍历实例详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-04-04
  • Java中关于size()>0 和isEmpt()的性能考量

    Java中关于size()>0 和isEmpt()的性能考量

    这篇文章主要介绍了Java中关于size()>0 和isEmpt()性能考量,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-02-02
  • 为什么SpringBoot的jar可以直接运行

    为什么SpringBoot的jar可以直接运行

    这篇文章主要介绍了为什么SpringBoot的jar可以直接运行,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-05-05
  • 吊打Java面试官!整理了一周的Spring面试大全(附答案)

    吊打Java面试官!整理了一周的Spring面试大全(附答案)

    这篇文章主要介绍了Spring面试资料(附答案)建议收藏留存,学Java的小伙伴都知道Spring是面试的必问环节,看完了一天就可掌握数据结构和算法的面试题,快来看看吧
    2021-08-08
  • java获取本地文件和远程文件的方式代码示例

    java获取本地文件和远程文件的方式代码示例

    这篇文章主要给大家介绍了关于java获取本地文件和远程文件的方式,我们项目开发的时候,经常会读取文件,如果文件在本服务器,则直接用new File()读取即可,但是有时候需要远程读取文件,需要的朋友可以参考下
    2023-08-08
  • mybatis3.3+struts2.3.24+mysql5.1.22开发环境搭建图文教程

    mybatis3.3+struts2.3.24+mysql5.1.22开发环境搭建图文教程

    这篇文章主要为大家详细介绍了mybatis3.3+struts2.3.24+mysql5.1.22开发环境搭建图文教程,感兴趣的小伙伴们可以参考一下
    2016-06-06
  • 在java程序中使用protobuf

    在java程序中使用protobuf

    这篇文章主要介绍了protobuf的基本使用和同java结合的具体案例,感性兴趣的小伙伴可以一起来阅读下文
    2021-08-08
  • 如何解决hibernate一对多注解懒加载失效问题

    如何解决hibernate一对多注解懒加载失效问题

    这篇文章主要介绍了解决hibernate一对多注解懒加载失效的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-10-10
  • Java 爬虫数据异步加载如何解决

    Java 爬虫数据异步加载如何解决

    这篇文章主要介绍了Java 爬虫遇上数据异步加载,试试这两种办法!问题如何解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-10-10

最新评论