检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
测试4.8.0版本RocketMQ实例性能 本章节主要测试RocketMQ实例4.8.0版本不同产品规格在发送1KB大小的消息,且CPU使用率达到80%以上时,实例的网络入流量、网络出流量、消息生产速率、消息消费速率、CPU核均负载和内存使用率。 测试环境 进行测试前,您需要先构建如下的测试环境:
测试5.x基础版本RocketMQ实例性能 本章节主要测试RocketMQ实例5.x基础版本不同产品规格在发送1KB大小的消息时,实例的生产速率、消费速率和平均生产时延。 测试环境 进行测试前,您需要先构建如下的测试环境: 购买如表1所示实例,购买步骤请参考购买实例。 表1 实例参数
测试实例性能 测试4.8.0版本RocketMQ实例性能 测试5.x基础版本RocketMQ实例性能
将介绍按需计费RocketMQ实例的计费规则。 适用场景 按需计费适用于具有不能中断的短期、突增或不可预测的应用或服务,例如电商抢购、临时测试、科学计算。 适用计费项 分布式消息服务RocketMQ版对您选择的RocketMQ实例和RocketMQ的磁盘存储空间收费。以下计费项支持按需计费。
单机 集群 专业版(公测) 单机 集群 单机实例如果出现单点故障,无法保障服务SLA,可能造成服务不可用。由于单机实例具备成本优势,建议作为测试环境使用。 5.x版本的优势 与4.8.0版本相比,5.x版本具有如下优势: 架构更先进 5.x版本提供无状态的Proxy接入,解决无法通过代理访问的问题。5
验证RocketMQ消息消费 消费验证是将消息重新发送到指定的在线客户端,验证消费者能否收到消息。消费验证会导致消息重复消费。 前提条件 仅在实例的“状态”为“运行中”时,才可以进行消费验证。 确保待进行消费验证的客户端处于在线状态,且消费者已订阅待重新发送的消息所属的Topic。 验证RocketMQ消息消费
单击“查看报告”,进入“实例诊断”页面,查看诊断结果。 您可以查看到消费组状态是否在线、消费者数量、订阅关系是否一致和消息堆积量,并根据结果分析处理生产和消费消息时所遇到的问题。 图1 诊断结果 消费组不在线时,可以诊断成功,但是会显示1项异常。 导出诊断记录 登录管理控制台。 在管理控制台左上角单击,选择区域。
SDK概述 本文介绍了分布式消息服务RocketMQ版提供的SDK语言版本,列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能,降低您使用SDK的难度,推荐使用。 SDK列表 表1提供了分布式消息服务RocketMQ版支
00400019 The password does not meet the complexity requirements. 密码复杂度不符合要求。 请检查密码复杂度 400 DMS.00400020 DHCP must be enabled for this subnet. 子网的DHCP必须开启。
BROADCASTING:表示广播消费模式。当使用广播消费模式时,RocketMQ会将每条消息推送给消费组所有的消费者,保证消息至少被每个消费者消费一次。 当消费组不在线时,“消费模式”取值显示为“--”。 父主题: 管理消费组
Tag是消息的标签,用于在同一Topic下区分不同类型的消息。来自同一业务单元的消息,可以根据不同业务目的在同一Topic下设置不同的标签。标签能够有效保持代码的清晰度和连贯性,并优化RocketMQ提供的查询系统。消费者可以根据Tag实现对不同Topic的不同消费逻辑,实现更好的扩展性。 Topic是消息
由浅入深,带您玩转分布式消息服务RocketMQ版 01 了解 了解分布式消息服务RocketMQ版的产品特点和业务使用场景,有助于您更准确地匹配实际业务,更快速地选择所需实例。 产品介绍 什么是分布式消息服务RocketMQ版 产品规格 与Kafka、RabbitMQ的差异 与开源RocketMQ的差异
消息消费的逻辑就会混乱,甚至导致消息丢失。 消费原理 RocketMQ为每个Topic划分了消息队列(Queue),队列数越大消费的并发度越大。一个消费组表示一个消费者群组,在分布式应用场景下,同一个消费组中的多个消费者共同完成Topic所有Queue的消费。Queue的分配以
磁盘类型和磁盘大小根据实际需求进行设置。RocketMQ实例创建后,磁盘类型不支持修改。 磁盘类型支持高I/O、超高I/O、通用型SSD和极速型SSD。对于测试环境使用的RocketMQ实例,推荐选择高I/O磁盘。对于生产环境使用的RocketMQ实例,推荐选择通用型SSD及以上的磁盘规格。具体如
主题(Topic) 消息关联的基础逻辑单元。消息生产与消费时的基础单位。 队列(Queue) 一个主题由多个队列组成。队列数越大消费的并发度越大。 生产者(Producer) 消息写入的触发者,负责将消息推送到服务端。 生产者组(Producer Group) 同一类生产者的集合
例数。 exact_match_name 否 String 是否按照实例名称进行精确匹配查询。 默认为“false”,表示模糊匹配实例名称查询。若参数值为“true”表示按照实例名称进行精确匹配查询。 enterprise_project_id 否 String 企业项目ID。 limit
问题。 消费并发度 客户端的消费并发度由单客户端线程数和客户端数量决定。单客户端线程数是指单个客户端所包含的线程数量,客户端数量是指消费组所包含的客户端(消费者)数量。对于普通消息、定时/延时消息、事务消息及顺序消息的消费并发度计算方法如下: 消息类型 消费并发度 普通消息 单客户端线程数
用于长期、稳定的业务需求。以下是一些适用于包年/包月计费模式的业务场景: 稳定业务需求:对于长期运行且资源需求相对稳定的业务,如企业官网、在线商城、博客等,包年/包月计费模式能提供较高的成本效益。 长期项目:对于周期较长的项目,如科研项目、大型活动策划等,包年/包月计费模式可以确保在整个项目周期内资源的稳定使用。
200 表3 响应Body参数 参数 参数类型 描述 group_name String 消费组名称。 online Boolean 消费组是否在线。 subscription_consistency Boolean 订阅关系是否一致。 total Integer 消费者总数。 next_offset
说明 套餐规格 选择“综合推荐”中的“入门规格”。针对入门级用户,提供兼容RocketMQ协议的基础版小规格实例,适用于性能诉求不高、时延容忍度较高的成本敏感业务或者预发环境等。 存储空间 根据实际需要选择存储RocketMQ数据的磁盘类型和磁盘大小。 RocketMQ实例创建后,磁盘类型不支持修改。