prince的文章

本文沿着《RocketMQ消息轨迹-设计篇》的思路，从如下3个方面对其源码进行解读： 1、 发送消息轨迹； 2、 消息轨迹格式； 3、 存储消息轨迹数据； 本节目录 1、发送消息轨迹流程 1.1 DefaultMQProducer构造函数 ...

赞(0)princeRocketMQ 源码分析 阅读(418)

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

赞(0)princeRocketMQ 源码分析 阅读(358)

有关RocketMQ ACL的使用请查看上一篇《RocketMQ ACL使用指南》，本文从源码的角度，分析一下RocketMQ ACL的实现原理。 备注：RocketMQ在4.4.0时引入了ACL机制，本文代码基于RocketMQ4.5.0...

赞(0)princeRocketMQ 源码分析 阅读(410)

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

赞(0)princeRocketMQ 源码分析 阅读(352)

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

赞(0)princeRocketMQ 源码分析 阅读(373)

本节目录 1、现象 2、 原理解读； 2.1 RocketMQ 网络处理机制概述 2.2 pair.getObject1().rejectRequest() 2.2.1 isOSPageCacheBusy() 2.2.2 isTransie...

赞(0)princeRocketMQ 源码分析 阅读(374)

本节目录 1、 现象； 2、 思考； 3、 原理； 3.1 RocketMQ基本路由规则 3.2 探究autoCreateTopicEnable机制 3.2.1 默认Topic路由创建时机 3.2.2 现象分析 1、现象 很多网友会问，为什...

赞(0)princeRocketMQ 源码分析 阅读(387)

  我们以一个订单流转流程来举例，例如订单子系统创建订单，需要将订单数据下发到其他子系统（与第三方系统对接）这个场景，我们通常会将两个系统进行解耦，不直接使用服务调用的方式进行交互。其业务实现步骤通常为：   1、A系统创建订单并入库。  ...

赞(0)princeRocketMQ 源码分析 阅读(391)

  本文将重点分析RocketMQ Broker如何处理事务消息提交、回滚命令，其核心实现就是根据commitlogOffset找到消息，如果是提交动作，就恢复原消息的主题与队列，再次存入commitlog文件进而转到消息消费队列，供消费者...

赞(0)princeRocketMQ 源码分析 阅读(399)

上节已经梳理了RocketMQ发送事务消息的流程（基于二阶段提交），本节将继续深入学习事务状态消息回查，我们知道，第一次提交到消息服务器，消息的主题被替换为RMQ_SYS_TRANS_HALF_TOPIC，当执行本地事务，如果返回本地事务状...

赞(0)princeRocketMQ 源码分析 阅读(371)