文档章节

Zookeeper开源客户端框架Curator的简单使用

乐在克里特
 乐在克里特
发布于 2017/02/23 09:50
字数 693
阅读 23
收藏 0

    Curator最初由Netflix的Jordan Zimmerman开发, Curator提供了一套Java类库, 可以更容易的使用ZooKeeper.

    所谓ZooKeeper技巧(ZooKeeper Recipes),也可以称之为解决方案, 或者叫实现方案, 是指ZooKeeper的使用方法, 比如分布式的配置管理, Leader选举等

    Curator作为Apache ZooKeeper天生配套的组件。ZooKeeper的Java开发者自然而然的会选择它在项目中使用。

官网链接:http://curator.apache.org/

提供的功能组件

1.Framework 提供了一套高级的API, 简化了ZooKeeper的操作。 它增加了很多使用ZooKeeper开发的特性,可以处理ZooKeeper集群复杂的连接管理和重试机制

2.Client 是ZooKeeper客户端的一个替代品, 提供了一些底层处理和相关的工具方法

3.Recipes 实现了通用ZooKeeper的recipe, 该组件建立在Framework的基础之上

4.Utilities 各种工具类

5.Errors 异常处理, 连接, 恢复等.

6.Extensions curator-recipes包实现了通用的技巧,这些技巧在ZooKeeper文档中有介绍。为了避免是这个包(package)变得巨大, recipes/applications将会放入一个独立的extension包下。并使用命名规则curator-x-name.

Curator 编译好的类库被发布到Maven Center中。Curator包含几个artifact. 你可以根据你的需要在你的项目中加入相应的依赖。对于大多数开发者来说,引入curator-recipes这一个就足够了.

依赖:

<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>2.6.0</version>
</dependency> 
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-client</artifactId>
    <version>2.6.0</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>2.6.0</version>
</dependency>

接下来是我实战中用到一些代码,(需要说明的是这里用到了zookeeper共享锁,按天执行的锁,并不是很完善,通过节点路径来控制)

示例代码:

@Component("userTask")
public class UserTask extends BaseTask {

    private static Logger logger = LoggerFactory.getLogger(UserTask .class);

    @Autowired
    private UserService userService;

    @Resource
    protected ZooKeeperClient zkClient;

    public static String LOCK_NODE = "/data/lockPs" + new DateTime().toString("yyyy-MM-dd");

    @Override
    public void doTask() {
        InterProcessMutex lock = new InterProcessMutex(zkClient.getClient(), "/data/lock");

        try {
            if (lock.acquire(2000, TimeUnit.MILLISECONDS)) {
                 List<String> list = zkClient.getChildren(LOCK_NODE);
                if (list.size() == 0) {
                    zkClient.create(LOCK_NODE, CreateMode.PERSISTENT);
                    //lock.acquire();
                    logger.info("开始执行任务:" + new DateTime().toString("yyyy-MM-dd HH:mm:ss"));
                    try {
                        userService.execute();
                    } catch (Exception e) {
                        logger.error("执行任务中抛错",e);
                    } finally {
                        logger.info("结束执行任务:" + new DateTime().toString("yyyy-MM-dd HH:mm:ss"));
                    }
                }
                lock.release();
            }
        } catch (Exception e) {
            logger.error("zkclient/执行任务抛错:",e);
        }
    }
}

另外需要说明是用到了封装好的zookeeper的客户端,这里在介绍一下,

获取zookeeper的客户端:

//1.方式一
class ZooKeeperClient{
    private CuratorFramework client;

    public ZooKeeperClient(String zkAddress) {
        client = CuratorFrameworkFactory.newClient(zkAddress, new ExponentialBackoffRetry(1000, 3));
        client.getCuratorListenable().addListener(new NodeEventListener());
        client.start();
    }
    ...
}

//2.方式二
class ZooKeeperClient{
    private CuratorFramework client;

