死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
队列模型基本概念
本文对 消息服务MNS 的队列模型涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列（Queue）消息存储的目的地，分成普通队列和延时队列两类。消息包含数据和属性，可以分成...
队列使用手册
本文介绍如何使用C#SDK创建队列、发送消息、接收和删除消息、以及删除队列。步骤一：准备工作 下载最新版C#SDK，解压后将工程导入到VisualStudio。找到工程里四个项目中SDK所在的项目 AliyunSDK_MNS，单击鼠标右键，选择重新生成，在 bin ...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
查询消息
云消息队列 RabbitMQ 版 支持按Queue查询和按Message ID查询两种方式，前者适用于只知道消息发送到的Queue，不知道发送消息时设置的Message ID的模糊查询场景。后者适用于知道发送消息时设置的Message ID的精确查询场景。使用限制 云消息...
使用任务队列ack-kube-queue
任务队列ack-kube-queue旨在管理Kubernetes中的AI/ML工作负载和批处理工作负载。它允许系统管理员使用自定义队列的作业队列管理，以提高队列的灵活性。结合Quota系统，ack-kube-queue自动优化了工作负载和资源配额管理，以便最大化利用集群...
从自建MySQL同步至云消息队列 Kafka 版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
配置消息日志
您可以使用 云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时，您可在日志服务查询并分析消息的操作日志，进行异常诊断。前提条件 创建 云消息队列...
实例管理
是否支持消息轨迹 最大连接数（该配置项适用于企业版实例和铂金版实例）消息存储空间（该配置项只适用于铂金版实例）Serverless版实例支持升级和降级的配置项如下：是否支持公网 是否支持消息轨迹 为实例续费 为避免实例因欠费被释放而导致...
DROP QUEUE TABLE
说明 PolarDB PostgreSQL版（兼容Oracle）为 DROP QUEUE TABLE SQL 命令包括额外的语法（Oracle 不提供）。可以将该语法与 DBMS_AQADM 联合使用。参数 参数 说明 name 将删除队列表的名称（可能是 schema 限定的）。IFEXISTS 包含 IF ...
消息存活时间
什么是消息存活时间 在 云消息队列 RabbitMQ 版 中，消息存活时间用于限制消息在Queue中可以存在的时间，如果消息在Queue中存在的时间超过了设置的消息存活时间，消息将会被进行如下处理：若您未给Queue设置死信Exchange，消息将被Queue...
使用ACL功能进行访问控制
当需要对不同的用户或用户组授予不同级别的访问权限时，您可以使用 云消息队列 Kafka 版 专业版实例的访问控制列表（ACL）功能，为SASL用户赋予对Topic、Group等资源的操作权限，实现细粒度的权限管理。背景信息 企业A购买了 云消息队列 ...
计费概述
计费文档概览 云消息队列 RocketMQ 版 提供标准版和企业铂金版两种类型实例，具体的规格差异和功能差异，请参见 实例规格。分类 相关文档 标准版实例 消息收发定价详情 公网流量定价详情 资源包说明 查看消费明细 免费说明 分账规则及最佳...
计费概述
计费组成 云消息队列 RabbitMQ 版 的计费项如下，具体计费项详情，请参见：预付费实例计费说明 Serverless后付费实例计费说明 实例到期说明 专业版、企业版和铂金版实例为预付费实例，实例到期前后的相关资源的状态变化如下：实例到期前 在...
服务端订阅（MNS）
本文介绍如何配置服务端订阅，将产品下的设备状态变化消息推送到消息服务（MNS）队列中；服务器通过监听MNS队列接收设备状态变化消息。前提条件 开通阿里云产品：物联网平台。消息服务。准备开发环境，本示例使用Java开发环境如下：操作...
消息收发计算规格费用
包年包月或按量付费计费方式下，消息收发计算规格为 云消息队列 RocketMQ 版 的必选计费项，云消息队列 RocketMQ 版 根据消息收发TPS上限提供不同的计算规格，并按照规格大小和购买时长计算费用。计算规格说明 计算规格能力约束 消息收发...
获取MQTT客户端在线状态
云消息队列 MQTT 版 提供同步查询和异步上下线事件通知两种方式，来获取MQTT客户端在线状态。本文介绍这两种方式的基本原理、应用场景、具体差异以及实现方式。基本原理 云消息队列 MQTT 版 服务端（下文简称为MQTT服务端）提供以下方式...
使用Resource Queue（资源队列）进行负载管理
创建Resource Queue 您可以使用如下语法创建Resource Queue：CREATE RESOURCE QUEUE name WITH(queue_attribute=value[,.])其中queue_attribute为Resource Queue的属性，可以取如下值：ACTIVE_STATEMENTS=integer[MAX_COST=float[COST_...
在ACK集群部署多租户任务调度管理
在ACK集群中，企业可以通过AI套件中的任务管理工具Arena、队列调度管理系统Kube Queue、配额管理工具ElasticQuotaTree以及Prometheus监控打造企业级任务调度系统。本文将从实际案例出发自底而上地介绍如何基于ACK集群构建一个任务调度系统...
消息负载均衡策略
因此，每台消费者机器处理的Queue的数量有以下几种可能：若消费者机器数量大于Queue的数量，则超出Queue数量的机器会处理0个Queue上的消息，如下图所示：若消费者机器数量等于Queue的数量，则每台机器会处理1个Queue上的消息，如下图所示：...
全球消息路由定价详情
全球消息路由为 云消息队列 RocketMQ 版 的高级功能，若您开通了全球消息路由功能，云消息队列 RocketMQ 版 会按照按量付费的方式进行计费，未使用该服务则不计费。高级功能不能单独使用，必须配合基础功能即消息收发功能一起使用。本文...
AMQP协议返回码
本文说明 云消息队列 RabbitMQ 版 客户端调用AMQP 0-9-1协议时的返回码，您可以根据返回信息与解决方案自助排查错误。返回码列表 返回码（reply-code）返回信息（reply-text）描述 解决方案 200 no route has mandatory 调用 basicPublish ...
SDK概述
本文介绍 云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK（Software Development Kit）即软件开发工具包，包含示例Demo、库文件、编译工具链以及编译脚本等，不需要开发者进行任何其他的配置，直接可以在SDK对应目录环境下，进行...
云消息队列 RabbitMQ 版自定义权限策略参考
DeleteQueue 删除Queue acs:amqp:$region:$accountid:/instances/$instanceId/vhosts/$vhostName/queues/$queueName GetQueue amqp:GetQueue 查看Queue acs:amqp:$region:$accountid:/vhosts/$vhostName/queues/$queueName queue.declare...
监控指标
您在创建 云消息队列 RabbitMQ 版 实例后，云监控自动开始对其进行监控。您可以查看实例、Vhost、Queue和Exchange的监控数据，分析实例的使用情况。您还可以对监控项设置报警规则，以便数据异常时收到报警消息，及时处理风险。前提条件 ...
JMS Pub/Sub（主账号与RAM账号）
前提条件 创建实例 创建Vhost 创建Exchange 创建Queue 创建绑定关系 背景信息 一条消息可以被多个订阅者消费。当某个发布者向某个Topic（消息主题）发布某条消息后，订阅了该Topic的所有订阅者都可以消费该条消息。发布者和订阅者之间存在...
全球消息路由
全球消息路由功能可用于跨地域间的消息同步，通过路由规则将消息从源实例的Topic中同步到目标实例的Topic，并支持过滤规则，按照指定的Tag将消息过滤后再进行同步。在容灾备份或异地多活场景下，您可以创建全球消息路由任务，确保跨地域间...
添加弹性伸缩规则
E-MapReduce弹性伸缩指标与YARN所属服务的对应关系 E-MapReduce弹性伸缩指标 所属服务 说明 yarn_resourcemanager_queue_AvailableVCores YARN root队列可供分配的虚拟核数。yarn_resourcemanager_queue_PendingVCores YARN root队列待分配...
Spring集成
前提条件 您已在 云消息队列 RabbitMQ 版控制台 创建实例、Vhost、Exchange、Queue等相关资源，具体操作，请参见 步骤二：创建资源。安装IDEA 安装1.8或以上版本JDK 安装2.5或以上版本Maven Demo工程示例 amqp-springboot-demo amqp-spring...
网络异常自动恢复
{instanceId}为实例ID，从云消息队列 RabbitMQ 版控制台实例详情页面获取。factory.setCredentialsProvider(new AliyunCredentialsProvider("${instanceId}"));设置Vhost名称，请确保已在消息队列AMQP版控制台上创建。factory....
Serverless后付费实例计费说明
云消息队列 RabbitMQ 版 的Serverless实例支持根据实际使用的资源量按量后付费，您可以弹性使用资源无需提前预留。本文为您介绍Serverless后付费实例的计费项及计费规则。地域限制 Serverless版实例暂时只在部分地域开服，其他地域将陆续...
Serverless实例计费说明
云消息队列 RocketMQ 版 的Serverless实例支持根据实际使用的资源量按量后付费，您可以弹性使用资源无需提前预留，可帮助您有效提高资源利用率并降低业务成本。本文为您介绍Serverless实例的计费项和计费规则。地域限制 Serverless实例暂时...
YARN高安全特性使用指南
队列ACL可以结合Capacity Scheduler调度器队列映射（Queue Mapping）特性使用，在 capacity-scheduelr.xml 配置文件中使用 yarn.scheduler.capacity.queue-mappings 配置用户或用户组提交作业的默认队列规则，通过 yarn.scheduler.capacity...
基于日志服务的日志说明
云消息队列 RabbitMQ 版 的日志管理功能将 云消息队列 RabbitMQ 版 实例的消息操作日志推送到日志服务，通过SLS分析语句快速查询并统计TPS流量图表。本文介绍SLS中日志字段和请求方法。字段说明 查询的日志字段说明如下表所示。表 1.日志...
TCP协议客户端大版本发布
云消息队列 RocketMQ 版 于2021年10月18日发布新版本Java SDK和C++ SDK客户端，本次发布对客户端大版本进行了升级。本文介绍发布的SDK版本信息、支持升级的地域以及主要的功能差异。SDK版本信息 本次发布的SDK客户端版本信息如下：协议 ...
ack-kube-queue
ack-kube-queue是云原生AI套件提供的任务队列组件，主要围绕着Kube Queue任务队列，结合调度器和Quota系统，提供队列管理、优先级调度、使用弹性配额等功能，帮助您优化Kubernetes中的AI/ML工作负载和批处理工作负载的管理效率和调度性能。...
ListQueueConsumers
调用ListQueueConsumers查询Queue的消费者。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 ...
使用云消息队列 Kafka 版时客户端的报错及解决方案
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
排他队列
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
ModifyInstance
调用ModifyInstance对实例资源配置进行变更。调用接口会创建一个变配实例资源的订单，并自动支付。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数...
- 产品推荐
- 这些文档可能帮助您