检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
opic的效果。 前提条件 已获取IAM和RocketMQ服务所在区域的Endpoint地址。 已获取RocketMQ实例的实例ID，以及实例所在区域的项目ID。 使用华为云SDK 5.x版本批量创建不同类型的Topic 新建“topics.txt”文件，用于存放待创建的Topic信息。
23:59:59 图1给出了上述示例配置的费用计算过程。 图中价格仅供参考，实际计算请以分布式消息服务RocketMQ版价格详情中的价格为准。 图1 包年/包月RocketMQ实例费用计算示例（华北-北京四区域） 按需计费模式下，各计费项的计费示例请参见计费示例。
第二章介绍如何获取RocketMQ实例连接信息。 第三章~第七章介绍Java、Go和Python客户端访问分布式消息服务RocketMQ版的示例代码，具体如表1所示。 表1 示例代码 客户端语言 示例代码 Java（TCP协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息
备节点分别创建在不同的物理机上。 多可用区 多可用区部署的前提需要满足该区域下有3个及3个以上的可用区选项，如图2所示。 图2 选择可用区 实例选择多可用区部署时，实例下的组件分别部署在三个不同的可用区内，可实现跨可用区容灾部署能力。 NameServer的2个节点分别部署在两个可用区中。
pName", rpcHook); ACL_ACCESS_KEY为用户名，ACL_SECRET_KEY为用户的密钥。创建用户的步骤，请参见创建用户。为了确保用户名和密钥的安全性，建议对用户名和密钥进行加密处理。 消费者增加用户认证信息 消费者初始化时需要增加“rpcHook”参数
Key查询：“Topic”选择待查询消息所在的Topic名称，“Message Key”输入待查询消息的Message Key，单击“查询”。 在待查询消息所在行，单击“查看详情”，查看消息的具体内容。 消息的具体内容包括消息大小、消息的生成时间以及消息的内容。 图1 查看消息详情 消息体
Key)：与访问密钥ID结合使用的密钥，对请求进行加密签名，可标识发送方，并防止请求被修改。 使用AK/SK认证时，您可以基于签名算法使用AK/SK对请求进行签名，也可以使用专门的签名SDK对请求进行签名。详细的签名方法和SDK使用方法请参见API签名指南。 签名SDK只提供签名功能，与服务提供的SDK不同，使用时请注意。
置过多或不足的风险。一般适用于电商抢购等业务需求量瞬间大幅波动的场景。 表1列出了两种计费模式的区别。 表1 计费模式 计费模式 包年/包月 按需计费 付费方式 预付费 按照订单的购买周期结算。 后付费 按照RocketMQ实例实际使用时长计费。 计费周期 按订单的购买周期计费。
管理页面。 在“后台任务”或“定时任务”页签左上角选择需要查看的时间段，界面显示相应时间段内启动的后台任务或定时任务。 在后台任务管理页面，您还可以执行以下操作： 通过筛选来查询对应的RocketMQ实例。当前支持的筛选条件为任务名、用户名、状态和其他信息。 单击“删除”，弹出“
请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在左侧导航栏，选择“实例诊断”，进入实例诊断页面。 选择待诊断的消费组名称，单击“开始诊断”。
如果您需要长期使用当前按需购买的RocketMQ实例，可以将该RocketMQ实例转为包年/包月计费模式，以节省开支。按需计费变更为包年/包月会生成新的订单，用户支付订单后，包年/包月资源将立即生效。 假设用户于2023/04/18 15:29:16购买了一个按需计费的RocketMQ实例，由于业务需要，于2023/04/18
配置RocketMQ实例标签 导出RocketMQ实例列表 诊断RocketMQ实例 重启RocketMQ实例的Broker节点 删除RocketMQ实例 配置RocketMQ实例回收站策略 修改RocketMQ实例的SSL配置 开启RocketMQ实例弹性TPS功能
x版本支持流控。 出现如下两种情况会触发流控： 短时间内生产、消费消息请求数量过多。 秒级突发流量过大时，可能出现该秒请求被流控。 监控数据采集的是一分钟内平均TPS，不是秒级监控。 当请求被流控时，会导致生产消息请求失败，且服务端返回215错误码。为避免出现流控情况，请确保生产、消费TPS在给定实例规格内。
系一致的概念、原理以及实施方法。 消息堆积处理建议 本章节介绍出现消息堆积的主要原因和实施方法。 配置消息堆积数监控 本章节介绍RocketMQ通过云监控配置告警规则的具体操作，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。
实例问题 RocketMQ实例兼容开源RocketMQ哪个版本？ 实例可靠性是怎么保障的？ 为什么RocketMQ 4.8.0版本不能选择2个可用区？ RocketMQ实例的SSL配置是否支持修改？ 磁盘类型对RocketMQ实例性能有什么影响？
自动续费可以减少手动续费的管理成本，避免因忘记手动续费而导致RocketMQ实例被自动删除。自动续费的规则如下所述： 以RocketMQ实例的到期日计算第一次自动续费日期和计费周期。 RocketMQ实例自动续费周期根据您开通自动续费的途径不同，遵循不同的规则。 在RocketM
send_message_sync() 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 topic：表示Topic名称。 gid：表示生产者组名称，请根据业务实际情况输入生产者组名称。 name_srv：表示实例连接地址和端口。 ACL_ACCESS_KEY：表示用户名。创建用户的步骤，请参见创建用户。
已被处理过的消息，最终消费者会消费到两条内容一样的重复消息。 实施方法 从上面的消费重复场景可以看到，不同Message ID的消息可能有相同的消息内容，因此Message ID无法作为消息的唯一标识符。RocketMQ可以为消息设置Key，把业务的唯一标识作为消息的唯一标识，从
2024-09-04 本次变更如下： 更新查询RocketMQ配置的响应示例。 2024-07-05 本次变更如下： 新增应用示例批量创建Topic。 2023-12-15 本次变更如下： 新增查询实例的扩容规格列表和实例规格变更接口。 2023-06-06 本次变更如下：
包括创建主题、删除主题、查询主题、修改主题、查询主题消费组列表、查询主题的消息数。 消息管理 包括查询消息、查询消息轨迹、导出死信消息、重发死信消息、消费验证。 用户管理 包括创建用户、查询用户、修改用户、删除用户、查询主题的授权用户列表、查询消费组的授权用户列表。 元数据迁移 包括新建元数据迁移任务
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
