链接方式存储的队列-链接方式存储的队列文档介绍内容-阿里云

消息发送重试和流控机制

本文为您介绍云消息队列 RocketMQ 版的消息发送重试机制和消息流控机制。背景信息消息发送重试云消息队列 RocketMQ 版的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...

队列（MessageQueue）

行为约束每个主题下会由一到多个队列来存储消息，每个主题对应的队列数与消息类型以及实例所处地域（Region）相关，队列数暂不支持修改。版本兼容性队列的名称属性在云消息队列 RocketMQ 版服务端的不同版本中有如下差异：服务端3.x/4....

消息（Message）

消息队列定义：实际存储当前消息的队列。更多信息，请参见队列（MessageQueue）。取值：由服务端指定并填充。消息位点定义：当前消息存储在队列中的位置。更多信息，请参见消费进度原理。取值：由服务端指定并填充。取值范围：0~long....

主题（Topic）

定义主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：定义数据的分类隔离在云消息队列 RocketMQ 版的方案设计中，建议将不同业务类型的数据拆分到不同的主题中管理，...

基本概念

主题（Topic）云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。更多信息，请参见主题（Topic）。消息类型（MessageType）云消息队列 RocketMQ 版中按照消息...

死信队列

对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...

配置消息监控告警实现风险预警

背景信息云消息队列 RocketMQ 版提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注实际的业务...

消息存储和清理机制

消息存储机制原理机制云消息队列 RocketMQ 版使用存储时长作为消息存储的依据，即每个节点对外承诺消息的存储时长。在存储时长范围内的消息都会被保留，无论消息是否被消费；超过时长限制的消息则会被清理掉。消息存储机制主要定义以下...

集成概述

例如，创建流出目标端为Tablestore的Sink Connector，请先开通表格存储（Tablestore）服务。说明若目标服务为日志服务，可不开通函数计算服务。计费说明事件总线目前处于公测中，免费使用。函数计算的计费说明，请参见计费概述。权限...

UpdateTopicConfig-修改Topic配置

目前 V2 实例仅支持 Local 存储引擎的 Topic，云存储引擎的 Topic 不支持修改。支持 V3 实例修改 Topic 配置。V2 实例的 local topic 支持的 key 为 retention.ms、retention.bytes、replications。V3 实例支持的 key 为 retention.hours、...

获取MQTT客户端在线状态

您可通过调用同步查询接口或使用异步上下线通知的方式获取云消息队列 MQTT 版客户端（下文简称为客户端）当前在线情况。应用场景云消息队列 MQTT 版需结合后端存储消息队列产品，如云消息队列 RocketMQ 版等使用，来和部署在云端...

使用限制

云消息队列 Kafka 版对某些具体指标进行了约束和规范，您在使用云消息队列 Kafka 版时注意不要超过相应的限制值，以免程序出现异常。重要若由于您的实例配置超出使用限制导致的任何不稳定情况，不在SLA承诺和赔偿范围内。云消息队列 ...

计费概述

本文介绍云消息队列 Kafka 版的计费方式，帮助您快速了解计费详情，按需选择计费方式。说明云消息队列 Kafka 版的Connector组件依赖于事件总线，云消息队列 Kafka 版不会额外收取费用。事件总线的计费说明，请参见计费说明。同时，...

为什么限制Topic总数（分区总数）？

Topic总数（分区总数）太多会使集群性能和稳定性能急剧下降。云消息队列 Kafka 版的存储和协调机制是以分区为粒度的，分区数太多，会导致存储碎片化严重，集群性能和稳定性都会急剧下降。

JMS P2P（RAM角色跨账号授权场景）

当您需要通过RAM STS角色授权的方式访问消息队列RabbitMQ版服务时，需要通过阿里云提供的权限认证类（AliyunCredentialsProvider）设置 AccessKey ID、AccessKey Secret 与 SecurityToken 进行权限认证才能访问。重要您的客户端在调用SDK...

不在同一可用区内的ECS实例如何访问云消息队列 Kafka ...

概述不在同一可用区内的ECS实例可通过非公网的方式访问云消息队列 Kafka 版实例，详情请查看以下内容。详细信息以非公网的方式访问云消息队列 Kafka 版实例时，必须满足以下两个条件：ECS实例与云消息队列 Kafka 版实例在同一VPC网络实例...

领域模型概述

队列（MessageQueue）：云消息队列 RocketMQ 版消息传输和存储的实际单元容器，类比于Kafka中的分区。云消息队列 RocketMQ 版通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。消息（Message）：云消息队列 ...

开源RabbitMQ迁移上云

迁移前须知云消息队列 RabbitMQ 版是阿里云基于专有的分布式消息存储技术开发的高级消息队列服务。它严格遵循AMQP 0-9-1协议，但并不是开源RabbitMQ的简单托管版本。云消息队列 RabbitMQ 版采用了独创的架构设计，有效避免了因消息积压...

开源对比

项目云消息队列 Kafka 版 Apache Kafka 差异原因 Topic 创建方式云消息队列 Kafka 版控制台云消息队列 Kafka 版 OpenAPI 服务端自动创建（默认不开启）Kafka CLI Kafka Manager 服务端自动创建云消息队列 Kafka 版默认通过阿里云控制...

生产者（Producer）

