Terraform
什么是Terraform 基本功能 Terraform是IT基础架构自动化编排工具，可以用代码来管理维护IT资源。更多信息，请参见 什么是Terraform。Terraform的命令行接口CLI（Command Line Interface）提供一种简单机制，用于将配置文件部署到阿里云或...
常见问题
消息队列RocketMQ版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？消息队列RocketMQ版的消息体最大是多少？消息在消息队列RocketMQ版中能保存多久？消息的负载均衡策略是什么？消息消费失败是否会重新消费？消息...
顺序消息
什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。顺序消息...
顺序消息
功能原理 什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持消费者按照发送消息的先后顺序获取消息，从而实现业务场景中的顺序处理。相比其他类型消息，顺序消息在发送、存储和投递的处理过程中，更多强调多...
定时/延时消息
功能原理 什么是定时消息 定时消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，消息被发送至服务端后，在指定时间后才能被消费者消费。通过设置一定的定时时间可以实现分布式场景的延时调度触发效果。定时时间设置原则 云消息队列 ...
事务消息
功能原理 什么是事务消息 事务消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。事务消息处理流程 事务消息交互流程如下图所示。生产者将消息发送至 云消息队列 RocketMQ 版...
QueryMqttTraceMessagePublish-查询消息发送轨迹
pub_mq：表示消息的发送者是云消息队列 RocketMQ 版客户端。pub_mqtt ActionCode string 消息动作的返回码。取值说明如下：mqtt.trace.action.msg.pub.mqtt：消息动作取值为 pub_mqtt时返回该参数值。mqtt.trace.action.msg.pub.mq：消息...
消息队列
配置消息队列 Rocket MQ触发器 说明 注意：配置消息队列Rocket MQ触发器，需要您先参考安装云服务集成章节完成云服务集成的安装，并参考集成消息队列Rocket MQ章节集成消息队列Rocket MQ。在消息队列 RocketMQ集成页面，单击 添加配置。在...
批量消费
什么是批量消费 定义 批量消费是 云消息队列 RocketMQ 版 通过Push消费者提供的、将消息分批次消费的功能。说明 根据消息获取方式，云消息队列 RocketMQ 版 提供Push和Pull两种类型的消费者，更多信息，请参见 基本概念。功能原理 批量消费...
P2P消息收发模式（MQTT）
什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即拥有一个或多个消息发送者和多个消息接收者的场景。在P2P模式中，发送者发送消息时...
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
普通消息
功能原理 什么是普通消息 定义：普通消息是 云消息队列 RocketMQ 版 基本消息功能，支持生产者和消费者的异步解耦通信。普通消息生命周期 初始化 消息被生产者构建并完成初始化，待发送到服务端的状态。待消费 消息被发送到服务端，对消费...
产品功能
云消息队列 RabbitMQ 版 兼容开源RabbitMQ并提供一套完善的运维工具。资源支持 云消息队列 RabbitMQ 版 兼容开源RabbitMQ的各个组件：Queue：支持消息存储，支持集群消费模式。说明 云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理...
发布者最佳实践
因此，云消息队列 Kafka 版 Producer客户端什么时候把消息批量发送至服务器是由 batch.size 和 linger.ms 共同决定的。您可以根据具体业务需求进行调整。为了提升发送的性能，保障服务的稳定性，建议您设置 batch.size=16384 和 linger.ms=...
云消息队列 Kafka 版自定义权限策略参考
什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来维护。创建自定义权限策略后，需为RAM用户、用户组或RAM角色绑定权限...
云消息队列 RocketMQ 版自定义权限策略
什么是自定义权限策略 在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来维护。创建自定义权限策略后，需为RAM用户、用户组或RAM角色绑定权限...
使用Canal和RocketMQ实现数据库变更订阅处理
MQ_INST_1266540465*_BYSLmTAL 高阶参数配置 数据同步Topic和顺序性设置 Canal传输数据库变更事件到 云消息队列 RocketMQ 版 默认遵循一定的顺序性原则，在早期版本中每个任务默认是发送到 云消息队列 RocketMQ 版 单个Topic的单个分区。...
使用Canal和RocketMQ实现数据库变更订阅处理
开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable.message.trace 设置为 true canal.mq.accessChannel 设置为 cloud 序列化方式设置 Canal向 云消息队列 RocketMQ 版 写入的数据是Canal指定的序列化格式，具体代码示例，请参见 ...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
微消息队列MQTT版推送事件到函数计算
本文介绍如何通过 事件总线EventBridge 将 云消息队列 MQTT 版 的数据推送到函数计算。前提条件 您已完成以下操作：事件总线EventBridge 开通事件总线EventBridge并授权 创建自定义总线 函数计算 创建服务 创建函数 创建日志项目和日志仓库...
延时消息
什么是延时消息 延时消息是指在指定时间段之后才被消费者消费的消息。应用场景 延时消息适用于以下场景：对消息生产和消费有时间窗口要求的场景。例如，在电商交易中超时未支付关闭订单的场景，在订单创建时会发送一条延时消息。这条消息将...
常见问题
按流量峰值收费的依据是什么？为什么额外增加分区要收费？我使用的Connector组件如何计费？客户端报错 使用云消息队列 Kafka 版时客户端的报错及解决方案 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息 网络...
授权信息
本文为您介绍 消息队列Kafka版（AliKafka）为RAM权限策略定义的操作（Action）、资源（Resource）和条件（Condition）。消息队列Kafka版（AliKafka）的RAM代码（RamCode）为 alikafka，支持的授权粒度为 RESOURCE。权限策略通用结构 权限...
基于Flink的资讯场景实时数仓
场景描述 本文首先介绍什么是实时数仓以及相关技术架构，接着介绍资讯聚合类业务的典型场景及其业务目标，并据此设计了相应的技术架构。然后介绍如何部署基础环境和搭建实时数仓，并介绍业务系统如何使用实时数仓。解决的问题 通过 云消息...
控制台使用相关问题
本文介绍 云消息队列 MQTT 版 控制台使用时的常见问题。云监控的最大查询范围是多少？云消息队列 MQTT 版 云监控支持查询3天以内的指标数据。为什么设备都断电了，控制台还显示设备在线？云消息队列 MQTT 版 会定时检查客户端心跳，当系统...
消息发送重试和流控机制
触发流控时客户端行为是什么？应该如何避免触发流控，以及如何应对突发流控？消息发送重试机制 重试基本概念 云消息队列 RocketMQ 版 客户端连接服务端发起消息发送请求时，可能会因为网络故障、服务异常等原因导致调用失败。为保证消息的...
云消息队列 RabbitMQ 版系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
消息队列Kafka版系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
计费FAQ
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...
计费FAQ
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...
RAM鉴权
mq:MqttInstanceAccess mq:RevokeToken QueryToken mq:MqttInstanceAccess mq:QueryToken ApplyToken mq:MqttInstanceAccess mq:ApplyToken CreateGroupId mq:MqttInstanceAccess mq:CreateGroupId DeleteGroupId mq:MqttInstanceAccess mq...
云消息队列 RocketMQ 版4.x系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
消费托管MQ接口
消费托管MQ接口主要用于获取托管MQ中的消息以及消息成功后进行确认的功能。获取消息 获取托管MQ中的消息，方法名称：consumeMQMessage。函数原型 ConsumeMQMessageResponse consumeMQMessage(final ConsumeMQMessageRequest request)请求...
云消息队列 RocketMQ 版5.x系统权限策略参考
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
配置网卡多队列的网络中断亲和性
多队列是指网络接口卡具有能力在多个发送和接收队列上并行处理网络数据包。在使用网卡多队列时，通常需要配置网络中断亲和性（IRQ Affinity），将不同的队列中断分配给特定的CPU处理，而不是由任意的CPU处理，这有助于减少CPU之间的争用并...
发送消息（多线程）
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高...
开通服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源，并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
- 产品推荐
- 这些文档可能帮助您