检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置消息堆积数监控 方案概述 在消息处理过程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息没有被及时消费就会产生消息堆积，从而会造成消息消费延迟。 如果您想要在消费组的消息堆积数超过阈值时，通过短信/邮件及时收到通知信息，
高吞吐、动态扩展、便捷多样的消息中间件服务。用户购买RocketMQ实例后，生产者客户端连接RocketMQ实例进行消息生产，生产的消息被存储在RocketMQ实例的Topic中，消费者客户端通过订阅Topic消费消息。 使用RocketMQ实例生产消费消息的流程如下图所示。 图1
cketMQ的磁盘存储空间收费。以下计费项支持按需计费。 表1 适用计费项 计费项 说明 实例费用 4.8.0版本的实例费用包括代理规格和代理数量。 5.x基础版和专业版的实例费用包括TPS和部署类型。 存储空间费用 总存储空间的费用。 4.8.0版本时，总存储空间的费用为单个代理的存储空间*代理数量。
engine_version 是 String 消息引擎的版本。取值填写为：4.8.0。 storage_space 是 Integer 存储空间。 vpc_id 是 String 虚拟私有云ID。 获取方法如下：登录虚拟私有云服务的控制台界面，在虚拟私有云的详情页面查找VPC ID。
15:30:00在“华北-北京四”区域购买了一个按需计费4.8.0版本的RocketMQ实例，规格配置如下： 规格：rocketmq.4u8g.cluster*1 总存储空间：高I/O，300GB 用了一段时间后，用户发现RocketMQ实例当前规格无法满足业务需要，于2023/03/20 9:00:00升配为rocketmq
RocketMQ实例的实例费用和存储空间费用会分别上报一条账单到计费系统进行结算。查看指定资源的账单时，需要分别查看实例账单和存储空间账单。 在RocketMQ实例列表页面如下图所示位置单击鼠标左键，复制实例的资源ID。 图1 复制实例资源ID 单击实例名称，进入实例详情页，复制存储空间的资源ID。
生产时延。 测试环境 进行测试前，您需要先构建如下的测试环境： 购买如表1所示实例，购买步骤请参考购买实例。 表1 实例参数 名称 规格 存储空间 ACL访问 公网访问 rocketmq-01 rocketmq.b2.large.4 超高I/O 300GB 关闭 关闭 rocketmq-02
测试环境 进行测试前，您需要先构建如下的测试环境： 购买如表1所示实例，购买步骤请参考购买实例。 表1 实例参数 名称 规格 代理数量 存储空间 ACL访问 公网访问 rocketmq-01 rocketmq.4u8g.cluster.small 1 高I/O 300GB 关闭
资源规格：定义使用的弹性云服务器的规格类型。 代理个数：定义实例的规模。 磁盘类型：定义存储空间的磁盘类型，包含高I/O、超高I/O、通用型SSD和极速型SSD。 存储容量：定义单个代理可以保存的存储容量。 单个代理TPS：定义单个代理的TPS性能。 单个代理Topic数上限：定义单个代理可以创建的Topic数量。
无论消息是否被消费，RocketMQ的消息默认保留时间为48小时，最长保留时间为720小时，修改保留时间的操作请参见修改RocketMQ消息保留时间。RocketMQ消息存储在CommitLog文件中，CommitLog文件大小为1GB，当一个CommitLog文件写满后，会生成一个新的CommitLog文件。
Q的磁盘存储空间收费。以下计费项支持包年/包月。 表1 适用计费项 计费项 说明 实例费用 4.8.0版本的实例费用包括代理规格和代理数量。 5.x基础版和专业版的实例费用包括TPS和部署类型。 存储空间费用 总存储空间的费用。随包年/包月RocketMQ实例创建的存储空间，其计费模式也为包年/包月。
x基础版单机） 资源规格 存储容量（GB） 实例TPS 实例Topic数上限 实例消费组数上限 rocketmq.b1.large.1 100 ~ 30000 500 50 500 表3 实例规格说明（分布式消息服务RocketMQ版5.x基础版集群） 资源规格 存储容量（GB） 实例TPS
x基础版单机） 资源规格 存储容量（GB） 实例TPS 实例Topic数上限 实例消费组数上限 rocketmq.b1.large.1 100 ~ 30000 500 50 500 表3 实例规格说明（分布式消息服务RocketMQ版5.x基础版集群） 资源规格 存储容量（GB） 实例TPS
"ACL_SECRET_KEY", # 角色密钥 '' )#用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险，建议在配置文件或者环境变量中密文存放，使用时解密。 producer.start() msg = create_message()
后付费 按照RocketMQ实例实际使用时长计费。 计费周期 按订单的购买周期计费。 秒级计费，按小时结算。 适用计费项 实例费用、存储空间费用 实例费用、存储空间费用 变更计费模式 支持变更为按需计费模式。 但包年/包月计费模式到期后，按需的计费模式才会生效。 支持变更为包年/包月计费模式。
store_timestamp 存储消息的时间。 born_timestamp 产生消息的时间。 reconsume_times 重试次数。 body 消息体。 body_crc 消息体校验和，用来检查消息体数据是否正确。 store_size 存储大小。 property_list
支持变更计费模式的RocketMQ实例计费项 计费项 变更说明 相关文档 实例规格 变更RocketMQ实例的计费模式会同时变更实例规格和存储空间的计费模式。 将RocketMQ实例的计费模式从按需计费转为包年/包月，可以让您享受一定程度的价格优惠。 将RocketMQ实例的计费
设置实例规格和存储空间，如图3所示，配置详情请参考表3。 表3 设置实例规格和存储空间 参数 说明 套餐规格 选择“综合推荐”中的“入门规格”。针对入门级用户，提供兼容RocketMQ协议的基础版小规格实例，适用于性能诉求不高、时延容忍度较高的成本敏感业务或者预发环境等。 存储空间 根
在回收站页面，单击RocketMQ实例名称，进入实例详情页，确认2中复制的资源ID是否为磁盘存储ID，如果是，此资源即为计费资源。如果不是，查看回收站中其他RocketMQ实例的磁盘存储ID，直到找到计费资源为止。 图2 查找资源 单击操作列的“更多 > 删除”，对RocketM
实现订阅关系一致 方案概述 订阅关系一致指的是同一个消费组下所有消费者所订阅的Topic、Tag必须完全一致。如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。 消费原理 RocketMQ为每个Topic划分了消息队列（Queue），队列数越大消费的并发度越大。一个消
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