消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从云消息队列 RocketMQ 版服务端中获取消息并消费。内部属性客户端ID 定义：生产者客户端的标识，用于区分不同的生产者。集群内全局...

基本概念

重置消费位点以时间轴为坐标，在消息持久化存储的时间范围内（默认3天），重新设置Consumer对已订阅的Topic的消费进度，设置完成后Consumer将接收设定时间点之后由Producer发送到云消息队列 RocketMQ 版服务端的消息。更多信息，请参见 ...

计费概述

云消息队列 MQTT 版 V2.x.x版本的存储依赖于云消息队列 RocketMQ 版，您在使用云消息队列 MQTT 版时，同时会收取云消息队列 RocketMQ 版的Topic资源占用费及API接口的调用费。因此，您的阿里云产品消费汇总中，会出现云消息队列 ...

存储费用

包年包月和按量付费计费方式下，存储费用为云消息队列 RocketMQ 版的必选计费项，系统会根据实例的存储空间占用量进行计费。计费说明项目说明计费公式存储费用=存储空间×存储单价×存储时长存储空间的值取计费周期（1小时）内起始...

消费者（Consumer）

消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从云消息队列 RocketMQ 版服务端中获取消息并消费。内部属性消费者分组名称定义：当前消费者关联的消费者分组名称，消费者必须关联...

接口和参数说明

云消息队列 RocketMQ 版提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从云消息队列 RocketMQ 版获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息云消息队列 RocketMQ 版支持以下两种消息获取方式：Push...

订阅关系（Subscription）

消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从云消息队列 RocketMQ 版服务端中获取消息并消费。内部属性过滤类型定义：消息过滤规则的类型。订阅关系中设置消息过滤规则后，...

控制台看到的最近消费时间是什么意思？

消息发布到云消息队列 Kafka 版服务器的存储时间。控制台看到的最近消费时间是指消息发布到云消息队列 Kafka 版服务器的存储时间。如果消费没有堆积，那么这个时间接近发送时间。

MQTT快速入门

注意事项云消息队列 MQTT 版需搭配后端消息存储队列一起使用，具体说明如下：云消息队列 MQTT 版实例是一个无状态网关类型实例，用来完成IoT移动场景下的客户端连接维持和消息转发，本身并不提供消息数据持久化功能，具体的消息存储和...

消息堆积和延迟问题

本文主要介绍云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解云消息队列 RocketMQ 版客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...

计费概述

本文为您介绍云消息队列 RocketMQ 版的计费方式、计费组成等主要计费信息。计费文档概览云消息队列 RocketMQ 版提供标准版和企业铂金版两种类型实例，具体的规格差异和功能差异，请参见实例规格。分类相关文档标准版实例消息收发...

MQTT客户端上下线事件数据流出

您可通过配置云消息队列 MQTT 版的客户端上下线通知规则，将获取的MQTT客户端上下线事件数据导出至其他阿里云产品。该方法为异步上下线通知。本文介绍客户端上下线通知的原理、应用场景、使用限制以及云消息队列 MQTT 版与其他阿里云...

退款说明

根据计费方式的特点，云消息队列 Kafka 版资源支持的退款情况如下：包年包月的云消息队列 Kafka 版资源如需退款，可在控制台上退订实例。详细信息，请参见实例生命周期管理。按量计费的云消息队列 Kafka 版资源在使用后才支付费用，...

开源SDK接入（跨云账号授权）

前提条件创建实例创建Vhost 背景信息当您需要通过RAM STS角色授权的方式访问云消息队列 RabbitMQ 版服务时，需要通过阿里云提供的权限认证类（AliyunCredentialsProvider）设置 AccessKeyID、AccessKeySecret 与 SecurityToken 进行...

集群消费和广播消费

集群消费和广播消费是云消息队列 RocketMQ 版的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息云消息队列 ...

基本概念

接入点 Producer或Consumer连接云消息队列 Kafka 版时使用的地址，由Broker的IP地址和端口号拼接而成，格式为 Broker的IP地址:端口号，或由云消息队列 Kafka 版实例域名和端口号拼接而成，格式为实例域名:端口号。更多信息，请参见接...

使用ACL功能进行访问控制

当需要对不同的用户或用户组授予不同级别的访问权限时，您可以使用云消息队列 Kafka 版专业版实例的访问控制列表（ACL）功能，为SASL用户赋予对Topic、Group等资源的操作权限，实现细粒度的权限管理。背景信息企业A购买了云消息队列 ...

步骤三：创建资源

当使用云消息队列 Kafka 版进行消息收发时，您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic，消费者通过订阅Topic获取消息进行消费。消费者消费消息时，需要指定Group订阅对应的Topic。Group和...

删除队列消息

本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下：channel.queuePurge("queue-name");

从自建MySQL同步至云消息队列 Kafka 版

通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至云消息队列 Kafka 版，扩展消息处理能力。前提条件您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署云消息队列 ...

MNS回调事件通知

您可以上传视频到不同地域的存储中，当视频处理（如上传、转码等）完成后，视频点播服务会根据存储地域配置的回调及时通知您，并将内容推送到您的MNS服务的队列中。推荐您按下述建议配置MNS消息队列的回调地域：如果视频保存在中国内地地域...

链接方式存储的队列

新品推荐