简介

应用接入消息队列 RocketMQ前，需要在控制台创建RocketMQ实例。您可根据业务需求选择不同的实例规格。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击“新建实例”。

(3)根据参数说明配置参数。

(4)单击“下一步”，确认配置无误。

(5)单击“立即开通”。

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入该实例概览页。

简介

实例创建成功后，如果对应的业务规模增长，当前实例规格不再满足需求，您可以适当升高实例的规格，避免因资源限制而导致处理能力下降，影响业务正常运行。

限制与指导

仅支持对状态为“运行中”的实例进行升配。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例别名/实例名称，进入实例详情页。

(3)单击“升配”，进入RocketMQ实例变更页。

(4)在变更配置模块，变更配置。

• 实例别名：根据需要变更实例别名。

• 实例规格：根据需要选择实例规格。

• 消息轨迹：开启则启动消息轨迹。

• 自动创建Topic：开启则变更自动创建Topic。

(5)确认配置信息后，单击“立即变更”。

简介

出于实际业务需求，如果不再需要使用某些实例，您可以及时释放实例，避免产生不必要的费用。

限制与指导

释放后不可恢复。

仅按需计费实例，支持释放。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例别名/实例名称，进入实例详情页。

(3)单击“释放”，弹出释放对话框。

(4)确认无误，单击“确定”。

简介

创建RocketMQ实例后，您可以在控制台查看RocketMQ实例列表和每个RocketMQ实例的详细信息。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例的实例别名/实例名称，进入实例详情页。

(3)查看该实例的基本信息、网络信息和事件列表。

• 基本信息：查看实例基本信息，可设置此实例是否开启消息轨迹、自动创建Topic、开启指标采集、日志采集。

• 网络信息：查看该实例网络信息，包括协议、接入点、专有网络、子网、是否开启TLS等信息。

• 事件列表：查看事件列表，事件信息包括创建时间、事件类型、事件原因、事件详情等信息。

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例的实例别名/实例名称，进入实例详情页。

(3)在网络信息模块，单击弹性公网后的开关，弹出开启弹性公网对话框。

(4)选择弹性公网。

如当前账号下没有可选的弹性公网 IP，请先单击“新建弹性公网 IP”，进入弹性公网 IP页，新建弹性公网 IP。

(5)单击“确定”。

简介

在RocketMQ实例中，Topic是消息发送与接收的基本单元，消息队列 RocketMQ通过Topic对各类消息进行分类管理。消息的生产者将消息发送到RocketMQ Topic中，而消息的消费者则通过订阅该RocketMQ Topic来消费消息。

限制与指导

仅状态为“运行中”的实例，支持创建Topic。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入该实例概览页。

(3)在左侧导航栏，选择“Topic管理”，进入Topic列表页。

(4)单击“新建”，弹出创建Topic对话框。

根据参数说明完成配置。

(6)单击“确定”。

简介

创建Topic之后，如果这个Topic中的数据被一些消费者消费，消息队列 RocketMQ版会记录并在控制台展示消费的相关信息，例如队列信息和消费组信息。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入实例概览页。

(3)在左侧导航栏，选择“Topic管理”，进入Topic列表页。

(4)单击目标Topic名称，进入该Topic详情页。

(5)查看数据概览和订阅关系。

简介

创建Topic之后，如有需要还可以对Topic信息进行编辑。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入实例概览页。

(3)在左侧导航栏，选择“Topic管理”，进入Topic列表页。

(4)单击目标Topic操作列的“编辑”，弹出编辑Topic对话框。

(5)按需更新信息。

(6)单击“确定”。

简介

无需继续使用某个Topic时，可将其删除。

限制与指导

• 仅状态为“运行中”的实例，支持删除其中的Topic。

• 删除该Topic后，相关的生产者、消费者将会立即停止服务，同时会删除Topic的元数据和消息数据，且数据不可恢复，请谨慎操作。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入实例概览页。

(3)在左侧导航栏，选择“Topic管理”，进入Topic列表页。

(4)单击目标Topic操作列的“删除”，弹出确认提示窗口。

(5)单击“确定”，删除该Topic。

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入该实例概览页。

(3)在左侧导航栏，选择“消费组管理”，进入消费组列表页。

(4)单击“新建”，弹出新建消费组对话框。

(5)根据参数说明完成配置。

(6)单击“‘确定”。

简介

成功创建消费组并启动消费之后，消息队列 RocketMQ版会记录并在控制台展示消费的相关信息，例如消费速度等基础消费信息、客户端IP等客户端信息订阅的Topic等订阅信息。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入实例概览页。

(3)在左侧导航栏，选择“消费组管理”，进入消费组列表页。

(4)单击目标消费组名称，进入消费组详情页。

(5)查看该消费组的数据概览和订阅关系等信息。

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入实例概览页。

(3)在左侧导航栏，选择“消费组管理”，进入消费组列表页。

(4)单击目标消费组名称，进入消费组详情页。

(5)在订阅关系模块，单击目标Topic操作列的“查看消费进度”，查看消费进度。

简介

在清除堆积消息、离线数据处理等场景下，需要消费过去某个时间点之后的消息，或清除所有堆积消息，可以对消费位点进行重置操作。消息队列 RocketMQ版支持重置消费位点，改变订阅者当前的消费位置，您可以通过重置消费位点功能直接从最新位点、最小位点或某个指定时间点来消费消息。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入实例概览页。

(3)在左侧导航栏，选择“消费组管理”，进入消费组列表页。

(4)单击目标消费组操作列的“重置消费状态”。

