检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
管理实例 查看和修改RocketMQ实例基本信息 查看RocketMQ实例后台任务 配置RocketMQ实例标签 导出RocketMQ实例列表 诊断RocketMQ实例 重启RocketMQ实例的Broker节点 删除RocketMQ实例 配置RocketMQ实例回收站策略 修改RocketMQ实例的SSL配置
已创建RocketMQ实例和Topic。 如果通过按Message ID查询,需要提前获取消息所在的Topic名称和消息的Message ID。 Message ID为生产消息后返回的MsgId,如6中返回的内容,也可先通过Topic查询消息,记录Message ID。 如果通过按Message
默认情况下,新建的IAM用户没有任何权限,您需要将其加入用户组,并给用户组授予策略或角色,才能使用户组中的用户获得相应的权限,这一过程称为授权。授权后,用户就可以基于已有权限对云服务进行操作。 权限根据授权的精细程度,分为角色和策略。角色以服务为粒度,是IAM最初提供的一种根据用户的工作职能定
要使用相同的Topic和消费组时,可通过元数据迁移操作将已有的Topic和消费组信息迁移到指定的RocketMQ实例中,无需再手动创建。 RocketMQ业务迁移主要涉及以下场景: 迁移其他RocketMQ的元数据到华为云上RocketMQ实例。其他RocketMQ元数据包括如下内容:
开启RocketMQ实例弹性TPS功能 当您遇到突发流量高峰的场景时,可以开启实例的弹性TPS功能。 仅5.x专业版支持开启弹性TPS功能。 前提条件 已购买RocketMQ 5.x专业版实例。 开启弹性TPS功能 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。
示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 test:表示Topic名称。 订阅普通消息 参考如下示例代码(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。 package main import ( "context"
测试实例性能 测试4.8.0版本RocketMQ实例性能 测试5.x基础版本RocketMQ实例性能
发送定时消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 2022年3月30日及以后购买的实例支持定时消息功能,在此之前购买的实例不支持此功能。 客户端连接RocketMQ实例5.x版本收发定时消息前,需要确保Topic的消息类型为“定时”。 适用场景 定时消息适用于以下场景:
接信息。 约束与限制 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。
单可用区内(单机房)部署RocketMQ实例,或跨可用区(同城灾备)部署。 在单可用区或多可用区中部署实例 副本冗余 使用一主两备架构,备节点通过数据同步的方式保持数据一致。当网络发生异常或节点故障时,通过Raft协议自动切换主备关系,保持数据一致性。 - 数据持久化 业务系统日
实例管理 查询实例节点 重启指定实例 父主题: API V2(推荐)
Topic,即消息主题,消息发送与接收的基本单元。购买RocketMQ实例成功后,需要手动创建Topic,然后才能进行生产消息和消费消息。 前提条件 已购买RocketMQ实例。 创建Topic 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件
管理消费组 创建RocketMQ消费组 查看RocketMQ消费组详情 查看RocketMQ消费者连接地址 修改RocketMQ消费组配置 重置RocketMQ消费进度 删除RocketMQ消费组
SDK概述 本文介绍了分布式消息服务RocketMQ版提供的SDK语言版本,列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能,降低您使用SDK的难度,推荐使用。 SDK列表 表1提供了分布式消息服务RocketMQ版支
查询可用区信息 功能介绍 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 region_id
发送定时消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 2022年3月30日及以后购买的实例支持定时消息功能,在此之前购买的实例不支持此功能。 客户端连接RocketMQ实例5.x版本收发定时消息前,需要确保Topic的消息类型为“定时”。 适用场景 定时消息适用于以下场景:
发送定时消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 2022年3月30日及以后购买的实例支持定时消息功能,在此之前购买的实例不支持此功能。 客户端连接RocketMQ实例5.x版本收发定时消息前,需要确保Topic的消息类型为“定时”。 适用场景 定时消息适用于以下场景:
err.Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 topic1:表示Topic名称。 事务消息生产者需要实现两个回调函数,其中ExecuteLocalTransaction回
表1 版本发布说明 实例版本 发布时间 新增/优化特性 5.x 2023年7月 兼容开源RocketMQ 5.x和4.x协议 实例支持gRPC协议 实例支持pop消费模式 4.8.0 2022年3月 实例支持定时消息 4.8.0 2021年8月 实例支持ACL访问控制权限 父主题:
已创建RocketMQ实例和消费组。 如果通过按Message ID查询,需要提前获取消息所在的消费组名称和消息的Message ID。 Message ID为生产消息后返回的MsgId,如6中返回的内容,也可先通过Topic查询消息,记录Message ID。 如果通过按Message