12.0 Zookeeper 数据同步流程
在 Zookeeper 中，主要依赖 ZAB 协议来实现分布式数据一致性。
ZAB 协议分为两部分：
- 消息广播
- 崩溃恢复
消息广播
Zookeeper 使用单一的主进程 Leader 来接收和处理客户端所有事务请求，并采用 ZAB 协议的原子广播协议，将事务请求以 Proposal 提议广播到所有 Follower 节点，当集群中有过半的Follower 服务器进行正确的 ACK 反馈，那么Leader就会再次向所有的 Follower 服务器发送commit 消息，将此次提案进行提交。这个过程可以简称为 2pc 事务提交，整个流程可以参考下图，注意 Observer 节点只负责同步 Leader 数据，不参与 2PC 数据同步过程。
崩溃恢复
在正常情况消息广播情况下能运行良好，但是一旦 Leader 服务器出现崩溃，或者由于网络原理导致 Leader 服务器失去了与过半 Follower 的通信，那么就会进入崩溃恢复模式，需要选举出一个新的 Leader 服务器。在这个过程中可能会出现两种数据不一致性的隐患，需要 ZAB 协议的特性进行避免。
- 1、Leader 服务器将消息 commit 发出后，立即崩溃
- 2、Leader 服务器刚提出 proposal 后，立即崩溃
ZAB 协议的恢复模式使用了以下策略：
- 1、选举 zxid 最大的节点作为新的 leader
- 2、新 leader 将事务日志中尚未提交的消息进行处理
下个章节详细讲解 leader 选举过程。
希望你也学会了，更多编程源码模板请来二当家的素材网：https://www.erdangjiade.com
相关文章：
12.0 Zookeeper 数据同步流程
在 Zookeeper 中，主要依赖 ZAB 协议来实现分布式数据一致性。 ZAB 协议分为两部分： 消息广播崩溃恢复 消息广播 Zookeeper 使用单一的主进程 Leader 来接收和处理客户端所有事务请求，并采用 ZAB 协议的原子广播协议，将事务请求…...
作业2.6
一、填空题 1、一个类的头文件如下所示，num初始化值为5，程序产生对象T，且修改num为10，并使用show()函数输出num的值10。 #include <iostream.h> class Test { private: static int num; public: Test(int); void sh…...
Qt应用软件【协议篇】TCP示例
文章目录 TCP协议简介Qt中的TCP编程完整代码示例实际使用中的技巧实际使用中的注意事项TCP协议简介 TCP（传输控制协议）是一种面向连接的、可靠的、基于字节流的传输层通信协议。与UDP不同，TCP提供了数据包排序、重传机制、流量控制和拥塞控制，确保了数据传输的可靠性和顺序…...
C# CAD交互界面-自定义面板集（四）
运行环境 vs2022 c# cad2016 调试成功 一、引用 using Autodesk.AutoCAD.Runtime; using Autodesk.AutoCAD.Windows; using System.Windows.Forms; 二、程序说明 创建自定义面板集（PaletteSet）的C#命令方法实现。该方法名为CreatePaletteÿ…...
物流自动化移动机器人｜HEGERLS三维智能四向穿梭车助力优化企业供应链
智能化仓库/仓储贯穿于物流的各个环节，不局限于存储、输送、分拣、搬运等单一作业环节的自动化，更多的是利用科技手段实现整个物流供应链流程的自动化与智能化，将传统自动化仓储物流各环节进行多维度的有效融合。 例如在数智化物流仓储的建设…...
EasyExcel下载带下拉框和批注模板
EasyExcel下载带下拉框和批注模板 一、 代码实现 controller下载入口 /***下载excel模板* author youlu* date 2023/8/14 17:31* param response* param request* return void*/PostMapping("/downloadTemplate")public void downloadExcel(HttpServletResponse r…...
C语言之字符逆序（牛客网）
个人主页（找往期文章包括但不限于本期文章中不懂的知识点）：我要学编程(ಥ_ಥ)-CSDN博客 字符逆序__牛客网 题目： 思路：既然有空格就不能用scanf函数来接收字符了。因为scanf函数遇到空格会停止读取。我们可以用get…...
RAPTOR：树组织检索的递归抽象处理
RAPTOR: RECURSIVE ABSTRACTIVE PROCESSING FOR TREE-ORGANIZED RETRIEVAL Title：树组织检索的递归抽象处理 https://arxiv.org/pdf/2401.18059.pdf 摘要 检索增强语言模型可以更好的融入长尾问题，但是现有的方法只检索短的连续块，限制了整…...
图论：合适的环
4979. 合适的环 - AcWing题库 给定一个 n 个点 m 条边的无向图。 图中不含重边和自环。 请你在图中选出一个由三个点组成的环。 设图中一共有 x 条边满足：不在选择的环内，且与选择的环内某个点相连。 我们希望通过合理选环，使得 x 的值尽可能…...
【数据分享】1929-2023年全球站点的逐月平均降水量（Shp\Excel\免费获取）
气象数据是在各项研究中都经常使用的数据，气象指标包括气温、风速、降水、湿度等指标，说到常用的降水数据，最详细的降水数据是具体到气象监测站点的降水数据！ 有关气象指标的监测站点数据，之前我们分享过1929-2023年全…...
React+Antd实现省、市区级联下拉多选组件（支持只选省不选市）
1、效果 是你要的效果，咱们继续往下看，搜索面板实现省市区下拉，原本有antd的Cascader组件，但是级联组件必须选到子节点，不能只选省，满足不了页面的需求 2、环境准备 1、react18 2、antd 4 3、功能实现 …...
CentOS镜像如何下载？在VMware中如何安装？
一、问题 CentOS镜像如何下载？在VMware中如何安装？ 二、解决 1、CentOS镜像的下载 （1）官方网站 The CentOS Project （2）官方中文官网 CentOS 中文 官网 （3）选择CentOS Linux…...
计算机科学导论（4）DMA传输原理
文章目录 DMA的工作原理DMA的优势DMA的类型DMA的应用 DMA（Direct Memory Access）直接内存访问是一种允许某些硬件子系统在不通过中央处理单元（CPU）的情况下，直接从内存读取或向内存写入数据的技术。这种方式可以显著提…...
select、poll和epoll的区别
文章目录 概要一、多路复用I/O模型的诞生1.1 多线程或进程方式1.2 通过数组，链表等方式保存socket fd，不断轮询 二、select三、poll四、epoll五、小结六、参考 概要 在Unix五种I/O模型一文中，提到了I/O多路复用模型，其在Linux下有…...
gpt今日最新新闻：gpts的广泛应用
最近，OpenAI给ChatGPT带来了一个备受期待的更新——“GPT提及（mentions）”功能。这项创新不仅增强了ChatGPT的实用性，也为AI在日常业务中的运用开辟了新路径。在本文中，我将分享我对这项新功能的初步体验，并…...
【进入游戏行业选游戏特效还是技术美术？】
进入游戏行业选游戏特效还是技术美术？ 游戏行业正处于蓬勃发展的黄金时期，科技的进步推动了游戏技术和视觉艺术的飞速革新。在这个创意和技术挑战交织的领域里，游戏特效和技术美术岗位成为了许多人追求的职业目标。 这两个岗位虽然紧密关联…...
 Object Pascal 学习笔记---第4章第2.3节（常量参数）)
