资讯专栏INFORMATION COLUMN

Curator: ZooKeeper的使用配方

yanbingyun1990 / 3178人阅读

摘要:领导人选举领导人选举配方。读写锁保持一对相关的锁,一个用于只读操作,一个用于写入。它首先尝试使用乐观锁定。您可以注册一个将在发生更改时收到通知的侦听器。名称来源策展人的产生于西方博物馆美术馆体系的建立密切相关。

Curator: ZooKeeper的使用配方

ZooKeeper 作为分布式的存储方式, 有很多种使用场景, 把典型的使用场景提取出来, 成为"配方", 方便用户参考. Curator 作为这些典型场景的具体实现框架, 进一步简化了用户的使用成本.

Curator 实现了 ZooKeeper 配方文档中列出的所有配方(两阶段提交除外)。单击下面的配方名称以获取详细文档。注意:大多数 Curator 配方将自动创建配方的路径的父节点, 默认值为 CreateMode.CONTAINER (即znode 为容器节点, 用于锁, 选举等功能, 空容器可能会被节点删除)。另请参阅有关“Curator Recipes Own Their ZNode/Paths”的技术说明7。

选举

领导者闩锁 - 在分布式计算中,领导者选举是指定单个流程作为分布在多个计算机(节点)中的某个任务的组织者的过程。在任务开始之前,所有网络节点都不知道哪个节点将充当任务的“领导者”或协调者。然而,在运行了领导者选举算法之后,整个网络中的每个节点都将特定的唯一节点识别为任务领导者。

领导人选举 - Curator 领导人选举配方。

共享重入锁 - 完全分布式锁,全局同步,意味着在任何快照时,没有两个客户端认为它们具有相同的锁定。

共享锁 - 与共享重入锁类似,但不可重入。

共享可重入读写锁 - 可跨 JVM 运行的可重入读/写互斥锁。读写锁保持一对相关的锁,一个用于只读操作,一个用于写入。只要没有写入时,读锁定可以由多个读取器进程同时保持。写锁是独占的。

共享信号量 - 一种适用于跨 JVM 的计数信号量。所有进程使用相同锁定路径的在全部 JVM 中的都将实现进程间有限的租约。此外,这个信号量大多是“公平的” - 每个用户将按照要求的顺序获得租约(从ZK的角度来看)。

多共享锁 - 将多个锁作为单个实体进行管理的容器。调用acquire() 时,将获取所有锁。如果失败,则释放所有已获取的路径。类似地,当调用release() 时,将释放所有锁(忽略失败)。

屏障

屏障 - 分布式系统使用屏障来阻止一组节点的处理,直到满足条件,此时允许所有节点继续运行。

双重屏障 - 双重屏障使客户端能够同步计算的开始和结束。当足够的进程加入屏障时,进程开始计算并在完成后离开屏障。

计数器

共享计数器 - 管理共享整数。观看相同路径的所有客户端将具有共享整数的最新值(考虑ZK的正常一致性保证)。

分布式原子长整形 - 一个尝试原子增量的计数器。它首先尝试使用乐观锁定。如果失败,则采用可选的 InterProcessMutex。对于乐观和互斥两种情况,都有重试策略用于重试增量。

高速缓存

路径缓存 - 路径缓存用于观察 ZNode。每当添加,更新或删除子项时,路径缓存将更改其状态以包含当前子项集,子项的数据和子项的状态。Curator 框架中的路径缓存由 PathChildrenCache 类提供。对路径的更改将传递给已注册的 PathChildrenCacheListener 实例。

节点缓存 - 一种试图保持本地缓存的节点数据的实用程序。此类将监听节点,响应更新/创建/删除事件,下拉数据等。您可以注册一个侦听器, 在发生更改时将收到通知。

树缓存 - 一种实用程序,它尝试在本地缓存 Z K路径的所有子节点的所有数据。此类将观察 ZK 路径,响应更新/创建/删除事件,下拉数据等。您可以注册一个将在发生更改时收到通知的侦听器。

节点

持久节点 - 尝试一直保持在 ZooKeeper 中的节点,即使通过连接和会话中断也是如此。

持久性TTL节点 - 当您需要创建 TTL 节点, 但又不希望通过定期手动设置数据来保持其活动时非常有用。

集团成员 - 集团成员管理。将此实例添加到组中,并在组中保留成员的缓存。

队列

分布式队列 - 分布式队列 ZK 配方的实现。保证排入队列的项目(通过 ZK 的PERSISTENTSEQUENTIAL 节点)。如果单个消费者从队列中取出物品,他们将按FIFO 排序。如果顺序很重要,请使用 LeaderSelector 指定单个消费者。

分布式Id队列 - DistributedQueue 的一个版本,它允许ID与队列项相关联。如果需要,可以从队列中删除项目。

分布式优先级队列 - 一种分布式优先级队列 ZK 配方的实现。

分布式延迟队列 - 一种分布式延迟队列的实现。

简单分布式队列 - ZK分发附带的 DistributedQueue 的替代品。

Curator 名称来源

策展人(curator)的产生于西方博物馆、美术馆体系的建立密切相关。英文“curator”一词在英汉词典中以前通常被翻译成“博物馆馆长”、“掌管者”、或“监护人”等,和艺术关系最为密切的大概是“博物馆馆长”。事实上,在西方语境中,“curator”作为职业最早也主要是指16世纪以来随着私人博物馆的兴起而出现的在馆内负责藏品研究、保管和陈列的专职人员。在某些情况下,curator可能也就是馆长(director),亦需负责博物馆的行政管理、资金筹集和社会关系等。后来,随着艺术品在馆藏中数量增多和重要性上升,出现了专门负责馆藏艺术品研究、保管和陈列的人员。

参考文献

http://curator.apache.org/cur...

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/73388.html

相关文章

  • Zookeeper 客户端 Api 基本使用

    零 版本 JDK 版本 : OpenJDK 11.0.1 IDE : idea 2018.3 Zookeeper Server 版本 : 3.5.4-beta Zookeeper Client 版本 : 3.5.4-beta Curator 版本 : 4.2.0 一 Zookeeper Client Zookeeper Client 是 Zookeeper 的经典原生客户端。使用之前需要在 Mav...

    fizz 评论0 收藏0
  • zookeeper一篇概述

    摘要:改变服务器状态崩溃恢复数据同步,或者崩溃恢复消息广播消息广播类似提交接受请求后,讲这个请求赋予全局的唯一位自增。将作为议案发给所有。所有的接受到议案后,想将议案写入硬盘后,马上回复一个。当接受到合法数量,给所有发送命令。 之前在公司由于业务需要,对zookeeper进行了一些知识点的梳理进行分享,对一些刚刚接触zookeeper的小伙伴来说,或许可以借鉴一下 一、zookeeper介绍...

    cppprimer 评论0 收藏0
  • 实现高可用两种方案与实战

    摘要:高可用的首要想法就是双机热备,故障时自动切换,所以我们要给加一个备机。注下面实现高可用都用的是双机热备,为了方便,把调度服务器简称为主机,把调度服务器的备机简称为备机。 我之前在一片文章 用Nginx+Redis实现session共享的均衡负载 中做了一个负载均衡的实验,其主要架构如下: showImg(https://segmentfault.com/img/bVushO); 把de...

    seal_de 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<