................................................................................. 5 一：Producer 启动流程 .................................................................................................. ................................................................................ 14 一：consumer 启动流程 .................................................................................................. .................................................................................. 46 二：Namesrv 启动流程： .................................................................................................

出代码的关键入口点，如 想详细了解 NameServer 路由消息、消息发送高可用的实现原理，建议查阅笔者的书籍《 RocketMQ 技术内幕》第二、三章。 Step1：在 Broker 启动流程中，会构建 TopicConfigManager 对象，其构造方法中 首先会判断是否开启了允许自动创建主题，如果启用了自动创建主题，则向 topicConfigT able 中添加默认主题的路由信息。 名称，消息发送 topic 名称，使用的队列 数量为 DefaultMQProducer#defaultTopicQueueNums，即默认为 4。 Step4：Broker 端收到消息后的处理流程 服务端收到消息发送的处理器为：SendMessageProcessor，在处理消息发送时， 会调用 super.msgCheck 方法： AbstractSendMessageProcessor#msgCheck 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 25 > 1.2 生产环境中，autoCreateTopicEnable 为什么不能设置为 true 现象分析 经过上面自动创建路由机制的创建流程，我们可以比较容易的分析得出如下结论： 因为开启了自动创建路由信息，消息发送者根据 Topic 去 NameServer 无法得到路由 信息，但接下来根据默认 Topic 从 NameServer

DISK Producer Flush Synchronously 同步刷盘不异步刷盘的唯一区别是异步刷盘写完 PAGECACHE 直接迒回，而同步刷盘需要等待刷盘完成才迒回， 同步刷盘流程如下： (1). 写入 PAGECACHE 后，线程等待，通知刷盘线程刷盘。 (2). 刷盘线程刷盘后，唤醒前端等待线程，可能是一批线程。 (3). 前端等待线程吐用户迒回成功。 项 式。 b) 提高单个 Consumer 的消费幵行线程，通过修改以下参数 consumeThreadMin consumeThreadMax 14.3.2 批量方式消费 某些业务流程如果支持批量方式消费，则可以很大程度上提高消费吞吏量，例如订单扣款类应用，一次处理一 个订单耗时 1 秒钟，一次处理 10 个订单可能也只耗时 2 秒钟，返样即可大幅度提高消费的吞吏量，通过设置 consumer

Apache软件基金会，连同350多个开源项目的全体志愿者、开发人员、管理人员 和孵化项目组织，宣布Apache®RocketMQ™从Apache孵化器毕业成为顶级项目，这表明该项目的 区和产品已根据ASF的精英流程和原则得到了很好的管理。 现今，Apache RocketMQ在社区各方面的努力下，茁壮发展，很多功能都得到了加强。 RocketMQ的技术概览 在我们看来，它最大的创新点在于能够通过精巧的横