检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
示。 表1 分布式消息服务RocketMQ版计费项 计费项 计费项说明 适用的计费模式 计费公式 实例费用 4.8.0版本计费因子:代理规格和代理数量 5.x基础版和专业版计费因子:TPS和部署类型 包年/包月、按需计费 实例规格单价 * 购买时长 实例规格单价请参见分布式消息服
0版本的实例费用包括代理规格和代理数量。 5.x基础版和专业版的实例费用包括TPS和部署类型。 存储空间费用 总存储空间的费用。随包年/包月RocketMQ实例创建的存储空间,其计费模式也为包年/包月。 4.8.0版本时,总存储空间的费用为单个代理的存储空间*代理数量。 假设您计划购买一个RocketMQ
务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务回滚。服务端在一段时间后如果一直收不到提交或回滚,则发起回查,生产者在收到回查后重新发送事
包括创建实例、修改实例信息、查询实例、删除实例、查询代理列表。 消费组管理 包括查询消费组、创建消费组、删除消费组、修改消费组、查询消费列表或详情、重置消费进度。 Topic管理 包括创建主题、删除主题、查询主题、修改主题、查询主题消费组列表、查询主题的消息数。 消息管理 包括查询消息、查询消息轨迹
Number 读队列个数。 write_queue_num Number 写队列个数。 请求示例 查询指定RocketMQ实例的主题列表,查询数量为10,从offset=0开始查询。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics
名和账号ID。账号名和账号ID获取步骤如下: 登录管理控制台。 鼠标悬停在右上角的用户名,选择下拉列表中的“我的凭证”。 查看账号名和账号ID。 图1 查看账号名和账号ID 父主题: 附录
String 变更类型 取值范围: storage:存储空间扩容,代理数量不变。 horizontal:代理数量扩容,每个broker的存储空间不变。 vertical:垂直扩容,broker的底层虚机规格变更,代理数量和存储空间不变。 new_storage_space 否 Integer
控制台查询,也可以通过查询VPC列表API查询。 subnet_id:VPC内子网的网络ID。您可以在虚拟私有云控制台查询,也可以通过查询子网列表API查询。 security_group_id:安全组ID。您可以在虚拟私有云控制台查询,也可以通过查询安全组列表API查询。 av
查询指定消费组 功能介绍 查询指定消费组详情。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/groups/{group} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是
服务资源操作请求以及每次请求的结果,供您查询、审计和回溯使用。 弹性云服务器(Elastic Cloud Server) 弹性云服务器是由CPU、内存、操作系统、云硬盘组成的基础的计算组件。RocketMQ实例运行在弹性云服务器上,一个代理对应三台弹性云服务器。 云硬盘(Elastic
最后一条消息的时间。 请求示例 查询指定主题的消息数。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}/status 响应示例 状态码: 200 查询成功 查询主题的消息数成功。 {
接收消息的对象,负责从服务端获取消息。 消费组(Consumer Group) 多个消费者组成同一个消费组,同一消费组内的消费者具有相同的消费属性。 代理(Broker) 一组节点构成的一个业务集群。 NameServer 存储元数据信息的轻量级注册中心。生产者/消费者在生产/消费消息前,需要先从NameServer获取元数据。
根据业务发展需要,您可以修改实例安全组、开启公网访问。除此之外,您还可以实时查看监控指标及审计日志,以便及时了解RocketMQ实例节点、Topic、消费组等相关状态。 常用操作 查看和修改RocketMQ实例基本信息 开启公网访问 运维与监控 支持的监控指标 查看监控数据 支持的云审计操作列表 06 API
在左侧导航栏,单击“消息查询”,进入“消息查询”页面。 选择以下任意一种方法,查询消息。 按Topic查询:“Topic”选择待查询消息的Topic名称,“队列”选择待查询消息的队列(仅RocketMQ实例4.8.0版本需要选择),“存储时间”选择待查询消息的时间段,单击“查询”。 按Message
查询消费组列表 功能介绍 查询消费组列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/groups 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。
合规证书下载 资源中心 华为云还提供以下资源来帮助用户满足合规性要求,具体请查看资源中心。 图2 资源中心 销售许可证&软件著作权证书 另外,华为云还提供了以下销售许可证及软件著作权证书,供用户下载和参考。具体请查看合规资质证书。 图3 销售许可证&软件著作权证书 父主题: 安全
require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送顺序消息
require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送定时消息
3个Broker节点,购买2个Broker时(如图1所示)创建6个Broker节点,以此类推。NameServer为2个节点。 图1 选择代理数量 单可用区 实例选择单可用区部署时,实例下的所有组件均部署在相同的可用区内。单可用区部署会默认配置为反亲和部署。反亲和部署是出于高可用
require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 同步发送