zookeeper之curator实现微服务监听

为了更好的实现java操作zookeeper服务器，后来出现Curator框架，非常的强大，目前已经是apache的顶级项目，里面提供了更多丰富的操作。例如：session超时重连，主从选举，分布式计数器，分布式锁等适用于各种复杂的zookeeper场景的API封装。

官方源码（一）

http://curator.apache.org/ 这个跟zkclient的区别是，zkclient就类似mybatis，curator类似hibernate。

•① maven依赖

•② 使用

Curator 框架提供了一种流式接口,通过 builder 串起来，传递参数都是调方法。Curator 框架通过 CuratorFrameworkFactory 以工厂模式和 builder 模式创建 CuratorFramework 实例。CuratorFramework 实例都是线程安全的，你应该在你的应用中共享同一个。工厂方法 newClient()提供了一个简单方式创建实例。而 Builder 提供了更多的参数控制。一旦你创建了一个 CuratorFramework 实例，你必须调用它的 start()启动，在应用退出时调用 close()方法关闭。

•③ 创建 Curator 连接实例

注意：一个 Zookeeper 集群只需要构造一个 CuratorFramework 实例对象即可。CuratorFramework 使用之前必须先调用client.start();

•④ CuratorFramework

提供的方法

事件类型以及事件的方法

监听器（二）

Curator 提供了三种 Watcher(Cache)来监听结点的变化：

•① Path Cache

监视一个路径下子结点的创建、删除，以及结点数据的更新。产生的事件会传递给注册的 PathChildrenCacheListener。

•② Node Cache

监视一个结点的创建、更新、删除，并将结点的数据缓存在本地。

•③ Tree Cache

Path Cache 和 Node Cache 的“合体”，监视路径下的创建、更新、删除事件，并缓存路径下所有子结点的数据。

重试机制（三）

Curator 内部实现的几种重试策略:

1.ExponentialBackoffRetry:重试指定的次数, 且每一次重试之间停顿的时间逐渐增加.2.RetryNTimes:指定最大重试次数的重试策略3.RetryOneTime:仅重试一次4.RetryUntilElapsed:一直重试直到达到规定的时间

分布式锁（四）

maven引入.用分布式锁或者原子操作、队列等功能需引入

PS：只是个工具，apache的顶级项目，可以通过源码来学习。