云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
云消息队列 RocketMQ 版 通过消费位点管理消费进度，本文为您介绍 云消息队列 RocketMQ 版 的消费进度管理机制。背景信息 云消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...
云消息队列 RocketMQ 版 的标准版实例按照按量付费方式对API请求资源和Topic资源进行计费，针对这两个计费项，云消息队列 RocketMQ 版 分别推出API请求次数和Topic次数资源包，帮助您以更优惠的价格享受等量资源。使用的资源在资源包规格内...
队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...
主题模型消息流 主题模型特性 通知消息 消息服务MNS 服务端主动将消息推送到您指定的队列，消除用户端不必要的轮询和资源消耗。您可以将资源集中在处理自身业务的逻辑中，避免对其他消息服务产品客户端的依赖，避免因为过多代码引入而影响...
消息队列RocketMQ版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？消息队列RocketMQ版的消息体最大是多少？消息在消息队列RocketMQ版中能保存多久？消息的负载均衡策略是什么？消息消费失败是否会重新消费？消息...
OpenAPI是阿里云产品提供的开放应用程序接口，是除控制台之外，云消息队列 RocketMQ 版 管理资源的主要方式之一。API参考汇总了 云消息队列 RocketMQ 版 所有对外公开的API接口。云消息队列 RocketMQ 版5.x系列 5.x系列SDK参考 5.x系列API...
什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。顺序消息...
功能原理 什么是事务消息 事务消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。事务消息处理流程 事务消息交互流程如下图所示。生产者将消息发送至 云消息队列 RocketMQ 版...
本文介绍 云消息队列 RocketMQ 版 的基本概念，以便您更好地理解和使用 云消息队列 RocketMQ 版。主题（Topic）云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。...
什么是批量消费 定义 批量消费是 云消息队列 RocketMQ 版 通过Push消费者提供的、将消息分批次消费的功能。说明 根据消息获取方式，云消息队列 RocketMQ 版 提供Push和Pull两种类型的消费者，更多信息，请参见 基本概念。功能原理 批量消费...
在DataWorks中，您可按照工作空间粒度指定各模块使用的YARN队列，后续各模块将默认使用该队列执行EMR任务。同时，可定义全局YARN资源队列优先级是否高于指定模块内配置的YARN资源队列优先级。本文为您介绍如何设置全局YARN资源队列。背景...
什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即拥有一个或多个消息发送者和多个消息接收者的场景。在P2P模式中，发送者发送消息时...
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
场景描述 本文首先介绍什么是实时数仓以及相关技术架构，接着介绍资讯聚合类业务的典型场景及其业务目标，并据此设计了相应的技术架构。然后介绍如何部署基础环境和搭建实时数仓，并介绍业务系统如何使用实时数仓。解决的问题 通过 云消息...
在某个实例下发起重启类任务（包括配置变更、版本升级、开启ACL、实例升配）后，您可以在 云消息队列 Kafka 版 控制台查看重启类任务的执行记录，帮助您跟踪任务进展、定位服务端异常重启原因等。前提条件 创建并部署 云消息队列 Kafka 版 ...
本文介绍如何使用队列分组管理计算节点，包括创建和删除队列，以及在队列之间移动节点。背景信息 创建集群时会自动创建一个默认队列，计算节点默认会加入到该队列中。操作步骤 打开 节点与队列 页面。登录 弹性高性能计算控制台。在顶部...
主要特性 CapacityScheduler具备如下的特性：多级队列（树形结构）：支持多级租户管理，父队列资源配额能够限制其下所有子队列的资源使用，单个子队列的资源配额也不能超过父队列的资源配额，因此对于多租户管理具备较高的可控性，能够满足...
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源，并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
主要能力是将各类数据流入至 云消息队列 Kafka 版，并且可靠地管理来自不同源头的数据源，同时对来源数据进行筛选和过滤。概念介绍—消息流出（Sink）消息流出的主要能力是将 云消息队列 Kafka 版 的数据流出到各类数据目标，Connector生态...
云消息队列 Kafka 版 提供全托管免运维服务，您无需登录机器。云消息队列 Kafka 版 是全托管的，由 云消息队列 Kafka 版 专业团队进行运维保障，您无需登录机器。集群的一些基础信息会通过监控告警进行透传。
云消息队列 RabbitMQ 版 存储加密默认采用行业标准的AES-256加密算法，利用密钥管理服务KMS（Key Management Service）加密您的数据信息，该项能力完全免费。传输加密 使用限制 传输加密仅Serverless版、企业版、铂金版实例支持，专业版...
本文为您介绍 云消息队列 RocketMQ 版 的领域模型。产品定位 云消息队列 RocketMQ 版 是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文 通信方式介绍 和 消息...
Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 ...
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...
问题现象 在 云消息队列 Kafka 版 控制台 的 Group 管理 页面查看您Kafka集群上所有存在的Group时，显示的Group数量多于您手动创建的数量。可能原因 若Group的 自动创建 栏为 否，说明此Group创建于 云消息队列 Kafka 版 控制台 的 Group ...
本文介绍如何使用Ruby SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 您已安装Ruby。更多信息，请参见 安装Ruby。安装Ruby依赖库 执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 准备配置 可选：下载SSL根...
本文介绍 云消息队列 RocketMQ 版 中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 主题是 云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：...
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...
消费流量 Group与Topic的订阅关系 服务端小版本升级 消费位点提交频率 存在Rebalance的Group 消费客户端主动离开队列 使用Sarama Go客户端 操作步骤 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。...
本文介绍 云消息队列 MQTT 版 控制台使用时的常见问题。云监控的最大查询范围是多少？云消息队列 MQTT 版 云监控支持查询3天以内的指标数据。为什么设备都断电了，控制台还显示设备在线？云消息队列 MQTT 版 会定时检查客户端心跳，当系统...
云消息队列 RabbitMQ 版 兼容开源RabbitMQ并提供一套完善的运维工具。资源支持 云消息队列 RabbitMQ 版 兼容开源RabbitMQ的各个组件：Queue：支持消息存储，支持集群消费模式。说明 云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理...
为什么选择云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 基于阿里云云原生优质的基础设施实现，兼容Apache RocketMQ的核心API和功能。相对于自建RocketMQ集群，云消息队列 RocketMQ 版 具有如下优势：架构先进性 全面采用存储和计算分离...
场景描述 适用于在线教育的视频直播场景，通过阿里云视频直播服务实现移动端的推拉流能力，同时移动端利用 云消息队列 MQTT 版 实现发送和接收消息，在消息转发时利用内容安全服务对消息内容进行审核。发送的消息可以存储在表格存储中。...
权限策略名称 说明 AliyunMQFullAccess 管理 云消息队列 MQTT 版 的权限，等同于阿里云账号的权限，被授予该权限的RAM用户具有所有消息收发权限且有控制台所有功能操作权限。AliyunMQPubOnlyAccess 云消息队列 MQTT 版 的发布权限，被授予...
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...