延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
开源RabbitMQ迁移上云
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...
历史功能发布记录（2023年）
全部 ack-fluid ack-kube-queue组件发布v0.2.0版本 ack-kube-queue是 云原生AI套件 提供的任务队列组件，v0.2.0版本中，新增支持队列级别开启队列阻塞功能，支持tfjob与pytorchjob运行超时任务重新入队，Argo Workflow整体排队，以及限制...
使用任务队列ack-kube-queue
任务队列ack-kube-queue旨在管理Kubernetes中的AI/ML工作负载和批处理工作负载。它允许系统管理员使用自定义队列的作业队列管理，以提高队列的灵活性。结合Quota系统，ack-kube-queue自动优化了工作负载和资源配额管理，以便最大化利用集群...
在ACK集群部署多租户任务调度管理
在ACK集群中，企业可以通过AI套件中的任务管理工具Arena、队列调度管理系统Kube Queue、配额管理工具ElasticQuotaTree以及Prometheus监控打造企业级任务调度系统。本文将从实际案例出发自底而上地介绍如何基于ACK集群构建一个任务调度系统...
部署异步推理服务
当输出队列满时，即无法向输出队列中写入数据时，服务框架也会停止从输入队列中接收数据，避免无法将推理结果输出到输出队列。如果您不需要输出队列，例如将推理结果直接输出到OSS或者您自己的消息中间件中，则可以在同步的HTTP推理接口中...
JMS概述
云消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...
使用Resource Queue（资源队列）进行负载管理
使用Resource Queue可以对云原生数据仓库PostgreSQL版的系统资源进行管理或隔离，本文将介绍如何在云原生数据仓库PostgreSQL版中创建和使用Resource Queue。Resource Queue介绍 一个数据库实例的CPU资源和内存资源是有限的，这些资源影响着...
查询消息
云消息队列 RabbitMQ 版 支持按Queue查询和按Message ID查询两种方式，前者适用于只知道消息发送到的Queue，不知道发送消息时设置的Message ID的模糊查询场景。后者适用于知道发送消息时设置的Message ID的精确查询场景。使用限制 云消息...
QueueHasDiffField
本文为您介绍 云消息队列 RabbitMQ 版 客户端报QueueHasDiffField类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报QueueHasDiffField类型错误。例如QueueHasDiffField...
Exchange
路由示例 Fanout Exchange忽略Routing Key和Binding Key的匹配规则将消息路由到所有绑定的Queue的示例如下：Message Routing Key Binding Key Queue Message A img.create files.cn.hz.#queue.msgText Queue A Queue B Message B queue....
在Knative上实现Kafka消息推送
Knative已支持Kafka事件源，您可将Knative与 云消息队列 Kafka 版 对接，在Knative上实现Kafka消息推送。前提条件 部署Knative 购买并部署 云消息队列 Kafka 版 实例 重要 云消息队列 Kafka 版 实例和Knative必须处于同一VPC内。云消息队列...
AI负载调度
本文介绍弹性资源调度、AI任务调度、异构资源调度和任务队列调度，帮助用户提升集群的资源利用率和作业运行效率。弹性调度 ACK为不同弹性资源提供了混合调度的能力。功能 描述 参考文档 弹性调度 阿里云提供了不同种类的弹性资源，如ECS和...
AMQP协议返回码
本文说明 云消息队列 RabbitMQ 版 客户端调用AMQP 0-9-1协议时的返回码，您可以根据返回信息与解决方案自助排查错误。返回码列表 返回码（reply-code）返回信息（reply-text）描述 解决方案 200 no route has mandatory 调用 basicPublish ...
基于事件流实现RabbitMQ消息路由
本文介绍如何应用 事件总线EventBridge 的事件流功能实现 云消息队列 RabbitMQ 版 的消息路由。前提条件 您已 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 ...
ExchangeHasDiffFields
介绍 云消息队列 RabbitMQ 版 客户端报ExchangeHasDiffFields类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报ExchangeHasDiffFields类型错误。例如ExchangeHasDiffFields...
全球消息路由
全球消息路由的功能和使用方式和开源Shovel插件保持一致，支持不同实例和Vhost间的Queue到Queue、Queue到Exchange的消息转发。在此基础上，除了可以本地域间消息转发，也可以支持跨地域消息转发，以便您按需同步消息，实现不同实例、不同...
开源SDK接入（跨云账号授权）
本文以调用Java SDK为例，介绍在RAM角色跨账号授权场景，通过开源SDK实现消息收发的操作过程，帮助您更好地理解消息收发的完整过程，其他语言或框架的SDK消息收发过程相似。前提条件 创建实例 创建Vhost 背景信息 当您需要通过RAM STS角色...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 您已完成以下操作：下载C...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，阅读 Demo工程 来了解搭建 云消息队列 RocketMQ 版 工程的...
基本概念
本文说明 云消息队列 Kafka 版 涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...
消息检索
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
Statement Queue
PolarDB 设计了针对语句的排队（Statement Queue）机制，将语句进行分桶排队，尽量把可能具有相同冲突（例如操作相同行）的语句放在一个桶内排队，减少冲突的开销。背景信息 MySQL的服务层和引擎层在语句并发执行过程中，有很多串行的点...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 下载.NET SDK。更多信息...
将云消息队列 Kafka 版接入阿里云Elasticsearch
随着时间的积累，云消息队列 Kafka 版 中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将...
怎样让Consumer不立即消费消息并使消息重入队列？
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...
怎样让Consumer不立即消费消息并使消息重入队列？
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...
通过RAM角色实现跨云账号授权
背景信息 企业A购买了 云消息队列 RocketMQ 版 服务来开展业务，并希望将部分业务授权给企业B。需求说明：A希望能专注于业务系统，仅作为资源Owner；而消息发布和订阅等任务委托或授权给企业B。企业A希望当企业B的员工加入或离职时，无需做...
什么是云原生多模数据库Lindorm
本文介绍 云原生多模数据库 Lindorm 的产品概要。产品介绍 Lindorm是面向物联网、互联网、车联网等设计和优化的云原生多模超融合数据库，支持宽表、时序、文本、对象、流、空间等多种数据的统一访问和融合处理，并兼容SQL、HBase/Cassandra...
全球消息路由
什么是全球消息路由 云消息队列 RocketMQ 版 的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线（高速通道无需另行开通），高效地实现不同地域之间的消息同步复制。具体实现如下图所示。计费影响 全球消息路由为 云消息队列 ...
权益分发
如果没有 云消息队列 RocketMQ 版，实现方法则十分复杂。支持实时消息收发以及重试功能，确保消息不丢，从而保证消息强一致性。更多信息 云消息队列 RocketMQ 版 的功能与特性详情，请参见以下文档：功能与特性概述 消息重试
DBMS_AQADM
您可以使用 DBMS_AQADM 包中的存储过程创建并管理消息队列和队列表。表 1.DBMS_AQADM函数/存储过程 函数/存储过程 返回类型 说明 ALTER_QUEUE N/A 修改现有的队列。ALTER_QUEUE_TABLE N/A 修改现有的队列表。CREATE_QUEUE N/A 创建队列。...
Topic使用变更
变更说明 由于V3.x.x版本的 云消息队列 MQTT 版 实现了自身的消息存储，因此所有的 云消息队列 MQTT 版 Topic资源都需要在 云消息队列 MQTT 版 控制台或调用其OpenAPI进行管理。云消息队列 MQTT 版 的Topic资源不再和 云消息队列 RocketMQ ...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
- 产品推荐
- 这些文档可能帮助您