【分布式技术】注册中心zookeeper

目录

一、ZooKeeper是什么

二、ZooKeeper的工作机制

三、ZooKeeper特点

四、ZooKeeper数据结构

五、ZooKeeper应用场景

●统一命名服务

●统一配置管理

●统一集群管理

●服务器动态上下线

●软负载均衡

六、ZooKeeper的选举机制

七、实操部署ZooKeeper集群

步骤一：先部署java环境

步骤二：完成zookeeper安装包下载

步骤三：完成部署启动

一、ZooKeeper是什么

Zookeeper是一个开源的分布式的，为分布式框架提供协调服务的Apache项目。

二、ZooKeeper的工作机制

Zookeeper从设计模式角度来理解：是一个基于观察者模式设计的分布式服务管理框架，它负责存储和管理大家都关心的数据，然后接受观察者的注册，一旦这些数据的状态发生变化，Zookeeper就将负责通知已经在Zookeeper上注册的那些观察者做出相应的反应。也就是说

Zookeeper = 注册中心+文件系统 + 通知机制。

三、ZooKeeper特点

（1）Zookeeper：一个领导者（Leader），多个跟随者（Follower）组成的集群。
（2）Zookeeper集群中只要有半数以上节点存活，Zookeeper集群就能正常服务。所以Zookeeper适合安装奇数台服务器。
（3）全局数据一致：每个Server保存一份相同的数据副本，Client无论连接到哪个Server，数据都是一致的。
（4）更新请求顺序执行，来自同一个Client的更新请求按其发送顺序依次执行，即先进先出。
（5）数据更新原子性，一次数据更新要么成功，要么失败。
（6）实时性，在一定时间范围内，Client能读到最新数据。

四、ZooKeeper数据结构

ZooKeeper数据模型的结构与Linux文件系统很类似，整体上可以看作是一棵树，每个节点称做一个ZNode。每一个ZNode默认能够存储1MB的数据，每个ZNode都可以通过其路径唯一标识。

五、ZooKeeper应用场景

提供的服务包括：

统一命名服务、统一配置管理、统一集群管理、服务器节点动态上下线、软负载均衡等。


●统一命名服务

在分布式环境下，经常需要对应用/服务进行统一命名，便于识别。例如：IP不容易记住，而域名容易记住。

●统一配置管理

（1）分布式环境下，配置文件同步非常常见。一般要求一个集群中，所有节点的配置信息是一致的，比如Kafka集群。对配置文件修改后，希望能够快速同步到各个节点上。
（2）配置管理可交由ZooKeeper实现。可将配置信息写入ZooKeeper上的一个Znode。各个客户端服务器监听这个Znode。一旦Znode中的数据被修改，ZooKeeper将通知各个客户端服务器。

●统一集群管理

（1）分布式环境中，实时掌握每个节点的状态是必要的。可根据节点实时状态做出一些调整。
（2）ZooKeeper可以实现实时监控节点状态变化。可将节点信息写入ZooKeeper上的一个ZNode。监听这个ZNode可获取它的实时状态变化。

●服务器动态上下线

客户端能实时洞察到服务器上下线的变化。

●软负载均衡

在Zookeeper中记录每台服务器的访问数，让访问数最少的服务器去处理最新的客户端请求（这边最小连接调度算法嘛）。

六、ZooKeeper的选举机制

  • 第一次启动选举机制

（1）服务器1启动，发起一次选举。服务器1投自己一票。此时服务器1票数一票，不够半数以上（3票），选举无法完成，服务器1状态保持为LOOKING；
（2）服务器2启动，再发起一次选举。服务器1和2分别投自己一票并交换选票信息：此时服务器1发现服务器2的myid比自己目前投票推举的（服务器1）大，更改选票为推举服务器2。此时服务器1票数0票，服务器2票数2票，没有半数以上结果，选举无法完成，服务器1，2状态保持LOOKING
（3）服务器3启动，发起一次选举。此时服务器1和2都会更改选票为服务器3。此次投票结果：服务器1为0票，服务器2为0票，服务器3为3票。此时服务器3的票数已经超过半数，服务器3当选Leader。服务器1，2更改状态为FOLLOWING，服务器3更改状态为LEADING；
（4）服务器4启动，发起一次选举。此时服务器1，2，3已经不是LOOKING状态，不会更改选票信息。交换选票信息结果：服务器3为3票，服务器4为1票。此时服务器4服从多数，更改选票信息为服务器3，并更改状态为FOLLOWING；（5）服务器5启动，同4一样当小弟。

