handleHeartBeat主节点的term大于从节点代码如何体现?

handleHeartBeat主节点的term大于从节点代码如何体现?

展开
收起
vncamyi27xznk 2021-11-22 09:20:52 432 分享 版权
1 条回答
写回答
取消 提交回答
  • image.png

    加锁来处理(这里更多的是从节点第一次收到主节点的心跳包) 代码@1:如果主节的投票轮次小于当前投票轮次,则返回主节点投票轮次过期。 代码@2:如果投票轮次相同。 如果当前节点的主节点字段为空,则使用主节点的 ID,并返回成功。 如果当前节点的主节点就是发送心跳包的节点,则更新上一次收到心跳包的时间戳,并返回成功。 如果从节点的主节点与发送心跳包的节点 ID 不同,说明有另外一个 Leaer,按道理来说是不会发送的,如果发生,则返回已存在主节点,标记该心跳包处理结束。 代码@3:如果主节点的投票轮次大于从节点的投票轮次,则认为从节点并为准备好,则从节点进入 Candidate 状态,并立即发起一次投票。 答复内容摘自《Apache RocketMQ 源码解析》,这本电子书收录开发者藏经阁 下载连接:https://developer.aliyun.com/topic/download?id=1140

    2021-11-24 09:11:04
    赞同 展开评论
问答地址:

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

收录在圈子:
+ 订阅
阿里云 云原生应用平台 肩负阿里巴巴集团基础设施云化以及核心技术互联网化的重要职责,致力于打造稳定、标准、先进的云原生产品,成为云原生时代的引领者,推动行业全面想云原生的技术升级,成为阿里云新增长引擎。商业化产品包括容器、云原生中间件、函数计算等。
还有其他疑问?
咨询AI助理