Consumer(消费消费者)．客户端在同一 时间只会连接一台 nameserver，只有在连接出现异常时才会向尝试连接另外一台。客户 端每隔 30s 向 Nameserver 发起 topic 的路由信息查询。 温馨提示：Nameserver 是在内存中存储 Topic 的路由信息，持久化 Topic 路由信息 的地方是在 Broker 中，即${ ROCKETMQ_HOME}/store/config/topics 进行扩容、缩容是一件非 常寻常的事情，那如果新增一个消费者，该消费者消费哪些队列呢？这就涉及到消息消费队 列的重新分配，即消费队列重平衡机制。 在 RocketMQ 客户端中会每隔 20s 去查询当前 topic 的所有队列、消费者的个数，运 用队列负载算法进行重新分配，然后与上一次的分配结果进行对比，如果发生了变化，则进 行队列重新分配；如果没有发生变化，则忽略。 例如采取的分配算法如下图所示，现在增加一个消费者 消息过滤是指消费端可以根据某些条件对一个 topic 中的消息进行过滤，即只消费一个 主题下满足过滤条件的消息。 RocketMQ 目前主要的过滤机制是基于 tag 的过滤与基于消息属性的过滤，基于消息 属性的过滤支持 SQL92 表达式，对消息进行过滤。 六、小结 本文的主要目的是介绍 RocketMQ 常见的术语，例如 nameserver、broker、主题、 消费组、消费者、队列负载算法、队列重平衡机制、并发消费、顺序消费、消费进度存储、

RocketMQ支持严格的意义上的消息顺序。即时在一台Broker宕机后，消息发送会失败，但是不会 序。 ● RocketMQ支持定时消息 ● RocketMQ支持分布式事务消息 ● RocketMQ支持根据消息标识或内容查询。 ● RocketMQ支持按照时间来回溯消息，精度毫秒，例如从一天之前的某时某分某秒开始重新消费消 原文链接：Apache RocketMQ 介绍 。 其他消息中间件 RabbitMQ是 w th sync mode to avoid message loss Supported Supported, property filter expressi ns based on SQL92 Supported High performance and low latency file storage upported timestamp and offset two indicates

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：构建索引服务 分 发 消 息

/ Phone : +358 469 335 071 Github: ​https://github.com/hiejulia Related skills : Java, Golang, SQL, NoSQL, Rest, gPRC, Microservices, Test, DevOps, Distributed system, Cloud(AWS, Azure) , Golang, Maven Batch example : send messages in batches, split into lists - Filter example: RocketMQ offer some SQL expression to filter out message - Logappender example: - Open Message example: OMS Producer &

IaaS 基础设施支持，降低成本 轻量级SDK： • 全面支持云原生通信标准 gRPC 协议 • 无状态 Pop 消费模式，多语言友好，易集成 从业务走向数据： • 事件流场景支撑 • 面向 SQL 的轻量级实时计算引擎 可分可合的存储计算分离： • Broker 升级为真正的无状态服务节点，无 binding • Broker和Store节点分离部署、独立扩缩 • 可分可合，适应多种业务场景，降低运维负担

Message File Service Aliware MQ Apache RocketMQ Replication DB Connector Third party partner SQL/RPC Filter DC Router Multi- tenancy Exactly Only once 24/7 Support LOG Connector IoT Connector

Message File Service Aliware MQ Apache RocketMQ Replication DB Connector Third party partner SQL/RPC Filter DC Router Multi- tenancy Exactly Only once 24/7 Support LOG Connector IoT Connector