一个队列-一个队列文档介绍内容-阿里云

不同地域中的同名队列是同一个队列吗？

本文介绍不同地域的同名队列之间的关系。不同地域中的同名队列不是同一个队列，不同地域的同名队列是各自独立的。

DeleteQueue-删除一个队列

调用DeleteQueue删除一个集群中的队列。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试授权信息下表是API对应的授权信息，可以在RAM权限策略语句的 ...

AddQueue-新建一个集群队列

调用AddQueue为指定集群新建一个队列。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试授权信息下表是API对应的授权信息，可以在RAM权限策略语句的 ...

生产者负载均衡

如上图所示，M1、M2表示生产者发送的第一条消息、第二条消息，Queue1、Queue2、Queue3表示主题中的三个队列。生产者按照轮询方式分别将消息依次发送到这三个队列中，M1发送至Queue1中、M2发送至Queue2中、M3发送至Queue3中，以此类推，第四...

消费者负载均衡

策略原理消息粒度负载均衡策略中，同一消费者分组内的多个消费者将按照消息粒度平均分摊主题中的所有消息，即同一个队列中的消息，可被平均分配给多个消费者共同消费。如上图所示，消费者分组Group A中有三个消费者A1、A2和A3，这三个消费...

顺序消息

消息组尽可能打散，避免集中导致热点云消息队列 RocketMQ 版保证相同消息组的消息存储在同一个队列中，如果不同业务场景的消息都集中在少量或一个消息组中，则这些消息存储压力都会集中到服务端的少量队列或一个队列中。容易导致性能热点...

消费进度管理

每条消息被某个消费者消费完成后不会立即在队列中删除，云消息队列 RocketMQ 版会基于每个消费者分组维护一份消费记录，该记录指定消费者分组消费某一个队列时，消费过的最新一条消息的位点，即消费位点。当消费者客户端离线，又再次重新...

主题（Topic）

约束：一个主题内至少包含一个队列。消息类型定义：主题所支持的消息类型。取值：创建主题时选择消息类型。云消息队列 RocketMQ 版支持的主题类型如下：Normal：普通消息，消息本身无特殊语义，消息之间也没有任何关联。FIFO：顺序消息，...

顺序消息

如果是普通消息，订单A的消息可能会被轮询发送到不同的队列中，不同队列的消息将无法保持顺序，而顺序消息发送时云消息队列 RocketMQ 版支持将Sharding Key相同（例如同一订单号）的消息序路由到一个队列中。云消息队列 RocketMQ 版服务...

云上迁移Group

本文介绍如何使用云消息队列 Kafka 版提供的迁移工具将某个云消息队列 Kafka 版实例的 Group 迁移到另一个云消息队列 Kafka 版实例。前提条件您已完成以下操作：下载JDK 8 下载迁移工具JAR文件重要迁移不会删除源云消息队列 ...

CreateQueue

调用CreateQueue接口创建一个新的队列。授权信息默认仅限阿里云账号使用本接口，RAM用户只有在被授予了相关API操作权限后方可使用。本接口的授权信息如下表所示。更多信息，请参见授权策略和示例。Name Value API CreateQueue RAM授权...

死信队列

一个死信队列包含了对应Group ID产生的所有死信消息，不论该消息属于哪个Topic。云消息队列 RocketMQ 版控制台提供对死信消息的查询、导出和重发的功能。查询死信消息的方式云消息队列 RocketMQ 版提供的查询死信消息的方式对比如下表所...

创建实例

创建云消息队列RabbitMQ的实例。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数名称类型是否必选示例值描述 Action String 是 ...

为什么同一个分区被多个消费线程消费了？

问题现象消费客户端使用“StickyAssignor”分配模式消费消息时，发现同一个分区被多个消费线程消费，出现数据错乱的情况。可能原因您的客户端低于2.3版本。2.3版本以前的客户端有可能将同一个分区分配给多个消费线程进行消费。更多信息，...

获取AccessKey

您可以为阿里云账号（主账号）和RAM用户创建一个访问密钥（AccessKey）。在调用阿里云API时您需要使用AccessKey完成身份验证。背景信息 AccessKey包括AccessKey ID和AccessKey Secret。AccessKey ID：用于标识用户。AccessKey Secret：用于...

产品架构

云消息队列 Kafka 版的发布/订阅模型 Group 和Topic的对应关系是N:N，即一个 Group 可以同时订阅多个Topic，一个Topic也可以被多个 Group 同时订阅。虽然一个Topic可以被多个 Group 同时订阅，但该Topic的消息只能被同一个 Group 内的任意...

资源使用变更

资源 V2.x.x使用说明 V3.x.x使用说明云消息队列 MQTT 版实例 V2.x.x版本云消息队列 MQTT 版实例使用前需要强制绑定一个云消息队列 RocketMQ 版实例。V3.x.x版本的云消息队列 MQTT 版实例无需绑定云消息队列 RocketMQ 版实例即可...

MQTT快速入门

现阶段要求每个云消息队列 MQTT 版实例（网关实例）必须绑定一个存储实例（云消息队列 RocketMQ 版实例）使用。消息存储实例目前只支持云消息队列 RocketMQ 版类型的后端存储实例。目前您在同一个地域（Region）可以创建有限数量的云...

队列（MessageQueue）

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

基本概念

当一个Topic被同一个 Group 的多个Consumer消费时，每一条消息都只会被投递到一个Consumer，实现消费的负载均衡。通过 Group，您可以确保一个Topic的消息被并行消费。Topic 消息的主题，用于分类消息。Topic引流云消息队列 Kafka 版集群...

快速入门概述

