`
bit1129
  • 浏览: 1069959 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

[Zookeeper学习笔记之四]Zookeeper Client Library会话重建

 
阅读更多

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

 

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这个单词,
这个单词是说重建的session从重新开始计算累计存活时间,还是说,是把之前Zookeeper活着的时候,已经走过的session时间计算在内了?

 

总结和问题:

1.在Zookeeper服务器不可用时,客户端等维持CONNECTING状态多长时间?

2.通过这个实例,我们在处理Disconnected事件时,不应该重新创建新的Zookeeper实例,试图创建新的会话,如果Zookeeper能够恢复,那么之前的Zookeeper实例在Zookeeper Client Library的帮助下可以完成会话重建,如果Zookeeper不能恢复,那么重新创建Zookeeper也是徒劳无功。

 

 
 

 

 

 

0
1
分享到:
评论

相关推荐

    zookeeper学习笔记

    ### Zookeeper 学习笔记 #### 一、Zookeeper 简介与安装配置 **Zookeeper** 是一个分布式协调服务框架,它提供了一种高效可靠的机制来维护集群中的配置信息、命名服务以及提供分布式锁等功能,使得开发人员能够...

    Zookeeper学习笔记.pdf

    Zookeeper是一种重要的分布式协调服务,尤其在处理高可用性、高性能的应用场景中。它最初设计的核心功能是提供分布式锁服务,但随着社区的发展,Zookeeper的功能得到了扩展,现在还用于配置维护、组服务、分布式消息...

    Zookeeper学习笔记.docx

    ZooKeeper 学习笔记 ZooKeeper 是一个开源的分布式协调服务,由 Hadoop 的创始人 Doug Cutting 等人开发。它为分布式应用提供了一个高效、可靠的协调机制,帮助开发者快速构建高可用、可扩展的分布式系统。 ...

    Zookeeper学习笔记

    【Zookeeper学习笔记】 Zookeeper是一个分布式协调服务,它的核心目标是简化分布式环境下的数据管理与系统协调。作为Apache Hadoop和HBase的重要组件,Zookeeper提供了简单的原语集,支持分布式应用程序之间的通信...

    2021尚硅谷技术之Zookeeper笔记

    在2021年的尚硅谷技术分享中,这些笔记涵盖了ZooKeeper的核心概念、安装配置、数据模型、会话与 watches、集群搭建以及常见应用场景。 **1. ZooKeeper核心概念** ZooKeeper的核心概念包括ZNode、ACL(访问控制列表...

    基于Java语言的Zookeeper学习笔记设计源码

    该项目为基于Java语言的Zookeeper学习笔记设计源码,总计包含20个文件,具体构成包括15个Java源文件、3个PNG图片文件以及1个Markdown文件。此外,项目还包含1个XML配置文件,适用于学习和实践Zookeeper相关知识。

    zookeeper学习笔记.pptx

    本文适合但不限于软件开发人员阅读。本文档能够使阅读者对zookeeper有一个宏观且全面的了解,内容主要包含zookeeper架构、数据模型、读写及工作原理、典型应用场景、指令汇总等,

    ZooKeeper3.7.0(ZooKeeper-client)编译的头文件和库

    linux下编译zookeeper3.7.0出的头文件和库: proto.h recordio.h zookeeper.h zookeeper.jute.h zookeeper_log.h zookeeper_version.h libzookeeper_mt.a libzookeeper_mt.la libzookeeper_mt.so libzookeeper_mt....

    ZooKeeper学习笔记

    - **会话管理**:客户端与ZooKeeper服务器之间的连接称为会话。每次客户端连接到一个新的服务器时,都会创建一个新的会话。会话的生命周期决定了客户端能够访问ZooKeeper服务的时间范围。 #### 集群架构 - **选举...

    hadoop,hbase,zookeeper安装笔记

    hadoop,hbase,zookeeper安装笔记hadoop,hbase,zookeeper安装笔记hadoop,hbase,zookeeper安装笔记

    Zookeeper学习资源和笔记(附代码)

    Zookeeper是Apache Hadoop项目下的一个子项目,它是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现。Zookeeper的设计目标是为分布式应用提供一致性服务,它主要用来解决分布式...

    zookeeper完整学习笔记

    Zookeeper 的架构主要包括Client(客户端)、Server(服务器)和 Ensemble(服务器集群)。每个客户端定期向服务器发送心跳以保持活动状态,服务器则回应确认消息。如果服务器失效,客户端会自动重定向到其他服务器...

    zookeeper笔记.pdf

    ZooKeeper笔记 ZooKeeper是一个分布式应用程序协调服务,提供了一个树形命名空间,用于存储和管理数据。 ZooKeeper主要用于分布式应用程序的配置管理、名称服务、分布式同步和提供组服务等。 ZooKeeper命令 * ...

    zookeeper笔记

    ### Zookeeper概述 Zookeeper是一种分布式协调服务框架,它的核心任务是为用户的分布式应用程序提供一系列的协调...无论是从其提供的服务还是从其内部的机制来看,Zookeeper都是值得深入学习和掌握的重要技术之一。

    ZooKeeper会话超时以及重连机制.pdf

    其中,会话管理是ZooKeeper的重要组成部分之一。本文将详细介绍ZooKeeper中的会话超时机制及其背后的原理。 ##### 1. 关键参数说明 - **`sessionTimeout`**:指定了客户端与服务器之间的通信超时时间,即客户端在...

    springboot-zookeeper-client.rar

    SpringBoot与Zookeeper客户端集成详解 在分布式系统中,Zookeeper作为一个高可用的分布式协调服务,扮演着重要的角色。它提供了诸如配置管理、命名服务、分布式锁、集群节点监控等多种功能。SpringBoot作为轻量级的...

    zookeeper笔记和搭建

    资源名称:zookeeper笔记和搭建 资源太大,传百度网盘了,链接在附件中,有需要的同学自取。

    Zookeeper笔记.docx

    Zookeeper笔记 Zookeeper是一个为分布式应用提供一致性服务的软件,提供配置服务、域名服务、分布式同步、组服务等。作为一个分布式系统的核心组件,Zookeeper 负责各个组件之间的协调服务。 Zookeeper 的安装 ...

    zookeeper-server-client 简单例子

    通常,客户端首先连接到 Zookeeper 集群中的一个节点,然后可以通过会话与 Zookeeper 进行通信,发送请求并接收响应。 **项目构建与配置(pom.xml)** 在 Maven 项目中,引入 Zookeeper 客户端依赖的配置如下: `...

    ZooKeeper笔记.pdf

    ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈进行下一步合理操作。最终将简单易用的接口和性能高效、功能稳定的系统提供给用户。...

Global site tag (gtag.js) - Google Analytics