总结：比较服务器的myid大小，谁的myid越大则获取其他节点的选票，当选票数量超过服务器节点数量的半数以后，则当选leader，其他节点为follower。即使有新的更大myid节点加入集群，也不变

  • 非第一次启动选举机制

1.EPOCH大的直接胜出
2.EPOCH相同，事务id大的胜出
3.事务id相同，服务器id大的胜出

SID：服务器ID。用来唯一标识一台ZooKeeper集群中的机器，每台机器不能重复，和myid一致。（表示服务器的唯一标志id）
ZXID：事务ID。ZXID是一个事务ID，用来标识一次服务器状态的变更。在某一时刻，集群中的每台机器的ZXID值不一定完全一致，这和ZooKeeper服务器对于客户端“更新请求”的处理逻辑速度有关。（表示处理任务的数量）
Epoch：每个Leader任期的代号。没有Leader时同一轮投票过程中的逻辑时钟值是相同的。每投完一次票这个数据就会增加（表示参与选举的次数）

七、实操部署ZooKeeper集群

步骤一：先部署java环境

步骤二：完成zookeeper安装包下载

//安装 JDK
yum install -y java-1.8.0-openjdk java-1.8.0-openjdk-devel
java -version//下载安装包
官方下载地址：https://archive.apache.org/dist/zookeeper/cd /opt
方法一：wget https://archive.apache.org/dist/zookeeper/zookeeper-3.5.7/apache-zookeeper-3.5.7-bin.tar.gz2.安装 Zookeeper
cd /opt
方法二：
tar -zxvf apache-zookeeper-3.6.4-bin.tar.gz
mv apache-zookeeper-3.6.4-bin /usr/local/zookeeper//修改配置文件
cd /usr/local/zookeeper/conf/
cp zoo_sample.cfg zoo.cfgvim zoo.cfg
tickTime=2000   #通信心跳时间，Zookeeper服务器与客户端心跳时间，单位毫秒
initLimit=10    #Leader和Follower初始连接时能容忍的最多心跳数（tickTime的数量），这里表示为10*2s
syncLimit=5     #Leader和Follower之间同步通信的超时时间，这里表示如果超过5*2s，Leader认为Follwer死掉，并从服务器列表中删除Follwer
dataDir=/usr/local/zookeeper-3.5.7/data      ●修改，指定保存Zookeeper中的数据的目录，目录需要单独创建
dataLogDir=/usr/local/zookeeper-3.5.7/logs   ●添加，指定存放日志的目录，目录需要单独创建
clientPort=2181   #客户端连接端口
#添加集群信息
server.1=192.168.20.12:3188:3288
server.2=192.168.20.15:3188:3288
server.3=192.168.20.16:3188:3288-------------------------------------------------------------------------------------
server.A=B:C:D
●A是一个数字，表示这个是第几号服务器。集群模式下需要在zoo.cfg中dataDir指定的目录下创建一个文件myid，这个文件里面有一个数据就是A的值，Zookeeper启动时读取此文件，拿到里面的数据与zoo.cfg里面的配置信息比较从而判断到底是哪个server。
●B是这个服务器的地址。
●C是这个服务器Follower与集群中的Leader服务器交换信息的端口。
●D是万一集群中的Leader服务器挂了，需要一个端口来重新进行选举，选出一个新的Leader，而这个端口就是用来执行选举时服务器相互通信的端口。
-------------------------------------------------------------------------------------//拷贝配置好的 Zookeeper 配置文件到其他机器上
scp /usr/local/zookeeper/conf/zoo.cfg 192.168.20.15:/usr/local/zookeeper/conf/
scp /usr/local/zookeeper/conf/zoo.cfg 192.168.20.16:/usr/local/zookeeper/conf///在每个节点上创建数据目录和日志目录
mkdir /usr/local/zookeeper/data
mkdir /usr/local/zookeeper/logs//在每个节点的dataDir指定的目录下创建一个 myid 的文件
echo 1 > /usr/local/zookeeper/data/myid
echo 2 > /usr/local/zookeeper/data/myid
echo 3 > /usr/local/zookeeper/data/myid

 

步骤三：完成部署启动

