当机或者添加，会导致分配到 mqSet 变 化， a) 将不在被本 consumer 消费的 messagequeue 的 ProcessQueue 删除， 其实是设 置 ProcessQueue 的 droped 属性为 true b) 将超过两份中没有拉取动作 ProcessQueue 删除 //TODO 为什么要删除掉，两分钟后来了消息怎么办? // 2) 添加新增队列， 比对 mqSet，给新增的 集合中，消费调后会删除掉，用来控制 consumer 消息堆积， TreeMap key 是消息在此 ConsumeQueue 队列中索引 (2) 对于顺序消息消费 处理 locked 属性:当 consumer 端向 broker 申请锁队列成功后设置 true， 只有被锁定 的 processqueue 才能被执行消费 rollback: 将消费在 msgTreeMapTemp 中的消息，放回 queue 被某个 client 锁定。 Broker 会返回成功锁定队列的集合， 根据成功锁定的 MessageQueue,设置对应的正 在处理队列 ProccessQueue 的 locked 属性为 true 没有锁定设置为 false 通过长轮询拉取到消息后会提交到消息服务 ConsumeMessageOrderlyService， ConsumeMessageOrderlyService

消息过滤是指消费端可以根据某些条件对一个 topic 中的消息进行过滤，即只消费一个 主题下满足过滤条件的消息。 RocketMQ 目前主要的过滤机制是基于 tag 的过滤与基于消息属性的过滤，基于消息 属性的过滤支持 SQL92 表达式，对消息进行过滤。 六、小结 本文的主要目的是介绍 RocketMQ 常见的术语，例如 nameserver、broker、主题、 消费组、消费者、队 conf 文件拷贝到【 Step2】中设置的主目录下,执行后的效果如下图所示： Step6：修改 broker.conf 中的配置，主要设置 nameserver 的地址，broker 的名称 等相关属性。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 37 > 1.3 实战：RocketMQ 学习环境搭建指南篇 vi broker.conf # 使用如下配置文件 brokerClusterName 的条件为：当前 所有可用消息数据(所有 commitlog)文件的大小已经超过了其阔值，默认为物理内存的 40%。 那 GetResult 的 suggestPullingFromSlave 属性在哪里使用呢？ 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.4 RocketMQ HA 核心工作机制 < 42 PullMessageProcessor#processRequest

CREATE_COMPLETE，此时堆栈创建成功。Apache RocketMQ 集群以及其他需要的组 件均已创建完毕。下图列出了默认设置部署完成后在 EC2 Console 的一个 截图，可以从 Name 属性判断这个 Instance 安装的是哪种类型的节点。 Page 13 of 18 使⽤ Apache RocketMQ Apache RocketMQ 在

CREATE_COMPLETE，此时堆栈创建成功。Apache RocketMQ 集群以及 其他需要的组件均已创建完毕。下图列出了默认设置部署完成后在 EC2 Console 的一 个 截图，可以从 Name 属性判断这个 Instance 安装的是哪种类型的节点。 使用 Apache RocketMQ Apache RocketMQ 在 EC2 上部署所在目录说明： Nameserver