Broker基于raft协议的主从架构
2022-03-29 09:48:27 0 举报RocketMq源码
作者其他创作
大纲/内容
异步复制日志
后台线程
重置计时器
状态follower
DLedgerraft实现框架
阻塞等待结果
是否收到Leader心跳包
切换leader状态
否
执行行为
状态
状态机
写入
状态Leader
写入消息
发投票请求给其它节点
给自己投票
是
写入日志
初始化
超过半数心跳响应
Page Cache
是否收到leader心跳包
CommitLog
DLedger
Page cache
Broker数据主节点leader
结果
定时发心跳给其它节点
Producer
Broker数据从节点follower
异步刷盘
leader选举
业务系统
随机到计时切换候选者状态
过半写入成功
返回投票请求
启动定时任务同步元数据
超过半数投票
随机倒计时切换leader候选者
ConsumerQueue
offset
倒计时完毕切换
0 条评论
下一页
