[Zookeeper学习笔记之四]Zookeeper Client Library会话重建-技术博客集

[Zookeeper学习笔记之四]Zookeeper Client Library会话重建
编程技术 / houtizong 发布于 3年前 165

为了说明问题，先来看个简单的示例代码：

package com.tom.zookeeper.book;import com.tom.Host;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher;import java.io.IOException;public class Master implements Watcher {    ZooKeeper zk;    String hostPort;    Master(String hostPort) {        this.hostPort = hostPort;    }    void startZK() throws IOException {        System.out.println("Start to create the ZooKeeper instance");        zk = new ZooKeeper(hostPort, 15000, this);        System.out.println("Finish to create the ZooKeeper instance");    }    public void process(WatchedEvent e) {        System.out.println(e);    }    public static void main(String args[]) throws Exception {        Master m = new Master(Host.HOST);        m.startZK();        Thread.sleep(60*1000); //sleep 60s    }}

1.不启动Zookeeper服务器

运行上面的代码，输出是

Start to create the ZooKeeper instance

Finish to create the ZooKeeper instance

因为会话没有建立，所以，Watcher的回调方法process没有被调用

2.启动Zookeeper服务器

运行上面的代码，在运行结束前，然后关闭Zookeeper服务器，输出是

Finish to create the ZooKeeper instance
WatchedEvent state:SyncConnected type:None path:null
WatchedEvent state:Disconnected type:None path:null

3.启动Zookeeper服务器，运行代码，在运行结束前，关闭服务器和重启服务器，输出是

Finish to create the ZooKeeper instance
WatchedEvent state:SyncConnected type:None path:null
WatchedEvent state:Disconnected type:None path:null
WatchedEvent state:SyncConnected type:None path:null

对于第三种情况，客户端重新建立会话，原因是当Zookeeper服务器不可用时，客户端维持的是CONNECTING状态，当Zookeeper服务器又可用时，客户端会自动重建会话

假如Zookeeper Client的超时时间是5秒钟，而Zookeeper服务器挂了10分钟，按理说，Zookeeper Client的连接早该超时了，可为什么能会话重建呢，为什么会有如下的事件发生呢？

WatchedEvent state:Disconnected type:None path:null
WatchedEvent state:SyncConnected type:None path:null

原因可以参考Zookeeper的官方FAQ，它就这个给出了答案：

What happens to ZK sessions while the cluster is down?

Imagine that a client is connected to ZK with a 5 second session timeout, and the administrator brings the entire ZK cluster down for an upgrade. The cluster is down for several minutes, and then is restarted.

In this scenario, the client is able to reconnect and refresh its session. Because session timeouts are tracked by the leader, the session starts counting down again with a fresh timeout when the cluster is restarted. So, as long as the client connects within the first 5 seconds after a leader is elected, it will reconnect without an expiration, and any ephemeral nodes it had prior to the downtime will be maintained.

The same behavior is exhibited when the leader crashes and a new one is elected. In the limit, if the leader is flip-flopping back and forth quickly, sessions will never expire since their timers are getting constantly reset.

意思就是说，如果在Zookeeper挂了之前，session没有超时，那么Zookeeper重启后，会完成会话重建，至于重建后的session还有多少时间就要timeout了，这个里面并没有说的很清楚，仅用了fresh这个单词，

上一篇：[Zookeeper学习笔记之二]Zookeeper部署脚本

下一篇：[Zookeeper学习笔记之三]Zookeeper实例创建和会话建立的异步特性

请勿发布不友善或者负能量的内容。与人为善，比聪明更重要！

<div > 为了说明问题，先来看个简单的示例代码： &nbsp; <pre name="code" class="java">package com.tom.zookeeper.book;import com.tom.Host;import org.apache.zookeeper.WatchedEvent;import org.apache.zookeeper.ZooKeeper;import org.apache.zookeeper.Watcher;import java.io.IOException;public class Master implements Watcher { ZooKeeper zk; String hostPort; Master(String hostPort) { this.hostPort = hostPort; } void startZK() throws IOException { System.out.println(&quot;Start to create the ZooKeeper instance&quot;); zk = new ZooKeeper(hostPort, 15000, this); System.out.println(&quot;Finish to create the ZooKeeper instance&quot;); } public void process(WatchedEvent e) { System.out.println(e); } public static void main(String args[]) throws Exception { Master m = new Master(Host.HOST); m.startZK(); Thread.sleep(60*1000); //sleep 60s }}</pre> &nbsp; &nbsp; &nbsp;1.不启动Zookeeper服务器 &nbsp;运行上面的代码，输出是 Start to create the ZooKeeper instance Finish to create the ZooKeeper instance 因为会话没有建立，所以，Watcher的回调方法process没有被调用 &nbsp; 2.启动Zookeeper服务器 运行上面的代码，在运行结束前，然后关闭Zookeeper服务器，输出是 Finish to create the ZooKeeper instance WatchedEvent state:SyncConnected type:None path:null WatchedEvent state:Disconnected type:None path:null &nbsp; 3.启动Zookeeper服务器，运行代码，在运行结束前，关闭服务器和重启服务器，输出是 Finish to create the ZooKeeper instance WatchedEvent state:SyncConnected type:None path:null WatchedEvent state:Disconnected type:None path:null WatchedEvent state:SyncConnected type:None path:null &nbsp; 对于第三种情况，客户端重新建立会话，原因是当Zookeeper服务器不可用时，客户端维持的是CONNECTING状态，当Zookeeper服务器又可用时，客户端会自动重建会话 &nbsp; 假如Zookeeper Client的超时时间是5秒钟，而Zookeeper服务器挂了10分钟，按理说，Zookeeper Client的连接早该超时了，可为什么能会话重建呢，为什么会有如下的事件发生呢？ WatchedEvent state:Disconnected type:None path:null WatchedEvent state:SyncConnected type:None path:null &nbsp; 原因可以参考Zookeeper的官方FAQ，它就这个给出了答案： <a href="http://wiki.apache.org/hadoop/ZooKeeper/FAQ#A9">What happens to ZK sessions while the cluster is down?</a> &nbsp; Imagine that a client is connected to ZK with a 5 second session timeout, and the administrator brings the entire ZK cluster down for an upgrade. The cluster is down for several minutes, and then is restarted. In this scenario, the client is able to reconnect and refresh its session. Because session timeouts are tracked by the leader, the session starts counting down again with a fresh timeout when the cluster is restarted. So, as long as the client connects within the first 5 seconds after a leader is elected, it will reconnect without an expiration, and any ephemeral nodes it had prior to the downtime will be maintained. The same behavior is exhibited when the leader crashes and a new one is elected. In the limit, if the leader is flip-flopping back and forth quickly, sessions will never expire since their timers are getting constantly reset. <div > 意思就是说，如果在Zookeeper挂了之前，session没有超时，那么Zookeeper重启后，会完成会话重建，至于重建后的session还有多少时间就要timeout了，这个里面并没有说的很清楚，仅用了fresh这个单词， </div>

留言需要登陆哦

技术博客集 - 网站简介：
前后端技术：
后端基于Hyperf2.1框架开发,前端使用Bootstrap可视化布局系统生成
网站主要作用：
1.编程技术分享及讨论交流，内置聊天系统;
2.测试交流框架问题，比如：Hyperf、Laravel、TP、beego;
3.本站数据是基于大数据采集等爬虫技术为基础助力分享知识，如有侵权请发邮件到站长邮箱，站长会尽快处理;
4.站长邮箱：[email protected];

文章归档

文章标签

友情链接

首页
关于我们

Auther ·HouTiZong: 侯体宗的博客