# 分布式消息服务RocketMQ版 > 低延迟、高可靠，兼容开源RocketMQ ## 服务公告 - [漏洞修复策略](https://support.huaweicloud.com/bulletin-hrm/hrm_bulletin_002.md): 高危漏洞：RocketMQ社区发现漏洞并发布修复方案后，分布式消息服务RocketMQ版一般在1个月内进行修复，修复策略与社区保持一致。操作系统紧急漏洞按照操作系统修复策略和流程对外发布，一般在一个月内提供修复方案，用户自行修复。RocketMQ社区发现漏洞并发布修复方案后，分布式消息服务RocketMQ版一般在1个月内进行修复，修复策略 - [版本支持公告](https://support.huaweicloud.com/bulletin-hrm/hrm_bulletin_004.md): 分布式消息服务RocketMQ版的版本号格式为：消息引擎类型 x.y.z，其中消息引擎类型为RocketMQ，版本号具体含义如图1所示。分布式消息服务RocketMQ版支持的版本：4.8.0、5.x分布式消息服务RocketMQ版的版本生命周期如表1所示。EOM：End of Marketing，停止该版本的销售。EOS：End of S - [版本发布说明](https://support.huaweicloud.com/bulletin-hrm/hrm_bulletin_005.md): 表1列出了分布式消息服务RocketMQ版相对开源版本新增/优化的特性。 ## 产品介绍 - [图解Kafka、RabbitMQ和RocketMQ的差异](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_012.md): 华为云帮助中心，为用户提供产品简介、价格说明、购买指南、用户指南、API参考、最佳实践、常见问题、视频帮助等技术文档，帮助您快速上手使用华为云服务。 - [什么是分布式消息服务RocketMQ版](https://support.huaweicloud.com/productdesc-hrm/hrm-pd-001.md): 分布式消息服务RocketMQ版是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。分布式消息服务RocketMQ版具有如下特点：兼容开源RocketMQ客户端。提供顺序、延迟、定时、重投、死信、事务消息等功能，更好地适配电商、金融等多样的业务场景。提供消息追踪、消息溯源、链路诊断、死信导出、监控告警等能力，帮助您全方面 - [产品优势](https://support.huaweicloud.com/productdesc-hrm/hrm-pd-002.md): 分布式消息服务RocketMQ版具有如下产品优势，旨在打造一个即开即用、全托管、低延迟、弹性高可靠、动态扩展、便捷管理和多样功能的消息队列。即开即用：简单几步即可在云上构建自己专属的消息服务，RocketMQ实例创建完成后，使用实例提供的访问地址即可快速接入。兼容开源RocketMQ，业务代码无需改造，即可上云。全托管服务：分布式消息服务 - [典型应用场景](https://support.huaweicloud.com/productdesc-hrm/hrm-pd-003.md): 对于同步链路，需要实时返回调用结果的场景，建议使用RPC（Remote Procedure Call）调用方案。电商应用存在诸多难题：电商场景中通常会涉及到订单、支付和通知等场景的业务处理。业务链通常都是多个系统相互协作完成一次作业，上层服务强依赖于下层服务，上层服务的性能也会强依赖于下层服务，当业务链过深时，会严重影响外层服务的性能和用 - [产品功能](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_023.md): 本页面介绍了分布式消息服务RocketMQ版支持的主要功能。关于各功能支持的地域（Region）信息，可通过控制台查询详情。您在使用分布式消息服务RocketMQ版前，需要先购买RocketMQ实例。RocketMQ实例采用物理隔离的方式部署，租户独占RocketMQ实例。详情请参见购买RocketMQ实例。开源RocketMQ客户端向R - [产品规格](https://support.huaweicloud.com/productdesc-hrm/hrm-pd-004.md): 分布式消息服务RocketMQ版兼容开源RocketMQ 4.8.0和5.x，具体产品规格如下。RocketMQ对消息的处理能力依赖于磁盘的吞吐能力，其性能基线建立在采用超高I/O及以上磁盘类型，且磁盘带宽未达到所选规格上限的场景下。关于磁盘类型对RocketMQ性能的具体影响请参见磁盘类型对RocketMQ实例性能有什么影响？。本章节中 - [实例版本概述](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_024.md): 本章节介绍分布式消息服务RocketMQ版不同版本支持的实例类型和部署架构，5.x版本相比4.8.0版本的优势，以及不同实例类型、部署架构之间的差异，为您选择适合您业务的实例提供参考。单机实例如果出现单点故障，无法保障服务SLA，可能造成服务不可用。由于单机实例具备成本优势，建议作为测试环境使用。与4.8.0版本相比，5.x版本具有如下优 - [与Kafka、RabbitMQ的差异](https://support.huaweicloud.com/productdesc-hrm/hrm-pd-005.md): 华为云帮助中心，为用户提供产品简介、价格说明、购买指南、用户指南、API参考、最佳实践、常见问题、视频帮助等技术文档，帮助您快速上手使用华为云服务。 - [与开源RocketMQ的差异](https://support.huaweicloud.com/productdesc-hrm/hrm-pd-006.md): 分布式消息服务RocketMQ版在兼容开源RocketMQ基础上，对版本特性做了一定程度的定制和增强。 - [身份认证与访问控制](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_015.md): 无论用户通过控制台还是API访问DMS for RocketMQ，都会要求访问请求方出示身份凭证，并进行身份合法性校验，同时提供登录保护和登录验证策略加固身份认证安全。DMS for RocketMQ基于统一身份认证服务（Identity and Access Management，简称IAM），支持三种身份认证方式：用户名密码、访问密钥 - [数据保护技术](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_016.md): DMS for RocketMQ通过多种数据保护手段和特性，保障DMS for RocketMQ的数据安全可靠。 - [审计与日志](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_017.md): 云审计服务（Cloud Trace Service，简称CTS），是华为云安全解决方案中专业的日志审计服务，提供对各种云资源操作记录的收集、存储和查询功能，可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。用户开通云审计服务并创建和配置追踪器后，CTS可记录DMS for RocketMQ的管理事件用于审计。CTS的详细介绍 - [服务韧性](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_018.md): DMS for RocketMQ提供了3级可靠性架构，通过跨AZ容灾、AZ内实例容灾、实例数据多副本技术方案，保障服务的持久性和可靠性。跨AZ容灾部署架构仅介绍4.8.0版本，5.x底层的架构不体现，只提供TPS。4.8.0版本中一个Broker由一个主节点和两个备节点组成，当您购买的Broker数为1时，实际创建3个Broker节点，购 - [监控安全风险](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_019.md): DMS for RocketMQ提供基于云监控服务CES的资源和操作监控能力，帮助用户对每个RocketMQ实例进行自动实时监控、告警和通知操作。用户可以实时掌握实例的各类业务请求、资源占用、流量、连接数和消息积压等关键信息。关于DMS for RocketMQ支持的监控指标，以及如何创建监控告警规则等内容，请参见支持的监控指标。 - [认证证书](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_020.md): 华为云服务及平台通过了多项国内外权威机构（ISO/SOC/PCI等）的安全合规认证，用户可自行申请下载合规资质证书。合规证书下载华为云还提供以下资源来帮助用户满足合规性要求，具体请查看资源中心。资源中心华为云安全服务提供了网络安全专用产品安全检测证书、软件著作权等证书，供用户下载和参考。具体请查看合规资质证书。合规资质证书 - [约束与限制](https://support.huaweicloud.com/productdesc-hrm/hrm-pd-010.md): 本章主要为您介绍分布式消息服务RocketMQ版使用过程中的一些限制。如果因为您的实例配置超过相应的约束和限制而导致的任何不稳定情况，不在SLA承诺和赔偿范围内。 - [与其他云服务的关系](https://support.huaweicloud.com/productdesc-hrm/hrm-pd-007.md): 虚拟私有云（Virtual Private Cloud）RocketMQ实例运行于虚拟私有云，需要使用虚拟私有云创建的IP和带宽。通过虚拟私有云安全组的功能可以增强访问RocketMQ实例的安全性。RocketMQ实例运行于虚拟私有云，需要使用虚拟私有云创建的IP和带宽。通过虚拟私有云安全组的功能可以增强访问RocketMQ实例的安全性。 - [主题（Topic）](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_025.md): 主题是消息生产和消费的基础逻辑单元。生产者将消息发送到特定主题，消费者从该主题订阅消息，从而实现消息的高效分发和可靠传递。在微服务架构下，服务间需要频繁进行数据交互。若采用同步调用，服务间强依赖会导致系统耦合度高，一旦下游服务故障，上游业务将受阻，难以应对高并发场景。面对系统解耦与流量削峰的需求，如何构建灵活、可靠的异步通信机制？主题提供 - [消费组（Consumer Group）](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_026.md): 消费组由多个具有相同消费属性的消费者组成，各自维护独立的消费进度（Offset）。不同消费组同时订阅同一主题时，每条消息会被每个消费组各自消费一次；同一消费组内（非广播模式），每条消息仅被组内某一个消费者消费一次。在现代分布式系统中，消息的消费端往往需要多个实例协同工作，以应对高并发和可靠性的需求。然而，多个消费者实例如何高效分摊消息、如 - [其他相关概念](https://support.huaweicloud.com/productdesc-hrm/hrm_pd_027.md): 一个主题由多个队列组成。队列数越大消费的并发度越大。消息写入的触发者，负责将消息推送到服务端。同一类生产者的集合，这类生产者发送同一类消息且发送逻辑一致。接收消息的对象，负责从服务端获取消息。一组节点构成的一个业务集群。存储元数据信息的轻量级注册中心。生产者/消费者在生产/消费消息前，需要先从NameServer获取元数据。 - [权限管理](https://support.huaweicloud.com/productdesc-hrm/hrm-pd-011.md): 如果您需要对华为云上购买的DMS for RocketMQ资源，为企业中的员工设置不同的访问权限，以达到不同员工之间的权限隔离，您可以使用统一身份认证服务（Identity and Access Management，简称IAM）进行精细的权限管理。该服务提供用户身份认证、权限分配、访问控制等功能，可以帮助您安全地控制华为云资源的访问。如 ## 计费说明 - [计费概述](https://support.huaweicloud.com/price-hrm/hrm_billing_001.md): 通过阅读本文，您可以快速了解分布式消息服务RocketMQ版的计费模式、计费项、续费、欠费等主要计费信息。计费模式分布式消息服务RocketMQ版提供包年/包月和按需计费两种计费模式，以满足不同场景下的用户需求。包年/包月是一种预付费模式，即先付费再使用，按照订单的购买周期进行结算，因此在购买之前，您必须确保账户余额充足。按需计费是一种后 - [计费模式概述](https://support.huaweicloud.com/price-hrm/hrm_billing_003.md): 分布式消息服务RocketMQ版提供包年/包月和按需计费两种计费模式，以满足不同场景下的用户需求。您需要快速了解分布式消息服务RocketMQ的具体计费模式对应的具体价格，请参见分布式消息服务RocketMQ版价格详情。包年/包月：一种预付费模式，即先付费再使用，按照订单的购买周期进行结算。购买周期越长，享受的折扣越大。一般适用于业务需求 - [包年/包月](https://support.huaweicloud.com/price-hrm/hrm_billing_004.md): 包年/包月是一种先付费再使用的计费模式，适用于对资源需求稳定且希望降低成本的用户。通过选择包年/包月的计费模式，您可以预先购买云服务资源并获得一定程度的价格优惠。本文将介绍包年/包月RocketMQ实例的计费规则。包年/包月计费模式需要用户预先支付一定时长的费用，适用于长期、稳定的业务需求。以下是一些适用于包年/包月计费模式的业务场景：稳 - [按需计费](https://support.huaweicloud.com/price-hrm/hrm_billing_005.md): 按需计费是一种先使用再付费的计费模式，适用于无需任何预付款或长期承诺的用户。本文将介绍按需计费RocketMQ实例的计费规则。按需计费适用于具有不能中断的短期、突增或不可预测的应用或服务，例如电商抢购、临时测试、科学计算。分布式消息服务RocketMQ版对您选择的RocketMQ实例和RocketMQ的磁盘存储空间收费。以下计费项支持按需 - [计费项](https://support.huaweicloud.com/price-hrm/hrm_billing_006.md): 分布式消息服务RocketMQ版的计费项由实例费用和存储空间费用组成。具体内容如表1所示。如您需要快速了解分布式消息服务RocketMQ版的具体价格，请参见分布式消息服务RocketMQ版价格详情。以包年/包月计费模式为例，假设您于2023/03/08 15:50:04在“华北-北京四”区域购买了一个包年/包月4.8.0版本的Rocket - [计费样例](https://support.huaweicloud.com/price-hrm/hrm_billing_007.md): 某用户于2023/03/18 15:30:00在“华北-北京四”区域购买了一个按需计费4.8.0版本的RocketMQ实例，规格配置如下：规格：rocketmq.4u8g.cluster*1总存储空间：高I/O，300GB用了一段时间后，用户发现RocketMQ实例当前规格无法满足业务需要，于2023/03/20 9:00:00升配为ro - [变更计费模式概述](https://support.huaweicloud.com/price-hrm/hrm_billing_009.md): 在购买RocketMQ实例后，如果发现当前计费模式无法满足业务需求，您可以变更计费模式。支持变更计费模式的RocketMQ实例计费项如表1所示。 - [按需转包年/包月](https://support.huaweicloud.com/price-hrm/hrm_billing_010.md): 如果您需要长期使用当前按需购买的RocketMQ实例，可以将该RocketMQ实例转为包年/包月计费模式，以节省开支。按需计费变更为包年/包月会生成新的订单，用户支付订单后，包年/包月资源将立即生效。假设用户于2023/04/18 15:29:16购买了一个按需计费的RocketMQ实例，由于业务需要，于2023/04/18 16:30: - [包年/包月转按需](https://support.huaweicloud.com/price-hrm/hrm_billing_011.md): 创建一个包年/包月RocketMQ实例后，您可以将该RocketMQ实例的计费模式转为按需计费，回收部分成本，同时更加灵活地按需使用RocketMQ实例。包年/包月变更按需计费时，生效时间分为以下两种：包年/包月资费模式到期后，按需的资费模式才会生效。提交变更后，按需的资费模式立即生效。RocketMQ实例计费模式为“包年/包月”。Roc - [续费概述](https://support.huaweicloud.com/price-hrm/hrm_billing_013.md): 包年/包月RocketMQ实例到期后会影响RocketMQ实例正常运行。如果您想继续使用，需要在指定的时间内为RocketMQ实例续费，否则RocketMQ实例资源会自动释放，数据丢失且不可恢复。续费操作仅适用于包年/包月RocketMQ实例，按需计费RocketMQ实例不需要续费，只需要保证账户余额充足即可。RocketMQ实例在到期前 - [手动续费](https://support.huaweicloud.com/price-hrm/hrm_billing_014.md): 包年/包月RocketMQ实例从购买到被自动删除之前，您可以随时在RocketMQ控制台为RocketMQ实例续费，以延长RocketMQ实例的使用时间。勾选RocketMQ实例名称左侧的方框，可选一个或多个，单击信息栏左上侧的“续费”，弹出“续费”对话框，单击“确定”，跳转到“续费”页面。在待续费的RocketMQ实例所在行，单击“更多 - [自动续费](https://support.huaweicloud.com/price-hrm/hrm_billing_015.md): 自动续费可以减少手动续费的管理成本，避免因忘记手动续费而导致RocketMQ实例被自动删除。自动续费的规则如下所述：以RocketMQ实例的到期日计算第一次自动续费日期和计费周期。RocketMQ实例自动续费周期根据您开通自动续费的途径不同，遵循不同的规则。在RocketMQ实例到期前均可开通自动续费，到期前7日凌晨3:00首次尝试自动续 - [费用账单](https://support.huaweicloud.com/price-hrm/hrm_billing_016.md): 您可以在“费用中心 > 账单管理”查看资源的费用账单，以了解该资源在某个时间段的使用量和计费信息。包年/包月计费模式的资源完成支付后，会实时上报两条账单（实例费用账单和存储空间费用账单）到计费系统进行结算。按需计费模式的资源按照固定周期上报使用量到计费系统进行结算。按需计费模式产品根据使用量类型的不同，分为按小时、按天、按月三种周期进行结 - [欠费说明](https://support.huaweicloud.com/price-hrm/hrm_billing_017.md): 用户在使用云服务时，账户的可用额度小于待结算的账单，即被判定为账户欠费。欠费后，可能会影响云服务资源的正常运行，请及时充值。购买了按需计费RocketMQ实例，并使用了一段时间后，账户的余额不足。包年/包月对于包年/包月RocketMQ实例，用户已经预先支付了资源费用，因此在账户出现欠费的情况下，已有的包年/包月RocketMQ实例仍可正 - [停止计费](https://support.huaweicloud.com/price-hrm/hrm_billing_018.md): 对于包年/包月计费模式的资源，例如包年/包月的RocketMQ实例，用户在购买时会一次性付费，服务将在到期后自动停止使用。如果在计费周期内不再使用包年/包月资源，您可以执行退订操作，系统将根据资源是否属于五天无理由退订、是否使用代金券和折扣券等条件返还一定金额到您的账户。详细的退订规则请参见云服务退订规则概览。需要注意，如果实例开启了回收 - [成本管理](https://support.huaweicloud.com/price-hrm/hrm_billing_019.md): 随着上云企业越来越多，企业对用云成本问题也越发重视。使用分布式消息服务RocketMQ版时，如何进行成本管理，减轻业务负担呢？本文将从成本构成、成本分配、成本分析和成本优化四个维度介绍成本管理，帮助您通过成本管理节约成本，在保障业务快速发展的同时获得最大成本收益。使用分布式消息服务RocketMQ版时，成本主要包括两个方面：资源成本：各类 ## 快速入门 - [快速连接RocketMQ并生产消费消息](https://support.huaweicloud.com/qs-hrm/hrm-qs-001.md): 本章节将为您介绍分布式消息服务RocketMQ版（以下简称RocketMQ）入门的使用流程，以创建一个开启SSL的RocketMQ实例，客户端使用内网通过同一个VPC连接RocketMQ实例生产消费消息为例，帮助您快速上手RocketMQ。准备工作。在创建RocketMQ实例前，您需要完成注册华为云并实名认证、为账户充值、为用户添加操作权 - [入门实践](https://support.huaweicloud.com/qs-hrm/hrm-qs-011.md): 当您购买了RocketMQ实例后，可以根据自身的业务需求使用分布式消息服务RocketMQ版提供的一系列常用实践。 ## 用户指南 - [RocketMQ业务使用流程](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-066.md): 分布式消息服务RocketMQ版（以下简称RocketMQ）是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。用户购买RocketMQ实例后，生产者客户端连接RocketMQ实例进行消息生产，生产的消息被存储在RocketMQ实例的Topic中，消费者客户端通过订阅Topic消费消息。使用RocketMQ实例生产消费消 - [通过IAM角色或策略授予使用DMS for RocketMQ的权限](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-030.md): 如果您需要对您所拥有的DMS for RocketMQ进行角色与策略的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），通过IAM，您可以：根据企业的业务组织，在您的华为账号中，给企业中不同职能部门的员工创建IAM用户，让员工拥有唯一安全凭证，并使用DMS for Rocke - [通过IAM身份策略授予使用DMS for RocketMQ的权限](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-054.md): 如果您需要对您所拥有的DMS for RocketMQ进行身份策略的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），通过IAM，您可以：根据企业的业务组织，在您的华为账号中，给企业中不同职能部门的员工创建用户或用户组，让员工拥有唯一安全凭证，并使用DMS for Rocke - [购买RocketMQ实例](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-002.md): RocketMQ实例采用物理隔离的方式部署，租户独占RocketMQ实例。支持用户自定义规格和自定义特性，您可以根据业务需要定制相应规格和存储空间的RocketMQ实例。本视频演示自定义购买RocketMQ实例的操作。因产品功能演进，操作界面可能存在差异，相关视频仅供参考，具体以实际环境为准。在购买RocketMQ实例前，您需要提前准备相 - [创建RocketMQ Topic](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-008.md): Topic，即消息主题，是消息发送与接收的基本单元。购买RocketMQ实例成功后，需要手动创建Topic，通过Topic完成消息的发布和订阅。消息生产者将消息发送到Topic中，而消息消费者则通过订阅该Topic来消费消息。Topic不能跨实例使用，例如在实例A中创建的Topic A不能在实例B中使用。在5.x版本中，客户端使用gRPC - [查看RocketMQ Topic详情](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-009.md): Topic创建成功后，可在控制台查看Topic的相关配置和状态信息。已创建Topic。RocketMQ实例版本为4.8.0时，显示信息如下：在详情页上方，可以查看Topic名称、关联代理、读队列个数、写队列个数、权限和描述信息。在详情页下方，不仅能查看Topic在每个代理上的队列状态，以及订阅该Topic的所有消费组信息、用户权限信息和监 - [修改RocketMQ Topic配置](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-010.md): RocketMQ实例为4.8.0版本时您可以根据业务需要修改Topic的权限配置、关联代理配置和描述信息，为5.x版本时仅支持修改描述信息。已创建Topic。在待修改的Topic所在行，单击“编辑”，弹出“编辑Topic”页面。单击待修改的Topic名称，进入Topic详情页面。在页面右上角，单击“编辑”，弹出“编辑Topic”页面。To - [导出RocketMQ Topic](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-089.md): RocketMQ支持通过控制台导出Topic列表信息，供用户查看和使用。Topic导出操作仅涉及Topic的基础信息，例如Topic名称、Topic的描述信息，不涉及Topic中消息数据的变更或迁移。已创建Topic。勾选待导出的Topic，单击“导出 > 导出已选中数据到XLSX”，导出指定Topic列表。单击“导出 > 导出全部数据到 - [删除RocketMQ Topic](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-011.md): 如果某个Topic不再使用，可参考本章节删除Topic，释放资源。仅在实例的“状态”为“运行中”时，才可以删除实例中的Topic。删除Topic会导致Topic中的数据也被删除，并且无法找回，同时会影响使用该Topic的相关业务。已创建Topic。删除Topic会导致消息丢失，请谨慎操作。在待删除的Topic所在行，单击“删除”。单击待删 - [连接RocketMQ网络要求](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-075.md): 客户端可以通过公网连接RocketMQ实例，也可以通过内网连接RocketMQ实例。使用内网连接时，注意以下几点：如果客户端和RocketMQ实例部署在同一个VPC内，网络默认互通。如果客户端和RocketMQ实例部署在不同VPC中，由于VPC之间逻辑隔离，客户端和RocketMQ实例不能直接通信，需要打通VPC之间的网络。客户端连接Ro - [配置RocketMQ实例的公网访问](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-033.md): 您需要通过公网地址访问RocketMQ实例时，开启实例的公网访问功能，并设置弹性IP地址。当业务不再使用公网访问功能时，关闭实例的公网访问功能。RocketMQ实例只支持绑定IPv4弹性IP地址。只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。您可以在实例的“实例管理 > 后台任务管理”页面，查看当前任务的操作进度。任务 - [开启RocketMQ ACL访问](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-070.md): 通过ACL（Access Control List）可以实现对RocketMQ实例中生产者和消费者身份的精确识别，达到权限管理的目的。开启ACL权限控制功能后，生产消息和消费消息时，需要鉴权。仅2021年8月21号后购买的实例，支持设置ACL访问控制。开启ACL访问控制会导致没有配置认证信息的客户端连接中断。已购买RocketMQ实例。左 - [配置RocketMQ ACL用户](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-035.md): RocketMQ实例开启ACL权限控制功能后，生产和消费消息时，须增加ACL用户信息，才能成功生产和消费消息。您还可以通过创建多个用户并为其赋予不同的Topic和消费组权限，以达到用户之间权限隔离的效果。已开启ACL访问控制。创建用户时会设置默认的Topic和消费组权限，如果需要修改默认权限，则可以在此处重新为用户设置。管理员默认具有所有 - [配置RocketMQ客户端](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-079.md): 本章节介绍RocketMQ客户端的配置建议。Java客户端版本建议使用5.1.4及以上版本。客户端的ClientId默认为进程号、本机IP、instanceName进行组合。如果同一个进程内，一个消费组下启动两个消费者，则会导致两者ClientId相同，从而出现有的队列重复消费、有的队列无法消费的情况。配置建议由于ClientId生成时会 - [使用客户端连接RocketMQ（关闭SSL）](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-039.md): 本文主要介绍在Linux系统的命令行模式下连接关闭SSL的RocketMQ实例的方法。关闭SSL表示客户端和RocketMQ实例进行通信时，数据通过明文传输，性能更好。本视频演示连接RocketMQ实例的操作。因产品功能演进，操作界面可能存在差异，相关视频仅供参考，具体以实际环境为准。已购买RocketMQ实例，并已将 “加密方式”设置为 - [使用客户端连接RocketMQ（开启SSL）](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-040.md): 本文主要介绍在Linux系统的命令行模式下连接开启SSL的RocketMQ实例的方法。开启SSL表示客户端和RocketMQ实例进行通信时，数据通过密文传输，安全性更高。本视频演示连接RocketMQ实例的操作。因产品功能演进，操作界面可能存在差异，相关视频仅供参考，具体以实际环境为准。已购买RocketMQ实例，并已将 “加密方式”设置 - [使用控制台连接RocketMQ](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-049.md): 本章节介绍RocketMQ实例如何在控制台生产消息。此功能通过将指定消息发送给RocketMQ实例，验证业务逻辑是否正常。已存在“运行中”的RocketMQ实例。已创建Topic，且Topic具有发布权限。在待生产消息的Topic所在行，单击“生产消息”，弹出“生产消息”对话框。单击待生产消息的Topic名称，进入Topic详情页面。在页 - [查看RocketMQ消息](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-027.md): RocketMQ提供了三种消息查询的方式，分别是按Topic、Message ID以及Message Key查询。您可以通过消息查询验证消息是否已成功发送和消费，验证消息发送的内容是否正确，以及进一步查看消息的轨迹信息。无论消息是否被消费，RocketMQ的消息默认保留时间为48小时，最长保留时间为720小时，修改保留时间的操作请参见修改 - [修改RocketMQ消息保留时间](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-059.md): 消息老化时间即消息的最长保留时间，消费者必须在此时间结束前消费消息，否则消息将被删除。删除的消息，无法被消费。正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制，消息老化时间修改后，正常消息的保留时间和死信消息的保留时间都会被修改。实例创建后，您可以根据业务需要修改消息老化时间。修改老化时间，不会重启实例。消息老化时间默认为48 - [开启和查询RocketMQ消息轨迹](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-028.md): 消息轨迹是指一条消息从生产者发出到消费者消费处理过程中，由各个相关节点的时间、地点等数据汇聚而成的完整链路信息。开启消息轨迹后，当消息收发不符合预期（如消息未发送成功或未消费成功）时，可以通过Message ID、Message Key或Topic的时间范围查询相关消息的消息轨迹，找到消息的实际收发状态，帮助您快速诊断消息问题。Rocke - [验证RocketMQ消息消费](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-050.md): 消费验证是将消息重新发送到指定的在线客户端，验证消费者能否收到消息。消费验证会导致消息重复消费。仅在实例的“状态”为“运行中”时，才可以进行消费验证。确保待进行消费验证的客户端处于在线状态，且消费者已订阅待重新发送的消息所属的Topic。消息重新发送成功后，“消费验证”对话框顶部会显示“消费验证成功”，此时客户端中会收到重新发送的消息。消 - [管理RocketMQ死信消息](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-023.md): 对于消费失败且重试后依然失败的消息，RocketMQ不会立即丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重新投递这些死信消息，让消费者重新消费；若您暂时无法处理这些死信消息，为避免到期后死信消息被删除，您也可以先将死信消息导出进行保存。死信消息具有如下特性：不会再被消费者正常消 - [创建RocketMQ消费组](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-013.md): 消费组，即一组具有相同行为的消费者，用于管理和维护消息的消费状态。消费者可以将同一类消息放在一个消费组里面，方便管理。如果没有创建消费组，则RocketMQ会自动创建消费组。消费组名称不能跨实例使用，例如实例A中创建的Group01不能在实例B中使用。已购买RocketMQ实例。消费组创建完成后，消费组列表中会增加“消费组状态”和“消费模 - [查看RocketMQ消费组详情](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-014.md): 消费组创建成功后，可在控制台查看消费组的相关配置和状态信息。已创建消费组。在详情页上方可以查看消费组的基本信息，具体参数说明请参见表1。在详情页下方可以查看到消费者列表信息，及消费组订阅的所有Topic、用户权限信息、订阅关系和监控数据，具体参数说明请参见表1。消费组详情参数说明参数说明消费者列表客户端ID消费者所在客户端的ID。消费者地 - [查看RocketMQ消费者连接地址](https://support.huaweicloud.com/usermanual-hrm/hrm_ug_045.md): 消费者连接地址即消费消息的客户端地址，当客户端连接RocketMQ消费消息时，可通过控制台查看客户端的连接地址。消费者处于连接RocketMQ实例时，才可以查看消费者连接地址。已创建消费组，且消费组中已存在消费者。已创建Topic。 - [修改RocketMQ消费组配置](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-015.md): 消费组创建成功后，可以根据业务需要修改消费组的配置信息。已创建消费组。在待修改的消费组所在行，单击“编辑”，弹出“编辑消费组”页面。单击待修改的消费组名称，进入消费组详情页面。在页面右上角，单击“编辑”，弹出“编辑消费组”页面。修改消费组也可以通过调用API完成，具体请参见批量修改消费组和修改消费组。消费重试指的是，消费者在消费某条消息失 - [重置RocketMQ消费进度](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-051.md): 重置RocketMQ消费进度即修改消费者的消费位置，重置消费进度后，消费者会从修改后的消息位置开始继续消费。RocketMQ通过消费位点管理消息的消费进度。每条消息被某个消费者消费完成后不会立即从队列中删除，RocketMQ会基于每个消费组维护一份消费记录，该记录指定了消费组下的消费者消费指定Topic时，消费过的最新一条消息的位点，即消 - [查看RocketMQ消费组和Topic的订阅关系](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-087.md): 订阅关系是指消息生产者发送的消息与消息消费者之间的关系。具体来说，它定义了消费者订阅哪些Topic，以及对这些Topic中的哪些消息类型（通过标签Tag来标识）进行订阅。订阅关系是RocketMQ实现消息过滤和路由的基础，确保了消息能够被正确地发送到订阅的消费者。在RocketMQ控制台，您可以实时查看RocketMQ消费组和Topic之 - [导出RocketMQ消费组](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-088.md): RocketMQ支持通过控制台导出消费组列表信息，供用户查看和使用。已创建消费组。勾选待导出的消费组，单击“导出 > 导出已选中数据到XLSX”，导出指定消费组列表。单击“导出 > 导出全部数据到XLSX”，导出全部消费组列表。 - [删除RocketMQ消费组](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-016.md): 如果消费组不再继续使用，需要清理时，参考本章节删除消费组。已创建消费组。在待删除的消费组所在行，单击“删除”。单击待删除的消费组名称，进入消费组详情页面。在页面右上角，单击“删除”。如需批量删除消费组，勾选待删除的消费组，单击“删除消费组”。删除消费组也可以通过调用API完成，具体请参见创建消费组或批量删除消费组和删除指定消费组。 - [查看和修改RocketMQ实例基本信息](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-004.md): 本节介绍如何在控制台查看RocketMQ实例的详细信息，以及修改RocketMQ实例的基本信息。创建RocketMQ实例成功后，您可以根据自己的业务情况对RocketMQ实例的部分配置信息进行调整，包括实例名称、描述、安全组等。已购买RocketMQ实例。企业用户才能使用企业项目进行筛选。资源标签筛选支持运算符操作，可选运算符包括：等于、 - [查看RocketMQ实例后台任务](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-062.md): 对实例的一些操作，如表1所示，会启动一个后台任务，您可以在后台任务页，查看该操作的状态等信息，同时可通过删除操作，清理任务信息。已购买RocketMQ实例。在后台任务管理页面，您还可以执行以下操作：通过筛选来查询对应的RocketMQ实例。当前支持的筛选条件为任务名、用户名、状态和其他信息。单击，刷新任务状态。单击“删除”，弹出“删除任务 - [配置RocketMQ实例标签](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-058.md): 标签是RocketMQ实例的标识，为RocketMQ实例添加标签，可以方便用户识别和管理拥有的RocketMQ实例资源。您可以在创建RocketMQ实例时添加标签，也可以在RocketMQ实例创建完成后，在“标签”页面添加标签。另外，您还可以删除不再使用的标签。如您的组织已经设定分布式消息服务RocketMQ版的相关标签策略，则需按照标签 - [导出RocketMQ实例列表](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-060.md): RocketMQ支持通过控制台导出实例列表信息，供用户查看和使用。已购买RocketMQ实例。勾选待导出的实例，单击“导出 > 导出已选中数据到XLSX”，导出指定实例列表。单击“导出 > 导出全部数据到XLSX”，导出全部实例列表。 - [诊断RocketMQ实例](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-042.md): 使用分布式消息服务RocketMQ版消费消息时，如果遇到消息消费缓慢或者消费不到消息等消费异常的场景，您可以借助实例诊断功能快速定位问题。本视频演示诊断RocketMQ实例的操作。因产品功能演进，操作界面可能存在差异，相关视频仅供参考，具体以实际环境为准。已创建消费组，且消费组中已存在消费者。已创建Topic。诊断完成后，在“诊断记录”区 - [重启RocketMQ实例的Broker节点](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-055.md): 分布式消息服务RocketMQ版控制台支持重启实例的某个Broker节点，或者所有Broker节点。怎么判断哪个是主节点？一个Broker由一个主节点和两个备节点组成，当您购买的Broker数为1时，实际创建3个Broker节点。三个节点采用raft模式部署，使用Broker ID分别为1、2、3，当其中一台节点选为主节点后，Broker - [删除RocketMQ实例](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-005.md): 对于按需计费的RocketMQ实例，控制台支持删除单个实例，也可批量删除实例。对于包年/包月的RocketMQ实例，如果不再使用，单击“操作”栏下的“更多 > 退订”，退订成功后，RocketMQ实例会自动被删除。RocketMQ实例状态为运行中、故障、已冻结的按需计费实例才能执行删除操作。在待删除的RocketMQ实例所在行，单击“更多 - [配置RocketMQ实例回收站策略](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-080.md): 开启回收站策略的实例在被删除后，会被临时存入回收站中，此时实例中的数据尚未被彻底删除，在保留天数内支持从回收站中恢复此实例。超过保留天数的实例会被彻底删除，无法恢复。回收站策略默认是关闭状态。回收站中的按需实例不会收取实例的费用，但是会收取存储空间的费用。包年/包月的实例退订后会存入回收站中，此时不会收取实例的费用，但是会按需收取存储空间 - [修改RocketMQ实例的SSL配置](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-061.md): 您可以通过明文接入RocketMQ实例，也可以通过密文接入RocketMQ实例，本章节指导您在控制台修改接入方式。RocketMQ实例支持的接入方式如下：SSL：服务端与客户端之间通过密文传输，安全性较高，性能较低。PLAINTEXT：服务端与客户端之间通过明文传输，安全性较低，性能较高。PERMISSIVE：服务端与客户端之间既能通过明 - [开启RocketMQ实例弹性TPS功能](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-081.md): TPS（Transaction per second）是指每秒可以生产和消费消息的总次数，可以理解为每秒生产和消费消息的总吞吐量。若实例每秒生产和消费消息的总吞吐量超过当前规格所支持的基础TPS上限，就会被限流，从而导致生产和消费消息失败。此时可以通过打开弹性TPS开关，为实例增加一些额外的TPS。开启弹性TPS功能后，消息的收发允许在一 - [调整RocketMQ实例消息收发请求比例](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-082.md): 消息收发请求比例是用来控制实例级别收发请求限流配额，默认创建时按照收发各50%的比例限流，如果业务上写少读多，可以调整写请求比例。已购买RocketMQ 5.x版本实例。默认发送和接收各占比50%。“接收占比”根据“发送占比”自动调整。 - [变更RocketMQ实例规格](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-038.md): RocketMQ实例创建成功后，您可以根据业务需要变更实例规格，RocketMQ实例支持的变更配置如表1所示。每次变更只支持一种配置类型的变更。本视频演示变更RocketMQ实例规格的操作。因产品功能演进，操作界面可能存在差异，相关视频仅供参考，具体以实际环境为准。rocketmq.4u8g.cluster.small规格不支持扩容代理规 - [自动扩容RocketMQ实例存储空间](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-078.md): RocketMQ实例的磁盘使用量达到容量阈值时会触发对应的阈值处理策略，可能会导致消息被删除。为了避免以上情况，您可以开启自动磁盘扩容功能。老实例不支持自动磁盘扩容功能，具体以控制台显示为准。如果短时间内磁盘使用量迅速增加，无法保证在磁盘使用量到达容量阈值前完成自动磁盘扩容。自动扩容存储空间不会影响业务。扩容RocketMQ实例存储空间会 - [RocketMQ元数据迁移概述](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-072.md): RocketMQ元数据包括Topic和消费组信息，但不包括Topic和消费组生产消息、消费消息的记录。当您需要使用相同的Topic和消费组时，可通过元数据迁移操作将已有的Topic和消费组信息迁移到指定的RocketMQ实例中，无需再手动创建。RocketMQ业务迁移主要涉及以下场景：迁移其他RocketMQ的元数据到华为云上Rocket - [迁移其他RocketMQ的元数据到RocketMQ实例](https://support.huaweicloud.com/usermanual-hrm/hrm_ug_046.md): 本章节指导您迁移其他RocketMQ的元数据到云上RocketMQ实例。主要提供以下两种迁移方法，请根据实际情况选择：方法一：通过mqadmin命令导出源实例的元数据，然后在云上RocketMQ实例中创建迁移任务。方法二：导出源实例的Topic和消费组列表（适用于不支持通过mqadmin命令导出元数据的场景），然后通过脚本将Topic和消 - [迁移RabbitMQ的元数据到RocketMQ实例](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-056.md): 分布式消息服务RocketMQ版支持通过控制台迁移RabbitMQ的元数据到云上RocketMQ实例。已购买RocketMQ实例。已开启RabbitMQ管理插件。已购买RabbitMQ 3.7.17/3.8.35版本实例。默认的用户名和密码即购买RabbitMQ实例时配置的用户名和密码。迁移完成后，在迁移任务列表页面查看“任务状态”。当“ - [导出RocketMQ实例迁移任务](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-085.md): 本章节指导您在控制台导出迁移任务列表。勾选待导出的迁移任务，单击“导出 > 导出已选中数据到XLSX”，导出指定迁移任务列表。单击“导出 > 导出全部数据到XLSX”，导出全部迁移任务列表。 - [删除RocketMQ实例迁移任务](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-086.md): 迁移任务无需继续使用，需要清理时，参考本章节删除迁移任务。在待删除的迁移任务所在行，单击“删除”。勾选待删除的迁移任务，单击任务列表左上侧的“删除”。删除迁移任务也可以通过调用API完成，具体请参见删除元数据迁移任务。 - [测试4.8.0版本RocketMQ实例性能（基础场景）](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-064.md): 本章节主要测试RocketMQ实例4.8.0版本不同产品规格在发送1 KB大小的消息，且消费堆积数较大时，同时进行生产和消费，得到实例的生产消费性能。进行测试前，您需要先构建如下的测试环境：购买如表1所示实例，购买步骤请参考购买实例。实例参数名称规格代理数量存储空间ACL访问公网访问SSLrocketmq-01rocketmq.4u8g. - [测试4.8.0版本RocketMQ实例性能（极限场景）](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-096.md): 本章节主要测试RocketMQ实例4.8.0版本不同产品规格在发送1 KB大小的消息，同时向大量Topic进行生产，每个Topic被两个消费组订阅，每个消费组下启动一个消费者进行消费，且消费堆积数较大时，得到实例的生产消费性能。进行测试前，您需要先构建如下的测试环境：购买如表1所示实例，购买步骤请参考购买实例。实例参数名称规格代理数量存储 - [测试5.x基础版本RocketMQ实例性能](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-065.md): 本章节主要测试RocketMQ实例5.x基础版本不同产品规格在发送3800字节大小的消息时，实例的生产速率、消费速率和平均生产时延。进行测试前，您需要先构建如下的测试环境：购买如表1所示实例，购买步骤请参考购买实例。实例参数名称规格存储空间ACL访问公网访问SSLrocketmq-01rocketmq.b2.large.4超高I/O 30 - [申请扩大RocketMQ配额](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-095.md): 为防止资源滥用，平台限定了各服务资源的配额，对用户的资源数量和容量做了限制。如您最多可以创建多少个RocketMQ实例。如果当前资源配额限制无法满足使用需要，您可以申请扩大配额。登录RocketMQ实例控制台。单击管理控制台左上角的，选择区域和项目。在页面右上角，选择“资源 > 我的配额”。系统进入“服务配额”页面。我的配额系统进入“服务 - [查看RocketMQ监控指标](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-019.md): 云监控对RocketMQ实例的运行状态进行日常监控，可以通过控制台直观地查看RocketMQ实例各项监控指标。在RocketMQ控制台的“监控与告警 > 监控”页面中，“主题”、“消费组”和“死信队列”的下拉框中每次最多只能选择50个进行查看。如果数量超过50个，建议分批查看。当RocketMQ的性能达到瓶颈时，可能会导致部分监控指标无法 - [RocketMQ支持的监控指标](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-018.md): 本章节定义了分布式消息服务RocketMQ版上报云监控服务的监控指标的命名空间，监控指标列表和维度定义，您可以通过分布式消息服务RocketMQ版控制台来检索相关监控指标和告警信息。SYS.DMSRocketMQ 4.8.0版本显示节点指标监控，RocketMQ 5.x版本没有节点指标监控。对于有多层测量维度的测量对象，使用接口查询监控指 - [配置RocketMQ监控告警](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-043.md): 本章节主要介绍部分监控指标的告警策略，以及配置操作。在实际业务中，建议按照以下告警策略，配置监控指标的告警规则。是否接近性能上限，表示当前资源支撑的性能为告警策略中设置的告警阈值，如果继续上升，业务可能出现问题。本视频演示配置RocketMQ监控告警通知的操作。因产品功能演进，操作界面可能存在差异，相关视频仅供参考，具体以实际环境为准。进 - [查看RocketMQ审计日志](https://support.huaweicloud.com/usermanual-hrm/hrm-ug-021.md): 通过云审计（Cloud Trace Service，CTS）服务，您可以记录与DMS for RocketMQ相关的操作事件，便于日后的查询、审计和回溯。已开通CTS。查看DMS for RocketMQ云审计日志，请参见查看审计事件。 ## 最佳实践 - [RocketMQ最佳实践汇总](https://support.huaweicloud.com/bestpractice-hrm/hrm-bp-008.md): 本文汇总了基于RocketMQ常见应用场景的操作实践，为每个实践提供详细的方案描述和操作指导，帮助用户轻松构建基于RocketMQ的业务。 - [通过消息幂等实现消息去重](https://support.huaweicloud.com/bestpractice-hrm/hrm-bp-002.md): 在RocketMQ的业务处理过程中，如果消息重发了多次，消费者端对该重复消息消费多次与消费一次的结果是相同的，多次消费并没有对业务产生负面影响，那么这个消息处理过程是幂等的。消息幂等保证了无论消息被重复投递多少次，最终的处理结果都是一致的，避免了因消息重复而对业务产生影响。例如在支付场景下，用户购买商品后进行支付，由于网络不稳定导致用户收 - [通过Topic和Tag实现消息分类](https://support.huaweicloud.com/bestpractice-hrm/hrm-bp-003.md): Topic是消息关联的基础逻辑单元，消息的生产与消费围绕着Topic进行。每个Topic包含若干条消息，每条消息只能属于一个Topic。Tag是消息的标签，用于在同一Topic下区分不同类型的消息。来自同一业务单元的消息，可以根据不同业务目的在同一Topic下设置不同的标签。标签能够有效保持代码的清晰度和连贯性，并优化RocketMQ提供 - [实现订阅关系一致](https://support.huaweicloud.com/bestpractice-hrm/hrm-bp-004.md): 订阅关系一致指的是同一个消费组下所有消费者所订阅的Topic、Tag必须完全一致。如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。消费原理RocketMQ为每个Topic划分了消息队列（Queue），队列数越大消费的并发度越大。一个消费组表示一个消费者群组，在分布式应用场景下，同一个消费组中的多个消费者共同完成Topic所有 - [消息堆积处理建议](https://support.huaweicloud.com/bestpractice-hrm/hrm-bp-005.md): 在RocketMQ的实际业务中，消息堆积是比较常见的问题。在消息处理过程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息没有被及时消费而产生消息堆积，从而会造成消息消费延迟。对于消息消费实时性要求较高的业务系统，即使是消息堆积造成的短暂消息延迟也无法接受。造成消息堆积的原因有以下两个 - [配置消息堆积数监控](https://support.huaweicloud.com/bestpractice-hrm/hrm-bp-007.md): 在消息处理过程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息没有被及时消费就会产生消息堆积，从而会造成消息消费延迟。如果您想要在消费组的消息堆积数超过阈值时，通过短信/邮件及时收到通知信息，可以参考本章节设置告警通知。您还可以参考本章节为分布式消息服务RocketMQ版的其他监控指 - [DMS for RocketMQ安全使用建议](https://support.huaweicloud.com/bestpractice-hrm/hrm-bp-006.md): 安全性是华为云与您的共同责任。华为云负责云服务自身的安全，提供安全的云；作为租户，您需要合理使用云服务提供的安全能力对数据进行保护，安全地使用云。详情请参见责任共担。本文提供了如何安全使用DMS for RocketMQ的最佳实践，旨在为提高整体安全能力提供可操作的规范性指导。根据该指导文档您可以持续评估DMS for RocketMQ资 ## 开发指南 - [概述](https://support.huaweicloud.com/devg-hrm/hrm-devg-001.md): 本指南主要介绍实例连接信息的收集，如获取实例连接地址、Topic名称等，然后提供Java、Go和Python语言的连接示例。客户端可以通过以下方式访问RocketMQ实例：如果客户端是云上ECS，与RocketMQ实例处于同region同VPC，则可以直接访问RocketMQ实例提供的内网连接地址。如果客户端是云上ECS，与RocketM - [收集连接信息](https://support.huaweicloud.com/devg-hrm/hrm-devg-008.md): 仅RocketMQ实例5.x版本支持gRPC协议，4.8.0版本不支持。实例连接地址和端口实例创建后，从RocketMQ实例控制台的“概览 > 连接信息”中获取，在客户端配置时，可将地址都配上。使用TCP协议通过内网连接RocketMQ实例时，获取“内网连接地址 IPv4”。使用gRPC协议通过内网连接RocketMQ实例时，获取“grp - [收发普通消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-002.md): 本章节介绍普通消息的收发方法和示例代码。其中，普通消息发送方式分为同步发送和异步发送。同步发送：消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息。异步发送：消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息。收发普通消息前，请参考收集连接信息收集RocketMQ所 - [收发顺序消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-003.md): 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。顺序消息分为全局顺序消息和分区顺序消息：全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和订阅。分区顺序消息：对于指定的一个Topic，同一个 - [收发事务消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-004.md): 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务回滚。服务端在一段时间后如果一直收不到提交或回滚，则发起回查，生产者在收到回查后重新发送事务提交或回 - [发送定时消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-009.md): 分布式消息服务RocketMQ版支持任意时间的定时消息，同时也支持定时消息的取消。定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。2022年3月30日及以后购买的实例支持定时消息功能，在 - [使用ACL权限访问](https://support.huaweicloud.com/devg-hrm/hrm-devg-006.md): 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5.1.4。通过以下任意一种方式引入依赖：使用Maven方式引入依赖。 org.apache.rocketmq - [消费端限流](https://support.huaweicloud.com/devg-hrm/hrm-devg-007.md): 在分布式消息服务RocketMQ版中，消费者消费消息时，可能会出现消费过快导致下游业务来不及处理的情况，进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码，以保障系统的稳定。开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5.1.4。使用Maven方式引入依赖。 - [RocketMQ-Spring的使用](https://support.huaweicloud.com/devg-hrm/rocketmq-spring.md): 本文介绍如何使用RocketMQ-Spring连接华为云RocketMQ实例进行消息的生产和消费。相关代码您可以从rocketmq-springboot-demo中获取。下文所有RocketMQ的配置信息，如实例连接地址、Topic名称、用户信息等，请参考收集连接信息获取。RocketMQ-Spring客户端2.2.2以下版本不支持开启S - [收发普通消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-026.md): 本章节介绍普通消息的收发方法和示例代码。其中，普通消息发送方式分为同步发送和异步发送。RocketMQ提供PushConsumer和SimpleConsumer类型的消费者，PushConsumer消费者订阅普通消息时，代码不区分同步订阅和异步订阅。SimpleConsumer消费者订阅普通消息时，代码需要区分同步订阅和异步订阅。普通消息 - [收发顺序消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-029.md): 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。顺序消息分为全局顺序消息和分区顺序消息：全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和订阅。分区顺序消息：对于指定的一个Topic，同一个 - [收发事务消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-030.md): 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务回滚。服务端在一段时间后如果一直收不到提交或回滚，则发起回查，生产者在收到回查后重新发送事务提交或回 - [发送定时消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-031.md): 分布式消息服务RocketMQ版支持任意时间的定时消息。定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。仅RocketMQ实例5.x版本支持gRPC协议，4.8.0版本不支持。客户端连接 - [收发普通消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-013.md): 本章节介绍普通消息的收发方法和示例代码。其中，普通消息发送方式分为同步发送和异步发送。同步发送：消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息。异步发送：消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息。收发普通消息前，请参考收集连接信息收集RocketMQ所 - [收发顺序消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-014.md): 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。顺序消息分为全局顺序消息和分区顺序消息：全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和订阅。分区顺序消息：对于指定的一个Topic，同一个 - [收发事务消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-015.md): 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务回滚。服务端在一段时间后如果一直收不到提交或回滚，则发起回查，生产者在收到回查后重新发送事务提交或回 - [发送定时消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-016.md): 分布式消息服务RocketMQ版支持任意时间的定时消息。定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。2022年3月30日及以后购买的实例支持定时消息功能，在此之前购买的实例不支持此功 - [使用ACL权限访问](https://support.huaweicloud.com/devg-hrm/hrm-devg-017.md): 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。普通消息、顺序消息和定时消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。import ( "context" "fmt" "os" "github.com/apache/rocketmq-client-go/v2" "github. - [收发普通消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-028.md): 本章节介绍普通消息的收发方法和示例代码。普通消息发送方式分为同步发送和异步发送。同步发送：消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息。异步发送：消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息。收发消息前，请参考收集连接信息收集RocketMQ所需的连接信 - [收发顺序消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-032.md): 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。顺序消息分为全局顺序消息和分区顺序消息：全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和订阅。分区顺序消息：对于指定的一个Topic，同一个 - [收发事务消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-033.md): 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务回滚。服务端在一段时间后如果一直收不到提交或回滚，则发起回查，生产者在收到回查后重新发送事务提交或回 - [发送定时消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-034.md): 分布式消息服务RocketMQ版支持任意时间的定时消息。定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。仅RocketMQ实例5.x版本支持gRPC协议，4.8.0版本不支持。客户端连接 - [收发普通消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-018.md): 本章节介绍普通消息的收发方法和示例代码。其中，普通消息发送方式分为同步发送和异步发送。同步发送：消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息。异步发送：消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息。以下示例仅介绍同步发送的示例代码。收发普通消息前，请参考 - [收发顺序消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-019.md): 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。顺序消息分为全局顺序消息和分区顺序消息：全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和订阅。分区顺序消息：对于指定的一个Topic，同一个 - [收发事务消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-020.md): 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务回滚。服务端在一段时间后如果一直收不到提交或回滚，则发起回查，生产者在收到回查后重新发送事务提交或回 - [发送定时消息](https://support.huaweicloud.com/devg-hrm/hrm-devg-021.md): 分布式消息服务RocketMQ版支持任意时间的定时消息。定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。2022年3月30日及以后购买的实例支持定时消息功能，在此之前购买的实例不支持此功 - [使用ACL权限访问](https://support.huaweicloud.com/devg-hrm/hrm-devg-022.md): 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。RocketMQ TCP协议的Python SDK只支持Linux系统，且不支持开启SSL。普通消息、顺序消息和定时消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。from rocketmq.client import Producer, Me ## API参考 - [使用前必读](https://support.huaweicloud.com/api-hrm/hrm-api-0001.md): 欢迎使用分布式消息服务RocketMQ版。分布式消息服务RocketMQ版是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。本文档提供了分布式消息服务RocketMQ版API的描述、语法、参数说明及样例等内容。分布式消息服务RocketMQ版持续增加新的功能，将不可避免对现有接口有所调整，比如增加响应参数。为了减少接口 - [API概览](https://support.huaweicloud.com/api-hrm/hrm-api-0003.md): 华为云帮助中心，为用户提供产品简介、价格说明、购买指南、用户指南、API参考、最佳实践、常见问题、视频帮助等技术文档，帮助您快速上手使用华为云服务。 - [构造请求](https://support.huaweicloud.com/api-hrm/hrm-api-0004.md): 本节介绍REST API请求的组成，并以调用IAM服务的管理员创建IAM用户来说明如何调用API。您还可以通过这个视频教程了解如何构造请求调用API：https://bbs.huaweicloud.com/videos/102987。请求URI由如下部分组成。{URI-scheme}://{Endpoint}/{resource-path - [认证鉴权](https://support.huaweicloud.com/api-hrm/hrm-api-0005.md): 调用接口有如下两种认证方式，您可以选择其中一种进行认证鉴权。AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key）加密调用请求。推荐使用AK/SK认证，其安全性比Token认证要高。Token认证：通过Token认证调用请求。AK/SK签名认证方式仅支持消息体大小12M以内，12M以上的请求请使 - [返回结果](https://support.huaweicloud.com/api-hrm/hrm-api-0006.md): 请求发送以后，您会收到响应，包含状态码、响应消息头和消息体。状态码是一组从1xx到5xx的数字代码，状态码表示了请求响应的状态，完整的状态码列表请参见状态码。对于管理员创建IAM用户接口，如果调用后返回状态码为201，则表示请求成功。对应请求消息头，响应同样也有消息头，如Content-type。对于管理员创建IAM用户接口，返回如图1所 - [快速入门](https://support.huaweicloud.com/api-hrm/api-getting-started.md): 您可以根据业务需要创建相应计算能力和存储空间的RocketMQ实例。API调用方法请参考如何调用API。已获取IAM和RocketMQ的Endpoint，具体请参见地区和终端节点。如下示例是创建RocketMQ实例的请求消息：name：实例名称，由您自行定义。engine：消息引擎，设置为rocketmq，也支持设置为reliabilit - [查询所有实例列表 - ListInstances](https://support.huaweicloud.com/api-hrm/ListInstances.md): 查询租户的实例列表，支持按照条件查询。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:i - [创建实例 - CreateInstanceByEngine](https://support.huaweicloud.com/api-hrm/CreateInstanceByEngine.md): 创建实例，该接口支持创建按需和包周期两种计费方式的实例。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖 - [查询指定实例 - ShowInstance](https://support.huaweicloud.com/api-hrm/ShowInstance.md): 查询指定实例的详细信息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance - [删除指定的实例 - DeleteInstance](https://support.huaweicloud.com/api-hrm/DeleteInstance.md): 删除指定的实例，释放该实例的所有资源。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:i - [修改实例信息 - UpdateInstance](https://support.huaweicloud.com/api-hrm/UpdateInstance.md): 修改实例相关信息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance:up - [批量删除实例 - BatchDeleteInstances](https://support.huaweicloud.com/api-hrm/BatchDeleteInstances.md): 批量删除实例。实例删除后，实例中原有的数据将被删除，且没有备份，请谨慎操作。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为 - [查询代理列表 - ListBrokers](https://support.huaweicloud.com/api-hrm/ListBrokers.md): 查询代理列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:broker:listLi - [查询消费组列表 - ListInstanceConsumerGroups](https://support.huaweicloud.com/api-hrm/ListInstanceConsumerGroups.md): 查询消费组列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group:listLi - [创建消费组或批量删除消费组 - CreateConsumerGroupOrBatchDeleteConsumerGroup](https://support.huaweicloud.com/api-hrm/CreateConsumerGroupOrBatchDeleteConsumerGroup.md): 创建消费组或批量删除消费组。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group: - [批量修改消费组 - BatchUpdateConsumerGroup](https://support.huaweicloud.com/api-hrm/BatchUpdateConsumerGroup.md): 批量修改消费组。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group:modify - [删除指定消费组 - DeleteConsumerGroup](https://support.huaweicloud.com/api-hrm/DeleteConsumerGroup.md): 删除指定消费组。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group:delete - [查询指定消费组 - ShowGroup](https://support.huaweicloud.com/api-hrm/ShowGroup.md): 查询指定消费组详情。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group:getR - [修改消费组 - UpdateConsumerGroup](https://support.huaweicloud.com/api-hrm/UpdateConsumerGroup.md): 修改指定消费组参数。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group:modi - [查询消费列表或详情 - ShowConsumerListOrDetails](https://support.huaweicloud.com/api-hrm/ShowConsumerListOrDetails.md): 查询消费列表或详情。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group:getR - [重置消费进度 - ResetConsumeOffset](https://support.huaweicloud.com/api-hrm/ResetConsumeOffset.md): 重置消费进度。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group:resetCo - [查询消费者列表 - ShowConsumerConnections](https://support.huaweicloud.com/api-hrm/ShowConsumerConnections.md): 查询消费组内消费者列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group:ge - [创建主题或批量删除主题 - CreateTopicOrBatchDeleteTopic](https://support.huaweicloud.com/api-hrm/CreateTopicOrBatchDeleteTopic.md): 创建主题或批量删除主题。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:topic:cr - [查询主题列表 - ListRocketInstanceTopics](https://support.huaweicloud.com/api-hrm/ListRocketInstanceTopics.md): 该接口用于查询指定RocketMQ实例的Topic列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖 - [删除指定主题 - DeleteTopic](https://support.huaweicloud.com/api-hrm/DeleteTopic.md): 删除指定主题。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:topic:deleteW - [查询单个主题 - ShowOneTopic](https://support.huaweicloud.com/api-hrm/ShowOneTopic.md): 查询单个主题。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:topic:getRead - [修改主题 - UpdateTopic](https://support.huaweicloud.com/api-hrm/UpdateTopic.md): 修改主题。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:topic:modifyWri - [查询主题消费组列表 - ListConsumerGroupOfTopic](https://support.huaweicloud.com/api-hrm/ListConsumerGroupOfTopic.md): 查询主题消费组列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:topic:getR - [查询主题的消息数 - ShowTopicStatus](https://support.huaweicloud.com/api-hrm/ShowTopicStatus.md): 查询主题的消息数。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:topic:getRe - [查询消息 - ListMessages](https://support.huaweicloud.com/api-hrm/ListMessages.md): 查询消息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:message:getRead - [发送消息 - SendMessage](https://support.huaweicloud.com/api-hrm/SendMessage.md): 发送消息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。POST /v2/{engine}/{project_id}/instances/{i - [查询消息轨迹 - ListMessageTrace](https://support.huaweicloud.com/api-hrm/ListMessageTrace.md): 查询消息轨迹。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:message:getTr - [重发死信消息 - SendDlqMessage](https://support.huaweicloud.com/api-hrm/SendDlqMessage.md): 重发死信消息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance:rese - [消费验证 - ValidateConsumedMessage](https://support.huaweicloud.com/api-hrm/ValidateConsumedMessage.md): 消费验证。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:message:sendWri - [创建用户 - CreateUser](https://support.huaweicloud.com/api-hrm/CreateUser.md): 创建用户。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:user:createWrit - [查询用户列表 - ListUser](https://support.huaweicloud.com/api-hrm/ListUser.md): 查询用户列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:user:listList - [修改用户参数 - UpdateUser](https://support.huaweicloud.com/api-hrm/UpdateUser.md): 修改用户参数。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:user:modifyWr - [查询用户详情 - ShowUser](https://support.huaweicloud.com/api-hrm/ShowUser.md): 查询用户详情。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:user:getReadr - [删除用户 - DeleteUser](https://support.huaweicloud.com/api-hrm/DeleteUser.md): 删除用户。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:user:deleteWrit - [查询主题的授权用户列表 - ListTopicAccessPolicy](https://support.huaweicloud.com/api-hrm/ListTopicAccessPolicy.md): 查询主题的授权用户列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:topic:ge - [查询消费组的授权用户列表 - ListConsumeGroupAccessPolicy](https://support.huaweicloud.com/api-hrm/ListConsumeGroupAccessPolicy.md): 查询消费组的授权用户列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:group:g - [新建元数据迁移任务 - CreateRocketMqMigrationTask](https://support.huaweicloud.com/api-hrm/CreateRocketMqMigrationTask.md): 新建元数据迁移任务。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance:c - [查询实例下所有迁移任务或查询指定迁移任务信息 - ListRocketMqMigrationTask](https://support.huaweicloud.com/api-hrm/ListRocketMqMigrationTask.md): 查询实例下所有迁移任务查询实例下所有迁移任务查询指定迁移任务信息查询指定迁移任务信息请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类 - [删除元数据迁移任务 - DeleteRocketMqMigrationTask](https://support.huaweicloud.com/api-hrm/DeleteRocketMqMigrationTask.md): 删除元数据迁移任务。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance:d - [批量删除元数据迁移任务 - BatchDeleteRocketMqMigrationTask](https://support.huaweicloud.com/api-hrm/BatchDeleteRocketMqMigrationTask.md): 批量删除元数据迁移任务。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance - [查询RocketMQ配置 - ShowRocketMqConfigs](https://support.huaweicloud.com/api-hrm/ShowRocketMqConfigs.md): 该接口用于查询RocketMQ配置，若成功则返回配置的相关信息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键 - [修改RocketMQ配置 - UpdateRocketMqConfigs](https://support.huaweicloud.com/api-hrm/UpdateRocketMqConfigs.md): 该接口用于修改RocketMQ配置。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:in - [批量添加或删除实例标签 - BatchCreateOrDeleteRocketmqTag](https://support.huaweicloud.com/api-hrm/BatchCreateOrDeleteRocketmqTag.md): 批量添加或删除实例标签。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance - [查询实例标签 - ShowRocketmqTags](https://support.huaweicloud.com/api-hrm/ShowRocketmqTags.md): 查询实例标签。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms::listProjectT - [查询项目标签 - ShowRocketmqProjectTags](https://support.huaweicloud.com/api-hrm/ShowRocketmqProjectTags.md): 查询项目标签。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms::listProjectT - [创建实例诊断任务 - CreateDiagnosisTask](https://support.huaweicloud.com/api-hrm/CreateDiagnosisTask.md): 创建实例诊断任务。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance:cr - [查询实例诊断报告列表 - ListDiagnosisReports](https://support.huaweicloud.com/api-hrm/ListDiagnosisReports.md): 查询实例诊断报告列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance: - [批量删除实例诊断报告 - BatchDeleteDiagnosisRecords](https://support.huaweicloud.com/api-hrm/BatchDeleteDiagnosisRecords.md): 批量删除实例诊断报告。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。POST /v2/{project_id}/{engine}/instan - [查询实例诊断报告 - ShowDiagnosisReport](https://support.huaweicloud.com/api-hrm/ShowDiagnosisReport.md): 查询实例诊断报告。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance:ge - [查询stack信息 - ShowDiagnosisStack](https://support.huaweicloud.com/api-hrm/ShowDiagnosisStack.md): 查询stack信息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{engine}/{project_id}/diagnosi - [查询实例的扩容规格列表 - ShowEngineInstanceExtendProductInfo](https://support.huaweicloud.com/api-hrm/ShowEngineInstanceExtendProductInfo.md): 查询实例的扩容规格列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{engine}/{project_id}/instan - [实例规格变更 - ResizeInstance](https://support.huaweicloud.com/api-hrm/ResizeInstance.md): 实例规格变更。当前通过调用API，只支持按需实例进行实例规格变更。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。POST /v2/{engin - [查询磁盘自动扩容配置 - ShowVolumeExpandConfig](https://support.huaweicloud.com/api-hrm/ShowVolumeExpandConfig.md): 查询磁盘自动扩容配置，包括磁盘自动扩容是否开启，以及开启后的扩容阈值、扩容步长、扩容上限信息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。G - [修改磁盘自动扩容配置 - UpdateVolumeExpansionConfig](https://support.huaweicloud.com/api-hrm/UpdateVolumeExpansionConfig.md): 该接口用于修改磁盘自动扩容配置，包含磁盘自动扩容是否开启、扩容阈值、扩容步长，以及扩容上限的配置。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限 - [查询RocketMQ实例扩容前置检查信息 - ShowRocketMqScalePreCheckInfo](https://support.huaweicloud.com/api-hrm/ShowRocketMqScalePreCheckInfo.md): 获取RocketMQ实例扩容前置检查信息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{project_id}/rocket - [查询实例节点 - ShowInstanceNodes](https://support.huaweicloud.com/api-hrm/ShowInstanceNodes.md): 查询实例节点信息。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{project_id}/{engine}/instances - [重启节点 - RestartInstance](https://support.huaweicloud.com/api-hrm/RestartInstance.md): 重启节点。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。POST /v2/{project_id}/{engine}/instances/{i - [修改实例SSL相关配置 - ModifyInstanceSslConfig](https://support.huaweicloud.com/api-hrm/ModifyInstanceSslConfig.md): 修改实例SSL相关配置。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance - [恢复回收站实例 - RestoreRecycleInstance](https://support.huaweicloud.com/api-hrm/RestoreRecycleInstance.md): 恢复回收站实例。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance:res - [查询回收站实例列表 - ShowRecycleInstances](https://support.huaweicloud.com/api-hrm/ShowRecycleInstances.md): 查询回收站实例列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{project_id}/recycle无状态码：200查询 - [更新回收站策略 - ModifyRecyclePolicy](https://support.huaweicloud.com/api-hrm/ModifyRecyclePolicy.md): 更新回收站策略。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms::updateRecyc - [查询后台任务管理中的指定记录 - ShowBackgroundTask](https://support.huaweicloud.com/api-hrm/ShowBackgroundTask.md): 查询后台任务管理中的指定记录。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{project_id}/instances/{i - [删除后台任务管理中的指定记录 - DeleteBackgroundTask](https://support.huaweicloud.com/api-hrm/DeleteBackgroundTask.md): 删除后台任务管理中的指定记录。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。DELETE /v2/{project_id}/instances - [查询实例的后台任务列表 - ListBackgroundTasks](https://support.huaweicloud.com/api-hrm/ListBackgroundTasks.md): 查询实例的后台任务列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{project_id}/instances/{inst - [查询实例的定时任务列表 - ListScheduledTasks](https://support.huaweicloud.com/api-hrm/ListScheduledTasks.md): 查询实例的定时任务列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，需具备如下身份策略权限。授权项访问级别资源类型（*为必须）条件键别名依赖的授权项dms:instance - [查询实例变更记录的进度 - ShowBackgroundTaskProgress](https://support.huaweicloud.com/api-hrm/ShowBackgroundTaskProgress.md): 查询后台任务管理中的指定实例变更记录的进度。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{project_id}/insta - [查询可用区信息 - ListAvailableZones](https://support.huaweicloud.com/api-hrm/ListAvailableZones.md): 在创建实例时，需要配置实例所在的可用区ID，可通过该接口查询可用区的ID。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/ava - [查询产品规格列表 - ListEngineProducts](https://support.huaweicloud.com/api-hrm/ListEngineProducts.md): 查询相应引擎的产品规格列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{engine}/products无状态码：200状 - [查询实例在CES的监控层级关系 - ShowCesHierarchy](https://support.huaweicloud.com/api-hrm/ShowCesHierarchy.md): 查询实例在CES的监控层级关系。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/{project_id}/instances/{ - [获取特性开关列表 - ListConfigFeatures](https://support.huaweicloud.com/api-hrm/ListConfigFeatures.md): 获取特性开关列表。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/config/features无状态码：200状态码：200查 - [查询RocketMQ产品规格核数 - ShowRocketMqProductCores](https://support.huaweicloud.com/api-hrm/ShowRocketMqProductCores.md): 查询RocketMQ产品规格核数。请参见如何调用API。账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。如果使用角色与策略授权，具体权限要求请参见权限和授权项。如果使用身份策略授权，当前API调用无需身份策略权限。GET /v2/rocketmq/products/cores - [批量创建Topic](https://support.huaweicloud.com/api-hrm/hrm-api-0021.md): RocketMQ未提供批量创建Topic接口，用户想批量创建Topic时只能手动多次调用接口一个个创建，效率低下。现通过代码实现接口循环调用，可实现批量创建Topic的效果。已获取IAM和RocketMQ服务所在区域的Endpoint地址。已获取RocketMQ实例的实例ID，以及实例所在区域的项目ID。新建topics.txt文件，用于 - [权限及授权项说明](https://support.huaweicloud.com/api-hrm/hrm-api-0015.md): 如果您需要对您所拥有的DMS for RocketMQ进行精细的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），如果华为账号已经能满足您的要求，您可以跳过本章节，不影响您使用DMS for RocketMQ服务的其它功能。通过IAM，您可以通过授权控制主体（IAM用户、用户 - [策略授权参考](https://support.huaweicloud.com/api-hrm/hrm-api-0016.md): 本章节介绍DMS for RocketMQ策略授权场景下支持的策略授权项。策略包含系统策略和自定义策略，如果系统策略不满足授权要求，管理员可以创建自定义策略，并通过给用户组授予自定义策略来进行精细的访问控制。策略支持的操作与API相对应，授权项列表说明如下：权限：允许或拒绝对指定资源在特定条件下进行某项操作。对应API接口：自定义策略实际 - [身份策略授权参考](https://support.huaweicloud.com/api-hrm/Permission.md): 云服务在IAM预置了常用的权限，称为系统身份策略。如果IAM系统身份策略无法满足授权要求，管理员可以根据各服务支持的授权项，创建IAM自定义身份策略来进行精细的访问控制，IAM自定义身份策略是对系统身份策略的扩展和补充。除IAM服务外，Organizations服务中的服务控制策略（Service Control Policy，以下简称S - [创建实例](https://support.huaweicloud.com/api-hrm/CreatePostPaidInstanceV1.md): 创建实例。当前页面API为历史版本API，未来可能停止维护。请使用创建实例。请参见如何调用API。POST /v1.0/{project_id}/instances无状态码： 200状态码： 200创建成功。请参见错误码。 - [查询实例](https://support.huaweicloud.com/api-hrm/ShowInstanceV1.md): 查询实例。当前页面API为历史版本API，未来可能停止维护。请使用查询指定实例。请参见如何调用API。GET /v1.0/{project_id}/instances/{instance_id}无状态码： 200状态码： 200查询成功。请参见错误码。 - [查询实例列表](https://support.huaweicloud.com/api-hrm/ListInstancesV1.md): 查询实例列表。当前页面API为历史版本API，未来可能停止维护。请使用查询所有实例列表。请参见如何调用API。GET /v1.0/{project_id}/instances无状态码： 200状态码： 200查询成功。请参见错误码。 - [修改实例](https://support.huaweicloud.com/api-hrm/UpdateInstanceV1.md): 修改实例。当前页面API为历史版本API，未来可能停止维护。请使用修改实例信息。请参见如何调用API。PUT /v1.0/{project_id}/instances/{instance_id}无无无请参见错误码。 - [删除实例](https://support.huaweicloud.com/api-hrm/DeleteInstanceV1.md): 删除实例。当前页面API为历史版本API，未来可能停止维护。请使用删除指定的实例。请参见如何调用API。DELETE /v1.0/{project_id}/instances/{instance_id}无无无请参见错误码。 - [查询可用区](https://support.huaweicloud.com/api-hrm/ListAvailableZonesV1.md): 查询可用区。当前页面API为历史版本API，未来可能停止维护。请使用查询可用区信息。请参见如何调用API。GET /v1.0/availableZones无状态码： 200状态码： 200查询成功。请参见错误码。 - [查询配额](https://support.huaweicloud.com/api-hrm/ShowQuotasV1.md): 查询配额信息。当前页面API为历史版本API，未来可能停止维护。请参见如何调用API。GET /v1.0/{project_id}/quotas/dms无状态码： 200状态码： 200查询成功。请参见错误码。 - [查询实例在CES的监控层级关系](https://support.huaweicloud.com/api-hrm/ShowCesHierarchyV1.md): 查询实例在CES的监控层级关系。当前页面API为历史版本API，未来可能停止维护。请使用查询实例在CES的监控层级关系。请参见如何调用API。GET /v1.0/{project_id}/instances/{instance_id}/ceshierarchy无状态码： 200状态码： 200查询成功。请参见错误码。 - [查询产品规格](https://support.huaweicloud.com/api-hrm/ListProductsV1.md): 查询产品规格信息。当前页面API为历史版本API，未来可能停止维护。请使用查询产品规格列表。请参见如何调用API。GET /v1.0/products无状态码： 200状态码： 200查询成功。请参见错误码。 - [查询指定实例](https://support.huaweicloud.com/api-hrm/ShowInstanceWithEngine.md): 查询指定实例的详细信息。当前页面API为历史版本API，未来可能停止维护。请参见如何调用API。GET /v2/{engine}/{project_id}/instances/{instance_id}无状态码： 200状态码： 200查询成功。请参见错误码。 - [查询所有消费组](https://support.huaweicloud.com/api-hrm/ListInstanceGroups.md): 查询所有消费组。当前页面API为历史版本API，未来可能停止维护。请使用查询消费组列表。请参见如何调用API。GET /v2/{engine}/{project_id}/instances/{instance_id}/groups无状态码： 200状态码： 200查询成功。请参见错误码。 - [更新消费组](https://support.huaweicloud.com/api-hrm/UpdateInstanceGroup.md): 更新消费组。当前页面API为历史版本API，未来可能停止维护。请使用批量修改消费组。请参见如何调用API。PUT /v2/{engine}/{project_id}/instances/{instance_id}/groups无状态码： 200状态码： 200操作成功。请参见错误码。 - [修改指定消费组](https://support.huaweicloud.com/api-hrm/UpdateInstanceConsumerGroup.md): 修改指定消费组。当前页面API为历史版本API，未来可能停止维护。请使用修改消费组。请参见如何调用API。PUT /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}无无无请参见错误码。 - [删除指定消费组](https://support.huaweicloud.com/api-hrm/DeleteInstanceConsumerGroup.md): 删除指定消费组。当前页面API为历史版本API，未来可能停止维护。请使用删除指定消费组。请参见如何调用API。DELETE /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group}无无无请参见错误码。 - [导出死信消息](https://support.huaweicloud.com/api-hrm/ExportDlqMessage.md): 导出死信消息。当前页面API为历史版本API，未来可能停止维护。请参见如何调用API。POST /v2/{project_id}/instances/{instance_id}/messages/export状态码：200导出主题中指定消息ID和Key的死信消息。状态码：200导出死信消息成功。请参见错误码。 - [批量删除实例诊断记录](https://support.huaweicloud.com/api-hrm/BatchDeleteDiagnosisReport.md): 批量删除实例诊断记录。当前页面API为历史版本API，未来可能停止维护。请使用批量删除实例诊断报告。请参见如何调用API。DELETE /v2/{engine}/{project_id}/instances/{instance_id}/diagnosis状态码：200批量删除实例诊断记录。状态码：200successSDK代码示例如下。批 - [状态码](https://support.huaweicloud.com/api-hrm/hrm-api-0009.md): 状态码如表1所示 - [错误码](https://support.huaweicloud.com/api-hrm/ErrorCode.md): 当您调用API时，如果遇到“APIGW”开头的错误码，请参见API网关错误码进行处理。更多服务错误码请参见API错误中心。 - [实例状态说明](https://support.huaweicloud.com/api-hrm/hrm-api-0010.md): 华为云帮助中心，为用户提供产品简介、价格说明、购买指南、用户指南、API参考、最佳实践、常见问题、视频帮助等技术文档，帮助您快速上手使用华为云服务。 - [获取项目ID](https://support.huaweicloud.com/api-hrm/hrm-api-0011.md): 在调用接口的时候，部分URL中需要填入项目ID，所以需要获取到项目ID。有如下两种获取方式：调用API获取项目ID从控制台获取项目ID项目ID可以通过调用查询指定条件下的项目信息API获取。获取项目ID的接口为“GET https://{Endpoint}/v3/projects”，其中{Endpoint}为IAM的终端节点，可以从地区和 - [获取账号名和账号ID](https://support.huaweicloud.com/api-hrm/hrm-api-0012.md): 在调用接口的时候，部分URL中需要填入账号名和账号ID，所以需要先在管理控制台上获取到账号名和账号ID。账号名和账号ID获取步骤如下：登录RocketMQ实例控制台。鼠标悬停在右上角的用户名，选择下拉列表中的“我的凭证”。查看账号名和账号ID。查看账号名和账号ID查看账号名和账号ID。 - [修订记录](https://support.huaweicloud.com/api-hrm/hrm-api-0014.md): 华为云帮助中心，为用户提供产品简介、价格说明、购买指南、用户指南、API参考、最佳实践、常见问题、视频帮助等技术文档，帮助您快速上手使用华为云服务。 ## SDK参考 - [SDK概述](https://support.huaweicloud.com/sdkreference-hrm/hrm-sdk-001.md): 本文介绍了分布式消息服务RocketMQ版提供的SDK语言版本，列举了最新版本SDK的获取地址。API Explorer能根据需要动态生成SDK代码功能，降低您使用SDK的难度，推荐使用。表1提供了分布式消息服务RocketMQ版支持的SDK列表，您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。表1提供的SDK为管 ## CLI参考 - [如何使用CLI](https://support.huaweicloud.com/clir-hrm/rocketmq-cli-001.md): 华为云命令行工具服务（Koo Command Line Interface，KooCLI，原名HCloud CLI）是为发布在API Explorer上的云服务API提供的命令行管理工具。您可以通过此工具调用API Explorer中RocketMQ开放的API，管理和使用您的RocketMQ资源。关于KooCLI的详细信息，请参见什么是 - [CLI命令参考](https://support.huaweicloud.com/clir-hrm/RocketMQ-cli.md): 华为云帮助中心，为用户提供产品简介、价格说明、购买指南、用户指南、API参考、最佳实践、常见问题、视频帮助等技术文档，帮助您快速上手使用华为云服务。 ## 常见问题 - [RocketMQ实例兼容开源RocketMQ哪个版本？](https://support.huaweicloud.com/hrm-faq/hrm-faq-002.md): RocketMQ实例兼容开源RocketMQ 4.8.0和5.x，Java客户端推荐使用5.1.4及更新的版本。 - [实例可靠性是怎么保障的？](https://support.huaweicloud.com/hrm-faq/hrm-faq-003.md): 通过以下两方面保障实例的可靠性：RocketMQ实例采用一主两备的方式存储数据RocketMQ实例支持跨AZ部署 - [为什么RocketMQ 4.8.0版本不能选择2个可用区？](https://support.huaweicloud.com/hrm-faq/hrm_faq_021.md): 如果您需要提高RocketMQ集群实例的可靠性，在创建4.8.0版本实例时，建议选择3个或以上的可用区，不支持选择2个可用区。原因如下：使用2个可用区的实例，如果其中一个可用区故障，可能会导致实例不可用。 - [RocketMQ实例的SSL配置是否支持修改？](https://support.huaweicloud.com/hrm-faq/hrm_faq_022.md): SSL配置支持修改，具体步骤请参考修改SSL。 - [RocketMQ实例的SSL开启后，客户端代码是否需要配置证书？](https://support.huaweicloud.com/hrm-faq/hrm_faq_031.md): 开启SSL后，客户端默认忽略证书校验，无需配置证书，但需要增加开启SSL的代码。具体请参考开发指南中客户端访问RocketMQ的示例代码。 - [磁盘类型对RocketMQ实例性能有什么影响？](https://support.huaweicloud.com/hrm-faq/hrm_faq_028.md): RocketMQ会将收到的消息进行持久化，因此，消息生产的吞吐量会一定程度上受到磁盘规格的影响。在其它条件相同的情况下，磁盘吞吐量越高，生产消息的性能越好。当磁盘性能达到瓶颈时，磁盘访问时延会增加，进而导致生产消息请求时延增加，严重情况下可能造成生产消息失败。RocketMQ消息落盘使用的是顺序写，在新的消息生产到消息队列上时，会先将消息 - [RocketMQ 4.8.0版本实例仅配置单组Broker有什么影响？](https://support.huaweicloud.com/hrm-faq/hrm_faq_030.md): 当使用RocketMQ 4.8.0版本实例，且只创建了一组Broker，或者Topic仅关联了一组Broker时，如果Broker故障则会触发主备倒换，且恢复时间较长，为30秒左右。如果Topic关联了多组Broker，Broker故障时，生产流量可自动切换到另一组Broker，可用性更高。您可以使用如下方法处理RocketMQ 4.8. - [RocketMQ实例兼容开源RocketMQ哪个版本？](https://support.huaweicloud.com/hrm-faq/hrm-faq-002.md): RocketMQ实例兼容开源RocketMQ 4.8.0和5.x，Java客户端推荐使用5.1.4及更新的版本。 - [实例可靠性是怎么保障的？](https://support.huaweicloud.com/hrm-faq/hrm-faq-003.md): 通过以下两方面保障实例的可靠性：RocketMQ实例采用一主两备的方式存储数据RocketMQ实例支持跨AZ部署 - [为什么RocketMQ 4.8.0版本不能选择2个可用区？](https://support.huaweicloud.com/hrm-faq/hrm_faq_021.md): 如果您需要提高RocketMQ集群实例的可靠性，在创建4.8.0版本实例时，建议选择3个或以上的可用区，不支持选择2个可用区。原因如下：使用2个可用区的实例，如果其中一个可用区故障，可能会导致实例不可用。 - [RocketMQ实例的SSL配置是否支持修改？](https://support.huaweicloud.com/hrm-faq/hrm_faq_022.md): SSL配置支持修改，具体步骤请参考修改SSL。 - [RocketMQ实例的SSL开启后，客户端代码是否需要配置证书？](https://support.huaweicloud.com/hrm-faq/hrm_faq_031.md): 开启SSL后，客户端默认忽略证书校验，无需配置证书，但需要增加开启SSL的代码。具体请参考开发指南中客户端访问RocketMQ的示例代码。 - [磁盘类型对RocketMQ实例性能有什么影响？](https://support.huaweicloud.com/hrm-faq/hrm_faq_028.md): RocketMQ会将收到的消息进行持久化，因此，消息生产的吞吐量会一定程度上受到磁盘规格的影响。在其它条件相同的情况下，磁盘吞吐量越高，生产消息的性能越好。当磁盘性能达到瓶颈时，磁盘访问时延会增加，进而导致生产消息请求时延增加，严重情况下可能造成生产消息失败。RocketMQ消息落盘使用的是顺序写，在新的消息生产到消息队列上时，会先将消息 - [RocketMQ 4.8.0版本实例仅配置单组Broker有什么影响？](https://support.huaweicloud.com/hrm-faq/hrm_faq_030.md): 当使用RocketMQ 4.8.0版本实例，且只创建了一组Broker，或者Topic仅关联了一组Broker时，如果Broker故障则会触发主备倒换，且恢复时间较长，为30秒左右。如果Topic关联了多组Broker，Broker故障时，生产流量可自动切换到另一组Broker，可用性更高。您可以使用如下方法处理RocketMQ 4.8. - [RocketMQ是否支持自建Broker连接云上nameserver？](https://support.huaweicloud.com/hrm-faq/hrm_faq_019.md): 不支持。自建Broker连接到云上RocketMQ的nameserver，会影响管理面功能，导致查询不到Topic等问题。 - [连接实例失败，报错RemotingTooMuchRequestException: sendDefaultImpl call timeout](https://support.huaweicloud.com/hrm-faq/hrm_faq_023.md): 连接RocketMQ实例失败，报错“RemotingTooMuchRequestException: sendDefaultImpl call timeout”。用户在安全组中未放通业务节点的端口。登录RocketMQ实例控制台。单击RocketMQ实例的名称，进入实例概览页面。获取“网络 > 需要放通的地址”中的端口号。单击安全组名称， - [连接实例失败，报错RemotingTimeoutException: wait response on the channel timeout](https://support.huaweicloud.com/hrm-faq/hrm_faq_034.md): 使用SDK或客户端连接RocketMQ实例时，出现类似以下错误：客户端与RocketMQ实例建立连接后，在等待服务端响应时，由于网络不通、SSL配置不一致、服务端负载过高或防火墙拦截等原因，导致请求超过了预设的超时时间。检查网络连通性。确认客户端能正常访问RocketMQ实例的IP和端口。使用telnet测试端口。telnet 需要放通的地址”中的端口号。单击安全组名称， - [连接实例失败，报错RemotingTimeoutException: wait response on the channel timeout](https://support.huaweicloud.com/hrm-faq/hrm_faq_034.md): 使用SDK或客户端连接RocketMQ实例时，出现类似以下错误：客户端与RocketMQ实例建立连接后，在等待服务端响应时，由于网络不通、SSL配置不一致、服务端负载过高或防火墙拦截等原因，导致请求超过了预设的超时时间。检查网络连通性。确认客户端能正常访问RocketMQ实例的IP和端口。使用telnet测试端口。telnet