//配置 Zookeeper 启动脚本
vim /etc/init.d/zookeeper
#!/bin/bash
#chkconfig: 2345 20 90
#description:Zookeeper Service Control Script
ZK_HOME='/usr/local/zookeeper'
case $1 in
start)echo "---------- zookeeper 启动 ------------"$ZK_HOME/bin/zkServer.sh start
;;
stop)echo "---------- zookeeper 停止 ------------"$ZK_HOME/bin/zkServer.sh stop
;;
restart)echo "---------- zookeeper 重启 ------------"$ZK_HOME/bin/zkServer.sh restart
;;
status)echo "---------- zookeeper 状态 ------------"$ZK_HOME/bin/zkServer.sh status
;;
*)echo "Usage: $0 {start|stop|restart|status}"
esac//	设置开机自启
chmod +x /etc/init.d/zookeeper
chkconfig --add zookeeper//分别启动 Zookeeper
service zookeeper start//查看当前状态
service zookeeper status

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/243301.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

线性代数：矩阵运算（加减、数乘、乘法、幂、除、转置）

线性代数：矩阵运算（加减、数乘、乘法、幂、除、转置）

目录 加减 数乘 矩阵与矩阵相乘 矩阵的幂 矩阵转置 方阵的行列式 方阵的行列式，证明：|AB| |A| |B| 加减 数乘 矩阵与矩阵相乘 矩阵的幂 矩阵转置 方阵的行列式 方阵的行列式，证明：|AB| |A| |B|
阅读更多...
续签KES证书

续签KES证书

MiniO KES（密钥加密服务）是 MinIO 开发的一项服务，旨在弥合在 Kubernetes 中运行的应用程序与集中式密钥管理服务 （KMS） 之间的差距。中央 KMS 服务器包含所有状态信息，而 KES 在需要执行与获取新密钥或更新…
阅读更多...
Unity 工厂方法模式（实例详解）

Unity 工厂方法模式（实例详解）

文章目录 在Unity中，工厂方法模式是一种创建对象的常用设计模式，它提供了一个接口用于创建对象，而具体的产品类是由子类决定的。这样可以将对象的创建过程与使用过程解耦，使得代码更加灵活和可扩展。 工厂模式的主要优点如下&…
阅读更多...
Unity中实现捏脸系统

Unity中实现捏脸系统

前言 目前市面上常见的捏脸一般是基于BlendShapes和控制骨骼点坐标两种方案实现的。后者能够控制的精细程度更高，同时使用BlendShapes来控制表情。 控制骨骼点坐标 比如找到控制鼻子的骨骼节点修改localScale缩放，调节鼻子大小。 BlendShapes控制表…
阅读更多...
gin中间件篇

gin中间件篇

1. 全局中间件 所有请求都经过此中间件 package mainimport ("fmt""time""github.com/gin-gonic/gin" )// 定义中间 func MiddleWare() gin.HandlerFunc {return func(c *gin.Context) {t : time.Now()fmt.Println("中间件开始执行了&quo…
阅读更多...
OceanBase集群扩缩容

OceanBase集群扩缩容

​ OceanBase 数据库采用 Shared-Nothing 架构，各个节点之间完全对等，每个节点都有自己的 SQL 引擎、存储引擎、事务引擎，天然支持多租户，租户间资源、数据隔离，集群运行的最小资源单元是Unit，每个租户在每…
阅读更多...
常用设计模式(工厂方法，抽象工厂，责任链，装饰器模式)

常用设计模式(工厂方法，抽象工厂，责任链，装饰器模式)

前言 有关设计模式的其他常用模式请参考 单例模式的实现 常见的设计模式(模板与方法，观察者模式，策略模式) 工程方法 定义 定义一个用于创建对象的接口，让子类决定实例化哪一个类。Factory Method使得一个类的实例化延迟到子类。 ——《设…
阅读更多...
Unity -简单键鼠事件和虚拟轴

Unity -简单键鼠事件和虚拟轴

