Apache Curator Path Cache Watcher...
分类:
Web程序 时间:
2015-02-27 17:07:19
阅读次数:
149
Apache Curator Tree Cache Watcher...
分类:
Web程序 时间:
2015-02-27 17:04:35
阅读次数:
322
还记得Curator提供哪几个组件吗? 我们不妨回顾一下: Recipes Framework Utilities Client Errors Extensions 前面的例子其实前五个组件都涉及到了, 比如Utilities例子的TestServer, Client里的CuratorZookeepe...
分类:
其他好文 时间:
2015-02-11 16:53:50
阅读次数:
180
转载请注明出处: jiq?钦's
technical Blog
本文将主要关注Curator是如何处理连接丢失和会话终止这两个关键问题的。
1. 连接丢失的处理
Curator中利用类ConnectionState来管理客户端到ZooKeeper集群的连接状态,其中用到原子布尔型变量来标识当前连接是否已经建立:
private
finalAtomicBoolean isCo...
分类:
其他好文 时间:
2015-01-10 23:43:12
阅读次数:
586
1、描述
共享锁:全局同步分布式锁,同一时间两台机器只能有一台获得锁
2、参与类
InterProcessMutex
3、用法
3.1 创建 InterProcessMutex 实例
public InterProcessMutex(CuratorFramework client,
String path)
Para...
分类:
其他好文 时间:
2015-01-10 21:04:20
阅读次数:
374
今天看Curator源码时发现其请求ZooKeeper集群时内部封装了重试机制,代码如下:
Stat resultStat = RetryLoop.callWithRetry
(
client.getZookeeperClient(),
new Callable()
{...
都说Curator的连接机制比较牛逼,所以在分析Curator的连接和重试机制之前,我想先搞清楚原生的ZooKeeper的连接存在哪些问题。
下面是我查阅资料总结的结果,转载请注明出处: jiq?钦's technical Blog
Curator虽然提供所谓的高层抽象API来简化了ZooKeeper的使用,但更重要的是封装了管理到ZooKeeper集群的连接以及重试机制的复杂性,...
分类:
其他好文 时间:
2015-01-06 23:13:47
阅读次数:
339
Curator是Netflix开源的一套ZooKeeper客户端框架. Netflix在使用ZooKeeper的过程中发现ZooKeeper自带的客户端太底层, 应用方在使用的时候需要自己处理很多事情, 于是在它的基础上包装了一下, 提供了一套更好用的客户端框架.
Netflix在用ZooKeeper的过程中遇到的问题, 我们也遇到了, 所以开始研究一下, 首先从他在github上的源码, w...
分类:
其他好文 时间:
2015-01-05 00:38:49
阅读次数:
284
接着上一篇,将分析测试程序中的访问接口部分。
2调用ZooKeeper访问接口
初始化和启动分析完了,操作接口调用代码如下:
String path = ZKPaths.makePath(PATH, name);
byte[] bytes =args[1].getBytes();
try
{
client.setData().forPath(path,bytes);
}...
分类:
其他好文 时间:
2015-01-05 00:38:17
阅读次数:
212
上一篇文章这里已经列出了Curator的一个使用的例子,这篇文章将详细分析其初始化和启动部分。
测试程序分析
1 初始化和启动
(1) newClient方法返回CuratorFramework接口对象:
public
staticCuratorFramework newClient(String connectString, int sessionTimeou...
分类:
其他好文 时间:
2015-01-05 00:37:59
阅读次数:
334