java链接zookeeper

服务器通信以及跨平台通信中会遇到zookeeper这个东西，至于什么是zookeeper，google it！

为了测试这块的东西，必须要懂zookeeper工作原理，因此，本人整理了一下zookeeper的一般用法便于理解，以及更好的测试~~

package com.kiven.test;import java.io.IOException;
import java.util.concurrent.CountDownLatch;import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.Watcher.Event.KeeperState;public class Demo implements Watcher {//缓存时间 private static final int SESSION_TIME   = 2000;    protected ZooKeeper zooKeeper; protected CountDownLatch countDownLatch= new CountDownLatch(1);public void connect(String hosts) throws IOException, InterruptedException{    zooKeeper = new ZooKeeper(hosts, SESSION_TIME, this);    countDownLatch.await();}/* (non-Javadoc)* @see org.apache.zookeeper.Watcher#process(org.apache.zookeeper.WatchedEvent)*/ public void process(WatchedEvent event) { // TODO Auto-generated method stub if(event.getState()==KeeperState. SyncConnected){ countDownLatch.countDown(); } }public void close() throws InterruptedException{zooKeeper.close();    }
}
=================================================================================================================================package com.kiven.test;import java.util.List;import org.apache.log4j.PropertyConfigurator;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs.Ids;public class MyTest extends Demo{   /*** *<b> function:</b> 创建持久态的znode,比支持多层创建.比如在创建/parent/child的情况下,无/parent.无法通过*@author cuiran*@createDate 2013 -01 -16 15:08:38*@param path*@param data*@throws KeeperException*@throws InterruptedException*/ public void create(String path, byte[] data) throws KeeperException, InterruptedException{ /*** 此处采用的是CreateMode是PERSISTENT   表示The znode will not be automatically deleted upon client's disconnect.* EPHEMERAL 表示The znode will be deleted upon the client's disconnect.*/  this. zooKeeper.create(path, data, Ids. OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); } /*** *<b> function:</b> 获取节点信息*@author cuiran*@createDate 2013 -01 -16 15:17:22*@param path*@throws KeeperException*@throws InterruptedException*/ public void getChild(String path) throws KeeperException, InterruptedException{    try{ List<String> list= this. zooKeeper.getChildren(path, false); if(list.isEmpty()){ System. out.println(path+ "中没有节点" );} else{ System. out.println(path+ "中存在节点" ); for(String child:list){System. out.println( "节点为："+child);} } } catch (KeeperException.NoNodeException e) { // TODO: handle exception throw e;} } public byte[] getData(String path) throws KeeperException, InterruptedException {    return  this. zooKeeper.getData(path, false, null);    }   public static void main(String args[]){PropertyConfigurator. configure("log4j.properties");try {    MyTest zkoperator = new MyTest();    zkoperator.connect( "172.16.3.9"); //          byte[] data = new byte[]{'a','b','c','d'};    //          zkoperator.create("/root",null);
//          System.out.println(Arrays.toString(zkoperator.getData("/root")));
//
//          zkoperator.create("/root/child1",data);
//          System.out.println(Arrays.toString(zkoperator.getData("/root/child1")));
//
//          zkoperator.create("/root/child2",data);
//          System.out.println(Arrays.toString(zkoperator.getData("/root/child2")));    String zktest= "ZooKeeper的Java API测试" ; zkoperator.create( "/test", zktest.getBytes());zkoperator.create( "/test/test1", zktest.getBytes());System. out.println( "获取设置的信息：" +new String(zkoperator.getData("/test" ))); System. out.println( "节点孩子信息:" );zkoperator.getChild( "/test");    zkoperator.close();    } catch (Exception e) {    e.printStackTrace();    } }
}

java链接zookeeper相关推荐

java zookeeper_Java zookeeper开发实例
1.安装zookeeper 下载zk http://archive.cloudera.com/cdh5/cdh/5/ 配置文件tickTime=2000 initLimit=10 syncLimit= ...
ZooKeeper入门（二）Java操作zookeeper
首先是pom依赖: <dependency><groupId>org.apache.zookeeper</groupId><artifactId>zoo ...
mysql数据库java链接,java链接MySQL数据库方法
第一步:安装MySQL 这步我就很少说了,点击去看看怎么安装吧.html 第二步:建立数据库安装好以后,咱们来建立一个数据库,一个表.(代码以下). //建立数据库 test: //在数据库中建立表 ...
java连接zookeeper_java 学习笔记（四） java连接ZooKeeper
public class Demo2 { public static void main(String[] args) { String connectString = "192.168.1 ...
Java链接Access工具类
Java链接Access工具类 import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedS ...
java链接MySQL
java链接MySQL 1.首先安装MySQL,把bin目录添加到path 环境变量 2.修改 sql 登录名为123456.update mysql.user set authentication_ ...
【转载】elastic-job链接zookeeper报错KeeperErrorCode = OperationTimeout
org.apache.zookeeper.KeeperException$OperationTimeoutException: KeeperErrorCode = OperationTimeout 报 ...
java 链接占用太多_Java程序链接数过多导致java.net.SocketException: No buffer space available问题...
发布时间: Aug 29, 2020 更新时间: Aug 29, 2020 总字数:482 阅读时间:1m 作者: 谢先斌 Java程序链接数过多导致java.net.SocketException: ...
java 链接为分布式 hbase,hbase学习记录（一）：hbase伪分布式安装
将安装包解压缩到/usr/local下,并将文件夹重命名为hbase tar -xvf hbase-1.2.6-bin.tar.gz -C /usr/local #解压缩到/usr/local文件夹 ...

java链接zookeeper

java链接zookeeper相关推荐

最新文章

热门文章