ZooKeeper安装、配置和使用 | 您所在的位置:网站首页 › zookeeper安装与配置 › ZooKeeper安装、配置和使用 |
Zookeeper的概述:
ZooKeeper是一个开源的分布式的,为分布式应用提供协调服务的Apache项目。 ZooKeeper从设计模式角度来理解:是一个基于观察者模式设计的分布式服务管理框架,它负责存储和管理大家都关心的数据,然后接受观察者的注册,一旦这些数据的状态发生变化,ZooKeeper就将负责通知已经在ZooKeeper上注册的那些观察者做出相应的反应。 例如:一组服务器集群、一组客户端,全部通过ZooKeeper注册,如果一台服务节点宕机,则ZooKeeper集群可以监测宕机几点服务器状态并通知客户端。 ZooKeeper的特点:1. ZooKeeper:一个领导者(Leader),多个跟随者(Follower)组成的集群。 2. 集群中只要有半数以上的节点存活,ZooKeeper集群就能正常服务。 3. 全局数据一致性:每个Server保存一份相同的数据副本,Client无论连接到哪个Server,数据都是一致的。 4. 更新请求顺序进行,来自同一个Client的更新请求按其发送顺序依次执行。 5. 数据更新原子性,一次数据更新要么成功,要么失败。 6. 实时性,在一定时间范围内,Client能读到最新数据。 ZooKeeper的数据结构ZooKeeper数据模型的结构与Unix文件系统类似,整体上可以看做是一棵树,每个节点称作一个ZNode。每一个ZNode默认能够存储1MB的数据,每个ZNode都可以通过其路径唯一标识。 ZooKeeper应用场景提供的服务包括:统一命名服务,统一配置管理,统一集群管理,服务器节点动态上下线,软负载均衡等。 ZooKeeper的内部原理选举机制 半数机制:集群中半数以上机器存活,集群可用。所以ZooKeeper适合安装奇数台服务器。 ZooKeeper虽然在配置文件中没有指定Master和Slave,但是在集群工作时,是有一个节点为Leader,其他节点为Follower的,Leader是通过内部的选举机制临时产生的。 初始化集群选举机制的解释:五台服务器的集群为例,当第一台服务器启动后,给自己投票,此时不符合半数机制(配置文件中已经配置了五台服务器);第二台服务器启动时,投自己一票,此时仍然不符合半数机制,所以第一台服务器的票也投给第二台服务器;第三台服务器启动,投自己一票,此时还是不符合半数机制,所以第一台、第二台服务器都将票投给第三台服务器,现在符合了半数机制,所以Leader为第三台服务器。 ZooKeeper的节点类型1. 持久(Persistent) 持久化目录节点: 客户端与ZooKeeper断开连接后,该节点依旧存在。 持久化顺序编号目录节点 客户端与ZooKeeper断开连接后,该节点依旧存在,只是ZooKeeper给该节点名称进行顺序编号。 说明:创建znode时设置顺序标识,znode名称后会附加一个值,顺序号是一个单调递增的计数器,由父节点维护。 注意:在分布式系统中,顺序号可以被用于为所有的事件进行全局排序,这样客户端可以通过顺序号推断时间的顺序。 2. 短暂 临时目录节点 客户端与ZooKeeper断开连接后,该节点被删除。 临时顺序编号目录节点 客户端与ZooKeeper断开连接后,该节点被删除,只是ZooKeeper给该节点名称进行顺序编号。 监听器的原理一)、监听器的原理详解 1. 首先要有一个main()线程。 2. 在main()线程中创建ZooKeeper客户端,这时就会创建两个线程,一个负责网络连接通信(connet),一个负责监听(listener)。 3. 通过connect线程将注册的监听事件发送给ZooKeeper。 4. 在ZooKeeper的注册监听器列表中将注册的监听事件添加到列表中。 5. ZooKeeper监听到有数据或路径变化,就会将这个消息发送给listener线程。 6. listener线程内部调用process()方法(程序员自己写的方法)。 二)、常见的监听 1. 监听节点数据的变化 1 get path [watch]2. 监听子节点增减的变化 1 ls path [watch] 写数据的流程1. Client向ZooKeeper的Server1上写数据,发送一个写请求。 2. 如果Server1不是Leader,那么Server1会把接收到的请求进一步转发给Leader,因为每个ZooKeeper的Server里面有一个是Leader。这个Leader会将写请求广播给各个Server,各个Server写成功后就会通知Leader。 3. 当Leader收到大多数的Server数据写成功了,那么就说明数据写成功了。如果三个节点的集群,只要有两个节点数据写成功了,那么就认为数据写功了(半数机制)。写成功之后,Leader会告诉Server1数据写成功了。 4. Server1就会进一步通知Client数据写成功了,这时就认为整个写操作成功。 ZooKeeper的分布式安装部署集群规划:三台服务器上部署ZooKeeper集群,基于前面的文章中已经部署的Hadoop环境的三台虚拟机。 打开ZooKeeper官方网站https://zookeeper.apache.org/
在ZooKeeper的/home目录下创建数据存储目录和myid文件: 1 # cd /home 2 # mkdir -p zookeeper/zookeeper_data
在打开的文件最后添加如下内容:
使用zkCli.sh客户端连接ZooKeeper服务: 1 # zkCli.sh -server IP:2181IP地址可以是ZooKeeper集群中任意节点的IP地址,2181为配置文件中client的端口。 在hadoop-1上使用客户端,可以直接使用zkCli.sh: 1 # zkCli.sh
顺序节点保证ZNode路径是唯一的,ZooKeeper服务自动向znode路径填充10位序列号。 2.创建临时节点,数据(data)为111: 1 create -e /snow-tmp 111当会话过期或客户端断开连接时,临时节点将会被删除。 3.创建持久节点,数据(data)为222: 1 create /snow-per 222set命令用以更改节点信息: 1 set /snow-per 333
1. 创建一个Zookeeper的Client对象,并使用改Client连接Zookeeper集群。 2. 使用Create方法创建子节点。 3. 获取子节点并监听节点的变化(监听是放到process方法中执行)。 4. 判断Znode是否存在 5. 监听服务器节点动态上下线 业务服务器也是Zookeeper的Client,遵循以下步骤:连接Zookeeper集群、注册节点(向集群中写数据)、业务逻辑处理。 业务客户端也是Zookeeper的Client,遵循以下步骤:获取Zookeeper集群连接、注册监听、业务逻辑处理。 |
CopyRight 2018-2019 实验室设备网 版权所有 |