zoukankan      html  css  js  c++  java
  • Zookeeper 重连机制

    Zookeeper 重连机制

    public class ZKConnectSessionWatcher implements Watcher {
    
    
        public final static String zkServerPath = "10.10.10.10:2181";
    
        public final  static  int timeout = 5000;
    
        public static void main(String[] args) throws  Exception {
            ZooKeeper zk = new ZooKeeper(zkServerPath, timeout, new ZKConnectSessionWatcher());
            long sessionId = zk.getSessionId();
            byte[] sessionPassword = zk.getSessionPasswd();
    
            log("客户端开始连接Zookeeper服务器...");
            log("连接状态:" + zk.getState());
    
            new Thread().sleep(1000);
            log("连接状态:" + zk.getState());
    
            log("开始会话重连。。。");
    
            ZooKeeper zkSession = new ZooKeeper(zkServerPath, timeout, new ZKConnectSessionWatcher(), sessionId, sessionPassword);
            log("重新连接zkSession:" + zkSession.getState());
            new Thread().sleep(1000);
            log("重新连接zkSession:" + zkSession.getState());
        }
    
        public void process(WatchedEvent event) {
            System.out.println("接收到watch通知:" + event.toString());
        }
    
        private static void log(String msg){
            System.out.println(msg);
        }
    

      

  • 相关阅读:
    成功引爆
    pecompact2脱壳手记
    象棋
    今天小雨
    出错了,怎么办?
    设计模式——Adapter模式
    表设计中应注意的2点
    设计模式——Singleton模式
    设计模式——Facade模式
    设计模式——Strategy模式
  • 原文地址:https://www.cnblogs.com/linlf03/p/9912201.html
Copyright © 2011-2022 走看看