本文介绍 云消息队列 RabbitMQ 版 中Connection和Channel的概念及其使用建议。Connection Connection是物理TCP连接。Connection将应用与 云消息队列 RabbitMQ 版 连接在一起。Connection会执行认证、IP解析、路由等底层网络任务。应用与 云...
在调用SDK收发消息前,您需要提前创建 云消息队列 RocketMQ 版 的相关资源,包括创建 云消息队列 RocketMQ 版 实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时,需要将这些资源信息填写到SDK代码中。前提条件 创建专有...
云消息队列 RocketMQ 版 支持消息重试功能,即Consumer消费某条消息失败或消费超时,云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ,其中 {SDK...
本文介绍如何在 云消息队列 Kafka 版 控制台完成实例升配,升级的配置项包括规格类型、流量规格、磁盘容量及分区规格等。前提条件 实例处于 服务中 或 未部署 状态。实例中没有进行中的Topic引流任务。注意事项 升级实例配置会引发集群逐台...
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版,实现MySQL数据库Binlog数据的变更处理。背景信息 CDC(Change Data Capture)是一种监测并捕获数据库变更的典型技术方案,常应用于异构数据源之间的数据同步。Canal...
作为一款典型的分布式中间件产品,云消息队列 RocketMQ 版 被广泛应用于业务核心链路中,每条消息都关联着核心业务数据的变化,通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版,实现MySQL数据库Binlog数据的变更处理。背景信息 CDC(Change Data Capture)是一种监测并捕获数据库变更的典型技术方案,常应用于异构数据源之间的数据同步。Canal...
本文以Java SDK为例,说明如何将开源SDK客户端接入 云消息队列 RabbitMQ 版 服务端,并完成消息收发。前提条件 创建资源 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA Ultimate为例。安装JDK 安装Maven 安装Java依赖...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用TCP协议下的.NET SDK收发普通消息的示例代码。前提条件 您已完成以下操作:下载.NET SDK。更多信息,请参见 版本...
云消息队列 RocketMQ 版 协议中的消息(Message)可以拥有自定义属性(Properties),而MQTT协议目前的版本不支持属性,但为了方便溯源MQTT协议中的Header信息和设备信息,云消息队列 MQTT 版 的部分信息将被映射到 云消息队列 RocketMQ 版...
顺序消息(FIFO 消息)是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的.NET SDK收发顺序消息的示例代码。顺序消息分类 顺序消息分为两类:全局顺序:对于指定的一个Topic,所有消息按照...
和开源Apache RocketMQ相比,阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验。本文为您介绍如何使用 云消息队列 RocketMQ 版...
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证,并限制访问权限,以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
背景信息 Rebalance是 云消息队列 Kafka 版 对分区和Consumer Group之间的消费对应关系进行重分配的过程。消费客户端出现Rebalance可能是以下原因:当消费者主动新增订阅或者取消订阅时,会触发该Consumer Group内的Rebalance。当Topic的...
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的,可以在多个线程之间共享使用。您可以在服务器上(或者多台服务器)部署多个生产者和消费者实例,也可以在同一个生产者或消费者实例里采用多线程发送或接收消息,从而提高...
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证,并限制访问权限,以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个Consumer实例,那么在集群消费模式下每个实例平均分摊,只消费其中的3条消息。...
前提条件 创建实例 创建Vhost 背景信息 当您需要通过RAM STS角色授权的方式访问 云消息队列 RabbitMQ 版 服务时,需要通过阿里云提供的权限认证类(AliyunCredentialsProvider)设置 AccessKeyID、AccessKeySecret 与 SecurityToken 进行...
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息,为什么收10次API调用费?将1条消息发送给10个Queue,实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费?虽然删除了...
创建云消息队列 RocketMQ 版5.x系列实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致链路产生风险...
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息,为什么收10次API调用费?将1条消息发送给10个Queue,实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费?虽然删除了...
云消息队列 Kafka 版 已与操作审计服务集成,您可以在操作审计中查询操作 云消息队列 Kafka 版 产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中,满足实时审计、问题回溯分析等需求。事件...
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的C#SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更多...
作为使用和熟悉产品功能的入门指导,本文提供如何快速使用 云消息队列 MQTT 版 通过默认支持的MQTT协议收发消息的步骤。对于非MQTT协议的接入,例如新能源,您必须首先购买 云消息队列 MQTT 版 企业铂金版,并通过专属通道享受对应的文档和...
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的Node.js SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示...
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的Python SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示...
云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储,因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通,创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信...
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的Java SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。...
更新云消息队列 RocketMQ 版实例的基本信息和规格配置。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致...
设置接入点,在云消息队列 RabbitMQ 版控制台实例详情页面获取。factory.setHost("xxx.xxx.aliyuncs.com");{instanceId}为实例ID,从云消息队列 RabbitMQ 版控制台实例详情页面获取。factory.setCredentialsProvider(new ...
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的PHP SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x实现了自身数据存储的能力,同时还去除了对 云消息队列 RocketMQ 版 的消息依赖,因此,云消息队列 MQTT 版 的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明 云消息队列 MQTT 版 ...
若您不需要使用自定义域名,[alt_names]直接填写为 云消息队列 MQTT 版 提供的域名。例如:DNS.2=mqtt-test.cn-qingdao.aliyuncs.com 。若您需要在多个Region的不同实例使用同一个服务器证书,域名填写可以使用通配符,例如:DNS.1=*.mqtt....
创建云消息队列RabbitMQ的实例。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 ...
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的Go SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
本文为您介绍 云消息队列 MQTT 版 对某些具体指标的约束和规范,您在使用 云消息队列 MQTT 版 时请不要超过相应的限制值,以免程序出现异常。具体的限制项和限制值请参见下表。如果您购买了铂金版的 云消息队列 MQTT 版 实例,则可按需定制...
本文介绍如何创建使用Tablestore Sink Connector,您可通过Tablestore Sink Connector将数据从 云消息队列 Kafka 版 实例的数据源Topic导出至Tablestore的表中。前提条件 创建资源及授权策略,请参见 创建前提。创建Connector时生成的函数...
本文说明 云消息队列 Kafka 版 涉及的专有名词和术语,帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台,可以实时发布、订阅、存储和处理数据流。更多信息,请参见 Apache Kafka。云消息队列 Kafka 版...
映射关系如下:消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...