zookeeper數據遷移


在不停機的情況下,實現集群之間數據遷移代碼:

 1 private void create(ZooKeeper zk1, ZooKeeper zk2, String path) throws Exception {
 2         List<String> list = zk1.getChildren(path, null);
 3         for (String str : list) {
 4             if (path.endsWith("/")) {
 5             } else {
 6                 path = path + "/";
 7             }
 8             System.out.println(path + str);
 9             zk2.create("/wapage_back" + path + str, zk1.getData(path+str, false, null), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
10             create(zk1, zk2, path + str);
11         }
12         if (!path.endsWith("/")) zk2.setData("/wapage_back" + path, zk1.getData(path, false, null), -1);
13     }

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM