中，这样在 Broker 关闭后再重启， 并不会丢失路由信息。 广大读者朋友，跟踪到这一步的时候，大家应该对启用自动创建主题机制时，新主题是 的路由信息是如何创建的，为了方便理解，给出创建主题序列图： 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 25 > 1.2 生产环境中，autoCreateTopicEnable 为什么不能设置为 true 现象分析 经过上面 Step4：启动 nameserver nohup ./mqnamesrv & 查看${user_home}/logs/rocketmqlogs/namesrv.log 日志文件，如果输出结果如下 图所示即表示启动成功。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.3 实战：RocketMQ 学习环境搭建指南篇 < 30 Step5：修改 broker 的配置文件 n sumeFromWhere consumeFromWhere)API 映入眼帘，从字面意思来看是设置消费者 从哪里开始消费，正是解开该问题的”钥匙“。ConsumeFromWhere 枚举类图如下：  CONSUME_FROM_MAX_OFFSET 从消费队列最大的偏移量开始消费。  CONSUME_FROM_FIRST_OFFSET 从消费队列最小偏移量开始消费。  CO

messageQueueList [userId%messageQueueList.size()] 2.3 分布式事物消息 先引入官方文档图： 分布式事物是基于二阶段提交的 1) 一阶段，向 broker 发送一条 prepared 的消息，返回消息的 offset 即消息地址 commitLog 中消息偏移量。Prepared 消息动作 序列图 1. 向 broker 发送长轮询请求 2. Broker 接收长轮询请求 3. Consumer 接收 broker 响应 长轮询活动图： 一张图画不下，再来一张 四：push

集群，如果其中一个 Broker 实例因故障无法提供服务，Raft 协议会自动在另外两个 Instance 中选择一个作 为 Master 继续提供服务从而达到高可用的效果，下图是部署完的一个架构实例图 Page 4 of 18 • (*) 跨越多个可用区的公有⼦网和私有⼦网的 VPC（由西云数据运营的 AMAZON WEB SERVICES（宁 夏）区域为 Profile”，如下图所⽰ Page 15 of 18 5. 在弹出的窗⼝中输⼊ New Profile 的名字，并点击右下方的 Create 按钮，如下 图： 6. 输⼊ Proxy Server 的信息，如下图，完成后点击左下方的 Apply changes，注意 Port 对应的值需要设置为您建立 ssh tunnel 的本地端⼝，见第一步的-D

Master1 Broker Master2 Broker Slave1 Broker Slave2 Producer集群 Consumer集群 图表 5-2RocketMQ 网络部署图 RocketMQ 网络部署特点  Name Server 是一个几乎无状态节点，可集群部署，节点乀间无任何信息同步。  Broker 部署相对复杂，Broker 分为 Master MEMORY JAVA HEAP DISK Producer Consumer1 Consumer2 Consumer3 ⑤ ④ ⑦ ⑥ ⑧ ③ ② ① 图表 7-7 消息在系统中流转图 (1). Producer 収送消息，消息从 socket 迕入 java 堆。 (2). Producer 収送消息，消息从 java 堆转入 PAGACACHE，物理内存。 (3).

集群，如果其中一个 Broker 实例 因故障无法提供服务，Raft 协议会自动在另外两个 Instance 中选择一个作为 Master 继续提供服务从而达到高可用的效果，下图是部署完的一个架构实例图 Page 4 of 21 • (*) 跨越多个可⽤区的公有⼦⽹和私有⼦⽹的 VPC（由西云数据运营的 亚 马逊云科技（宁 夏）区域为 3 个，由光环新⽹运营的