01_zookeeper简介(刷新) 1. 分布式系统及其问题 2. 分布式锁的实现 3. zookeeper概述 4. zookeeper应用一: 分布式系统选主 5、zookeeper实现配置管理 6、zookeeper实现集群管理

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

zookeeper是帮助我们构建分布式系统的一个软件(协调员的角色)
首先,我们要明白分布式系统以及它的问题,之后才能理解为什么有zookeeper

1.1 分布式系统

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

分布式系统,就是多台机器通过网络互连,形成1个系统,对系统外的用户提供服务,用户看到的是1个服务,并不会感知到内部的多台机器

1.2 分布式系统的难点(问题)

考虑一下,如何对这个系统中不同机器上的进程进行协同或者说调度:
1)假设第1台机器上挂载了1个资源,3个不同机器上的进程都需要对该资源进行访问
2)对资源的访问就需要协调,做到不能同时访问,就需要1个协调员
3)单机上不同进程对资源的访问,可以通过锁机制
     进程1访问资源,先获得锁,之后会该资源保持独占
     进程1访问资源结束,释放锁,其他进程再来获得锁
4)如果分布式系统下,也有类似的锁机制,问题就得到解决

分布式系统下的这个锁机制 = 分布式锁 = zookeeper

2. 分布式锁的实现

2.1 面临的问题

对分布式系统的协调,难点在于网络的不确定性以及很多异常情况的考虑:

1、对服务调用的失败,并不一定是真失败;可能是返回值由于网络的原因,没有传回
2、AB都去调用C服务,并不是谁先调用,谁先执行,要考虑网络拥堵和延迟
3、类似的其他很多的问题,代码都要考虑
同时,如果给每一个分布式系统都去写一个协调软件,就是重复造*,更需要1个可靠、通用地协调机制

2.2 市面上哪家强?

目前比较好的分布式锁有两家:
1 Google chubby (非开源,自己用)
2 Apache zookeeper (Yahoo开发,捐赠给了Apache)

3. zookeeper概述

3.1 zookeeper是针对分布式系统设计的高可用,高性能的协调服务

zookeeper的系统模型

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

zookeeper系统中的三种角色

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理


最开始zookeeper只提供分布式锁服务,后续又摸索出了其他用法:配置维护,消息订阅/分发,集群选主等;zookeeper提供这些服务,依赖于3个重要元素:
1)znode数据结构
2)对znode进行操作的函数(原语)
3)watcher通知机制

3.2 znode数据结构

zookeeper维护了1个类似文件系统目录树的数据模型

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

zookeeper树中的每一个成员,称为节点,znode; 和文件系统目录树还是存在区别
1)只有绝对路径
树中的每一个节点,只能使用绝对路径表示


2)znode兼备文件和目录两种特征
*文件:znode能够记录元数据(主要是版本号),数据,ACL,时间戳等
*目录:每个节点是路径标识的一部分

每个znode由3部分组成:
(1)stat:          状态信息,该znode的版本,权限等信息
(2)data:           该znode关联的数据
(3)children:    该znode下的子节点
znode虽然能够关联数据,但并不是被设计来存储大量数据,相反znode只能存储和管理调度数据(要协调的分布式应用的数据),这些数据的数据量都很小,kB级别, znode能关联的数据最大为1MB

3)znode节点类型
3种:临时节点、永久节点、顺序节点;
(1) 节点类型在创建时被确定,不能改变
(2) 临时节点节点的生命周期依赖于Client和zk间的会话(session); 会话结束,临时节点被自动删除;每个临时节点和某一个client绑定,但所有client都能看到这个节点;临时节点不能有子节点
(3) 永久节点:节点的生命周期不依赖于会话(session),只有被Client显示删除时才会消失
(4) 顺序节点:client创建顺序节点时,指定一个路径,zookeeper自动在路径尾部添加1个递增的计数器,计数值对于此节点的父节点唯一(10位数字); 需要注意的是,删除1个顺序节点,编号005,再增加一个顺序节点,新节点的编号从006开始

3.3 znode版本和zookeeper时间

ZooKeeper有多种记录时间的形式,主要几个属性如下:
(1) Zxid格式时间戳
znode节点状态改变的每一个操作,都会在znode元数据中记录1个Zxid格式时间戳
Zxid时间戳全局有序:Zxid1<Zxid2, 则Zxid1标记的事件发生在Zxid2标记的事件之前
Zxid时间戳的本质:64位数字

(2) znode上的3个Zxid格式事务ID
每个znode, 维护3个Zxid值: cZxid、mZxid、pZxid
*cZxid: 节点被创建的Zxid格式事务ID
*mZxid: 节点被修改的Zxid格式事务ID
*pZxid: 节点的子节点最新被修改的Zxid格式事务ID

(3) znode版本号
znode节点有三个版本号,对znode的操作会导致相应的版本号发生变化
* version:节点数据版本号
* cversion:子节点版本号
* aversion:节点ACL版本号

3.4 znode元数据汇总

*cZxid: 节点被创建的Zxid事务ID
*mZxid: 节点被修改的Zxid事务ID
*pZxid: 节点被最新修改的Zxid事务ID

*ctime: 节点被创建的时间
*mtime: 节点被修改的时间

* version:节点的数据版本号
* cversion: 子节点版本号
* aversion: 节点ACL版本号

*numChildren: 子节点个数
*dataLength: 节点数据的长度

* ephermeralOwner: 临时节点所对应的会话(session)的ID;非临时节点则值为0

3.5 znode操作

