Zookeeper实例Curator API-使用curator来创建一个含隔离命名空间的ZooKeeper客户端

时间:2022-04-24 21:18:26


import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;

/**
*
* @ClassName: Create_Session_Sample_With_Namespace
* @Description: TODO(使用curator来创建一个含隔离命名空间的ZooKeeper客户端)
* @author RongShu
* @date 2017年6月17日 上午9:49:24
*
*/
public class Create_Session_Sample_With_Namespace {
public static void main(String[] args) throws Exception {
RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
CuratorFramework client = CuratorFrameworkFactory.builder().connectString("localhost:2181")
.sessionTimeoutMs(5000).retryPolicy(retryPolicy).namespace("base").build();
client.start();
Thread.sleep(Integer.MAX_VALUE);
}
}


注意:

为了实现不同的Zookeeper业务之间的隔离,往往会为每个业务分配一个独立的命名空间,既制定一个Zookeeper根路径。


参考

1.《从Paxos到Zookeeper:分布式一致性原理与实践》

2.https://zookeeper.apache.org/doc/r3.5.3-beta/javaExample.html