前言
Curator是Netflix开源的一套ZooKeeper客户端框架:
- 1.封装ZooKeeper client与ZooKeeper server之间的连接处理;
- 提供了一套Fluent风格的操作API;
- 提供ZooKeeper各种应用场景(recipe, 比如共享锁服务, 集群领导选举机制)的抽象封装。
Curator几个组成部分:
- Client:是ZooKeeper客户端的一个替代品, 提供了一些底层处理和相关的工具方法
- Framework: 用来简化ZooKeeper高级功能的使用, 并增加了一些新的功能, 比如管理到ZooKeeper集群的连接, 重试处理
- Recipes:实现了通用ZooKeeper的recipe, 该组件建立在Framework的基础之上
- Utilities:各种ZooKeeper的工具类
- Errors: 异常处理, 连接, 恢复等
- Extensions: recipe扩展
Curator内部实现的几种重试策略:
- ExponentialBackoffRetry:重试指定的次数, 且每一次重试之间停顿的时间逐渐增加
- RetryNTimes:指定最大重试次数的重试策略
- RetryOneTime:仅重试一次
- RetryUntilElapsed:一直重试直到达到规定的时间
正文
1.项目使用maven工程,在pom.xml中添加依赖
1 | <dependency> |
2.下面代码从增删改查、事务、事件订阅/监听器来实现的。
1 | package om.xbq.demo; |
源码下载
点击阅读原文下载源码哦