一站了解zookeeper的关键知识

news2024/11/26 13:54:33

ZooKeeper 是 Apache 软件基金会的一个软件项目,它为大型分布式计算提供开源的分布式配置服务、同步服务和命名注册。

ZooKeeper 的架构通过冗余服务实现高可用性。

Zookeeper 的设计目标是将那些复杂且容易出错的分布式一致性服务封装起来,构成一个高效可靠的原语集,并以一系列简单易用的接口提供给用户使用。

一个典型的分布式数据一致性的解决方案,分布式应用程序可以基于它实现诸如数据发布/订阅、负载均衡、命名服务、分布式协调/通知、集群管理、Master 选举、分布式锁和分布式队列等功能。

简单的剖析一下这几个关键的功能:

数据发布/订阅:用到了zookeeper的watcher机制

负载均衡:一般是将负载均衡的算法 外加上 zookeeper的分布式锁相结合使用,例如kafka中,就使用了改功能,详情的话,请查看kafka的文章。

集群管理、Master选举,分布式锁:等都是主要使用了分布式的锁的概念,外加一下其他的思想实现。

那对于我们想要快速的开发的话,其实去了解到zookeeper的watcher机制,以及zookeeper的分布式锁相关,那就已经能去快速开发了。

但是想要利用zookeeper去面试相关的,那就得需要了解一下zookeeper的选举机制以及数据同步机制。

一、zookeeper的watcher机制

        分为四部分:1:客户端注册watcher;2:服务端响应watcher;3:服务端触发watcher;4:客户端调用回调函数。

        背景说明:zk的存储数据的模式,类似于一个树的数据结构,每个节点上可以存储数据,也可以有子节点。

        watcher可以监听三种模式,增删改.假设我们监听了header的节点,那么如果这个节点下的数据增删改,或者子节点有增删改,都会触发 客户端的 回调函数。执行回调函数里面的内容。这里要注意一下,原生的watcher机制是执行一次之后 就自动注销掉了,也就是只能触发一次回调函数,如果我们想持续的监听这个节点的状态,必须的自己实现重新去注册watcher。或者使用封装好的类,比如java的NodeCache 、PathChildrenCache、Tree Cache。这个里面简单讲解一下,NodeCache会监听某一个节点的数据变化,节点的新增,但是监听不了节点的删除。PathChildrenCache会监听自己节点下的子节点的变化,子节点的增删改。Tree Cache就是监听节点下面的全部的节点变化。

二、zookeeper的分布式锁

        分布式锁,是控制分布式系统访问某一资源的一种控制方式。

        分布式锁分为两种:排他锁跟共享锁:

        排他锁:顾名思义,加上排他锁之后,就禁止其他的进程再去对这个节点加锁。

        底层实现原理:多个线程并行去创建一个临时节点,那个线程先创建成功了,则这个线程就会获取到这个锁,那其他线程怎么再去抢夺呢,并且怎么实现及时性,那自然就是watcher机制了,创建失败的线程会在这个节点上创建watcher,获取锁的线程任务执行完之后,会断开连接,临时节点有个特性,就是没有线程连接的时候,会自动消亡,节点一旦消亡,就会触发起来watch机制,引导其他线程在抢夺这个锁。

        共享锁:就是可以多个线程去对同一节点进行加锁,但是获取执行权的永远是编号最小的线程。

        底层实现原理:

        1:多个线程创建临时节点,会按照读锁或者写锁,然后加上序列号,比如说001

        2:客户端获取这个节点下的所有节点,判断一下,是否自己的序号小于其他的节点。读锁判断读锁的,写锁判断写锁的。如果自己的节点是最小的,那么自己获得了这个锁。

        3:那如果自己的序号不是最小的,那么会找到比自己的锁序号小一个的节点上,注册watcher。读锁跟写锁分开找。

这种共享锁很适合用作分布式系统中,分布式微服务的选主。

 

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

maven下载和maven配置(以maven3示例)

