检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
据自身的业务需求使用分布式消息服务RocketMQ版提供的一系列常用实践。 表1 常用最佳实践 实践 描述 RocketMQ业务迁移 介绍将其他厂商或者自建的RocketMQ迁移到华为云分布式消息服务RocketMQ版。 迁移RabbitMQ的元数据 迁移RabbitMQ的元数据到云上RocketMQ实例。
default_topic_perm 否 String 默认的主题权限。 default_group_perm 否 String 默认的消费组权限。 topic_perms 否 Array of topic_perms objects 特殊的主题权限。 group_perms 否 Array
List)可以实现对RocketMQ实例中生产者和消费者身份的精确识别,达到权限管理的目的。开启ACL权限控制功能后,生产消息和消费消息时,需要鉴权。 约束与限制 仅2021年8月21号后购买的实例,支持设置ACL访问控制。 开启ACL访问控制会导致没有配置认证信息的客户端连接中断。 前提条件 已购买RocketMQ实例。
置过多或不足的风险。一般适用于电商抢购等业务需求量瞬间大幅波动的场景。 表1列出了两种计费模式的区别。 表1 计费模式 计费模式 包年/包月 按需计费 付费方式 预付费 按照订单的购买周期结算。 后付费 按照RocketMQ实例实际使用时长计费。 计费周期 按订单的购买周期计费。
询消息的Topic名称,“队列”选择待查询消息的队列(仅RocketMQ实例4.8.0版本需要选择),“存储时间”选择待查询消息的时间段,单击“查询”。 按Message ID查询:“Topic”选择待查询消息所在的Topic名称,“Message ID”输入待查询消息的Message
RocketMQ实例的版本为5.x时,需要设置此参数。 开启顺序消费后,消费者将顺序消费消息。按顺序消费可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费。 描述 消费组的描述信息。 取值长度为0~200个字符。 配置完成后,单击“确定”,完成消费组的创建。 消费组
engine_version:消息引擎的版本。 storage_space:消息存储空间,单位MB。具体取值范围,请参考创建实例。 vpc_id:RocketMQ实例所在的VPC(虚拟私有云)的ID。您可以在虚拟私有云控制台查询,也可以通过查询VPC列表API查询。 subnet_id:VPC内子网的网络ID
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 批量修改消费组成功。 错误码 请参见错误码。 父主题:
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询RocketMQ代理列表成功。 错误码 请参见错误码。
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询实例标签成功。 错误码 请参见错误码。 父主题:
制,精度会变差。 在0.1s的精度内,不保证消息投递的顺序性。即如果两条定时消息的定时时间差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆
制,精度会变差。 在0.1s的精度内,不保证消息投递的顺序性。即如果两条定时消息的定时时间差距小于0.1s,他们投递的顺序与他们发送的顺序无法确保一致。 无法确保定时消息仅投递一次,定时消息可能会重复投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆
String offset消息ID。 tags String 消息的标签。 keys String 消息的keys。 store_host String 存储消息的主机IP。 client_host String 产生消息的主机IP。 retry_times Integer 重试次数。
消息属性列表。 born_host String 产生消息的主机IP。 store_host String 存储消息的主机IP。 queue_id Integer 队列ID。 queue_offset Integer 在队列中的偏移量。 表5 property_list 参数 参数类型
消息内容:生产消息的内容。输入长度不能超过2000个字符。 (可选)消息Key:消息键。输入长度不能超过128个字符。若key包含空格,则被视为多个key,在消息查询中无法以Message Key的方式准确查询出消息。 (可选)消息Tag:消息标签,用来进一步区分某个Topic下的消息分类
default_topic_perm String 默认的主题权限。 default_group_perm String 默认的消费组权限。 topic_perms Array of topic_perms objects 特殊的主题权限。 group_perms Array of group_perms
本章节介绍分布式消息服务RocketMQ版不同版本支持的实例类型和部署架构,5.x版本相比4.8.0版本的优势,以及不同实例类型、部署架构之前的差异,为您选择适合您业务的实例提供参考。 不同版本支持的实例类型和部署架构 表1 不同版本支持的实例类型和部署架构 实例版本 实例类型 部署架构
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 返回状态码。 错误码 请参见错误码。 父主题: 元数据迁移
} else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询消费组成功。 错误码 请参见错误码。 父主题: 消费组管理
default_topic_perm String 默认的主题权限。 default_group_perm String 默认的消费组权限。 topic_perms Array of topic_perms objects 特殊的主题权限。 group_perms Array of group_perms