检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
查看RocketMQ消费组详情 消费组创建成功后,可在控制台查看消费组的相关配置和状态信息。 前提条件 已创建消费组。 查看RocketMQ消费组详情 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件
修改RocketMQ消费组配置 消费组创建成功后,可以根据业务需要修改消费组的配置信息。 前提条件 已创建消费组。 修改RocketMQ消费组配置 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件
修改RocketMQ消息保留时间 消息老化时间即消息的最长保留时间,消费者必须在此时间结束前消费消息,否则消息将被删除。删除的消息,无法被消费。 正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制,消息老化时间修改后,正常消息的保留时间和死信消息的保留时间都会被修改。
按需转包年/包月 如果您需要长期使用当前按需购买的RocketMQ实例,可以将该RocketMQ实例转为包年/包月计费模式,以节省开支。按需计费变更为包年/包月会生成新的订单,用户支付订单后,包年/包月资源将立即生效。 假设用户于2023/04/18 15:29:16购买了一个按
包年/包月转按需 创建一个包年/包月RocketMQ实例后,您可以将该RocketMQ实例的计费模式转为按需计费,回收部分成本,同时更加灵活地按需使用RocketMQ实例。 包年/包月转按需,需包年/包月计费模式到期后,按需的计费模式才会生效。 前提条件 RocketMQ实例计费模式为“包年/包月”。
标签管理 批量添加或删除实例标签 查询实例标签 查询项目标签 父主题: API V2(推荐)
管理RocketMQ死信消息 死信队列用于处理无法被正常消费的消息。 一条消息初次消费失败会被重试消费,若重试次数达到最大值(默认16次,在创建RocketMQ消费组中可配置)时,依然消费失败,则其将被投递到该消费者对应的特殊队列(即死信队列)中,这种消息被称为死信消息。 死信消息具有如下特性:
重置RocketMQ消费进度 重置消费进度即修改消费者的消费位置,重置消费进度后,消费者会从修改后的消息位置开始继续消费。 重置消费进度可能会导致重复消费,请谨慎操作。 操作视频 本视频演示重置RocketMQ消费进度的操作。 前提条件 已创建消费组,且消费组中已存在消费者。 已创建Topic。
配置RocketMQ网络连接 连接RocketMQ网络要求 配置RocketMQ实例的公网访问 父主题: 连接实例
配置RocketMQ访问控制 开启RocketMQ ACL访问 配置RocketMQ ACL用户 父主题: 连接实例
计费模式概述 分布式消息服务RocketMQ版提供包年/包月和按需计费两种计费模式,以满足不同场景下的用户需求。 包年/包月:一种预付费模式,即先付费再使用,按照订单的购买周期进行结算。购买周期越长,享受的折扣越大。一般适用于业务需求量长期稳定的成熟业务。 按需计费:一种后付费模
创建用户 功能介绍 创建用户。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/users 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。
消费验证 功能介绍 消费验证。 调用方法 请参见如何调用API。 URI POST /v2/{engine}/{project_id}/instances/{instance_id}/messages/resend 表1 路径参数 参数 是否必选 参数类型 描述 engine 是
修改RocketMQ Topic配置 您可以根据业务需要修改Topic的权限配置和关联代理配置。 仅在RocketMQ实例4.8.0版本支持修改Topic参数,5.x版本不支持。 前提条件 已购买RocketMQ实例。 已创建Topic。 修改Topic信息 登录管理控制台。 在管理控制台左上角单击,选择区域。
删除RocketMQ Topic 如果某个Topic不再使用,可参考本章节删除Topic,释放资源。 仅在实例的“状态”为“运行中”时,才可以删除实例中的Topic。 前提条件 已购买RocketMQ实例。 已创建Topic。 删除Topic 登录管理控制台。 在管理控制台左上角单击,选择区域。
使用ACL权限访问 实例开启ACL访问控制后,消息生产者和消费者都需要增加用户认证信息。 生产者增加用户认证信息 普通消息、顺序消息和定时消息,参考如下代码。以下加粗内容需要替换为实例自有信息,请根据实际情况替换。 import ( "context" "fmt" "os"
查询消息 功能介绍 查询消息。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/{project_id}/instances/{instance_id}/messages 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎。
修改主题 功能介绍 修改主题。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/topics/{topic} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
使用ACL权限访问 实例开启ACL访问控制后,消息生产者和消费者都需要增加用户认证信息。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。 <dependency>
使用ACL权限访问 实例开启ACL访问控制后,消息生产者和消费者都需要增加用户认证信息。 生产者增加用户认证信息 普通消息、顺序消息和定时消息,参考如下代码。以下加粗内容需要替换为实例自有信息,请根据实际情况替换。 from rocketmq.client import Producer