欢迎您的访问
专注架构,Java,数据结构算法,Python技术分享

RocketMQ

三十六:RocketMQ 主题扩分片后遇到的坑

站长阅读(728)赞(1)

消息组接到某项目组反馈,topic 在扩容后出现部分队列无法被消费者,导致消息积压,影响线上业务? 考虑到该问题是发送在真实的线上环境,为了避免泄密,本文先在笔者的虚拟机中来重现问题。 本节目录 1、案情回顾 1.1 集群现状 1.2、Ro...

三十三:RocketMQ 多副本前置篇:初探raft协议

站长阅读(823)赞(1)

Raft协议是分布式领域解决一致性的又一著名协议,主要包含Leader选举、日志复制两个部分。 温馨提示: 本文根据raft官方给出的raft动画进行学习,其动画展示地址:http://thesecretlivesofdata.com/ra...

三十一:RocketMQ源码分析消息轨迹

站长阅读(642)赞(0)

1、 发送消息轨迹 2、 消息轨迹格式 3、 存储消息轨迹数据 本节目录 1、发送消息轨迹流程 1.1 DefaultMQProducer构造函数 1.2 SendMessageTraceHookImpl钩子函数 1.2.1 SendMes...

三十:RocketMQ消息轨迹-设计篇

站长阅读(658)赞(0)

本节目录 1、消息轨迹数据格式2、记录消息轨迹 3、如何存储消息轨迹数据 RocketMQ 消息轨迹主要包含两篇文章:设计篇与源码分析篇,本节将详细介绍 RocketMQ 消息轨迹-设计相关。 RocketMQ 消息轨迹,主要跟踪消息发送、...

二十八:RocketMQ ACL使用指南

站长阅读(901)赞(0)

本节目录 1、什么是ACL?2、ACL基本流程图 3、如何配置ACL 3.1 acl配置文件 3.1.1 globalWhiteRemoteAddresses3.1.2 accounts 3.1.2.1 accessKey 3.1.2.2 ...

二十七:RocketMQ HA机制(主从同步)

站长阅读(569)赞(0)

温馨提示:建议参考代码RocketMQ4.4版本,4.5版本引入了多副本机制,实现了主从自动切换,本文并不关心主从切换功能。 本节目录 1、初识主从同步2、提出问题 3、原理探究 3.1 RocketMQ主从读写分离机制 3.2 消息消费进...