(delphi11最新学习资料) Object Pascal 学习笔记---第4章第2.3节（常量参数）
4.2.3 常量参数 作为引用参数的替代，您可以使用const参数。由于您无法在例程内为const参数赋予新值，因此编译器可以优化参数传递。编译器可以选择与引用参数相似的方法（或者在C术语中是const引用），但行为类似于值参…...
事件在状态流程图中的工作方式
什么是事件？ 事件是一个Stateflow对象，它可以触发以下对象中一个动作： Simulink触发子系统 Simulink函数调用子系统 状态流程图 何时使用事件 当你想： 激活Simulink触发的子系统 激活Simulink函数调用子系统 在状态流程图…...
幻兽帕鲁能在Mac上运行吗？幻兽帕鲁Palworld新手攻略
幻兽帕鲁能在Mac上运行吗？ 《幻兽帕鲁》目前还未正式登陆Mac平台，不过通过一些方法是可以让游戏在该平台运行的。 虽然游戏不能在最高配置下运行，但如果你安装了CrossOver这个软件，就可以玩了。这是为Mac、Linux和ChromeOS等设计…...
elementPlus实现动态表格单元格合并span-method方法总结
最近在做PC端需求的时候，需要把首列中相邻的同名称单元格合并。 我看了一下elementPlus官网中的table表格，span-method可以实现单元格合并。 我们先看一下官网的例子： 合并行或列 多行或多列共用一个数据时，可以合并行或列。 …...
业务系统对接大模型的基础方案：架构设计与关键步骤
业务系统对接大模型：架构设计与关键步骤 在当今数字化转型的浪潮中，大语言模型（LLM）已成为企业提升业务效率和创新能力的关键技术之一。将大模型集成到业务系统中，不仅可以优化用户体验，还能为业务决策提供…...
1.3 VSCode安装与环境配置
进入网址Visual Studio Code - Code Editing. Redefined下载.deb文件，然后打开终端，进入下载文件夹，键入命令 sudo dpkg -i code_1.100.3-1748872405_amd64.deb 在终端键入命令code即启动vscode 需要安装插件列表 1.Chinese简化 2.ros …...
Module Federation 和 Native Federation 的比较
前言 Module Federation 是 Webpack 5 引入的微前端架构方案，允许不同独立构建的应用在运行时动态共享模块。 Native Federation 是 Angular 官方基于 Module Federation 理念实现的专为 Angular 优化的微前端方案。 概念解析 Module Federation (模块联邦) Modul…...
docker 部署发现spring.profiles.active 问题
报错： org.springframework.boot.context.config.InvalidConfigDataPropertyException: Property spring.profiles.active imported from location class path resource [application-test.yml] is invalid in a profile specific resource [origin: class path re…...
安宝特案例丨Vuzix AR智能眼镜集成专业软件，助力卢森堡医院药房转型，赢得辉瑞创新奖
在Vuzix M400 AR智能眼镜的助力下，卢森堡罗伯特舒曼医院（the Robert Schuman Hospitals, HRS）凭借在无菌制剂生产流程中引入增强现实技术（AR）创新项目，荣获了2024年6月7日由卢森堡医院药剂师协会࿰…...
Python Ovito统计金刚石结构数量
大家好，我是小马老师。 本文介绍python ovito方法统计金刚石结构的方法。 Ovito Identify diamond structure命令可以识别和统计金刚石结构，但是无法直接输出结构的变化情况。 本文使用python调用ovito包的方法，可以持续统计各步的金刚石结构，具体代码如下： from ovito…...
push [特殊字符] present
push 🆚 present 前言present和dismiss特点代码演示 push和pop特点代码演示 前言 在 iOS 开发中，push 和 present 是两种不同的视图控制器切换方式，它们有着显著的区别。 present和dismiss 特点 在当前控制器上方新建视图层级需要手动调用…...
解读《网络安全法》最新修订，把握网络安全新趋势
《网络安全法》自2017年施行以来，在维护网络空间安全方面发挥了重要作用。但随着网络环境的日益复杂，网络攻击、数据泄露等事件频发，现行法律已难以完全适应新的风险挑战。 2025年3月28日，国家网信办会同相关部门起草了《网络安全…...
【从零开始学习JVM | 第四篇】类加载器和双亲委派机制(高频面试题)
前言： 双亲委派机制对于面试这块来说非常重要，在实际开发中也是经常遇见需要打破双亲委派的需求，今天我们一起来探索一下什么是双亲委派机制，在此之前我们先介绍一下类的加载器。 目录 编辑 前言： 类加载器 1. …...
tomcat入门
1 tomcat 是什么 apache开发的web服务器可以为java web程序提供运行环境tomcat是一款高效，稳定，易于使用的web服务器tomcathttp服务器Servlet服务器 2 tomcat 目录介绍 -bin #存放tomcat的脚本 -conf #存放tomcat的配置文件 ---catalina.policy #to…...