本站是 好好学java 的技术分享博客,涵盖Java后端技术、SpringBoot、微服务架构、分布式、Java面试等知 ...
正在加载今日诗词...
RocketMQ生产环境主题扩分片后遇到的坑 RocketMQ生产环境主题扩分片后遇到的坑
消息组接到某项目组反馈,topic 在扩容后出现部分队列无法被消费者,导致消息积压,影响线上业务? 考虑到该问题是发送在真实的线上环境,为了避免泄密,本文先在的虚拟机中来重现问题。 1、案情回顾1.1 集群现状集群信息如下: 例如业务主体名
源码分析 RocketMQ DLedger 多副本存储实现 源码分析 RocketMQ DLedger 多副本存储实现
RocketMQ DLedger 的存储实现思路与 RocketMQ 的存储实现思路相似,本文就不再从源码角度详细剖析其实现,只是点出其实现关键点。我们不妨简单回顾一下 CommitLog 文件、ConsumeQueue 文件设计思想。 其
源码分析RocketMQ多副本之Leader选主 源码分析RocketMQ多副本之Leader选主
温馨提示:《RocketMQ技术内幕》作者倾力打造的全新专栏 RocketMQ 多副本(主从切换): 1、 本文将按照 《》 的思路来学习RocketMQ选主逻辑。首先先回顾一下关于Leader 的一些思考: 节点状态 需要引入3
源码分析RocketMQ消息轨迹 源码分析RocketMQ消息轨迹
本文沿着的思路,从如下3个方面对其源码进行解读: 发送消息轨迹 消息轨迹格式 存储消息轨迹数据 消息轨迹格式 发送消息轨迹流程首先我们来看一下在消息发送端如何启用消息轨迹,示例代码如下: 1public class Tra
RocketMQ 多副本前置篇——初探raft协议 RocketMQ 多副本前置篇——初探raft协议
Raft协议是分布式领域解决一致性的又一著名协议,主要包含Leader选举、日志复制两个部分。 温馨提示:本文根据raft官方给出的raft动画进行学习,其动画展示地址:http://thesecretlivesofdata.com/r
RocketMQ实战——一个新的消费组初次启动时从何处开始消费呢? RocketMQ实战——一个新的消费组初次启动时从何处开始消费呢?
本文首先重现网友提出的问题,然后对其进行原理分析,然后验证猜想,并给出实战建议。 抛出问题一个新的消费组订阅一个已存在的Topic主题时,消费组是从该Topic的哪条消息开始消费呢? 首先翻阅DefaultMQPushConsumer的AP
RocketMQ消息轨迹-设计篇 RocketMQ消息轨迹-设计篇
RocketMQ消息轨迹主要包含两篇文章:设计篇与源码分析篇,本节将详细介绍RocketMQ消息轨迹-设计相关。 RocketMQ消息轨迹,主要跟踪消息发送、消息消费的轨迹,即详细记录消息各个处理环节的日志,从设计上至少需要解决如下三个核心
源码分析RocketMQ ACL实现机制 源码分析RocketMQ ACL实现机制
有关RocketMQ ACL的使用请查看上一篇,本文从源码的角度,分析一下RocketMQ ACL的实现原理。 备注:RocketMQ在4.4.0时引入了ACL机制,本文代码基于RocketMQ4.5.0版本。 根据RocketMQ A
RocketMQ ACL使用指南 RocketMQ ACL使用指南
什么是ACL?RocketMQ在4.4.0版本开始支持ACL。ACL是access control list的简称,俗称访问控制列表。访问控制,基本上会涉及到用户、资源、权限、角色等概念,那在RocketMQ中上述会对应哪些对象呢? 用户
RocketMQ HA机制(主从同步) RocketMQ HA机制(主从同步)
温馨提示:建议参考代码RocketMQ4.4版本,4.5版本引入了多副本机制,实现了主从自动切换,本文并不关心主从切换功能。 初识主从同步主从同步基本实现过程如下图所示: RocketMQ 的主从同步机制如下:A. 首先启动Master
3 / 4