消息发送重试和流控机制
若某些场景例如业务上新等需要回溯到指定时刻前开始消费，此时队列的存储压力会瞬间飙升，触发消息流控。服务端请求任务排队溢出：若消费者消费能力不足，导致队列中有大量堆积消息，当堆积消息超过一定数量后会触发消息流控，减少下游消费...
消费进度管理
说明 消费位点的保存和恢复是基于 云消息队列 RocketMQ 版 服务端的存储实现，和任何消费者无关。因此 云消息队列 RocketMQ 版 支持跨消费者的消费进度恢复。队列中消息位点MinOffset、MaxOffset和每个消费者分组的消费位点ConsumerOffset...
消息存储和清理机制
背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限存储。但是在实际部署场景中，服务端节点的物理存储空间有限，消息无法做到永久存储。因此，在实际使用中...
UpdateInstance-更新实例
云消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性，按照实际存储空间收取费用，您可以通过调整消息保存时长来控制消息的存储容量。更多信息，请参见 存储费用。72 traceOn boolean 否 是否开启消息轨迹功能。true：开启消息轨迹...
实例使用变更
变更说明 由于V3.x.x版本的 云消息队列 MQTT 版 实现了自身的消息存储，因此 云消息队列 MQTT 版 实例购买开通后即可直接创建资源使用，无需和任何其他云产品绑定使用。如您只需使用MQTT协议来收发消息，则更容易理解。变更说明的详细信息...
CreateInstance-创建实例
云消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性，按照实际存储空间收取费用，您可以通过调整消息保存时长来控制消息的存储容量。更多信息，请参见 存储费用。72 chargeType string 否 计费模式。参数取值如下：provisioned：...
Topic使用变更
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x后，实现了独立存储，Topic资源不再依赖于 云消息队列 RocketMQ 版，因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 ...
GetInstance-获取指定实例的详情
消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性，按照实际存储空间收取费用，您可以通过调整消息保存时长来控制消息的存储容量。更多信息，请参见 存储费用。72 supportAutoScaling boolean 实例是否支持开启规格外突发弹性能力...
队列（MessageQueue）
云消息队列 RocketMQ 版 的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，...
领域模型概述
消息存储 主题（Topic）：云消息队列 RocketMQ 版 消息传输和存储的分组容器，主题内部由多个队列组成，消息的存储和水平扩展实际是通过主题内的队列实现的。队列（MessageQueue）：云消息队列 RocketMQ 版 消息传输和存储的实际单元容器，...
主题（Topic）
主题内部由多个队列组成，消息的存储和水平扩展能力最终是由队列实现的；并且针对主题的所有约束和属性设置，最终也是通过主题内部的队列来实现。内部属性 主题名称 定义：主题的名称，用于标识主题，主题名称集群内全局唯一。取值：由用户...
基本概念
云消息队列 RocketMQ 版 的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列通过QueueId来做唯一标识和区分。更多信息，请参见 队列（MessageQueue）。消息（Message）消息是 云消息队列 RocketMQ 版 中...
为什么限制Topic总数（分区总数）？
Topic总数（分区总数）太多会使集群性能和稳定性能急剧下降。云消息队列 Kafka 版 的存储和协调机制是以分区为粒度的，分区数太多，会导致存储碎片化严重，集群性能和稳定性都会急剧下降。
资源使用变更
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明 云消息队列 MQTT 版 ...
存储费用
包年包月和按量付费计费方式下，存储费用为 云消息队列 RocketMQ 版 的必选计费项，系统会根据实例的存储空间占用量进行计费。计费说明 项目 说明 计费公式 存储费用=存储空间×存储单价×存储时长 存储空间的值取计费周期（1小时）内起始...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...
消息检索
背景信息 云消息队列 Kafka 版 消息检索借助 云消息队列 Kafka 版 的Connector功能及表格存储（Tablestore）实现，通过Connector对Topic中的消息进行转储，发送到表格存储中的数据表中，由表格存储索引功能提供消息检索的能力。开通消息...
消息（Message）
消息队列 定义：实际存储当前消息的队列。更多信息，请参见 队列（MessageQueue）。取值：由服务端指定并填充。消息位点 定义：当前消息存储在队列中的位置。更多信息，请参见 消费进度原理。取值：由服务端指定并填充。取值范围：0~long....
API概览
本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
使用限制
云消息队列 Kafka 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 Kafka 版 时注意不要超过相应的限制值，以免程序出现异常。重要 若由于您的实例配置超出使用限制导致的任何不稳定情况，不在SLA承诺和赔偿范围内。云消息队列 ...
V2.x.x到V3.x.x的升级公告
V3.x.x版本除了独立存储之外，还对V2.x.x版本实现的 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 互通的功能进行抽象，使得 云消息队列 MQTT 版 的数据可以根据您配置相应规则转发到其他阿里云产品，也可以配置规则从其他阿里云产品导入...
控制台看到的最近消费时间是什么意思？
消息发布到 云消息队列 Kafka 版 服务器的存储时间。控制台看到的 最近消费时间 是指消息发布到 云消息队列 Kafka 版 服务器的存储时间。如果消费没有堆积，那么这个时间接近发送时间。
安全合规概述
阿里云表格存储Tablestore具有丰富的安全防护能力，通过多项合规认证，支持服务器端加密、数据传输加密、细粒度权限管控、日志审计、数据监控等特性。表格存储为您的云端数据安全进行全方位的保驾护航，并满足您企业数据的安全与合规要求。...
什么是云消息队列 RocketMQ 版？
存储实现Serverless弹性化，按量付费使用，相比挂载云盘无法缩容的情况，具备极大的弹性优势，成本更低。运维可观测 提供丰富的运维可观测能力，可以一键集成OpenTelemetry、全链路Trace、Prometheus等可观测系统；提供完善的OpenAPI能力，...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
消息收发流程变更
由于 云消息队列 MQTT 版 V2.x.x和V3.x.x相比，V3.x.x实现了独立存储，对 云消息队列 RocketMQ 版 没有强依赖，因此消息收发流程有相应的变更。云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储，因此 云消息队列...
产品功能
说明 云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。Exchange：支持将消息按照规则路由到一个或多个Queue，同时对不符合路由规则的消息进行丢弃。...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
表格存储
表格存储（Tablestore）是阿里云自研的结构化数据存储，提供海量结构化数据存储以及快速的查询和分析服务。表格存储提供兼容HBase的WideColumn模型、消息模型Timeline以及时空模型Timestream，实现PB级存储、千万TPS以及毫秒级延迟的服务...
在线教育视频直播
场景描述 适用于在线教育的视频直播场景，通过阿里云视频直播服务实现移动端的推拉流能力，同时移动端利用 云消息队列 MQTT 版 实现发送和接收消息，在消息转发时利用内容安全服务对消息内容进行审核。发送的消息可以存储在表格存储中。...
消息查询
云消息队列 RocketMQ 版 提供了三种消息查询的方式，分别是按Message ID、Message Key以及Topic查询。您可以通过消息查询验证消息是否发送成功、验证消息发送的内容是否正确、以及进一步查看消息的轨迹信息。查询方式说明 由于消息在 云...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
在Knative上实现Kafka消息推送
Knative已支持Kafka事件源，您可将Knative与 云消息队列 Kafka 版 对接，在Knative上实现Kafka消息推送。前提条件 部署Knative 购买并部署 云消息队列 Kafka 版 实例 重要 云消息队列 Kafka 版 实例和Knative必须处于同一VPC内。云消息队列...
数据湖投递概述
应用场景 利用数据湖投递可以实现如下场景需求：冷热数据分层 数据湖投递结合 表格存储 的 数据生命周期 功能，可以快速实现OSS低成本存储全量数据，表格存储 提供热数据的低延迟查询和分析的需求。全量数据备份 数据湖投递可以自动将 表格...
块存储
块存储是阿里云为云服务器ECS提供的块设备类型产品，具备高性能、低时延等特性。您可以像使用物理硬盘一样格式化并建立文件系统来使用块存储，可满足绝大部分通用业务场景下的数据存储需求。适用场景 阿里云为您的云服务器ECS提供了丰富的 ...
快速使用MQTT.fx模拟SDK收发消息
如下图所示，您可以使用MQTT.fx作为MQTT客户端，在MQTT.fx客户端配置相关参数后接入 云消息队列 MQTT 版 实现消息的发送和接收。云消息队列 MQTT 版 同时提供了 公网接入点 和 VPC 接入点。在物联网和移动互联网的场景中，客户端推荐使用 ...
背景
存储水平扩展，查询能力强 表格存储可实现PB级数据的存储和查询，同时提供全局二级索引、多元索引等功能扩充查询能力，满足多种业务的负载和查询需求。如果采用组合使用MySQL、HBase、Elasticsearch等多款产品的方式实现不同业务的查询需求...
应用场景
云消息队列 Kafka 版 作为数据中转枢纽具备以下优势：高容量存储：能在商业硬件上存储高容量的数据，实现可横向扩展的分布式系统。一对多消费模型：发布/订阅模型，支持同份数据集能同时被消费多次。同时支持实时和批处理：支持本地数据...
- 产品推荐
- 这些文档可能帮助您