maven下载和maven配置(以maven3示例) 1.maven下载1.1 直接使用idea捆绑的(很轻松)1.2 手动下载到本机服务器(推荐)1.2.1 官网下载maven1.2.2 选好版本后,选二进制目录 binaries1.2.3 文件选择1.…

Jmeter的Content-Type设置方式

今天调Jmeter脚本遇到一个问题:接口的请求体为Body Data时,没有在HTTP信息头管理加Content-Type参数,Content-Type: application/json,导致脚本一直跑不通,报错,一顿排查,才发现是请求头的原因。…

SpringCloud项目将某个子模块改成以war的形式打包,需要修改的地方

SpringCloud项目将某个子模块改成以war的形式打包&#xff0c;需要修改的地方 在GAV后面添加 《packaging》 war 《/packaging》 在GAV后面添加 《packaging》 war 《/packaging》 添加war打包方式 <packaging>war</packaging>添加之后项目会报错&#xff0c;工程…

Ada学习(2)Statements

文章目录 if statements / expressionif statementsif expression Case Statement / ExpressionCase StatementCase Expression Loop Statement基本循环结构 loopwhile loopFor 循环NoteFor ... loop Control VariableFor ... loop Range EvaluationDeclare block (声明代码块)…

手把手教小白安装Jenkins

一、Jenkins简介 Jenkins是一个开源软件项目&#xff0c;是基于Java开发的一种持续集成工具&#xff0c;用于监控持续重复的工作&#xff0c;旨在提供一个开放易用的软件平台&#xff0c;使软件的持续集成变成可能。 简而言之&#xff0c;Jenkins就是一款将构建&#xff0c;打…

例3:模板

例&#xff1a;如图所示流程&#xff0c;乙烷和丙烷混合液进入蒸发器Evaporator&#xff0c;从天然气吸收热量后进入压缩机Compressor&#xff0c;压缩后的气体进入冷凝器Condenser&#xff0c;最后通过J-T阀&#xff08;焦耳-汤姆逊节流膨胀阀&#xff09;回到进入蒸发器前的状…

抖音SEO矩阵营销系统/MVC源码部署二次开发搭建

首先&#xff0c;抖音SEO矩阵系统源码开发&#xff0c;如何做独立部署&#xff0c;首先我们需要深刻理解这个系统的开发逻辑是什么&#xff1f;开发的前言是在抖音平台做流量新增&#xff0c;现在抖音及各大主流短视频平台&#xff0c;流量新增&#xff0c;各大企业需要在短视频…

10- YOLO算法一 (目标检测)

要点&#xff1a; yolo算法属于 One-stage detector 一 YOLO v1 1) 将一幅图像分成SxS个网格(grid cell)&#xff0c;如果某个object的中心 落在这个网格中&#xff0c;则这个网格就负责预测这个object。 2)每个网格要预测B个bounding box&#xff0c;每个bounding box 除了…

springboot配置多个数据源【详解】

springboot配置多个数据源【详解】 前言&#xff0c;什么是数据源与数据库连接池一、配置文件进行配置&#xff1a;1.导入依赖&#xff1a; 二、编写配置类&#xff1a;1.用来指定包扫描、指定sqlSessionTemplateRef2&#xff0c;用来指定mapper.xml的路径3.Mybatis主数据源ds1…

DNS协议、ICMP协议、NAT技术

目录 一、DNS协议 1.1 认识DNS 1.2 域名简介 1.3 域名解析过程 1.4 使用dig工具分析DNS过程 二、ICMP协议 2.1 ICMP协议的定位 2.2 ICMP功能 2.3 ICMP协议格式&#xff08;了解&#xff09; 2.4 ping命令 2.5 traceroute命令 三、NAT技术&#xff08;重点&#xff…

JavaWeb13-JavaScript 开发利器之 jQuery-01

