7篇文章 · 3817字 · 2人关注
流程就不写了,写点自己的总结,希望对各位有用,从解决问题的角度去观察RocketMq的设计思路,本人水平有限,说错的地方请及时指出。 问题一 R...
提供的方式 方式1 tag过滤消息,优点过滤简单 高效 不适合复杂过滤 方式2 filterService 过滤,定制化过滤,...
先抛出几个问题带着问题去学习 1 HA的整体流程 2 对应的api的关键点 代码1 master启动监听端口,等待slave连接 从b...
场景: 通过mq 进行分布式事务的一致性控制,参考转账事务原理 目的: 保持本地事务和mq发送的原子性 过程: 步骤1: 发送prepar...
DefaultMQProduce 主要作用 1发送消息,异步,同步,和OneWay发送。 消息发送消息流程图 2 同步消息,异步消息,和...
1 broken ,主题topic 路由信息的管理。 2 nameservice 为了提高性能,nameservice之间不通信,原因失...
1 存储篇 1.1 整体结构 存储层的结构如下图所示,业务层均通过DefaultMessageStore类提供的方法作为统一入口访问底层文件。R...
文集作者