windows下 java使用zookeeper案例，神策数据java面试题-Toy模板网

这篇具有很好参考价值的文章主要介绍了windows下 java使用zookeeper案例，神策数据java面试题。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

public class BaseZookeeper implements Watcher {

private ZooKeeper zookeeper;

/**

* 超时时间

private static final int SESSION_TIME_OUT = 2000;

private CountDownLatch countDownLatch = new CountDownLatch(1);

@Override

public void process(WatchedEvent event) {

if (event.getState() == KeeperState.SyncConnected) {

System.out.println(“Watch received event”);

countDownLatch.countDown();

}

/**

连接zookeeper
* @param host
* @throws Exception

public void connectZookeeper(String host) throws Exception {

zookeeper = new ZooKeeper(host, SESSION_TIME_OUT, this);

countDownLatch.await();

System.out.println(“zookeeper connection success”);

}

/**

* 创建节点
* @param path
* @param data
* @throws Exception

public String createNode(String path, String data) throws Exception {

return this.zookeeper.create(path, data.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

}

/**

* 获取路径下所有子节点
* @param path
* @return
* @throws KeeperException
* @throws InterruptedException

public List getChildren(String path) throws KeeperException, InterruptedException {

List children = zookeeper.getChildren(path, false);

return children;

}

/**

* 获取节点上面的数据
* @param path 路径
* @return
* @throws KeeperException
* @throws InterruptedException

public String getData(String path) throws KeeperException, InterruptedException {

byte[] data = zookeeper.getData(path, false, null);

if (data == null) {

return “”;

}

return new String(data);

}

/**

* 设置节点信息
* @param path 路径
* @param data 数据
* @return
* @throws KeeperException
* @throws InterruptedException

public Stat setData(String path, String data) throws KeeperException, InterruptedException {

Stat stat = zookeeper.setData(path, data.getBytes(), -1);

return stat;

}

public void updateNode(String path, String data) throws KeeperException, InterruptedException {

zookeeper.setData(path, data.getBytes(), -1);

}

/**

* 删除节点
* @param path
* @throws InterruptedException
* @throws KeeperException

public void deleteNode(String path) throws InterruptedException, KeeperException {

zookeeper.delete(path, -1);

}

/**

* 获取创建时间
* @param path
* @return
* @throws KeeperException

自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。

深知大多数Java工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！

因此收集整理了一份《2024年Java开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。
windows下 java使用zookeeper案例，神策数据java面试题,2024年程序员学习,java-zookeeper,java,zookeeper