1. 说明 1.1 现状 1、jquery 使用情况 2、Vue 使用情况 1.2 官方文档 学习地址: https://www.w3school.com.cn/jquery/index.asp API地址: https://jquery.cuishifeng.cn/ 1.3 JQuery 是什么? 1.3.1 基本介绍 jQuery 是一个快速的&#xff0c;简洁的 javaScript 库…

BAPC 2022 Pre 部分题解

BAPC 2022 Pre 部分题解 K (11). Lots of Liquid题目描述题意思路代码 F (6). Fastestest Function题目描述题意思路代码 B (2). Bubble-bubble Sort题目代码 A (1). Abbreviated Aliases题目题意思路代码 I (9). Jabbing Jets题目题意思路代码 E (5). Extended Braille题目题意…

SQL调优-性能参数介绍

-- 课程表 create table course ( cid int(3), cname varchar(20), tid int(3) ); -- 教师表 create table teacher (tid int(3),tname varchar(20),tcid int(3) ); -- 教师证表 create table teacherCard (tcid int(3),tcdesc varchar(200) );explain select语句分析 1.id…

自监督ViT:DINO-v1和DINO-v2

1. 概述 基于ViT&#xff08;Vision Transformer&#xff09;自监督在最近几年取得了很大进步&#xff0c;目前在无监督分类任务下已经超过了之前的一些经典模型&#xff0c;同时在检测分割等基础任务领域也展现出了强大的泛化能力。这篇文章将主要基于DINO系列自监督算法介绍…

NoSQL之Redis高可用与优化

目录 一、Redis高可用二、Redis 持久化2.1 Redis 提供两种方式进行持久化2.2 RDB持久化2.2-1 触发条件2.2-2 执行流程2.2-3 启动时加载 2.3 AOF 持久化2.3.1 开启AOF2.3.2 执行流程2.3.3 执行流程启动时加载 三、RDB和AOF的优缺点四、Redis 性能管理4.1 查看Redis内存使用4.2 内…

Linux上,多个JDK版本如何管理(交流贴)

1. 多个JDK版本面临的问题 公司大多数业务都是用Oracle JDK 8&#xff0c;笔者做大数据查询引擎调研时&#xff0c;则需要使用JDK 17 因此&#xff0c;需要在Linux服务器同时安装JDK 8和17&#xff0c;同时需要能智能地快速切换JDK版本&#xff0c;已使用不同的查询引擎需求 …

一致性哈希算法

如何分配请求&#xff1f; 大多数网站背后肯定不是只有一台服务器提供服务&#xff0c;因为单机的并发量和数据量都是有限的&#xff0c;所以都会用多台服务器构成集群来对外提供服务。 但是问题来了&#xff0c;现在有那么多个节点&#xff08;后面统称服务器为节点&#xf…

史上最详细sqlmap入门教程

最近做安全测试&#xff0c;遇到了SQL盲注的漏洞&#xff0c;从发现漏洞&#xff0c;确认漏洞&#xff0c;协助开发复现漏洞&#xff0c;验证漏洞一整套流程下来&#xff0c;有了亿点点收获&#xff0c;下面分享给大家&#xff0c;希望对软件测试同学有所启发&#xff0c;难度不…

ChatGPT原理简介

承接上文GPT前2代版本简介 GPT3的基本思想 GPT2没有引起多大轰动&#xff0c;真正改变NLP格局的是第三代版本。 GPT3训练的数据包罗万象&#xff0c;上通天文下知地理&#xff0c;所以它会胡说八道,会说的贼离谱&#xff0c;比如让你穿越到唐代跟李白对诗&#xff0c;不在一…

JavaScript如何实现上拉加载,下拉刷新?

一、前言 下拉刷新和上拉加载这两种交互方式通常出现在移动端中。本质上等同于PC网页中的分页&#xff0c;只是交互形式不同。开源社区也有很多优秀的解决方案&#xff0c;如iscroll、better-scroll、pulltorefresh.js库等等。这些第三方库使用起来非常便捷。我们通过原生的方式…