对znode的操作(zk提供的原语)主要为9类:
*create    创建znode,父节点必须已经存在
*delete    删除znode, 该znode没有子节点
*getACL/setACL:    获取/设置znode的ACL
*sync:    同步客户端和zk的视图(更新client端看到的zk树)

*exists: 判断znode是否存在,并获取其元数据;客户端使用该原语,将在zk中注册1个watcher
*getData/setData: 获取/设置znode关联的数据;客户端使用该原语,将在zk中注册1个watcher
*getChildren: 获取子节点列表;客户端使用该原语,将在zk中注册1个watcher

 3.5 watcher机制

(1) watcher概述
* Client端对znode的读操作,会自动在zk中注册1个watcher.
* 读操作包括:exists(), getData(), getChildren()
* 当znode发生变化, 将触发一些对应的事件event, zk自动发给事件给相应的Client端(异步发送)

(2) watcher类型
ZooKeeper中的watcher分为两类:
* 数据watcher:  getData和exists会自动注册这类watcher到zk
* 孩子watcher:    getChildren会自动注册这类watcher到zk

节点操作,可能会触发多个watcher事件
(1)setData,将触发该znode的数据watcher
(2)create, 将触发该znode的数据watcher, 以及其父节点的孩子watcher
(3)delete, 将触发该znode的数据watcher, 以及其父节点的孩子watch

(3) Client端在zk注册watcher和watcher事件触发

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

(1) exists操作上的watch,在被监视的Znode创建、删除或数据更新时被触发
(2) getData操作上的watch,在被监视的Znode删除或数据更新时被触发。在被创建时不能被触发,因为只有Znode一定存在,getData操作才会成功。
(3) getChildren操作上的watch,在被监视的Znode的子节点创建或删除,或是这个Znode自身被删除时被触发。可以通过watch事件类型, 区分出是Znode还是子节点被删除:NodeDelete表示Znode被删除,NodeDeletedChanged表示子节点被删除

节点事件的触发,通过函数exists,getData或getChildren来处理这类函数,有双重作用
(1) 向zk服务器注册触发事件
(2) 函数本身的功能

(4) Watcher的本地维护和一次触发特点
1、Watcher在ZooKeeper服务器本地维护,设置、管理和分派。
2、Client和zk服务器断开连接后,watcher将不再被接收
3、Client和zk服务器重新建立连接后,任何先前注册过的watcher都会被重新注册
4、watcher具有一次性,在被触发一次后,就需要client端重新注册该watcher

4. zookeeper应用一: 分布式系统选主

传统的主备检测和倒换机制

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

zookeeper下的主备检测和倒换
(1) 启动阶段
01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

(2) Master故障
如果"主节点-A"故障,它所注册的节点将被zk自动删除,zk会然后再次发出选举,这时候"主节点-B"将在选举中获胜,成为主节点

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

(3) 主节点恢复
如果主节点恢复,则会再次向ZooKeeper注册一个节点,此时注册的节点编号将会是"master-00003",ZooKeeper会再次发动选举,"主节点-B"会再次获胜并继续担任"主节点","主节点-A"会担任备用节点

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

5、zookeeper实现配置管理

集中式的配置管理在应用集群中是非常常见的,一般商业公司内部都会实现一套集中的配置管理中心,应对不同的应用集群对于共享各自配置的需求,并且在配置变更时能够通知到集群中的每一个机器。

Zookeeper很容易实现这种集中式的配置管理,比如将APP1的所有配置配置到/APP1 znode下,APP1所有机器一启动就对/APP1这个节点进行监控(zk.exist("/APP1",true)),并且实现回调方法process,当zookeeper上/APP1 znode节点数据发生变化的时候,每个机器都会收到通知,Watcher实例调用process方法,各个机器去获取最新的数据即可(zk.getData("/APP1",false, stat);

01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理

6、zookeeper实现集群管理

多台机器构成的应用系统,我们可能需要让每一个机器知道集群中(或依赖的其他某一个集群)哪些机器是live的,并且能够在不人工介入的场景下自动将节点down的事件通知到每一个机器。

Zookeeper可以容易地实现这个功能: 比如zookeeper服务器端有一个znode叫/APP1Servers,  应用集群中每台机器启动时,都去这个节点下创建一个临时节点,比如server1创建/APP1Servers/Server1(可以使用ip,保证不重复),server2创建/APP1Servers/Server2, 所有应用集群的机器都关注 /APP1Servers这个节点的数据变化或者子节点列表变化,当有某一台应用集群的机器down机,触发子节点列表发生变化的event,  zk集群自动通知关注该事件的所有zk客户端。本质上,是利用了当zk客户端和zk服务器断连或者session过期就会自动删除临时节点的特性

另外有一个应用场景就是集群选master,一旦master挂掉能够马上能从slave中选出一个master,实现步骤和前者一样,只是机器在启动的时候在APP1SERVERS创建的节点类型变为EPHEMERAL_SEQUENTIAL类型,这样每个节点会自动被编号,

我们默认规定编号最小的为master,所以当我们对/APP1SERVERS节点做监控的时候,得到服务器列表,当编号最小的master宕机,znode自动消失,zk客户端在收到event后,再次获取最新的子节点列表,并且设置最小编号的节点为master,就完成了动态master选举

 01_zookeeper简介(刷新)
1. 分布式系统及其问题
2. 分布式锁的实现
3. zookeeper概述
4. zookeeper应用一: 分布式系统选主
5、zookeeper实现配置管理
6、zookeeper实现集群管理


 【参考博客】http://www.cnblogs.com/sunddenly/p/4033574.html

 【参考博客】http://cailin.iteye.com/blog/2014486/