数据库分布式集群动态调整quorum值方案对比


难度 中等

背景

在数据库分布式集群中,在半数以上节点宕机后,期望剩下的节点机器仍然能提供服务

举例来说,一个包含5个节点的数据库集群,当集群挂掉3个节点后,因为不符合半数以上节点正常原则,数据库集群将无法对外提供服务,需要人为介入。但在数据库的实际使用场景中,我们期望即使只剩下一个节点也能对外提供服务。实际上,当5个集群节点挂掉2个节点后,应将剩下3个节点看成一个3节点的集群,动态调整对应的quorum值,并允许再挂掉一个节点。基于该中情况对分布式集群选举算法提出了动态调整quorum值的要求。

当前业界主流的分布式协议主要有raft协议和totem协议,并且业界均有相关协议成熟的开源实现,如jraft是raft协议的开源实现,corosync是totem协议的开源实现。我们将对照这两种协议的特点及相关开源实现,来选择动态调整quorum值的方案。

备注:需要特别说明的raft协议和totem协议是算法和通信协议,是分布式集群实现的理论基础,jraft和corosync是框架实现,pacemaker+corosync是其中一种解决方案。

实现方案

要达到动态调整quorum值,当前有两种实现方式:

  1. 修改quorum;
  2. 修改集群节点

修改quorum

使用修改quorum动态调整quorum的算法如下(假设集群节点总数为n,采用quorum机制投票半数原则进行选举):

  1. 初始化时expect_vote为n,选举leader时需要的quorum为(expect_vote/2)+ 1;
  2. 当在线节点数与quorum相等时,需启动动态quorum定时器;
  3. 当quorum定时器超时时,此时需要将expect_vote修改为quorum,quorum值修改为(expect_vote/2)+ 1;
  4. 当leader节点挂掉时,根据quorum机制选举新的leader,选举leader时需要的quorum为(expect_vote/2)+ 1;;
  5. 当有节点新加入时,计算在线节点数,则更新expect_vote为当前节点数;此时需要将expect_vote修改为quorum,quorum值修改为(expect_vote/2)+ 1;
  6. 当集群在线节点数为2时,若再有集群挂掉,则集群将不提供服务;

corosync当前版本已支持该方式。

修改集群节点

修改集群节点的算法与修改quorum流程相似,与其不同的是修改集群节点通过移除或者添加节点的方式来触发expect_vote和quorum值改变,而不是在定时器超时后直接修改quorum。

corosync和raft相关开源实现均未支持该方式。但raft的开源实现jraft提供了从集群中动态添加/移除节点的接口,可基于此进行二次开发。

总结起来,当前有两种实现方式:

  1. 基于corosync直接修改quorum实现,不需要修改开源代码;
  2. 基于jraft动态添加删除节点实现,需修改开源代码;

方案对比

jraft

  • jraft基于faft协议实现,其底层通信采用rpc机制,节点之间采用多播通信,且节点之间多播通信不会阻塞
  • jraft仅仅实现了协议框架,要将其运用在项目中需要项目集成,其使用java语言编写,与java生态兼容性好。
  • jraft参考自百度使用c++编写的braft,braft功能与jraft基本一致,对C++兼容性好,但c语言不兼容
  • 其底层rpc框架使用sofa-bolt,当其仅有java、js、c++版本,对C语言兼容性不好。
  • jraft开源实现仅提供动态添加/删除节点的接口,要实现动态修改quorum值需要修改开源代码,添加多数节点挂掉后修改节点或quorum的机制
  • jraft提供了开发框架,需将框架集成到数据库系统中,定制化程度高,但未提供可直接搭配数据库的解决方案

corosync

  • corosync基于totem协议实现,其底层通信采用基于udp的令牌环机制实现,在节点间多播通信时需要等待token,节点之间多播通信会阻塞
  • corosync使用c语言编写,对c语言兼容性好
  • corosync当前版本通过LSM特性支持动态调整quorum,无需修改代码,通过配置即可实现
  • corosync是一个开发框架,可作为第三方库引入,定制化程度高
  • 开源社区围绕corosync已形成pacemaker+corosync+服务的解决方案,数据库可作为一种服务直接使用该解决方案而无需任何开发,仅需修改相关配置文件即可

文章作者: growdu
版权声明: 本博客所有文章除特別声明外,均采用 CC BY 4.0 许可协议。转载请注明来源 growdu !
  目录
分类导航
随笔2 AI27 算法1 计算机基础13 博客搭建7 ChatGPT2 集群63 计算机通信1 数据库34 数据库深入80 DPDK26 Docker11 Elasticsearch4 编辑工具4 FAQ1 Go Web1 hometown2 编程语言16 网络9 OPC1 Linux38 openGauss4 页面12 PostgreSQL54 程序员自我修养1 协议11 成长之路1 stock1 存储5 工具20 VPP18 视频作品1 Vue13 Web1 代码示例11 数据库15 BenchmarkSQL1 PostgreSQL 源码修炼之路14
最热文章
1
13 逻辑复制深入
数据库深入🔥 1570
2
0 Postgresql存储、索引及系统优化、主备切换
PostgreSQL🔥 1495
3
一文读懂openguass dcf网络模块
集群🔥 1420
4
逻辑复制源码分析
数据库深入🔥 1327
5
PostgreSQL 分区表:从一行 `PARTITION BY` 到路由热路径的全链路拆解
数据库🔥 1094
6
applyparallelworker.c 之 LA 端源码深度解析:Leader Apply Worker 的指挥中枢
数据库深入🔥 1082
7
PostgreSQL Background Worker 全解:从 `RegisterBackgroundWorker` 到逻辑复制 4 类 worker 的全生命周期
数据库🔥 1078
8
PostgreSQL的后台进程walsender分析 - 关系型数据库 - 亿速云
PostgreSQL🔥 1033
9
PostgreSQL 逻辑复制的监控:六张视图 + 一组可执行 SQL,把 publisher/subscriber 的速率与健康度彻底看透
数据库🔥 1032
10
PostgreSQL 逻辑复制支持 DDL 之后:DDL 与 DML 的时序难题(重点:分区表)
数据库🔥 999
11
reorderbuffer.c 源码深度解析:PostgreSQL 逻辑复制的"事务重组引擎
数据库深入🔥 953
12
PostgreSQL 内核开发:读取一张表的 9 步标准流程与缓存全景
数据库🔥 938
13
从 `postgres` 二进制到生产级守护 —— PostgreSQL 最外层模块与启动全流程拆解
数据库🔥 936
14
支持逻辑复制同步 DDL 适配 SQL Server 方案
数据库深入🔥 934
15
PostgreSQL 逻辑复制的 ReorderBuffer 与事务机制:从一行 WAL 到一致性变更流的全链路绑定
数据库🔥 913
16
DDL同步架构(美化版)
数据库深入🔥 908
17
PostgreSQL Latch 机制详解:从一行 SetLatch 到 epoll 的内核之旅
数据库🔥 871
18
pgbench 源码全解:一个 C 文件如何撑起 PostgreSQL 官方压测工具
数据库🔥 860
19
PostgreSQL libpq 机制与缓冲区详解
数据库🔥 850
20
PostgreSQL 逻辑复制 spill 文件深度剖析:从 `xid-*.spill` 到 TPC-C 的增长方程
数据库🔥 845