RocketMQ 第2页

2020-08-12站长阅读(675)赞(0)

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

2020-08-12站长阅读(1532)赞(3)

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

2020-08-12站长阅读(724)赞(0)

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

2020-08-12站长阅读(455)赞(0)

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

2020-08-12站长阅读(521)赞(0)

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

2020-08-12站长阅读(523)赞(0)

根据上节Demo示例，发送事务消息的入口为：TransactionMQProducer\#sendMessageInTransaction： public TransactionSendResult sendMessageInTransac...

2020-08-12站长阅读(533)赞(0)

 RocketMQ4.3.0版本开始支持事务消息，本节开始将剖析事务消息的实现原理，首先将从官方给出的 Demo 实例入手，以此通往 RocketMQ 事务消息的世界中。 官方版本未发布之前，从 apache rocketmq 第一个版本上...

2020-08-12站长阅读(615)赞(0)

RocketMQ在消息拉取时是如何根据消息消费队列 MessageQueue 来选择 Broker 的呢？消息消费队列如图所示： RocketMQ 根据 MessageQueue 查找 Broker 地址的唯一依据便是 brokerName...

2020-08-12站长阅读(512)赞(1)

HA主从同步的核心类图如图所示： 初始RocketMQ HA HAService：主从同步核心实现类。 * AtomicInteger connectionCount：Master维护的连接数。（Slave的个数）。 * List< ...

2020-08-12站长阅读(672)赞(0)

由于 RocketMQ 操作 CommitLog、ConsumeQueue 文件，都是基于内存映射方法并在启动的时候，会加载 commitlog、ConsumeQueue 目录下的所有文件，为了避免内存与磁盘的浪费，不可能将消息永久存储在消...