循环队列怎么用-循环队列怎么用文档介绍内容-阿里云

产品优势

开箱即用云消息队列 Kafka 版 100%兼容开源，使您无缝迁移上云。兼容开源：云消息队列 Kafka 版 100%兼容开源Apache Kafka，您可以直接使用开源Apache Kafka客户端与云消息队列 Kafka 版通讯。云消息队列 Kafka 版目前支持0.10.x~2.6.x...

创建资源

在调用TCP协议的SDK收发消息前，您需在云消息队列 RocketMQ 版控制台创建相关资源。...完成以上准备工作后，您就可以运行示例代码，用云消息队列 RocketMQ 版进行消息发送和订阅了。后续步骤调用TCP协议的SDK收发普通消息

创建资源

在调用HTTP协议的SDK收发消息前，您需在云消息队列 RocketMQ 版控制台创建相关资源。...完成以上准备工作后，您就可以运行示例代码，用云消息队列 RocketMQ 版进行消息发送和订阅了。后续步骤调用HTTP协议的SDK收发普通消息

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Java SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示。...

示例代码

云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...

消费重试

消费者出现异常，云消息队列 RocketMQ 版会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景云消息队列 RocketMQ 版的消费重试主要解决的是业务处理逻辑失败导致的...

消息堆积和延迟问题

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

新功能发布记录

新增 Serverless后付费实例规格弹性策略 2024-04-08 功能名称功能描述功能类型相关文档升级多可用区云消息队列 Kafka 版 V2系列专业版实例支持从单可用区部署升级为多可用区部署架构。新增升级多可用区 2024-03-12 功能名称功能...

直播互动解决方案

同一直播间的客户端发送和订阅消息的Topic需分开创建和使用，以免云消息队列 RocketMQ 版形成消费死循环。具体示例如下。场景一：直播互动消息例如，一个在线教育直播间中有三名成员，一名老师和两名学生。学生A在直播间发文字消息，...

队列（MessageQueue）

使用建议按照实际业务消耗设置队列数云消息队列 RocketMQ 版的应遵循少用够用原则，避免随意增加队列数量。主题内队列数过多可能对导致如下问题：集群元数据膨胀云消息队列 RocketMQ 版会以队列粒度采集指标和监控数据，队列过多容易...

产品优势

本文主要介绍云消息队列 RabbitMQ 版相比于自建开源RabbitMQ所具备的优势，以便您更进一步了解云消息队列 RabbitMQ 版。灵活易用开箱即用完全兼容 AMQP 0-9-1 标准协议，完全兼容RabbitMQ开源社区，快速迁移上云。全托管服务一键开通...

发布者最佳实践

在消息没有指定Key的情况下，云消息队列 Kafka 版 2.4版本之前的默认策略是循环使用主题的所有分区，将消息以轮询的方式发送到每一个分区上。但是，这种默认策略Batch的效果会比较差，在实际使用中，可能会产生大量的小Batch，从而使得实际...

功能与特性概述

概览云消息队列 RocketMQ 版在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布服务。云消息队列 RocketMQ 版提供TCP和HTTP协议的多语言接入...

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

云消息队列 RocketMQ 版联合阿里云云监控提供了开箱即用且免费的监控报警服务，可帮助您解决如下问题：实例规格水位监控预警若您实际使用的指标值超过实例的规格限制，云消息队列 RocketMQ 版会进行强制限流。提前配置实例规格水位告...

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

云消息队列 RocketMQ 版联合阿里云云监控提供了开箱即用且免费的监控报警服务，可帮助您解决如下问题：实例规格水位监控预警若您实际使用的指标值超过实例的规格限制，云消息队列 RocketMQ 版会进行强制限流。提前配置实例规格水位告...

权限策略

在RAM中，权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的Resource（资源集）、Action（操作集）以及授权条件。云消息队列 MQTT 版有以下两类RAM的权限策略：系统策略：统一由阿里云创建，您只能使用不能修改，策略...

基本概念

在云消息队列 RocketMQ 版中，通过消费者分组内初始化多个消费者实现消费性能的水平扩展以及高可用容灾。更多信息，请参见消费者分组（ConsumerGroup）。消费者（Consumer）消费者是云消息队列 RocketMQ 版中用来接收并处理消息的运行...

排他队列

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

消息收发流程变更

