检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go
与其他云服务的关系 虚拟私有云(Virtual Private Cloud) RocketMQ实例运行于虚拟私有云,需要使用虚拟私有云创建的IP和带宽。通过虚拟私有云安全组的功能可以增强访问RocketMQ实例的安全性。 云监控(Cloud Eye) 云监控是一个开放性的监控平台,提供资源的实时监控、告警、通知等服务。
RocketMQ消息落盘使用的是顺序写,在新的消息生产到消息队列上时,会先将消息保存在内存中。如果消费者在启动消费时从最新的消息开始消费,则会直接从内存中获取消息进行消费。 当消费者不是从最新的消息开始消费时,RocketMQ需要从磁盘中读取历史消息保存到内存中,由此产生了冷读现象。如果有大量消费者触发冷读,使I
准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go
变更计费模式 变更计费模式概述 按需转包年/包月 包年/包月转按需
关于两种计费模式的详细介绍请参见计费模式概述。 在购买RocketMQ实例后,如果发现当前计费模式无法满足业务需求,您还可以变更计费模式。详细介绍请参见变更计费模式概述。 计费项 分布式消息服务RocketMQ版的计费项由实例费用和存储空间费用组成。了解每种计费项的计费因子、计费公式等信息,请参考计费项。
查询产品规格 功能介绍 查询产品规格信息。 调用方法 请参见如何调用API。 URI GET /v1.0/products 表1 Query参数 参数 是否必选 参数类型 描述 instance_id 是 String 实例ID。 product_id 是 String 产品ID。
准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go
布式消息服务RocketMQ专享版页面。 通过以下任意一种方法,变更实例规格。 在待变更规格的实例所在行,单击“更多 > 变更规格”。 单击RocketMQ实例名称,进入实例详情页面。单击右上角的“更多 > 变更规格”。 根据实际情况选择扩容的配置。 RocketMQ实例4.8.
理”,可以在其他代理上创建Topic,并设置Topic的队列个数。 如果需要新增关联代理,则需要先扩容代理个数,具体操作请参见变更RocketMQ实例规格。扩容代理个数后,用户可以创建的最大Topic数也会增加。例如扩容前实例的代理数为1,每个代理的最大Topic数为4000;扩
按需转包年/包月 如果您需要长期使用当前按需购买的RocketMQ实例,可以将该RocketMQ实例转为包年/包月计费模式,以节省开支。按需计费变更为包年/包月会生成新的订单,用户支付订单后,包年/包月资源将立即生效。 假设用户于2023/04/18 15:29:16购买了一个按需计费
批量资源到期转按需:选择需要更改计费模式的RocketMQ实例,单击列表左上角的“到期转按需”。 图2 多个资源转按需 查看计费变更的相关信息后,单击“到期转按需”。 图3 到期转按需 父主题: 变更计费模式
发送下一条消息。 以下示例仅介绍同步发送的示例代码。 收发普通消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 在命令行输入python,检查是否已安装Python。得到如下回显,说明Python已安装。 Python 3.7.1 (default, Jul
生产者Java客户端版本在4.9.0以上才支持事务消息的轨迹,如果版本不满足要求,请先升级。 开启SSL的RocketMQ实例,生产者和消费者的Java客户端版本在4.9.2以上才支持消息轨迹,如果版本不满足要求,请先升级。 开启RocketMQ消息轨迹(Java) 在客户端开启消息轨迹的方法如下:
扩容实例代理个数。具体操作,请参考变更实例规格。 将已有Topic扩展到新代理上。具体操作,请参考修改RocketMQ Topic配置。 内存使用率 0~100 告警阈值:原始值>85 连续触发次数:3 告警级别:紧急 是 指标说明:该指标为RocketMQ节点虚拟机层面采集的内存使用率。单位:%。
直没被消费,那么这条消息将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间,大量使用定时消息时需要注意存储空间占用。 准备环境 在命令行输入python,检查是否已安装Python。得到如下回显,说明Python已安装。 Python 3.7.1 (default, Jul
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
查询产品规格列表 功能介绍 查询相应引擎的产品规格列表。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/products 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎的类型。支持的类型为rocketmq。 表2
查询RocketMQ产品规格核数 功能介绍 查询RocketMQ产品规格核数。 调用方法 请参见如何调用API。 URI GET /v2/rocketmq/products/cores 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 core_nume
待规划 不支持 实例诊断 一键诊断消费问题 不支持 实例监控 支持以图表形式查看历史值,18+监控项 仅支持查看当前监控值,不支持CPU、内存等监控指标。 ACL访问控制 灵活配置,一键生效 配置复杂 运维扩容 极速扩容,一键生效 手动扩容,操作复杂