简单键鼠事件 — “Test_03” KeyTest 键鼠事件每帧都要监听，要放在Update()中处理 public class KeyTest : MonoBehaviour {// Start is called before the first frame updatevoid Start(){}// Update is called once per framevoid Update(){// 【鼠标点击事件…
阅读更多...
C++ ：命名空间域

C++ ：命名空间域

目录 冲突与命名： 举个例子： 全局与局部： 域作用限定符： 命名空间域： 冲突与命名： 在C语言中，我们通常会使用stdlib.h 而stdlib.h 本质上是一个函数的库，在程序中使用的大多数…
阅读更多...
java面试——juc篇

java面试——juc篇

目录 一、线程基础 1、进程与线程的区别？（⭐⭐⭐） 2、并行和并发的区别（⭐） 3、创建线程的方式有哪些？（⭐⭐⭐⭐） runnable和Callable的区别： 线程中的run()和 star…
阅读更多...
自然语言处理研究的内容

自然语言处理研究的内容

一.基础技术 1.1 词法分析 词法分析（Lexical Analysis），也称为词法扫描或扫描器，是自然语言处理（NLP）中的基础步骤之一，用于将输入的文本分割成词法单元（Token）。词法单…
阅读更多...
条件风险价值CVaR内容介绍(MATLAB例程)

条件风险价值CVaR内容介绍(MATLAB例程)

在对微电网优化调度过程中，由于新能源机组出力和负荷的不确定性，若采用确定性的优化调度方案会存在一定的风险。当风电和光伏输出功率的实际值低于预测值时，需要增加可控机组出力或切除部分负荷；反之，若风电和光伏输出…
阅读更多...
php array_diff 比较两个数组bug避坑 深入了解

php array_diff 比较两个数组bug避坑 深入了解

今天实用array_diff出现的异常问题，预想的结果应该是返回 "integral_initiate">"0"，实际没有 先看测试代码： $a ["user_name">"测","see_num">0,"integral_initiate&quo…
阅读更多...
数据操作——缺失值处理

数据操作——缺失值处理

缺失值处理 缺失值的处理思路 如果想探究如何处理无效值, 首先要知道无效值从哪来, 从而分析可能产生的无效值有哪些类型, 在分别去看如何处理无效值 什么是缺失值 一个值本身的含义是这个值不存在则称之为缺失值, 也就是说这个值本身代表着缺失, 或者这个值本身无意义, 比如…
阅读更多...
Hylicos - MINI2440 - 中断控制

Hylicos - MINI2440 - 中断控制

中断 中断源管理 中断是一种异步异常，CPU需要处理很多来自设备的中断请求，而CPU引出的line只有IRQ线和FIQ线，所以就得引入中断控制器帮助CPU搞清楚是中断的来源。 MINI2440的中断控制器，可以接受来自60个中断源的请求。提供这些…
阅读更多...
MySQL面试总结

MySQL面试总结

MySQL优化 1.MySQL如何定位慢查询 1.1开源工具 1.2MySQL自带慢日志 1.3解答 2.EXPLAIN 2.1解答 3.什么是索引 4.B树 4.1数据结构对比 5.聚簇索引（聚集索引） 6.覆盖索引 7.索引创建原则 8.什么情况下索引失效 9.你对sql优化经验 10.事务 11.MVCC 11.主从…
阅读更多...
开源堡垒机JumpServer本地安装并配置公网访问地址

开源堡垒机JumpServer本地安装并配置公网访问地址

文章目录 前言1. 安装Jump server2. 本地访问jump server3. 安装 cpolar内网穿透软件4. 配置Jump server公网访问地址5. 公网远程访问Jump server6. 固定Jump server公网地址 前言 JumpServer 是广受欢迎的开源堡垒机，是符合 4A 规范的专业运维安全审计系统。JumpS…
阅读更多...
Python多线程爬虫——数据分析项目实现详解

Python多线程爬虫——数据分析项目实现详解

前言 前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家：https://www.captainbed.cn/z 「个人网站」：雪碧的个人网站 ChatGPT体验地址 文章目录 前言爬虫获取cookie网站爬取与启动CS…
阅读更多...
Spring boot项目java bean和xml互转

Spring boot项目java bean和xml互转

Spring boot项目实现java bean和xml互转 项目场景：互转方法使用jackson进行互转使用jaxws进行xml与bean的互转 搞定收工！ 项目场景： 工作中需要给下游第三方收费系统做数据挡板，由于下游系统使用的是soap webservice,里面涉及各种…
阅读更多...
牛客周赛 Round 21 解题报告 | 珂学家 | 堆栈的妙用

牛客周赛 Round 21 解题报告 | 珂学家 | 堆栈的妙用

前言 整体评价 从A题中的Baidu, 可以猜到这场有几道题来自于百度校招。 其实B题有点意思，如果把十字星的范围放大，那就可以成为一个hard题。 D题也挺意思的，大概有两种思路，一种是从左到右枚举右端点，增量累加&…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023