检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
收发消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议，4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发普通消息前，需要确保Topic的消息类型为“普通”。 准备环境 执行以下命令，检查是否已安装Go。
收发顺序消息 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息： 全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First
请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在左侧导航栏，单击“死信队列”，进入“死信队列”页面。 选择以下任意一种方法，查询死信消息。
请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 在实例所在行，单击实例名称，进入实例详情页面。 在左侧导航栏单击“标签”，进入标签管理页面。 界面显示该实例的标签列表。
实例规格说明（分布式消息服务RocketMQ版5.x基础版单机） 资源规格 存储容量（GB） 实例TPS 实例Topic数上限 实例消费组数上限 rocketmq.b1.large.1 100 ~ 30000 500 50 500 表3 实例规格说明（分布式消息服务RocketMQ版5.x基础版集群） 资源规格
计费模式概述 分布式消息服务RocketMQ版提供包年/包月和按需计费两种计费模式，以满足不同场景下的用户需求。 包年/包月：一种预付费模式，即先付费再使用，按照订单的购买周期进行结算。购买周期越长，享受的折扣越大。一般适用于业务需求量长期稳定的成熟业务。 按需计费：一种后付费模
实现订阅关系一致 方案概述 订阅关系一致指的是同一个消费组下所有消费者所订阅的Topic、Tag必须完全一致。如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。 消费原理 RocketMQ为每个Topic划分了消息队列（Queue），队列数越大消费的并发度越大。一个消
API V1 实例管理类接口 其他接口 父主题： 历史API
元数据迁移 新建元数据迁移任务 查询实例下所有迁移任务或查询指定迁移任务信息 删除元数据迁移任务 父主题： API V2（推荐）
在分布式消息服务RocketMQ版中，消费者消费消息时，可能会出现消费过快导致下游业务来不及处理的情况，进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码，以保障系统的稳定。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务
通过消息幂等实现消息去重 方案概述 在RocketMQ的业务处理过程中，如果消息重发了多次，消费者端对该重复消息消费多次与消费一次的结果是相同的，多次消费并没有对业务产生负面影响，那么这个消息处理过程是幂等的。消息幂等保证了无论消息被重复投递多少次，最终的处理结果都是一致的，避免了因消息重复而对业务产生影响。
标签管理 批量添加或删除实例标签 查询实例标签 查询项目标签 父主题： API V2（推荐）
收发顺序消息 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息： 全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First
客户端连接RocketMQ实例5.x版本收发普通消息前，需要确保Topic的消息类型为“普通”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖： 使用Maven方式引入依赖。 <dependency> <groupId>org
发送定时消息 分布式消息服务RocketMQ版支持任意时间的定时消息，最大推迟时间可达到1年。同时也支持定时消息的取消。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前，请参考收
在IAM控制台创建用户，并将其加入1中创建的用户组。 用户登录并验证权限 新创建的用户登录控制台，切换至授权区域，验证权限： 在“服务列表”中选择分布式消息服务RocketMQ版分布式消息服务RocketMQ，进入RocketMQ实例主界面，单击右上角“购买RocketMQ实例”，尝试购买RocketMQ实例，如果无
请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称，进入实例详情页面。 在左侧导航栏，单击“消费组管理”，进入消费组列表页面。 在
配置RocketMQ网络连接 连接RocketMQ网络要求 配置RocketMQ实例的公网访问 父主题： 连接实例
配置RocketMQ访问控制 开启RocketMQ ACL访问 配置RocketMQ ACL用户 父主题： 连接实例
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
