检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
0版本的实例费用包括代理规格和代理数量。 5.x基础版和专业版的实例费用包括TPS和部署类型。 存储空间费用 总存储空间的费用。随包年/包月RocketMQ实例创建的存储空间,其计费模式也为包年/包月。 4.8.0版本时,总存储空间的费用为单个代理的存储空间*代理数量。 假设您计划购买一个RocketMQ
示。 表1 分布式消息服务RocketMQ版计费项 计费项 计费项说明 适用的计费模式 计费公式 实例费用 4.8.0版本计费因子:代理规格和代理数量 5.x基础版和专业版计费因子:TPS和部署类型 说明: 实例在账单中显示的产品名称为“分布式消息服务专享版”,如图1所示。 包年/包月、按需计费
Cloud Server) 弹性云服务器是由CPU、内存、操作系统、云硬盘组成的基础的计算组件。RocketMQ实例运行在弹性云服务器上,一个代理对应三台弹性云服务器。 云硬盘(Elastic Volume Service) 云硬盘为云服务器提供块存储服务,RocketMQ的所有数据
指标说明:该指标为从RocketMQ节点虚拟机层面采集的CPU每个核的平均负载。 处理建议:出现该告警时,参考如下操作: 扩容实例代理个数。具体操作,请参考变更实例规格。 将已有Topic扩展到新代理上。具体操作,请参考修改RocketMQ Topic配置。 内存使用率 0~100 告警阈值:原始值>85
RocketMQ实例创建成功后,您可以根据业务需要,扩容存储空间和代理个数。不支持同时扩容存储空间和代理个数,如果需要可以分别进行扩容。 当前只支持扩容,不支持缩容。扩容存储空间有次数限制,只能扩容20次。 支持区域: 全部 扩容存储空间或代理个数 公网访问 您需要通过公网地址访问RocketM
修改是否开启SSL 修改SSL的配置。 开启公网访问 修改“公网访问”为开启。 关闭公网访问 修改“公网访问”为关闭。 变更规格 扩容存储空间 扩容代理数量 扩容代理规格 批量删除消费组 选择多个消费组,进行批量删除。 批量删除Topic 选择多个Topic,进行批量删除。 消息轨迹变更 消息轨迹发生变化。
0版本仅支持“集群”。 代理/实例规格 请根据业务需求选择相应的代理/实例规格。 5.x版本时,该参数显示为“实例规格”。 4.8.0版本时,该参数显示为“代理规格”。 请根据实际情况选择。 代理数量 选择代理数量。 4.8.0版本时才显示该参数。 单个代理存储空间/存储空间 存储
接收消息的对象,负责从服务端获取消息。 消费组(Consumer Group) 多个消费者组成同一个消费组,同一消费组内的消费者具有相同的消费属性。 代理(Broker) 一组节点构成的一个业务集群。 NameServer 存储元数据信息的轻量级注册中心。生产者/消费者在生产/消费消息前,需要先从NameServer获取元数据。
迁移元数据导入Topic和消费组时,Topic和消费组会创建在所有代理上。因此,在4.8.0版本中,迁移能导入的Topic上限为单个代理的Topic上限。例如,rocketmq.4u8g.cluster*2代理的实例,单个代理Topic上限为4000,则通过迁移整个实例最多能导入4000个Topic。
objects Topic关联代理(当查询Topic消费“详情”才显示此参数)。 表4 Brokers 参数 参数类型 描述 broker_name String Topic关联代理名称。 queues Array of Queue objects 关联代理的队列详情。 表5 Queue
配置RocketMQ实例的公网访问 您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。当业务不再使用公网访问功能时,关闭实例的公网访问功能。 约束与限制 RocketMQ实例只支持绑定IPv4弹性IP地址。 前提条件 只有处于“运行中”状态
enabled Boolean 是否可以消费。 broadcast Boolean 是否广播。 brokers Array of strings 关联的代理列表。 name String 消费组名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。 group_desc
生命周期管理 查询所有实例列表 创建实例 查询指定实例 删除指定的实例 修改实例信息 批量删除实例 查询代理列表 父主题: API V2(推荐)
of brokers objects 关联的代理。 message_type String 消息类型(RocketMQ实例5.x版本才包含此参数)。 表3 brokers 参数 参数类型 描述 broker_name String 代理名称。 read_queue_num Number
3个Broker节点,购买2个Broker时(如图1所示)创建6个Broker节点,以此类推。NameServer为2个节点。 图1 选择代理数量 单可用区 实例选择单可用区部署时,实例下的所有组件均部署在相同的可用区内。单可用区部署会默认配置为反亲和部署。反亲和部署是出于高可用
查看RocketMQ消费者连接地址 消费者连接地址即消费消息的客户端地址,当客户端连接RocketMQ消费消息时,可通过控制台查看客户端的连接地址。 约束与限制 消费者处于连接RocketMQ实例时,才可以查看消费者连接地址。 前提条件 已创建消费组,且消费组中已存在消费者。 已创建Topic。
of brokers objects 关联的代理。 message_type String 消息类型(RocketMQ实例5.x版本才包含此参数)。 表5 brokers 参数 参数类型 描述 broker_name String 代理名称。 read_queue_num Number
API概览 表1 实例管理类接口 API 说明 生命周期管理 包括创建实例、修改实例信息、查询实例、删除实例、查询代理列表。 消费组管理 包括查询消费组、创建消费组、删除消费组、修改消费组、查询消费列表或详情、重置消费进度。 Topic管理 包括创建主题、删除主题、查询主题、修改
境使用。 5.x版本的优势 与4.8.0版本相比,5.x版本具有如下优势: 架构更先进 5.x版本提供无状态的Proxy接入,解决无法通过代理访问的问题。5.x提供了Pop消费模式,降低消费堆积发生的概率。 开发门槛更低 支持开源gRPC协议SDK,提供更多种语言的SDK,API更加简洁友好。
require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送定时消息