............................................................................................ 3 部署说明................................................................................................... ................................................................ 13 APACHE ROCKETMQ 在 EC2 上部署所在目录说明： .......................................................................... 13 Nameserver： ..... 5 of 18 为由光环新网运营的 AMAZON WEB SERVICES（北京）区域，因其对外 提供 2 个可用区，本解决方案将重复使用其中一个可用区来创建第三个⼦网。 部署说明 1. 此方案仅针对使用由西云数据运营的 AMAZON WEB SERVICES（宁夏）区域或由 光环新网运营的 AMAZON WEB SERVICES（北京）区域。在开始之前，请先确保 您已经有了一个可以访问这两个区域的

............................................................................................ 3 部署说明 .................................................................................................. ................................................................ 15 APACHE ROCKETMQ 在 EC2 上部署所在目录说明： ..................................................................... 15 Nameserver ........... 区中。如果您选择的 AMAZON WEB SERVICES 区域为由光环新⽹运营的 亚马逊云科技（北京）区域，因其对 外 提供 2 个可⽤区，本解决方案将重复使⽤其中⼀个可⽤区来创建第三个 ⼦⽹。 部署说明 1. 此⽅案仅针对使⽤由西云数据运营的 亚马逊云科技（宁夏）区域或由光环新⽹ 运营的 亚马逊云科技（北京）区域。在开始之前，请先确保您已经有了⼀个可 以访问这两个区域的 AMAZON WEB

算法。  AllocateMessageQueueAveragely  平均分配  AllocateMessageQueueAveragelyByCircle  轮流平均分配 为了说明这两种分配算法的分配规则，现在对 16 个队列，进行编号，用 q0~q15 表示， 消费者用 c0～c2 表示。 AllocateMessageQueueAveragely 分配算法的队列负载机制如下： 服务器在处理消息时，首先会查看自 己的路由配置管理器(TopicConfigManager)中的路由信息，此时不存在对应的路由信息， 然后尝试查询是否存在默认 Topic 的路由信息，如果存在，说明启用了 autoCreateTopi cEnable，则在 TopicConfigManager 中创建新 Topic 的路由信息，此时存在与 Broker 服务端的内存中，然后本次消息发送结束。此时，在 的采集机制是 broker 端会每 10s 会记录一下消费组对应的拉取消息数量与拉取次数。 那既然消息延迟(堆积数量在不断减少)，说明消费端正在消费，按道理来说，通过上述 机制进行计算，TPS 不可能会是 0？那又是什么原因呢？如果 TPS 为 0，可以说明消费 端并没有向 broker 拉取消息，因为一旦从 broker 拉取消息，有关 StatsItem 的 拉取 消息总数(value)

队列 Buffer 迕行扩展的能力，(4)只是一个内存的镜像，作用是当 Broker 挂掉重启后仍然能将乀前内存的数据恢复出来。 JMS 不 CORBA Notification 规范没有明确说明如何持丽化，但是持丽化部分的性能直接决定了整个消息中间件 的性能。 RocketMQ 参考了 Kafka 的持丽化方式，充分利用 Linux 文件系统内存 cache 来提高性能。 4.6 namesrvAddr 返个参数可以返样配置，其他参数同理。 producer.setNamesrvAddr("192.168.0.1:9876"); 11.2.2 客户端的公共配置 参数名 默认值 说明 namesrvAddr Name Server 地址列表，多个 NameServer 地址用分号 隔开 clientIP 本机 IP 客户端本机 IP 地址，某些机器会发生无法识别客户端 persistConsumerOffsetInterval 5000 持久化 Consumer 消费进度间隔时间，单位毫秒 11.2.3 Producer 配置 参数名 默认值 说明 producerGroup DEFAULT_PRODUCER Producer 组名，多个 Producer 如果属于一 个应用，发送同样的消息，则应该将它们 归为同一组 createTopicKey

判断最终一致的点所在的文件是哪个 从最新的 mapedFile 开始，获取存储的一条消息在 broker 的生成时间，大 于 checkpoint 时间点的放弃找前一个文件，小于等于 checkpoint 时间点的 说明 checkpoint 在此 mapedfile 文件中 从 checkpoint 所在 mapedFile 开始恢复数据，它的整体过程跟正常恢复 commitlog 类似，最重要的区别在于 应过来，就用不到缓存中的 ResponseFuturel） responseFuture.waitResponse(timeoutMillis)获取响应 发送成功，没有响应对象说明超时 2. invokeAsyncImpl 异步调用实现 异步一般链路耗时比较长， 为了防止本地缓存的 netty 请求过多， 使用信号量控制上 限默认 2048 个