调用OpenOnsService开通云消息队列 RocketMQ 版服务。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...
如果您准备使用或正在使用 云消息队列 RabbitMQ 版,有任何产品相关疑问和建议,欢迎自行搜索以下群号加入钉钉群与我们交流。钉钉群号:31735582
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警,登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象:在 Group 详情 页面,看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹,单击 创建查询任务,...
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式,可根据本文提供的签名计算方式获取签名,再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述,如果选择签名校验模式,MQTT客户端实际连接MQTT消息服务器时,...
本文介绍如何在 云消息队列 Confluent 版 控制台中进行RBAC授权。背景信息 RBAC的全称是Role Based Access Control。RBAC的授权方式是基于角色进行授权的,而ACL是基于权限进行授权。因此,RBAC比ACL更适合批量授权以及权限回收。RBAC授权...
本文为您介绍快速使用 云消息队列 RabbitMQ 版 进行消息收发的操作流程。操作流程 后续步骤 步骤一:(可选)RAM用户授权 步骤二:创建资源 步骤三:调用SDK收发消息
本文为您介绍如何使用 云消息队列 RocketMQ 版 的迁移工具将开源自建的Apache RocketMQ迁移至阿里云 云消息队列 RocketMQ 版。前提条件 创建消息队列RocketMQ版5.0系列实例 创建服务关联角色 角色名称:AliyunServiceRoleForRMQMigration ...
当消费客户端出现Rebalance时,您可以查看Rebalance的详情,包括Rebalance的时间、耗时、次数、原因以及...后续步骤 当客户端频繁出现Rebalance时,您可以参考以下文档解决此问题:使用云消息队列 Kafka 版时消费客户端频繁出现Rebalance。
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同,都是服务端根据消息设置的定时时间在某一固定时刻...
当使用 云消息队列 Kafka 版 进行消息收发时,您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic,消费者通过订阅Topic获取消息进行消费。消费者消费消息时,需要指定Group订阅对应的Topic。Group和...
本文介绍使用 云消息队列 RocketMQ 版 提供的商业版HTTP协议的SDK收发消息时可能遇到的错误码,以及建议的处理方式。错误码 错误描述 HTTP状态码 建议处理方式 AccessDenied The OwnerId that your Access Key Id associated to is ...
在使用云消息队列 Kafka 版时,客户端可能报错,您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权(sasl.mechanisms)...
本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P,顾名思义,是一对一的消息收发模式,即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景,即...
本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P,顾名思义,是一对一的消息收发模式,即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景,即...
在创建并部署 云消息队列 Kafka 版 实例后,您可以使用 云消息队列 Kafka 版 控制台直接发送消息,快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
本产品(云消息队列 Kafka 版/2019-09-16)的OpenAPI采用 RPC 签名风格,签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK,开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用...
例如,您首次使用 云消息队列 RocketMQ 版 仪表盘功能时,系统会自动创建AliyunServiceRoleForOns服务关联角色。角色名称 角色权限策略 角色权限 AliyunServiceRoleForOns AliyunServiceRolePolicyForOns 云消息队列 RocketMQ 版 通过扮演...
例如,您首次使用 云消息队列 RocketMQ 版 仪表盘功能时,系统会自动创建AliyunServiceRoleForOns服务关联角色。角色名称 角色权限策略 角色权限 AliyunServiceRoleForOns AliyunServiceRolePolicyForOns 云消息队列 RocketMQ 版 通过扮演...
消费者订阅了某个主题后,云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息,可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤,只获取到需要关注的消息子集,避免接收到大量无效的...
本文介绍 云消息队列 MQTT 版 的Demo工程,包含各种应用场景的使用指导,请参见程序源码的文档注释进行理解。获取多语言Demo 示例代码全集请参见 mqtt-demo。下载完成后解压即可看到本地新增了 mqtt-demo-main 文件夹。其中一级文件夹是...
本文介绍使用 云消息队列 MQTT 版 云端SDK时的常见问题。使用云端SDK发送消息成功,为什么无法消费?云端SDK发送消息,只能使用终端SDK消费消息;或终端SDK发送消息,云端SDK消费消息,不支持云端SDK发送消息,云端SDK消费消息。终端SDK...
云消息队列 MQTT 版 的Serverless实例购买成功后,默认为您预留固定规格的资源,若实际使用量超过预留规格,则按照实际使用量弹性计费,可以帮助您提高资源利用率并降低业务成本。重要 Serverless版实例购买后,无论是否使用实例都会开始按...
本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类,以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时,服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景,...
使用 云消息队列 Kafka 版 时,可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况,以及处理方法。客户端消费流程 了解客户端消费流程,有助于理解消息是否堆积。一般情况下,客户端消费流程大致如下:判断消息...
根据MQTT协议,Topic存在多级,定义第一级Topic为父级Topic,在使用 云消息队列 MQTT 版 前,需先创建该父级Topic资源。注意事项 Topic不能跨实例使用,例如不能使用实例B的接入点订阅创建在实例A中的Topic。Topic名称长度限制为3~64个字符...
使用前,请注意以下几点:使用 云消息队列 RocketMQ 版 服务的应用程序需要部署在阿里云ECS上。代码里涉及到的Topic和Group ID,需要到控制台上创建。Message Tag可以完全由应用自定义。创建步骤,请参见快速入门中的 创建资源。Windows....
本文介绍 云消息队列 MQTT 版 的Demo工程,包含各种应用场景的使用指导,请参见程序源码的文档注释进行理解。获取多语言Demo 示例代码全集请参见 mqtt-demo。下载完成后解压即可看到本地新增了 mqtt-demo-main 文件夹。其中一级文件夹是...
如果您想创建一个只有自己可见的队列,不允许其他用户访问,您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性,将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下:排他队列只对首次声明它的连接(Connection)可见,...
重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力研发版本,和 云消息队列 RocketMQ 版 5.x服务端完全兼容,提供了更全面的功能并支持更多增强特性。更多信息,请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构...使用限制 云消息队列 RabbitMQ 版 对集群、接口调用以及字符进行了限制,您在 云消息队列 RabbitMQ 版 时注意不要超过相应的限制值,以免程序出现异常。更多信息,请参见 使用限制。
使用 云消息队列 Kafka 版 提供默认值的配置项:plugin.path rest.advertised.port topic.creation.enable listeners 不会传输至Kafka Connect的配置项。sasl.*ssl.*security.*rest.advertised.host.name rest.advertised.listener rest....
本文从稳定性、内核能力、治理能力以及使用习惯等方面,对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
问题现象 所有Sarama Go版本客户端存在...如果发生了位点重置,产生大量堆积,您可以使用 云消息队列 Kafka 版 控制台提供的重置消费位点功能,手动重置消费位点到某一时间点,无需改代码或换Consumer Group。具体操作,请参见 重置消费位点。
问题现象 使用阿里云 云消息队列 Kafka 版 时,删除 Group 后,仍然收到消息堆积的告警信息。可能原因 发生消息堆积告警信息的原因如下:2.0.0以前的Kafka服务端版本,开源Kafka未提供删除 Group 和消费位点的OpenAPI,因此删除 Group,...
更多信息,请参见 使用云消息队列 Kafka 版时出现消息堆积。相关文档 如果您希望通过API方式查询消费状态,请参见 GetConsumerProgress-查询消费组消费状态。如果您暂时不想处理堆积的消息,可以通过 重置消费位点 的方式跳过堆积消息。
在调用SDK收发消息前,您需要提前创建 云消息队列 RocketMQ 版 的相关资源,包括创建 云消息队列 RocketMQ 版 实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时,需要将这些资源信息填写到SDK代码中。前提条件 创建专有...
本文介绍 云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK(Software Development Kit)即软件开发工具包,包含示例Demo、库文件、编译工具链以及编译脚本等,不需要开发者进行任何其他的配置,直接可以在SDK对应目录环境下,进行...
产品定位 云消息队列 RocketMQ 版 是一款典型的分布式架构下的中间件产品,使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明,请参见下文 通信方式介绍 和 消息传输模型介绍。云消息队列 RocketMQ 版 产品具备异步...
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制,包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义,消息按照达到服务器的先后顺序被存储到队列中,理论上每个队列都支持无限...