RocketMQ有用Dledge架构的吗?

RocketMQ有用Dledge架构的吗?

展开
收起
嘟嘟嘟嘟嘟嘟 2023-10-07 07:41:17 117 分享 版权
1 条回答
写回答
取消 提交回答
  • 有的,参考:
    RocketMQ 中DLedger框架 基于Raft算法实现选主及日志同步
    https://blog.csdn.net/xiaqingxue930914/article/details/122343307

    与原有Maser/Slave 结构相比,多了 RoleChangeHandler, commitLog变为 DLedgerCommitLog

    DLedger 将 原有 commitLog 进行包装,产生一种新的数据格式的log。

    不影响原有的commitLog的功能作用。同时实现DLedger自身功能

    DLedgerCommitlog 结构: 给原有commitLog 加了一个 head。即commitLog内容作为DLedgerCommitlog 的body

    Raft算法:分布式一致性算法。

    主要功能体现在三个方面:1)选主; 2)日志复制; 3)安全性

    选主

    LeaderElector

    角色(Role):

    1) Leader 主节点:发送心跳,和日志;如果发现比leader更新的任期(term),则变为follower。

    2) Candidate 候选节点: 发送投票请求用于成为leader,如果发现比leader更新的任期(term),则变为follower

    3) Follower 跟随者: 响应 Leader 和 Candidate的请求。超过选举时间未收到Leader的心跳请求和candidate的选举请求,则成为candidate。Follower 不能发起投票,不能直接成为leader

    raft算法,三种状态间的流转过程:

    516e1085c31523b29414271e42784712_e1eb676572c07fd69f9d7faae18f3eed.png

    2023-10-12 09:44:07
    赞同 展开评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

还有其他疑问?
咨询AI助理