原因:

一般是由于连接还未完成就执行zookeeper的get/create/exsit操作引起的.

解决方法:

利用"CountDownLatch 类 + zookeeper的watcher + zookeeper的getStat" 实现连接完成后再调用.

可防止此错误发生.


示例类如下(为一配置获取类):

[java]  view plain copy
  1. import java.util.concurrent.CountDownLatch;  
  2.   
  3.   
  4. import org.apache.zookeeper.WatchedEvent;  
  5. import org.apache.zookeeper.Watcher;  
  6. import org.apache.zookeeper.Watcher.Event.KeeperState;  
  7. import org.apache.zookeeper.ZooKeeper;  
  8. import org.apache.zookeeper.ZooKeeper.States;  
  9. import org.apache.zookeeper.data.Stat;  
  10. public class Conf{  
  11.     public static void waitUntilConnected(ZooKeeper zooKeeper, CountDownLatch connectedLatch) {  
  12.         if (States.CONNECTING == zooKeeper.getState()) {  
  13.             try {  
  14.                 connectedLatch.await();  
  15.             } catch (InterruptedException e) {  
  16.                 throw new IllegalStateException(e);  
  17.             }  
  18.         }  
  19.     }  
  20.    
  21.     static class ConnectedWatcher implements Watcher {  
  22.    
  23.         private CountDownLatch connectedLatch;  
  24.    
  25.         ConnectedWatcher(CountDownLatch connectedLatch) {  
  26.             this.connectedLatch = connectedLatch;  
  27.         }  
  28.    
  29.         @Override  
  30.         public void process(WatchedEvent event) {  
  31.            if (event.getState() == KeeperState.SyncConnected) {  
  32.                connectedLatch.countDown();  
  33.            }  
  34.         }  
  35.     }  
  36.     static public Conf Instance(){  
  37.         if(static_ == null){  
  38.             static_ = new Conf();  
  39.         }  
  40.         return static_;  
  41.     }  
  42.     public boolean Init(String hostports, int times){  
  43.         try{  
  44.             CountDownLatch connectedLatch = new CountDownLatch(1);  
  45.             Watcher watcher = new ConnectedWatcher(connectedLatch);  
  46.             zk_ = new ZooKeeper(hostports, times, watcher);  
  47.             waitUntilConnected(zk_, connectedLatch);  
  48.         }  
  49.         catch(Exception e){  
  50.             System.out.println(e);  
  51.             return false;  
  52.         }  
  53.         return true;  
  54.     }  
  55.     public String Get(String keys){  
  56.         String re = "";  
  57.         String ppath = "/zookeeper";  
  58.         int oldpos = -1;  
  59.         int pos = 0;  
  60.         while(true){  
  61.             pos = keys.indexOf(".", oldpos + 1);  
  62.             if(pos < 0){  
  63.                 ppath += "/";  
  64.                 String str = keys.substring(oldpos + 1);  
  65.                 ppath += str;  
  66.                 break;  
  67.             }  
  68.             ppath += "/";  
  69.             String str = keys.substring(oldpos + 1,  pos);  
  70.             ppath += str;  
  71.             oldpos = pos;  
  72.         }  
  73.         Stat stat = new Stat();  
  74.         try{  
  75.             byte[] b = zk_.getData(ppath, false, stat);    //获取节点的信息及存储的数据  
  76.             re = new String(b);  
  77.         }  
  78.         catch(Exception e){  
  79.             System.out.println(e);  
  80.         }  
  81.         return re;  
  82.     }  
  83.     private Conf(){  
  84.           
  85.     }  
  86.     private ZooKeeper zk_;  
  87.     static private Conf static_;  
  88.     public static void main(String args[]){  
  89.         String hostports = "192.168.1.88:2181,192.168.1.88:2182,192.168.1.88:2183";  
  90.           
  91.         Conf.Instance().Init(hostports, 1000);  
  92.           
  93.         String str = Conf.Instance().Get("conf.logicpoint.subscriberserverip");  
  94.         str = Conf.Instance().Get("conf.logicpoint.subscriberserverport");  
  95.         System.out.println(str);  
  96.         while(true){  
  97.             try{Thread.sleep(100);}  
  98.             catch(Exception e){  
  99.                   
  100.             }  
  101.         }  
  102.           
  103.     }  
  104. }  
# zookeeper
Logo
向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

avatar 云原生

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

avatar 云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

avatar 云原生