.................................................................................. 31 11.1 客户端如何寻址 .................................................................................................. Consumer 的要求做过滤，优点是减少了对亍 Consumer 无用消息的网络传输。 缺点是增加了 Broker 的负担，实现相对复杂。 (1). 淘宝 Notify 支持多种过滤方式，包含直接挄照消息类型过滤，灵活的诧法表达式过滤，几乎可以满足 最苛刻的过滤需求。 (2). 淘宝 RocketMQ 支持挄照简单的 Message Tag 过滤，也支持挄照 Message Header、body 迕行扩展的能力，(4)只是一个内存的镜像，作用是当 Broker 挂掉重启后仍然能将乀前内存的数据恢复出来。 JMS 不 CORBA Notification 规范没有明确说明如何持丽化，但是持丽化部分的性能直接决定了整个消息中间件 的性能。 RocketMQ 参考了 Kafka 的持丽化方式，充分利用 Linux 文件系统内存 cache 来提高性能。 4.6 Message Reliablity

一位名不经传的新人，按照出版行业的惯例，需要找一些该领域内专家大牛帮忙做序或写写 推荐语。当时我也是初生牛犊不怕虎，蹦出了一个非常大胆的想法，是不是可以联系到 RocketMQ 官方的一些大佬，最终我直接锁定了 RocketMQ 创始人冯嘉大神，希望他 能帮我作序推荐，令人惊喜的是冯嘉大神非常平易见人，得知我的来意后，他说了这样一句 话：“我是非常愿意为写书的朋友作序，但需要评估一下书稿的质量，如果质量 核心概念扫盲篇 < 14 该分配算法的特点就是轮流一个一个分配。 温馨提示：如果 topic 的队列个数小于消费者的个数，那有些消费者无法分配到消息。 在 RocketMQ 中一个 topic 的队列数直接决定了最大消费者的个数，但 topic 队列个数的 增加对 RocketMQ 的性能不会产生影响。 在实际过程中，对主题进行扩容(增加队列个数)或者对消费者进行扩容、缩容是一件非 常寻常的事情 那这就奇了怪了， 咋消息积压在快速减少，但为啥消费 TPS 还是为 0 呢？ 接下来将该问题进行探讨。 温馨提示：在问题分析部分，作者没有直接给出答案，而是一步一步探寻答案，因此会 通过追踪源码来寻求答案，如果大家想急于答案，可以跳过问题分析，直接查看本文末尾的 问题解答部分。 通过本文的阅读，您将获得如下信息： 1. RocketMQ 消费 TPS 的收集与计算逻辑。 2. RocketMQ

consumeMessageBatchMaxSize = 1， 默认批量个数为一个 ConsumeRequest 任务 run 方法执行 判断 proccessQueue 是否被 droped 的， 废弃直接返回，不在消费消息 构建并行消费上下文 给消息设置消费失败时候的 retry topic，当消息发送失败的时候发送到 topic 为%RETRY%groupname 的队列中 但其实这里消 费端是消费了消息的，这种情况感觉有被重复消费的风险 处理消费结果 消费成功， 对于批次消费消息，返回消费成功并不代表所有消息都消费成功， 但是消费消息的时候一旦遇到消费消息失败直接放回，根据 ackIndex 来标记 成功消费到哪里了 消费失败， ackIndex 设置为-1 广播模式发送失败的消息丢弃， 广播模式对于失败重试代价过高，对整个集 群性能会有较大影响，失败重试功能交由应用处理 ProcessQueue 和 Messagequeue 组成。 ConsumeRequest 任务的 run 方法 判断 proccessQueue 是否被 droped 的， 废弃直接返回，不在消费消息 每个 messagequeue 都会生成一个队列锁来保证在当前 consumer 内，同一个队列串行 消费， 判断 processQueue 的 lock 属性是否为

当前部署方案在每个 Nameserver 的 instance 上都安装了 Web Console 的应用，但是因 为 Nameserver 的 instance 是运⾏在 private subnet，所以无法直接 通过浏览器访问 Nameserver 私有 IP 的 8080 端⼝访问，请按照下面的步骤建立和 Bastion Host 的 SSH Tunnel 并通过 SSH Tunnel 来访问 Nameserver

当前部署方案在每个 Nameserver 的 instance 上都安装了 Web Console 的应用， 但是因为 Nameserver 的 instance 是运行在 private subnet，所以无法直接 通过浏 览器访问 Nameserver 私有 IP 的 8080 端口访问，请按照下面的步骤建立和 Bastion Host 的 SSH Tunnel 并通过 SSH Tunnel 来访问 Nameserver