zookeeper的几种使用场景

1、数据的发布与订阅

通过发布与订阅实现配置的信息的统一管理,主要采用zk节点可以存储数据的特性,我们可以将一些配置信息存放到某一节点上,订阅这个节点的服务就可以动态的获取这个节点的数据。在应用启动的时候主动来获取一次,并且在节点上注册一个Watcher,以后每次配置有更新,实时通知到应用,获取最新配置信息。

2、Name Service

由于节点路径的唯一性,这个path就作为服务名称。

3、分布式锁

zk上的一个znode看作是一把锁,通过create znode的方式来实现。所有客户端都去创建 /distribute_lock 节点,最终成功创建的那个客户端也即拥有了这把锁。

4、集群管理

实时监控系统对集群的管理,传统的监控方式是监控系统ping其它系统来进行判断,或者其它系统发送心跳来实现。但是这样会存在一定的弊端,集群中机器数量发生改变时,修改的西东比较多,另一个就是监控有一定的延时。利 用ZooKeeper有两个特性,就可以实时另一种集群机器存活性监控系统:a. 客户端在节点 x 上注册一个Watcher,那么如果 x 的子节点变化了,会通知该客户端。b. 创建EPHEMERAL类型的节点,一旦客户端和服务器的会话结束或过期,那么该节点就会消失。

5、分布式队列

zk的分布式队列主要有两种模式,一种是传统的先进先出模式,通过创建节点的顺序来控制。是要等到队列成员聚齐之后的才统一按序执行。通常可以在 /queue 这个znode下预先建立一个/queue/num 节点,并且赋值为n(或者直接给/queue赋值n),表示队列大小,之后每次有队列成员加入后,就判断下是否已经到达队列大小,决定是否可以开始执行 了。这个和java并发编程包里面一个类的CountDownLatch的使用非常类似,等待一组任务执行完成后再开始执行其他的任务。这种用法的典型场景是,分布式环境中,一个大任务Task A,需要在很多子任务完成(或条件就绪)情况下才能进行。这个时候,凡是其中一个子任务完成(就绪),那么就去 /taskList 下建立自己的临时时序节点(CreateMode.EPHEMERAL_SEQUENTIAL),当 /taskList 发现自己下面的子节点满足指定个数,就可以进行下一步按序进行处理了。

原文地址:https://www.cnblogs.com/mars-zyt/p/8579175.html