同一个云消息队列 RocketMQ 版实例既有TCP协议接入点，又有HTTP协议的接入点，您需分别获取TCP协议和HTTP协议的SDK来使用对应协议的接入点，不能混用。TCP协议和HTTP协议在各地域均提供公网和内网接入点。生产环境默认推荐使用VPC专有...

创建前提

资源创建购买一个云消息队列 Kafka 版实例，详细步骤，请参见购买Kafka实例。创建Topic资源。详细步骤，请参见创建资源。（可选）创建Group资源。您可以提前创建Group，也可以在创建Connector时创建Group。详细步骤，请参见创建资源...

基本概念

消息位点（MessageQueueOffset）消息是按到达云消息队列 RocketMQ 版服务端的先后顺序存储在指定主题的多个队列中，每条消息在队列中都有一个唯一的Long类型坐标，这个坐标被定义为消息位点。更多信息，请参见消费进度管理。消费位点...

关于TCP内网接入点设置的公告

需特别注意的是，以下参数所对应的资源应处于同一地域：GROUP_ID：您在云消息队列 RocketMQ 版控制台上创建的Group ID。Topic：您在云消息队列 RocketMQ 版控制台上创建的Topic。NAMESRV_ADDR：您从云消息队列 RocketMQ 版控制台的 ...

云上迁移Topic

本文介绍如何使用云消息队列 Kafka 版提供的迁移工具将某个云消息队列 Kafka 版实例的Topic迁移到另一个云消息队列 Kafka 版实例。前提条件您已完成以下操作：下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署云...

消息检索

开通消息检索相当于自动化创建了一个云消息队列 Kafka 版同步数据至表格存储的Connector任务，名称格式为：ots-ms-{Topic名称}-{6位随机字符}，该Connector任务在消息检索页面显示和管理，而不在 Connector 任务列表页面显示和管理。...

发布者最佳实践

提升发送性能（减少碎片化发送请求）一般情况下，一个云消息队列 Kafka 版 Topic会有多个分区。云消息队列 Kafka 版 Producer客户端在向服务端发送消息时，需要先确认往哪个Topic的哪个分区发送。我们给同一个分区发送多条消息时，...

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

资源映射方式同一个云消息队列 MQTT 版 Group ID下的所有客户端的状态变更通知都会转发到您配置的同一个其他阿里云产品的资源里。表 1.映射关系 MQTT资源其他阿里云产品其他阿里云产品资源数据包定义 MQTT Group ID 云消息队列 ...

Terraform

以创建一个云消息队列 Kafka 版实例为例，示例代码如下：resource"alicloud_alikafka_instance""default"{ name=var.instance_name partition_num=50 disk_type=1 disk_size=500 deploy_type=5 io_max=20 vswitch_id=alicloud_vswitch....

Serverless版实例计费

计费示例假设您在华东1（杭州）地域下，购买了一个云消息队列 MQTT 版的Serverless实例，假设实例购买时间为11月12日，自购买日起3天内的实例费用如下：时间 11月12日 11月13日 11月14日同时在线连接数 0 200个 600个在线连接数费用 ...

基本概念

每个Topic包含一个或多个队列。创建Topic时队列由系统自动分配，不支持自定义修改。集群消费一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个Consumer实例，那么在集群消费模式下每个实例...

订阅者最佳实践

负载均衡每个 Group 可以包含多个消费实例，即可以启动多个云消息队列 Kafka 版 Consumer，并把参数 group.id 设置成相同的值。属于同一个 Group 的消费实例会负载消费订阅的Topic。例如 Group A订阅了Topic A，并开启三个消费实例C1、C2...

消息负载均衡策略

假设目前云消息队列 RocketMQ 版只有一个Broker节点，消息从Producer发送至云消息队列 RocketMQ 版的Topic，默认会将这些Topic下的消息均衡负载至8个Queue（逻辑概念）。云消息队列 RocketMQ 版 Broker会将这些Queue再平均分配至属于同...

Spring集成

或者如果在运行时删除一个或多个队列，是否停止容器。默认值为true。spring.rabbitmq.listener.simple.idle-event-interval 发布空闲容器事件的时间间隔，单位：毫秒。spring.rabbitmq.listener.simple.retry.enabled 监听重试是否可用。...

排他队列

如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用云消息队列 RabbitMQ 版的排他性队列特性，将指定的队列声明为排他性。什么是排他队列排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...

产品架构

集群级别的高可用，是云消息队列 RocketMQ 版跟其他的消息服务器的主要区别，消息生产者发送一条消息到消息服务器，消息服务器会随机的选择一个消费者，只要这个消费者消费成功就认为是成功了。重要文中所提及的云消息队列 RocketMQ 版...

名词解释

Q Queue 消息队列，每个消息都会被投入到一个或多个Queue里。R Routing Key 生产者在向Exchange发送消息时，需要指定一个Routing Key来设定该消息的路由规则。Routing Key需要与Exchange类型及Binding Key联合使用才能生效。一般情况下，...

查看订阅关系

对于大多数分布式应用来说，一个Group ID下通常会挂载多个Consumer实例。云消息队列 RocketMQ 版的订阅关系主要由Topic+Tag共同组成，即一个Group ID下所有的Consumer实例订阅的Topic以及这些Topic中的过滤规则Tag。同一个Group ID下所有...

迁移上云

前提条件您已购买并部署云消息队列 Kafka 版实例，且该实例满足以下条件：项目说明状态服务中版本云消息队列 Kafka 版实例的版本必须满足以下任意一种要求：大版本为2.2.0，小版本为最新版本。大版本为2.6.2，小版本为最新版本。...

步骤二：创建资源

一个新的应用接入云消息队列 RabbitMQ 版服务端，您需要提前创建云消息队列 RabbitMQ 版的相关资源，包括创建云消息队列 RabbitMQ 版实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...

一个队列

新品推荐