Curator是Netflix开源的一套ZooKeeper客户端框架,用它来操作zookeeper更加简单方便,按Curator官方所比喻的,guava to JAVA, Curator to Zookeeper,Curator采用了fluent风格的代码,非常简洁。
有关curator的介绍:请参照官方文档:http://curator.apache.org/index.html
本篇主要看下,使用curator操作zookeeper的一些基础例子:
主要的功能:
1,在zk上添加,或更新数据
2,删除zk节点上数据
3,读取某个节点上的数据
4,上传一些本地文件到zk节点上
5,检查zookeeper上是否存在某个节点路径
核心代码如下:
- package com.qin.curator.zk;
- import java.io.File;
- import java.util.List;
- import org.apache.commons.io.FileUtils;
- import org.apache.curator.CuratorZookeeperClient;
- import org.apache.curator.RetryPolicy;
- import org.apache.curator.framework.CuratorFramework;
- import org.apache.curator.framework.CuratorFrameworkFactory;
- import org.apache.curator.framework.CuratorFrameworkFactory.Builder;
- import org.apache.curator.framework.api.CreateBuilder;
- import org.apache.curator.retry.ExponentialBackoffRetry;
- import org.apache.zookeeper.WatchedEvent;
- import org.apache.zookeeper.Watcher;
- import org.apache.zookeeper.ZKUtil;
- import framework.CrudExamples;
- /**
- * @author qindongliang
- * curator操作zookeeper的
- * 基本例子
- * **/
- public class CuratorTools {
- static CuratorFramework zkclient=null;
- static String nameSpace="php";
- static {
- String zkhost="192.168.46.22:2181";//zk的host
- RetryPolicy rp=new ExponentialBackoffRetry(1000, 3);//重试机制
- Builder builder = CuratorFrameworkFactory.builder().connectString(zkhost)
- .connectionTimeoutMs(5000)
- .sessionTimeoutMs(5000)
- .retryPolicy(rp);
- builder.namespace(nameSpace);
- CuratorFramework zclient = builder.build();
- zkclient=zclient;
- zkclient.start();// 放在这前面执行
- zkclient.newNamespaceAwareEnsurePath(nameSpace);
- }
- public static void main(String[] args)throws Exception {
- CuratorTools ct=new CuratorTools();
- //ct.getListChildren("/zk/bb");
- //ct.upload("/jianli/123.txt", "D:\\123.txt");
- //ct.createrOrUpdate("/zk/cc334/zzz","c");
- //ct.delete("/qinb/bb");
- //ct.checkExist("/zk");
- ct.read("/jianli/123.txt");
- zkclient.close();
- }
- /**
- * 创建或更新一个节点
- *
- * @param path 路径
- * @param content 内容
- * **/
- public void createrOrUpdate(String path,String content)throws Exception{
- zkclient.newNamespaceAwareEnsurePath(path).ensure(zkclient.getZookeeperClient());
- zkclient.setData().forPath(path,content.getBytes());
- System.out.println("添加成功!!!");
- }
- /**
- * 删除zk节点
- * @param path 删除节点的路径
- *
- * **/
- public void delete(String path)throws Exception{
- zkclient.delete().guaranteed().deletingChildrenIfNeeded().forPath(path);
- System.out.println("删除成功!");
- }
- /**
- * 判断路径是否存在
- * @param path
- * **/
- public void checkExist(String path)throws Exception{
- if(zkclient.checkExists().forPath(path)==null){
- System.out.println("路径不存在!");
- }else{
- System.out.println("路径已经存在!");
- }
- }
- /**
- * 读取的路径
- * @param path
- * **/
- public void read(String path)throws Exception{
- String data=new String(zkclient.getData().forPath(path),"gbk");
- System.out.println("读取的数据:"+data);
- }
- /**
- * @param path 路径
- * 获取某个节点下的所有子文件
- * */
- public void getListChildren(String path)throws Exception{
- List<String> paths=zkclient.getChildren().forPath(path);
- for(String p:paths){
- System.out.println(p);
- }
- }
- /**
- * @param zkPath zk上的路径
- * @param localpath 本地上的文件路径
- *
- * **/
- public void upload(String zkPath,String localpath)throws Exception{
- createrOrUpdate(zkPath, "");//创建路径
- byte[] bs=FileUtils.readFileToByteArray(new File(localpath));
- zkclient.setData().forPath(zkPath, bs);
- System.out.println("上传文件成功!");
- } }
相关推荐
Curator是Netflix公司开源的一套ZooKeeper客户端框架,Curator解决了很多ZooKeeper客户端非常底层的细节开发工作,包括连接重连、反复注册Watcher和NodeExistsException异常等,实现了Fluent风格的API接口,目前已经...
zookeeper客户端curator操作示例
使用apache curator-test单元测试zookeeper
Zookeeper客户端Curator Framework示例代码,博客详解链接:https://blog.csdn.net/u010889616/article/details/80209629
NULL 博文链接:https://m635674608.iteye.com/blog/2232760
主要介绍了浅谈Zookeeper开源客户端框架Curator的相关内容,具有一定参考价值,需要的朋友可以了解下。
策展人示例 ZooKeeper 客户端 Curator 示例
zookeeper客户端apache-curator-2.5.0-source-release 服务器管理包node-zk-browser-master
本文深入探讨了Zookeeper的关键应用和集群特性,涉及官方客户端的使用、Apache Curator客户端框架的应用,以及Zookeeper集群的不停机动态扩容和缩容。通过实际代码示例,详细说明了Zookeeper客户端实例的创建、节点...
zookeeper客户端工具,下载到本地后请使用ide工具进行编译,运行工程目录下的\zooinspector-master\target\zooinspector-pkg\bin里的bat或者sh。即可使用。
使用原生的zookeeper的依赖包,如果为了方便也可以使用Curator框架的包。
Zookeeper_Java客户端Curator
zookeeper 使用 Curator 进行增、删、改、查、监听、分布式锁
Curator解决了很多Zookeeper客户端非常底层的细节开发工作,包括连接重连,反复注册Watcher和NodeExistsException异常等,现已成为Apache的顶级项目。
curator zookeeper 3.4.6 2.9.1
curator zookeeper 3.4.6 2.9.1
ZooKeeper-Curatorzookeeper的curator客户端#在学习时的代码上传以备工作时获取。
5、zookeeper的java -Curator(服务注册与发现)...该示例会涉及到本专栏下的其他文章,比如:4、zookeeper的java三种客户端介绍-Curator(crud、事务操作、监听、分布式计数器、分布式锁) 等文章,都是在该专栏下的。
zookeeper 客户端 curator 源文件
NULL 博文链接:https://supben.iteye.com/blog/2094077