检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RocketMQ业务使用流程 分布式消息服务RocketMQ版(以下简称RocketMQ)是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。用户购买RocketMQ实例后,生产者客户端连接RocketMQ实例进行消息生产,生产的消息被存储在RocketMQ实例
分布式消息服务RocketMQ版的版本号格式为:消息引擎类型 x.y.z,其中消息引擎类型为RocketMQ,版本号具体含义如图1所示。 图1 版本号示例 版本支持情况 分布式消息服务RocketMQ版支持的版本:4.8.0、5.x 版本生命周期 分布式消息服务RocketMQ版的版本生命周期如表1所示。
在电商促销活动中,需要用户拥有订阅通知的能力。 分布式消息服务RocketMQ版为搭建电商系统提供了更多的选择。 分布式消息服务RocketMQ版可以解除多个业务系统之间的耦合度,提升各系统的处理能力和响应速度。 分布式消息服务RocketMQ版提供的定时、延迟等能力,满足需要订阅通知的电商场景。 金融场景
API V2(推荐) 生命周期管理 消费组管理 Topic管理 消息管理 用户管理 元数据迁移 参数管理 标签管理 其他接口 规格变更管理 实例管理
Java(TCP协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问 消费端限流 RocketMQ-Spring的使用
RocketMQ实例创建成功后,您可以根据业务需要,进行扩容,4.8.0版本的RocketMQ实例支持的变更配置如表1所示,5.x版本的RocketMQ实例支持的变更配置如表2所示。 表1 变更配置列表(RocketMQ实例4.8.0版本) 变更配置类型 是否支持扩容 是否支持缩容 代理个数 √
为分布式消息服务RocketMQ版的其他监控指标设置告警通知。 前提条件 已购买RocketMQ实例、创建Topic,并且已成功消费消息。 实施步骤 本操作中RocketMQ实例相关的截图以5.x基础版为例。 登录分布式消息服务RocketMQ版控制台,单击待创建告警通知的实例名称,进入实例详情页。
适用计费项 分布式消息服务RocketMQ版对您选择的RocketMQ实例和RocketMQ的磁盘存储空间收费。以下计费项支持包年/包月。 表1 适用计费项 计费项 说明 实例费用 4.8.0版本的实例费用包括代理规格和代理数量。 5.x基础版和专业版的实例费用包括TPS和部署类型。 存储空间费用
构造请求 本节介绍REST API请求的组成,并以调用IAM服务的管理员创建IAM用户来说明如何调用API。 您还可以通过这个视频教程了解如何构造请求调用API:https://bbs.huaweicloud.com/videos/102987。 请求URI 请求URI由如下部分组成。
获取项目ID 操作场景 在调用接口的时候,部分URL中需要填入项目ID,所以需要获取到项目ID。有如下两种获取方式: 调用API获取项目ID 从控制台获取项目ID 调用API获取项目ID 项目ID可以通过调用查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET ht
收集连接信息 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议,4.8.0版本不支持。 获取实例连接信息 实例连接地址和端口 实例创建后,从RocketMQ实例控制台的“基本信息”页面获取,在客户端配置时,可将地址都配上。 使用TCP协议通过内网连接RocketMQ实例时,获取“连接地址”。
Java(gRPC协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息
请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。 选择以下任意一种方法删除按需的RocketMQ实例。 在待删除的RocketMQ实例所在行,单击“更多 > 删除”。
请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“消息查询”,进入“消息查询”页面。 选择以下任意一种方法,查询消息。
适用计费项 分布式消息服务RocketMQ版对您选择的RocketMQ实例和RocketMQ的磁盘存储空间收费。以下计费项支持按需计费。 表1 适用计费项 计费项 说明 实例费用 4.8.0版本的实例费用包括代理规格和代理数量。 5.x基础版和专业版的实例费用包括TPS和部署类型。 存储空间费用
与其他云服务的关系 虚拟私有云(Virtual Private Cloud) RocketMQ实例运行于虚拟私有云,需要使用虚拟私有云创建的IP和带宽。通过虚拟私有云安全组的功能可以增强访问RocketMQ实例的安全性。 云监控(Cloud Eye) 云监控是一个开放性的监控平台
批量创建Topic RocketMQ未提供批量创建Topic接口,用户想批量创建Topic时只能手动多次调用接口一个个创建,效率低下。现通过代码实现接口循环调用,可实现批量创建Topic的效果。 前提条件 已获取IAM和RocketMQ服务所在区域的Endpoint地址。 已获取
API V2 查询指定实例 查询所有消费组 更新消费组 修改指定消费组 删除指定消费组 父主题: 历史API
请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“消息查询”,进入“消息查询”页面。 在
实现订阅关系一致 方案概述 订阅关系一致指的是同一个消费组下所有消费者所订阅的Topic、Tag必须完全一致。如果订阅关系不一致,消息消费的逻辑就会混乱,甚至导致消息丢失。 消费原理 RocketMQ为每个Topic划分了消息队列(Queue),队列数越大消费的并发度越大。一个消