检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
表1 版本发布说明 实例版本 发布时间 新增/优化特性 5.x 2023年7月 兼容开源RocketMQ 5.x和4.x协议 实例支持gRPC协议 实例支持pop消费模式 4.8.0 2022年3月 实例支持定时消息 4.8.0 2021年8月 实例支持ACL访问控制权限 父主题:
资源独享 底层物理资源采用独享型专有资源部署,保障性能的稳定,具备更好的可靠性和可服务性。 单机实例和集群实例的差异 表3 单机实例和集群实例的差异 维度 单机 集群 使用场景 开发测试场景,对性能和可靠性无要求。 生产环境,无法容忍单点故障,有高可用诉求。 部署架构 采用单节点
35版本:不支持。 AMQP-0-9-1版本:支持。 消费模式 支持客户端主动拉取和服务端推送两种方式。 客户端主动拉取。 支持客户端主动拉取和服务端推送两种模式。 广播消费 支持 支持 支持 消息回溯 支持 支持。Kafka支持按照offset和timestamp两种维度进行消息回溯。 3.8
主节点重启过程中,客户端的生产和消费请求会被拒绝,持续时间不超过30s,建议在业务量少时重启节点。重启备节点,不会影响业务的使用。 怎么判断哪个是主节点? 一个Broker由一个主节点和两个备节点组成,当您购买的Broker数为1时,实际创建3个Broker节点。三个节点采用raft模式部署,使用Broker
删除消费组的任务ID name String 创建成功的消费组名称。 请求示例 4.8.0版本RocketMQ实例创建一个消费组,不允许以广播模式消费,关联代理为broker-0,最大重试次数为16。 POST https://{endpoint}/v2/{project_id}/i
修改如表1所示配置信息。 表1 消费组参数说明 参数 说明 最大重试次数 设置消费失败的最大重试次数。 取值范围:1~16 是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。 是否顺序消费
海一”和“华南-广州”上线。 约束与限制 回收站中的按需实例不会收取实例的费用,但是会收取存储空间的费用。 包年/包月的实例退订后会存入回收站中,此时不会收取实例的费用,但是会按需收取存储空间的费用。 包年/包月的实例从回收站中恢复后,计费模式会变为按需计费。 处于宽限期和保留期
创建RocketMQ消费组 消费组,即一组具有相同行为的消费者集合,用于管理和维护消息的消费状态。消费者可以将同一类的消费消息放在一个消费组里面,方便管理。 如果没有创建消费组,则RocketMQ会自动创建消费组。 前提条件 已购买RocketMQ实例。 创建RocketMQ消费组
MQ实例生产和消费消息的操作请参见使用客户端连接RocketMQ(关闭SSL)。 如果您需要创建多个用户并为其赋予不同的Topic和消费组权限,以达到用户之间的权限隔离,那么您需要先开启ACL访问控制并配置ACL用户,具体操作请参考开启RocketMQ ACL访问和配置RocketMQ
RocketMQ实例支持通过筛选来查询对应的RocketMQ实例。当前支持的筛选条件为状态、名称、版本、实例类型、规格、已用/可用存储空间、计费模式、可用区、企业项目和标签。RocketMQ实例状态请参见表1。 表1 RocketMQ实例状态说明 状态 说明 创建中 创建RocketMQ实例后,
broker_num 是 Integer 代理个数。 bss_param 否 BssParam object 表示包周期计费模式的相关参数。 如果为空,则默认计费模式为按需计费;否则是包周期方式。 表3 BssParam 参数 是否必选 参数类型 描述 is_auto_renew 否 Boolean
收发普通消息 本章节介绍普通消息的收发方法和示例代码。其中,普通消息发送方式分为同步发送和异步发送。RocketMQ提供PushConsumer和SimpleConsumer类型的消费者,PushConsumer消费者订阅普通消息时,代码不区分同步订阅和异步订阅。SimpleConsum
创建告警规则操作,请查看创建告警规则。 设置告警名称和告警的描述。 设置告警策略和告警级别。 如下图所示,在进行指标监控时,如果连续3次周期,磁盘容量使用率原始值超过85%,则产生告警,如果未及时处理,则产生告警通知。 图1 设置告警策略和告警级别 设置“发送通知”开关。当开启时,设置
购买时长为1个月。那么在3~4月份,该RocketMQ实例总共产生多少费用呢? 计费构成分析 可以将RocketMQ实例的使用阶段按照计费模式分为两段:在2023/03/18 15:30:00 ~ 2023/03/20 10:30:00期间为按需计费,2023/03/20 10:30:00
名称 消息类型 topic-01 普通 创建如表3所示消费组,创建步骤请参考创建消费组。 表3 消费组参数 名称 最大重试次数 是否允许以广播模式消费 是否顺序消费 group-01 16 否 否 购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持
长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 value String 标签值。 长度为0~255个字符(中文也可以输入255个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @
长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 value String 标签值。 长度为0~255个字符(中文也可以输入255个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @
本章节定义了分布式消息服务RocketMQ版上报云监控服务的监控指标的命名空间,监控指标列表和维度定义,您可以通过分布式消息服务RocketMQ版控制台来检索分布式消息服务RocketMQ版产生的监控指标和告警信息。 命名空间 SYS.DMS 实例监控指标 表1 实例支持的监控指标 指标ID
arch_types Array of strings 支持的CPU架构类型。 charging_mode Array of strings 支持的计费模式类型。 ios Array of RocketMQExtendProductIosEntity objects 磁盘IO信息。 properties
参数类型 描述 groupName 否 String 消费组名。 consumeBroadcastEnable 否 Boolean 是否允许以广播模式消费。 consumeEnable 否 Boolean 是否允许消费。 consumeFromMinEnable 否 Boolean 是否从最小偏移量开始消费。