博客
关于我
Zookeeper概念-选举机制和监听器原理
阅读量:154 次
发布时间:2019-02-27

本文共 1183 字,大约阅读时间需要 3 分钟。

Zookeeper简介

Zookeeper是一种开源的分布式协调服务,主要功能包括统一命名服务、统一配置管理、统一集群管理等。它通过保持各个节点的状态一致,确保集群服务的稳定性和可用性。

Zookeeper角色

Zookeeper集群由三个角色组成:Leader、Follower和Observer。

Leader:负责发起投票和决议,更新系统状态,是集群的决策者。

Follower:接收客户端请求并返回结果,在选主过程中参与投票。

Observer:接收客户端连接,将写请求转发给Leader,不参与投票。

Zookeeper选举机制

Zookeeper的选举机制基于半数机制,集群中半数以上节点存活时,集群可用。虽然没有显式的master和slave设置,但通过内部选举产生一个临时的Leader。

假设有五台服务器组成的Zookeeper集群,依次启动分析如下:

  • 服务器1启动,成为唯一存活节点,处于LOOKING状态。

  • 服务器2启动,与服务器1交换选举信息,由于没有历史数据,id较大的服务器2胜出,但未达到半数以上(3台)认可,仍处于LOOKING状态。

  • 服务器3启动,成为三台服务器中的老大,超过半数认可,正式成为Leader。

  • 服务器4启动,虽然本身id更大,但因已有半数以上(3台)认可服务器3,无法成为Leader。

  • 服务器5启动,同样无法成为Leader。

  • Zookeeper特点

  • 集群由一个Leader和多个Follower组成。

  • Leader负责发起投票和决议。

  • Follower参与投票和接收请求。

  • 集群需半数以上节点存活。

  • 数据一致:每个节点保存相同数据副本。

  • 更新有序:同一客户端的更新按发送顺序执行。

  • 原子性:一次更新要么成功要么失败。

  • 实时性:客户端能在一定时间内读到最新数据。

  • Zookeeper监听器原理

    Zookeeper客户端在main线程启动时创建Zookeeper连接,生成connect和listener线程:

  • connect线程负责网络通信。

  • listener线程接收Zookeeper的通知消息。

  • process方法处理收到的事件。

  • 常见监听类型包括:

    • 监听节点数据变化:使用get path [watch]

    • 监听子节点变化:使用ls path [watch]

    Zookeeper数据结构

    Zookeeper的每个节点称为znode,路径唯一标识,存储1M数据,类型包括:

    • persistent:持久化节点

    • persistent_sequential:持久化顺序编号节点

    • ephemeral:临时节点

    • ephemeral_sequential:临时顺序编号节点

    Zookeeper与Hbase关系

    Zookeeper和Hbase作为大数据系统的重要组成部分,分别负责数据协调和存储,共同支撑分布式系统的高效运行。

    转载地址:http://dgmb.baihongyu.com/

    你可能感兴趣的文章
    org.hibernate.HibernateException: Unable to get the default Bean Validation factory
    查看>>
    org.springframework.orm.hibernate3.support.OpenSessionInViewFilter
    查看>>
    org.springframework.web.multipart.MaxUploadSizeExceededException: Maximum upload size exceeded
    查看>>
    org.tinygroup.serviceprocessor-服务处理器
    查看>>
    org/eclipse/jetty/server/Connector : Unsupported major.minor version 52.0
    查看>>
    org/hibernate/validator/internal/engine
    查看>>
    SQL-36 创建一个actor_name表,将actor表中的所有first_name以及last_name导入改表。
    查看>>
    orm总结
    查看>>
    os.system 在 Python 中不起作用
    查看>>
    OSCACHE介绍
    查看>>
    SQL--合计函数(Aggregate functions):avg,count,first,last,max,min,sum
    查看>>
    OSChina 周四乱弹 ——程序员为啥要买苹果手机啊?
    查看>>
    OSError: no library called “cairo-2“ was foundno library called “cairo“ was foundno library called
    查看>>
    OSG学习:几何体的操作(二)——交互事件、Delaunay三角网绘制
    查看>>
    OSG学习:几何对象的绘制(三)——几何元素的存储和几何体的绘制方法
    查看>>
    OSG学习:几何对象的绘制(二)——简易房屋
    查看>>
    OSG学习:场景图形管理(一)——视图与相机
    查看>>
    OSG学习:场景图形管理(三)——多视图相机渲染
    查看>>
    OSG学习:场景图形管理(四)——多视图多窗口渲染
    查看>>
    OSG学习:新建C++/CLI工程并读取模型(C++/CLI)——根据OSG官方示例代码初步理解其方法
    查看>>