从zookeeper znode获取数据

1yjd4xko  于 2021-06-01  发布在  Hadoop
关注(0)|答案(1)|浏览(334)

我尝试使用javaapi从zookeeper的znode获取数据。跟随下面的链接
https://www.tutorialspoint.com/zookeeper/zookeeper_api.htm 程序:zkgetdata.java
我得到了这样的结果
“(clustersecondaryn1node4.test.com�>(�>)"
如何单独获得“node4.test.com”。

irtuqstp

irtuqstp1#

强烈建议对zk使用一些层,比如apachecurator或zkclient。下面是一个例子

CuratorFramework zkClient = CuratorFrameworkFactory.builder().connectString("localhost:2181").build();
zkClient.start();
boolean isExist = zkClient.checkExists().forPath("/myNode") != null;
if (isExist) {
    byte[] myNodeBytes = zkClient.getData().forPath("/myNode");
    if (myNodeBytes != null && myNodeBytes.length > 0) {
        System.out.println(new String(myNodeBytes));
    }
}
else {
    zkClient.create().withMode(CreateMode.PERSISTENT).forPath("/myNode", "foo".getBytes());
}

相关问题