CreateInstance-创建实例
创建云消息队列 RocketMQ 版5.x系列实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
企业铂金版生命周期管理
创建企业铂金版实例 云消息队列 RocketMQ 版 铂金版实例支持通过控制台创建，操作入口如下：在 云消息队列 RocketMQ 版 控制台 的 实例列表 页面选择指定地域。在 实例列表 页选择 创建实例，按照提示完成购买。实例版本：选择 4.0系列 ...
订阅关系（Subscription）
本文介绍 云消息队列 RocketMQ 版 中订阅关系（Subscription）的定义、模型关系、内部属性及使用建议。定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端...
企业铂金版计费说明
消息存储空间：企业铂金版实例独享物理存储空间的大小。计费单价 企业铂金版实例的费用详情和价格示例，请以 企业铂金版实例售卖页 为准。相关文档 企业铂金版实例和标准版实例差异，请参见 实例规格。企业铂金版实例的相关操作，包括创建...
领域模型概述
云消息队列 RocketMQ 版 通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。消息（Message）：云消息队列 RocketMQ 版 的最小传输单元。消息具备不可变性，在初始化发送和完成存储后即不可变。消息消费 消费者分组...
监控报警
云消息队列 RocketMQ 版 支持通过云监控创建监控规则，帮助您自动监控服务的运行状态，并自动发送报警通知，便于您及时预警服务的异常信息，提高运维效率。云监控服务的详细信息，请参见 云产品监控。监控项说明 说明 已就绪消息量 和 已...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
CreateTopic-创建主题
主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。调试 您可以在OpenAPI Explorer中直接运行该接口，免去...
功能发布列表
本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档，帮助您了解 云消息队列 RocketMQ 版 的发布动态。2024-04-24 实例系列 功能名称 功能描述 变更类型 相关文档 5.x系列实例 Serverless公网...
死信消息
云消息队列 RocketMQ 版 支持将这些死信消息保存至指定Topic，方便后续进行业务恢复或回溯。本文介绍死信消息的应用场景、死信策略、使用限制、配置方法和使用建议。应用场景 典型死信消息处理场景 消息重试失败后，您可以选择将死信消息...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
OnsInstanceCreate-创建实例
实例是用于云消息队列 RocketMQ 版服务的虚拟机资源，用来存储 Topic 和 Group 信息。该接口一般在新业务发布需要创建新的服务资源的情况下使用。该接口只支持创建标准版实例，不支持创建铂金版实例。云消息队列 RocketMQ 版控制台同时支持...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
配置消息监控告警实现风险预警
背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储、网络吞吐等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注...
消息发送重试和流控机制
本文为您介绍 云消息队列 RocketMQ 版 的消息发送重试机制和消息流控机制。背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...
配置消息监控告警实现风险预警
背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注实际的业务...
ResetConsumeOffset-重置消费位点
可选时间范围中的起始和终止时间分别是该 Topic 中储存的最早的和最晚的一条消息的生产时间，不能选择超过可选时间范围的时间点。重置到某一时刻对应的消费位点，匹配位点时，服务端会根据自动匹配到该时刻最接近的消费位点。LATEST_OFFSET...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
OnsMessageDetail-查询消息详细信息
请求参数 名称 类型 必填 描述 示例值 InstanceId string 是 云消息队列 RocketMQ 版实例 ID。MQ_INST_184681981*_BXig0x6A Topic string 是 需查询的消息的 Topic 名称。test-mq_topic MsgId string 是 需查询的消息的 ID，即 Message ID...
GetInstance-获取指定实例的详情
消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性，按照实际存储空间收取费用，您可以通过调整消息保存时长来控制消息的存储容量。更多信息，请参见 存储费用。72 supportAutoScaling boolean 实例是否支持开启规格外突发弹性能力...
生产者负载均衡
生产者发送消息到 云消息队列 RocketMQ 版 服务端时，云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...
OnsConsumerResetOffset-重置Group ID消费位点
重置指定的Group ID的...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsConsumerResetOffset 接口，您还可以通过云消息队列 RocketMQ 版控制台重置指定 Group ID 的消费位点。具体操作，请参见 重置消费位点。
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
仪表盘
借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版 提供可实时进行数据统计的仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘...
OnsMessageGetByMsgId-通过MsgId查询消息
通过传入 Message ID 查询指定消息的信息...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageGetByMsgId 接口，您还可以通过消息队列 RocketMQ 版控制台查看消息的详细信息。具体操作，请参见 消息查询。
OnsMessageGetByKey-根据Message Key查询消息
根据 Topic 和 Message Key 模糊查询消息...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsMessageGetByKey 接口，您还可以通过云消息队列 RocketMQ 版控制台查看消息的详细信息。具体操作，请参见 消息查询。
OnsDLQMessageGetById-根据Message ID查询死信消息
包括存储时间、消息体、Key和Tag。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。根据 ...
消费者负载均衡
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
OnsDLQMessagePageQueryByGroupId-查询Group ID内所有...
通过传入Group ID和时间段，分页查询...变更历史 变更时间 变更内容概要 操作 暂无变更历史 控制台操作 除了调用 OnsDLQMessagePageQueryByGroupId 接口，您还可以通过云消息队列 RocketMQ 版控制台查看死信消息。具体操作，请参见 死信队列。
调用TCP协议的SDK收发普通消息
存储时间 表示 云消息队列 RocketMQ 版 服务端存储这条消息的时间。如果查询到此信息，表示消息已经成功发送到服务端。重要 此步骤演示的是第一次使用 云消息队列 RocketMQ 版 的场景，此时消费者从未启动过，所以消息状态显示暂无消费数据...
消费进度管理
云消息队列 RocketMQ 版 通过消费位点管理消费进度，本文为您介绍 云消息队列 RocketMQ 版 的消费进度管理机制。背景信息 云消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...
Serverless实例计费说明
计费公式 每小时存储费用＝存储空间占用大小（GB）×存储单价（元/G/小时）计费单价 地域 存储空间单价（元/GB/小时）所有支持地域 0.0014 Topic费用 云消息队列 RocketMQ 版 的Serverless实例按照Topic数量收取费用。说明 Topic费用是只要...
版本说明
若您使用存量 云消息队列 RocketMQ 版 实例并通过经典网络访问，请勿将Java SDK升级到V2.x.x.Final版本，否则将无法访问 云消息队列 RocketMQ 版 实例。Java SDK 2.x.x.Final仅支持有命名空间的实例，若您使用的实例无命名空间，请勿将客户...
使用Exactly-Once投递语义收发消息
在用于存储消息消费结果的数据库中创建transaction_record表。更多信息，请参见 步骤二：创建消费事务表。重要 存储消息消费结果的数据库系统必须支持本地事务。在消息生产端使用PropertyKeyConst.EXACTLYONCE_DELIVERY属性设置打开Exactly...
授权信息
权限策略通用结构 权限策略支持JSON格式，其通用结构如下：{"Version":"1","Statement":[{"Effect":"<Effect>","Action":"<Action>","Resource":"<Resource>","Condition":{"<Condition_operator>":{"<Condition_key>":["<Condition_value>...
重置消费位点
选择从指定时间点重置时，可以选择的最早时间为Topic中最早一条消息的存储时间，而 云消息队列 RocketMQ 版 4.x系列实例的最大消息存储时长为3天，超过3天的消息会从Topic中被删除。因此，通过重置消费位点最多可重新消费到3天前的消息。...
服务接入点
亚太 地域名称 地域ID 公网接入地址 VPC接入地址 华北1（青岛）cn-qingdao rocketmq.cn-qingdao.aliyuncs.comrocketmq-vpc.cn-qingdao.aliyuncs.com华北2（北京）...华北3（张家口）...
- 产品推荐
- 这些文档可能帮助您