Consumer(消费消费者)．客户端在同一 时间只会连接一台 nameserver，只有在连接出现异常时才会向尝试连接另外一台。客户 端每隔 30s 向 Nameserver 发起 topic 的路由信息查询。 温馨提示：Nameserver 是在内存中存储 Topic 的路由信息，持久化 Topic 路由信息 的地方是在 Broker 中，即${ ROCKETMQ_HOME}/store/config/topics 进行扩容、缩容是一件非 常寻常的事情，那如果新增一个消费者，该消费者消费哪些队列呢？这就涉及到消息消费队 列的重新分配，即消费队列重平衡机制。 在 RocketMQ 客户端中会每隔 20s 去查询当前 topic 的所有队列、消费者的个数，运 用队列负载算法进行重新分配，然后与上一次的分配结果进行对比，如果发生了变化，则进 行队列重新分配；如果没有发生变化，则忽略。 例如采取的分配算法如下图所示，现在增加一个消费者 法获取一个不存在的主题的 路由信息，那该如何处理这种情况呢？ 在 RocketMQ 中，如果 autoCreateTopicEnable 设置为 true，消息发送者向 NameServer 查询主题的路由消息返回空时，会尝试用一个系统默认的主题名称( MixAll.AUTO_CREATE_TOPIC_KEY_TOPIC)，此时消息发送者得到的路由信息为： 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。

7.3 消息查询 ......................................................................................................................................................... 20 7.3.1 挄照 Message Id 查询消息 ..... ....................................................................... 20 7.3.2 挄照 Message Key 查询消息 ................................................................................................ 消息，Producer Group 作用如下： 项目开源主页：https://github.com/alibaba/RocketMQ 13 1. 标识一类 Producer 2. 可以通过运维工具查询返个収送消息应用下有多个 Producer 实例 3. 収送分布式事务消息时，如果 Producer 中途意外宕机，Broker 会主劢回调 Producer Group 内的任意 一台机器来确讣事务状态。

终 止遍历 调 transactionCheckExecuter.gotocheck 方法向 producer 回查事物状态， 根据 group 随机选择一台 producer 查询消息，根据 commitLogOffset 和 msgSize 到 commitlog 查找消息 向 Producder 发起请求,请求 code 类型为 CHECK_TRANSACTION_STATE，producer commitLog 根据 storeCheckPoint 会重 建之后的索引文件， 3. Run 方法，任务从阻塞队列中获取请求构建索引 4. queryOffset 根据 topic key 时间跨度来查询消息 倒叙遍历所有索引文件 每一个 indexfile 存储了第一个消息和最后一个消息的存储时间，根据传入时间范围来判 断索引是否落在此索引文件 6.3：构建索引服务 分 发 消 息

RocketMQ支持严格的意义上的消息顺序。即时在一台Broker宕机后，消息发送会失败，但是不会 序。 ● RocketMQ支持定时消息 ● RocketMQ支持分布式事务消息 ● RocketMQ支持根据消息标识或内容查询。 ● RocketMQ支持按照时间来回溯消息，精度毫秒，例如从一天之前的某时某分某秒开始重新消费消 原文链接：Apache RocketMQ 介绍 。 其他消息中间件 RabbitMQ是