【README】

java本地連接zk cluster, refer to?https://blog.csdn.net/PacosonSWJTU/article/details/111404364;??

?

【1】 創建zk節點 star （明星節點）?

/*** 測試 zk * @author pacoson**/ public class TestZK {/*** zk server 連接串 */private String connectString = "192.168.163.201:2181,192.168.163.202:2181,192.168.163.203:2181";/*** 超時時間*/private int sessionTimeout = 3000; /*** zk客戶端實例 */private ZooKeeper zkClient; /*** 0-獲取zk連接 * @throws IOException*/@Before public void init() throws IOException {/* 連接zk服務器 */zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent event) {}});}/*** 1-創建zk節點 * @throws InterruptedException * @throws KeeperException */@Testpublic void createNode() throws KeeperException, InterruptedException {String path = zkClient.create("/star", "star list".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);System.out.println(path); } }

【2】我們可以 在 linux zk 客戶端查看其創建的節點

?

總結

以上是生活随笔為你收集整理的java本地创建zk节点的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。