云消息队列 MQTT 版 V2.x.x版本强依赖云消息队列 RocketMQ 版作为消息存储，因此云消息队列 MQTT 版消息和云消息队列 RocketMQ 版天然打通，创建了Topic后即可天然使用云消息队列 RocketMQ 版和云消息队列 MQTT 版的SDK相互通信...

资源使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对云消息队列 RocketMQ 版的消息依赖，因此，云消息队列 MQTT 版的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明云消息队列 MQTT 版 ...

调用方式

Parameters：请求参数，每个参数之间用“&”分隔。请求参数由公共请求参数和API自定义参数组成。公共参数中包含API版本号、身份验证等信息。详情请参见公共参数。SDK调用云消息队列 RabbitMQ 版提供多语言SDK。阿里云SDK免去您手动签名...

MQTT与RocketMQ的消息结构映射

本文针对使用云消息队列 RocketMQ 版 SDK与云消息队列 MQTT 版交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版是一款面向移动端的网关产品，可通过数据互通...

默认配置映射关系

映射关系如下：消息服务MNS 默认入参目标端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body ...

默认配置映射关系

映射关系如下：消息服务MNS 默认入参目标端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body ...

默认配置映射关系

映射关系如下：消息服务MNS 默认入参目标端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body ...

死信队列

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

权限策略

策略类别在RAM中，权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的Resource（资源集）、Action（操作集）以及授权条件。云消息队列 MQTT 版有以下两类RAM的权限策略：系统策略：统一由阿里云创建，您只能使用不能...

MQTT快速入门

作为使用和熟悉产品功能的入门指导，本文提供如何快速使用云消息队列 MQTT 版通过默认支持的MQTT协议收发消息的步骤。对于非MQTT协议的接入，例如新能源，您必须首先购买云消息队列 MQTT 版企业铂金版，并通过专属通道享受对应的文档和...

计费FAQ

本文汇总了云消息队列 RabbitMQ 版计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...

产品架构

本文介绍云消息队列 Kafka 版的系统架构和发布/订阅模型。云消息队列 Kafka 版系统架构如云消息队列 Kafka 版的系统架构所示，一个云消息队列 Kafka 版集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...

接入Logstash

本文介绍如何将云消息队列 Kafka 版接入Logstash。Logstash Logstash是开源的服务器端数据处理管道，能够同时从多个数据源采集数据，然后对数据进行转换，并将数据写入指定的存储中。Logstash的数据处理流程如下：输入：采集各种格式、...

跨云产品数据流入

您可通过配置云消息队列 MQTT 版的数据流入规则来自定义数据从其他阿里云产品流入到云消息队列 MQTT 版。本文介绍跨产品数据流入的原理、应用场景、使用限制以及云消息队列 MQTT 版与其他阿里云产品的资源映射关系。基本原理如需将...

开源对比

本文从稳定性、内核能力、治理能力以及使用习惯等方面，对比阿里云云消息队列 Kafka 版与开源Apache Kafka。稳定性项目云消息队列 Kafka 版 Apache Kafka 磁盘水位磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离读冷数据仍可以...

默认配置映射关系

映射关系如下：消息服务MNS 默认入参源端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body 数据...

计费FAQ

本文汇总了云消息队列 RabbitMQ 版计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...

消费者分组（ConsumerGroup）

在云消息队列 RocketMQ 版中，通过消费者分组内初始化多个消费者实现消费性能的水平扩展以及高可用容灾。在消费者分组中，统一定义以下消费行为，同一分组下的多个消费者将按照分组内统一的消费行为和负载均衡策略消费消息。订阅关系：云...

Topic使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x后，实现了独立存储，Topic资源不再依赖于云消息队列 RocketMQ 版，因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 ...

什么是云消息队列 Kafka 版？

云消息队列 Kafka 版是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势云消息队列 ...

升级多可用区

当您使用的是专业版实例，且部署时仅选择了单可用区部署，可以通过编辑备可用区，升级集群为多可用区架构部署，从而增强集群的容灾能力。前提条件您使用的云消息队列 Kafka 版实例类型为专业版。实例当前为单可用区部署。实例当前读写...

消费者负载均衡

消费者从云消息队列 RocketMQ 版获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍云消息队列 RocketMQ 版消费者的负载均衡...

循环队列怎么用

新品推荐