diff --git a/src/main/java/cn/uncode/schedule/zk/ZKTools.java b/src/main/java/cn/uncode/schedule/zk/ZKTools.java index ad6ed3dd3c88ebd0c9c48fd923c039bf087ca1a3..d9ab8751c309d3491298a2415c2e6a2249eb40a7 100644 --- a/src/main/java/cn/uncode/schedule/zk/ZKTools.java +++ b/src/main/java/cn/uncode/schedule/zk/ZKTools.java @@ -8,6 +8,7 @@ import java.util.List; import org.apache.commons.lang3.StringUtils; import org.apache.log4j.chainsaw.Main; import org.apache.zookeeper.CreateMode; +import org.apache.zookeeper.ZKUtil; import org.apache.zookeeper.ZooKeeper; import org.apache.zookeeper.data.ACL; import org.apache.zookeeper.data.Stat; @@ -45,10 +46,7 @@ public class ZKTools { } } public static void deleteTree(ZooKeeper zk,String path) throws Exception{ - String[] list = getTree(zk,path); - for(int i= list.length -1;i>=0; i--){ - zk.delete(list[i],-1); - } + ZKUtil.deleteRecursive(zk, path); } private static String[] getTree(ZooKeeper zk, String path) throws Exception{