    public ZooKeeperClient(String connectString, int sessionTimeout, String parent) throws Exception {  
        zkClient = new CuratorZookeeperClient(connectString, sessionTimeout, sessionTimeout, zNodeWatcher, new ExponentialBackoffRetry(1000, Integer.MAX_VALUE));  
        zkClient.start();//must,but anytime before zookeeper operation  
        zkClient.blockUntilConnectedOrTimedOut(); //first connection should be successful  
    }  
    ...
}

 推荐看:

https://yq.aliyun.com/articles/43537

http://shift-alt-ctrl.iteye.com/blog/1981751

© 著作权归作者所有

共有 人打赏支持
乐在克里特
粉丝 16
博文 268
码字总数 394729
作品 0
杭州
程序员
私信 提问
ZooKeeper学习笔记六 ZooKeeper开源客户端Curator

本文学习资源来自《从Paxos到ZooKeeper分布式一致性原理与实践》 Curator Curator是Netflix公司开源的一套ZooKeeper客户端框架,作者是Jordan Zimmerman。 和ZkClient一样,Curator解决了很多...

xundh
04/28
0
0
Apache Curator 2.6.0 发布

Apache Curator 2.6.0 发布,此版本包括了一些新特性(curator RPC)和 bug 修复: Bug 修复: [CURATOR-110] - LeaderLatch does not complete if it is started without a connection to Z......

oschina
2014/07/13
1K
0
Apache Curator 3.0.0 发布,ZooKeeper 客户端简化

Apache Curator 3.0.0 发布,该版本带来的对 ZooKeeper 的新的动态配置 APIs 的兼容,更新内容如下: 子任务 [CURATOR-160] - Support Dynamic Reconfig [CURATOR-161] - Support Watcher R...

oschina
2015/10/15
1K
3
Apache Curator 2.9 发布,ZooKeeper 客户端简化

Apache Curator 2.9 发布,此版本改进了 Java 库,使得 Apache ZooKeeper 使用更简单更可靠。 更新内容: Bug 修复 [CURATOR-167] - All registered watchers should be cleared on close [...

oschina
2015/09/12
1K
3
Apache Curator 2.4.2 发布

Apache Curator 就是为了简化 zookeeper客户端调用而生,利用它,可以更好的使用zookeeper。 Apache Curator 2.4.2 发布了,改进内容包括: Bug [CURATOR-74] - Documentation on InterProce...

oschina
2014/04/25
1K
0

没有更多内容

加载失败,请刷新页面

加载更多

微服务分布式事务实现

https://www.processon.com/view/link/5b2144d7e4b001a14d3d2d30

WALK_MAN
今天
2
0
《大漠烟尘》读书笔记及读后感文章3700字

《大漠烟尘》读书笔记及读后感文章3700字: 在这个浮躁的社会里,你有多久没有好好读完一本书了? 我们总觉得自己和别人不一样,所以当看到别人身上的问题时,很少有“反求诸己”,反思自己。...

原创小博客
今天
4
0
大数据教程(9.5)用MR实现sql中的jion逻辑

上一篇博客讲解了使用jar -jar的方式来运行提交MR程序,以及通过修改YarnRunner的源码来实现MR的windows开发环境提交到集群的方式。本篇博主将分享sql中常见的join操作。 一、需求 订单数据表...

em_aaron
今天
3
0
十万个为什么之什么是resultful规范

起源 越来越多的人开始意识到,网站即软件,而且是一种新型的软件。这种"互联网软件"采用客户端/服务器模式,建立在分布式体系上,通过互联网通信,具有高延时(high latency)、高并发等特点...

尾生
今天
3
0
Terraform配置文件(Terraform configuration)

Terraform配置文件 翻译自Terraform Configuration Terraform用文本文件来描述设备、设置变量。这些文件被称为Terraform配置文件,以.tf结尾。这一部分将讲述Terraform配置文件的加载与格式。...

buddie
今天
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部