检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Topic名称的命名规则是什么？ 创建Topic时，请确保唯一性。Topic名称命名规则必须满足如下要求： 长度为3~64个字符。 只能由英文字母、数字、百分号、竖线、中划线、下划线组成。 不能以“rmq_sys_”开头。 不能和以下字符串相同： TBW102 SCHEDULE_TOPIC_XXXX BenchmarkTest
重置消费进度可能会导致重复消费，请谨慎操作。 操作视频 本视频演示重置RocketMQ消费进度的操作。 前提条件 已创建消费组，且消费组中已存在消费者。 已创建Topic。 重置RocketMQ消费进度 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
消费。相关代码您可以从rocketmq-springboot-demo中获取。 下文所有RocketMQ的配置信息，如实例连接地址、Topic名称、用户信息等，请参考收集连接信息获取。 在pom.xml文件中引入RocketMQ-Spring依赖 <dependency>
服务。用户购买RocketMQ实例后，生产者客户端连接RocketMQ实例进行消息生产，生产的消息被存储在RocketMQ实例的Topic中，消费者客户端通过订阅Topic消费消息。 使用RocketMQ实例生产消费消息的流程如下图所示。 图1 RocketMQ业务使用流程 创建用户并授权使用DMS
创建实例时或者在实例基本信息中，将“SSL”配置为“SSL”或“PERMISSIVE”（通过密文传输），即为已开启SSL。 操作视频 本视频演示使用客户端连接RocketMQ实例的操作。 前提条件 已创建RocketMQ实例，并记录实例详情中的“连接地址”（内网访问）/“公网
从控制台获取项目ID 在调用接口的时候，部分URL中需要填入项目ID（project_id），所以需要先在管理控制台上获取到项目ID。 项目ID获取步骤如下： 登录管理控制台。 鼠标悬停在右上角的用户名，选择下拉列表中的“我的凭证”。 在“API凭证”页面的项目列表中查看项目ID。 图1 查看项目ID
本章节介绍RocketMQ实例如何在控制台生产消息。此功能通过将指定消息发送给RocketMQ实例，验证业务逻辑是否正常。 前提条件 已存在“运行中”的RocketMQ实例。 已创建Topic。 使用控制台连接RocketMQ生产消息 登录管理控制台。 在管理控制台左上角单击，选择区域。
消费消息的记录。当您需要使用相同的Topic和消费组时，可通过元数据迁移操作将已有的Topic和消费组信息迁移到指定的RocketMQ实例中，无需再手动创建。 RocketMQ业务迁移主要涉及以下场景： 迁移其他RocketMQ的元数据到华为云上RocketMQ实例。其他RocketMQ元数据包括如下内容：
时，可通过控制台查看客户端的连接地址。 消费者处于连接RocketMQ实例时，才可以查看消费者连接地址。 前提条件 已创建消费组，且消费组中已存在消费者。 已创建Topic。 查看RocketMQ消费者连接地址 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
配置RocketMQ实例的公网访问 内网连接 客户端和RocketMQ实例部署在同一个VPC中，此时网络默认互通。 - 客户端和RocketMQ实例部署在同一个Region的不同VPC中，利用VPC对等连接将两个VPC间的网络打通，实现跨VPC访问。 对等连接 客户端连接Rock
您需要通过公网地址访问RocketMQ实例时，开启实例的公网访问功能，并设置弹性IP地址。当业务不再使用公网访问功能时，关闭实例的公网访问功能。 前提条件 只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。 开启公网访问 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
消费端限流 在分布式消息服务RocketMQ版中，消费者消费消息时，可能会出现消费过快导致下游业务来不及处理的情况，进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码，以保障系统的稳定。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4
常的场景，借助实例诊断功能可以帮助您快速定位问题。 操作视频 本视频演示诊断RocketMQ实例的操作。 前提条件 已创建消费组，且消费组中已存在消费者。 已创建Topic。 诊断实例 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
Q实例中创建迁移任务。 方法二：导出源实例的Topic和消费组列表（适用于不支持通过mqadmin命令导出元数据的场景），然后通过脚本将Topic和消费组列表导入到云上RocketMQ实例中。 前提条件 已购买RocketMQ实例。 准备一台Linux系统的主机，在主机中安装Java
IAM是华为云提供权限管理的基础服务，无需付费即可使用，您只需要为您账号中的资源进行付费。关于IAM的详细介绍，请参见《IAM产品介绍》。 DMS for RocketMQ的权限与策略基于分布式消息服务DMS，因此在IAM服务中为DMS for RocketMQ分配用户与权限时，请选择并使用“DMS”的权限与策略。
实施步骤 本操作中RocketMQ实例相关的截图以5.x基础版为例。 登录分布式消息服务RocketMQ版控制台，单击待创建告警通知的实例名称，进入实例详情页。 在左侧导航栏，选择“监控与告警 > 监控”，进入监控页面。 在“消费组”页签的“消费组”下拉框中，选择需要创建告警通知的消费组。
开启和查询RocketMQ消息轨迹 在一条消息从生产者发出到消费者消费处理过程中，由各个相关节点的时间、地点等数据汇聚而成的完整链路信息。通过消息轨迹，您能清晰定位消息从生产者发出，经由RocketMQ服务端，投递给消费者的完整链路，方便定位排查问题。 本章节介绍使用Java、G
验证RocketMQ消息消费 消费验证是将消息重新发送到指定的在线客户端，验证消费者能否收到消息。消费验证会导致消息重复消费。 前提条件 仅在实例的“状态”为“运行中”时，才可以进行消费验证。 确保待进行消费验证的客户端处于在线状态，且消费者已订阅待重新发送的消息所属的Topic。 验证RocketMQ消息消费
通过消息幂等实现消息去重 方案概述 在RocketMQ的业务处理过程中，如果消息重发了多次，消费者端对该重复消息消费多次与消费一次的结果是相同的，多次消费并没有对业务产生负面影响，那么这个消息处理过程是幂等的。消息幂等保证了无论消息被重复投递多少次，最终的处理结果都是一致的，避免了因消息重复而对业务产生影响。
重启RocketMQ实例的Broker节点 分布式消息服务RocketMQ版控制台支持重启实例的某个Broker节点，或者所有Broker节点。 主节点重启过程中，客户端的生产和消费请求会被拒绝，持续时间不超过30s，建议在业务量少时重启节点。重启备节点，不会影响业务的使用。 怎么判断哪个是主节点？
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
