最近更新时间: 2021-03-15 17:25:29

如遇消息消费有问题，则可通过查询具体发送的消息内容来排查问题。消息队列 RocketMQ 提供了三种消息查询的方式，分别是按 Message ID、Message Key 以及 Topic 查询。

查询方式说明

由于消息在消息队列 RocketMQ 中存储的时间为 3 天，即只能查询从当前查询时间算起 3 天内的消息。例如，当前时间是 2019 年 6 月 10 日 15：09：48，那么能查询到的某 Topic 下的消息最早的时间点为 2019 年 6 月 7 日 15：09：48。 三种查询方式的特点和对比如下表所述。

推荐查询过程

推荐按照以下流程查询消息。

操作步骤

登录消息队列 RocketMQ 控制台。在左侧导航栏，单击消息查询。 在消息查询页面，您可单击以下任一页签，然后按页面提示输入相应信息，再单击搜索按钮来查询消息。

• 按 Message ID 查询 按 Message ID 查询消息属于精确查询，您输入 Topic 和 Message ID 即可精确查询到任意一条消息。因此，为了尽可能精确地查询，建议在发送消息成功后将 Message ID 信息打印到日志中，方便问题排查。 以 Java SDK 为例，获取 Message ID 的方法如下：

   SendResult sendResult = producer.send(msg);
   String msgId = sendResult.getMessageId();

其他语言可参见 Group 管理页面的示例代码获取。

• 按 Message Key 查询 消息队列 RocketMQ 根据您设置的 Message Key 建立消息的索引信息，当您输入 Key 进行查询时，消息队列 RocketMQ 根据该索引即可匹配相关的消息返回。 注意： 若按 Message Key 查询消息，请注意以下几点：
• 按 Message Key 查询的条件是用户设置的 Message Key 属性。
• 按 Message Key 查询仅仅返回符合条件的最近的 64 条消息，因此建议您尽可能保证设置的 Key 是唯一的，并具有业务区分度。 设置 Message Key 的方法如下：

      Message msg = new Message("Topic","*","Hello MQ".getBytes());
      /**
       * 对每条消息设置其检索的 Key，该 Key 值代表消息的业务关键属性，请尽可能全局唯一。
       * 以方便您在无法正常收到消息情况下，可通过消息队列 RocketMQ 控制台查询消息。 不设置也不会影响消息正常收发。
       */
      msg.setKey("TestKey"+System.currentTimeMillis());

• 按 Topic 查询 按 Topic 查询一般用在 Message ID 和 Message Key 都无法获得的情况下，根据 Topic 和消息的发送时间范围，批量获取该时间范围内的所有消息，然后再找到关心的数据。 注意： 若按 Topic 查询消息，请注意以下几点：
• 按 Topic 查询属于范围查询，获取 Topic 下符合时间条件的所有消息，消息量大，建议尽量缩短查询区间。
• 按 Topic 查询数据量大，采用分页展示。

查询结果说明

您可以在控制台的消息查询页面看到查询到的消息。直接显示的信息包含 Message ID、Tag、Key 和存储时间。此外，您还可以在每一行消息的操作列下载消息内容、查询消息轨迹以及查看消息详情。

查看消息详情

其中，投递状态是消息队列 RocketMQ 根据各个 Group ID 的消费进度计算出的结果，投递状态的信息参考以下表格。 注意：投递状态仅仅是根据消费进度估算的结果，如果需要详细的消费信息，请使用消息轨迹工具查询。消息轨迹可以展示该条消息的完整链路，详情参见查询消息轨迹。

投递状态表