curator fix

Author: qq254963746

lts-core/src/main/java/com/lts/zookeeper/curator/CuratorZkClient.java

@@ -21,6 +21,7 @@
 import java.io.IOException;
 import java.io.Serializable;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 /**
  * @author Robert HG (254963746@qq.com) on 5/16/15.
@@ -234,6 +235,7 @@ protected void doClose() {
     public class PathChildrenListener {
         private PathChildrenCache childrenCache;
         private PathChildrenCacheListener childrenCacheListener;
+        private AtomicBoolean start = new AtomicBoolean(false);
 
         public PathChildrenListener(String path, final ChildListener listener) {
             childrenCache = new PathChildrenCache(client, path, true);
@@ -259,18 +261,22 @@ public void childEvent(CuratorFramework c, PathChildrenCacheEvent event)
 
         public void startListener() {
             try {
-                childrenCache.start(PathChildrenCache.StartMode.POST_INITIALIZED_EVENT);
-                childrenCache.getListenable().addListener(childrenCacheListener);
+                if (start.compareAndSet(false, true)) {
+                    childrenCache.start(PathChildrenCache.StartMode.POST_INITIALIZED_EVENT);
+                    childrenCache.getListenable().addListener(childrenCacheListener);
+                }
             } catch (Exception e) {
                 throw new ZkException(e);
             }
         }
 
         public void stopListener() {
             try {
-                childrenCache.getListenable().removeListener(childrenCacheListener);
-                childrenCache.clear();
-                childrenCache.close();
+                if (start.compareAndSet(true, false)) {
+                    childrenCache.getListenable().removeListener(childrenCacheListener);
+                    childrenCache.clear();
+                    childrenCache.close();
+                }
             } catch (IOException e) {
                 throw new ZkException(e);
             }
@@ -290,9 +296,9 @@ public void nodeChanged() throws Exception {
 
                     Object data = nodeCache.getCurrentData().getData();
 
-                    if(data == null){
+                    if (data == null) {
                         listener.dataDeleted(path);
-                    }else{
+                    } else {
                         listener.dataChange(path, data);
                     }
                 }

lts-example/src/main/java/com/lts/example/api/JobClientTest.java

@@ -90,7 +90,7 @@ public static void console() throws IOException {
 //        jobClient.setIdentity("test_jobclient_0000001");
 //        jobClient.addConfig(SpiKey.LTS_JSON, "fastjson");
 //        jobClient.addConfig("lts.remoting", "netty");
-        jobClient.addConfig("zk.client", "curator");
+//        jobClient.addConfig("zk.client", "curator");
         jobClient.start();
 
         JobClientTest jobClientTest = new JobClientTest();