检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
集群 使用场景 开发测试场景,对性能和可靠性无要求。 生产环境,无法容忍单点故障,有高可用诉求。 部署架构 采用单节点部署,高可用能力依赖于ECS的HA能力,节点故障期间无法提供服务。 采用多节点集群部署,具有分布式高可用能力,无单点故障问题,出现故障服务自动切换。 SLA 无 参考SLA
击信息栏左上侧的“恢复”。 在待恢复RocketMQ实例所在行,单击“恢复”。 在弹出的“恢复实例”对话框中,单击“确定”。 恢复实例大约需要3~10分钟,在“RocketMQ专享版”页面查看已恢复的实例。 包年/包月的实例从回收站中恢复后,计费模式会变为按需计费。 修改保留天数
description 否 String 实例的描述信息。 长度不超过1024的字符串。 说明: \与"在json报文中属于特殊字符,如果参数值中需要显示\或者"字符,请在字符前增加转义字符\,比如\或者"。 security_group_id 否 String 安全组ID。 获取方法如
分布式消息服务RocketMQ版支持4种高级特性。 消息过滤:消费者根据分布式消息服务RocketMQ版设置的标签对已订阅Topic中的消息进行过滤,达到只消费需要的消息的目的。 消息重试:消费者消费某条消息失败后,分布式消息服务RocketMQ版根据重试机制将消息重新发送给消费者进行消费。如果重试次
为什么不能选择2个可用区? 如果您需要提高RocketMQ集群实例的可靠性,在创建实例时,建议选择3个或以上的可用区,不支持选择2个可用区。原因如下:使用2个可用区的实例,如果其中一个可用区故障,可能会导致实例不可用。 父主题: 实例问题
快速入门 场景描述 您可以根据业务需要创建相应计算能力和存储空间的RocketMQ实例。 API调用方法请参考如何调用API。 前提条件 已获取IAM和RocketMQ的Endpoint,具体请参见地区和终端节点。 创建RocketMQ实例 如下示例是创建RocketMQ实例的请求消息:
rver地址与端口 rocketmq.name-server=127.0.0.1:9876 生产消息 生产消息的示例代码如下(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。 @SpringBootApplication public class ProduceDemoApplication
内,网络默认互通。 如果客户端和RocketMQ实例部署在不同VPC中,由于VPC之间逻辑隔离,客户端和RocketMQ实例不能直接通信,需要打通VPC之间的网络。 客户端连接RocketMQ实例的方式如表1所示。 表1 连接方式说明 连接方式 实现方式 参考文档 公网连接 在R
规格:rocketmq.4u8g.cluster*1 总存储空间:高I/O,300GB 用了一段时间后,用户发现RocketMQ实例当前规格无法满足业务需要,于2023/03/20 9:00:00升配为rocketmq.8u16g.cluster*1。因为该RocketMQ实例打算长期使用下去,于2023/03/20
RocketMQ元数据迁移概述 RocketMQ元数据包括Topic和消费组信息,但不包括Topic和消费组生产消息、消费消息的记录。当您需要使用相同的Topic和消费组时,可通过元数据迁移操作将已有的Topic和消费组信息迁移到指定的RocketMQ实例中,无需再手动创建。 R
查询可用区信息 功能介绍 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 region_id
单个资源开通自动续费:选择需要开通自动续费的RocketMQ实例,单击操作列“开通自动续费”。 图2 单个资源开通自动续费 批量资源开通自动续费:选择需要开通自动续费的RocketMQ实例,单击列表左上角的“开通自动续费”。 图3 多个资源开通自动续费 选择续费时长,并根据需要设置自动续费次数,单击“开通”。
迁移RabbitMQ的元数据到RocketMQ实例 分布式消息服务RocketMQ版支持通过控制台迁移RabbitMQ的元数据到云上RocketMQ实例。 前提条件 已购买RocketMQ实例。 已开启RabbitMQ管理插件。 已购买RabbitMQ 3.7.17/3.8.35版本实例。
存中。如果消费者在启动消费时从最新的消息开始消费,则会直接从内存中获取消息进行消费。 当消费者不是从最新的消息开始消费时,RocketMQ需要从磁盘中读取历史消息保存到内存中,由此产生了冷读现象。如果有大量消费者触发冷读,使I/O压力飙升,可能会达到磁盘性能瓶颈,造成消费者拉取消
关联的代理(仅RocketMQ实例4.8.0版本需要填写此参数)。 queue_num 否 Number 队列数,范围1~50。 queues 否 Array of queues objects 队列(仅RocketMQ实例4.8.0版本需要填写此参数)。 permission 否 String
pic和Tag的具体使用场景: 根据消息类型判断:RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息、事务消息,不同类型的消息需要用不同的Topic来区分,无法通过Tag区分。 根据消息优先级判断:在业务中紧急程度高和紧急程度一般的消息用不同的Topic来区分,方便后续业务处理。
划线组成,长度3~64个字符。 brokers 否 Array of strings 关联的代理列表(仅RocketMQ实例4.8.0版本需要填写此参数)。 broadcast 否 Boolean 是否广播。 retry_max_time 否 Integer 最大重试次数,取值范围为1~16。
String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 task_ids 是 Array of strings 需要删除的任务列表。 响应参数 无 请求示例 删除元数据迁移任务。 DELETE https://{endpoint}/v2/{project
升级版本与当前版本相同 请重新选择升级的版本号 400 DMS.00400055 Resource sold out. 资源不足,包括ecs,volume等 请稍后再试 400 DMS.00400060 This instance name already exists. 实例名称已经存在。
划线组成,长度3~64个字符。 brokers 否 Array of strings 关联的代理列表(仅RocketMQ实例4.8.0版本需要填写此参数)。 broadcast 否 Boolean 是否广播。 retry_max_time 否 Integer 最大重试次数,取值范围为1~16。