(5)填写Topic名称，选择重置方式。

• 从最新位点开始消费：选择从最新位点开始消费。

• 从指定时间的位点开始消费：在起始时间选择框中选择时间。

• 从最小位点开始消费：选择从最小位点开始消费。

(6)单击“确定”。

简介

创建消息组后，可根据实际情况编辑消费组。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入实例概览页。

(3)在左侧导航栏，选择“消费组管理”，进入消费组列表页。

(4)单击目标消费组操作列的“编辑”，弹出编辑消费组对话框。

(5)更新信息

(6)单击“确定”。

简介

无需继续使用某个消费组时，可将其删除。

限制与指导

• 仅状态为“运行中”的实例，支持删除其中的消费组。

• 删除消费组后，由该消费组ID标识的消费者实例将立即停止接收消息，同时删除消费组相关资源。此操作不可恢复，请谨慎操作。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入实例概览页。

(3)在左侧导航栏，选择“消费组管理”，进入消费组列表页。

(4)单击目标消费组操作列的“删除”，弹出删除对话框。

(5)单击“确定”。

简介

成功接入消息队列 RocketMQ版之后，如果生产环境的消息收发不符合预期，可以通过消息查询功能查看服务端的详细消息内容，确认服务端的消息详情是否与生产端或消费端完全一致，排查消息生产或消费问题。

消息队列 RocketMQ版提供以下方式查询消息详情。

• 按消息ID查询：查询指定Topic中、指定消息ID的消息详情。按消息ID查询时，可以精确到某一条消息，适用于精确查询的情况。

• 按时间查询：查询指定Topic在指定时间范围内的消息列表。按时间范围查询时，会筛选出符合条件的消息列表，适用于范围查询的情况。

• 按位点查询：按具体位点开始查询。

• 按消息Key查询：模糊查询，适用于您没有记录消息ID，但是设置了消息Key的场景。

前提条件

已开启消息轨迹。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入实例详情页。

(3)在左侧导航栏，选择“消息查询”，进入消息查询页。

• 在Topic后的下拉框选择Topic。

• 选择查询方式。

• 设置时间、消息ID、消息Key、代理名称、队列、位点数等。

(4)单击“查询”，查看消息。

简介

当一条消息从生产者发送到消息队列 RocketMQ版服务端，再由消费者进行消费，消息队列 RocketMQ版会完整记录这条消息的全链路流转过程，并以消息轨迹的形式呈现在消息队列 RocketMQ版控制台。该轨迹可作为生产环境中排查问题强有力的数据支撑。消息轨迹记录了消息从生产端到消息队列 RocketMQ版服务端，最后到消费端的整个过程，包括各阶段状态、耗时、生产者IP地址、消费者IP地址等。

前提条件

已在实例详情页，开启消息轨迹。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入该实例概览页。

(3)在左侧导航栏，选择“消息查询”，进入消息列表页。

(4)单击目标消息操作列的“消息轨迹”，查看本条消息轨迹信息。

3.5.3.1 概述

在RocketMQ中，死信队列用于处理无法被正常消费的消息，即死信消息。

如果一条消息消费失败，消息队列 RocketMQ版会自动重试消费，达到最大重试次数后，如果仍旧消费失败，说明消费者在正常情况下无法正确地消费该消息。这种消息被称为死信消息。这种情况下，消息队列 RocketMQ版会将死信消息发送至该消费者对应的特殊队列中，这种存储死信消息的特殊队列称为死信队列。

在消息队列 RocketMQ版控制台中，您可以在线查询死信消息，并在消息被过期清理前，及时导出未正常消费的信息，排查消息生产或消费问题，避免消息丢失。

消息队列 RocketMQ版提供以下方式查询消息详情。

• 按消息ID查询。查询指定Group ID下指定Message ID的消息。按消息ID查询时，可以精确到某一条消息，适用于精确查询的情况。

• 按时间范围查询。根据Group ID和死信消息产生的时间范围，查询该Group ID在某段时间内产生的所有死信消息。按时间范围查询时，会筛选出符合条件的消息列表，查询到的死信消息可能比较多。

3.5.3.2 查询死信消息

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入该实例概览页。

(3)在左侧导航栏，选择“消息查询”，进入消息查询页。

(4)切换至死信队列页签。

(5)按照需要，设置查询条件。

(6)单击“查询”，查询死信消息。

3.5.3.3 重发消息

简介

死信消息由于某些原因无法正常被消费者消费，请排查相关原因并解决，然后在控制台重新投递死信消息到源Topic，重新消费。

操作步骤

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入该实例概览页。

(3)在左侧导航栏，选择“消息查询”，进入消息查询页。

(4)切换至死信队列页签。

(5)单击目标消息操作列的“重发消息”，弹出重发消息对话框。

(6)单击“确定”。

3.5.3.4 下载消息

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入该实例概览页。

(3)在左侧导航栏，选择“消息查询”，进入消息查询页。

(4)切换至死信队列页签。

(5)单击目标消息操作列的“下载消息”，将消息下载至本地。

(1)进入“消息服务RocketMQ”产品页。

(2)单击目标实例操作列的“访问”，进入该实例概览页。

(3)在左侧导航栏，选择“运行观测”，进入运行观测页。

(4)查看运行观测数据。

• 概览：在概览页签，按时间范围，查看总体数据图标或走势。

• Topic：在Topic页签，可选择Topic。设置时间范围，查看对应的数据和走势图。

消费组：在消费组页签，选择Topic、消费组，设置时间范围，查看对应的