首页 > 其他 > 详细

zookeeper数据迁移

时间:2016-05-31 13:42:43      阅读:205      评论:0      收藏:0      [点我收藏+]

在不停机的情况下,实现集群之间数据迁移代码:

 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     }

 

zookeeper数据迁移

原文:http://www.cnblogs.com/wq920/p/5545447.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!