检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
API V2(推荐) 生命周期管理 消费组管理 Topic管理 消息管理 用户管理 元数据迁移 参数管理 标签管理 其他接口 规格变更管理 实例管理
实例状态说明 表1 实例状态说明 状态 说明 CREATING 申请实例后,在实例状态进入运行中之前的状态。 RUNNING 实例正常运行状态。在这个状态的实例可以运行您的业务。 ERROR 实例处于故障的状态。 RESTARTING 实例正在进行重启操作。 STARTING 实例从已冻结到运行中的中间状态。
Java(TCP协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问 消费端限流 RocketMQ-Spring的使用
消息管理 查询消息 查询消息轨迹 导出死信消息 重发死信消息 消费验证 父主题: API V2(推荐)
是否支持自动创建Topic? RocketMQ实例不支持自动创建Topic。 父主题: Topic问题
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
实例管理 查询实例节点 重启指定实例 父主题: API V2(推荐)
支持多少个Topic? 不同实例规格支持的Topic个数不同,具体参见表1、表2、表3、表4和表5。 表1 实例规格说明(分布式消息服务RocketMQ版4.8.0) 资源规格 代理(个) 存储容量(GB/代理) 单个代理TPS 单个代理Topic数上限 单个代理消费组数上限 rocketmq
管理RocketMQ死信消息 死信队列用于处理无法被正常消费的消息。 一条消息初次消费失败会被重试消费,若重试次数达到最大值(默认16次,在创建RocketMQ消费组中可配置)时,依然消费失败,则其将被投递到该消费者对应的特殊队列(即死信队列)中,这种消息被称为死信消息。 死信消息具有如下特性:
配置RocketMQ实例标签 标签是RocketMQ实例的标识,为RocketMQ实例添加标签,可以方便用户识别和管理拥有的RocketMQ实例资源。 您可以在创建RocketMQ实例时添加标签,也可以在RocketMQ实例创建完成后,在“标签”页面添加标签,您最多可以给实例添加20个标签。另外,您还可以删除标签。
计费模式概述 分布式消息服务RocketMQ版提供包年/包月和按需计费两种计费模式,以满足不同场景下的用户需求。 包年/包月:一种预付费模式,即先付费再使用,按照订单的购买周期进行结算。购买周期越长,享受的折扣越大。一般适用于业务需求量长期稳定的成熟业务。 按需计费:一种后付费模
API V1 实例管理类接口 其他接口 父主题: 历史API
元数据迁移 新建元数据迁移任务 查询实例下所有迁移任务或查询指定迁移任务信息 删除元数据迁移任务 父主题: API V2(推荐)
消费端限流 在分布式消息服务RocketMQ版中,消费者消费消息时,可能会出现消费过快导致下游业务来不及处理的情况,进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码,以保障系统的稳定。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
标签管理 批量添加或删除实例标签 查询实例标签 查询项目标签 父主题: API V2(推荐)
收发普通消息 本章节介绍普通消息的收发方法和示例代码。其中,普通消息发送方式分为同步发送和异步发送。 同步发送:消息发送方发出一条消息到服务端,服务端接收并处理消息,然后返回响应给发送方,发送方收到响应后才会发送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。
配置RocketMQ网络连接 连接RocketMQ网络要求 配置RocketMQ实例的公网访问 父主题: 连接实例
配置RocketMQ访问控制 开启RocketMQ ACL访问 配置RocketMQ ACL用户 父主题: 连接实例
RocketMQ元数据迁移概述 RocketMQ元数据包括Topic和消费组信息,但不包括Topic和消费组生产消息、消费消息的记录。当您需要使用相同的Topic和消费组时,可通过元数据迁移操作将已有的Topic和消费组信息迁移到指定的RocketMQ实例中,无需再手动创建。 R