在使用 云消息队列 MQTT 版 客户端(下文简称MQTT客户端)收发消息前,需根据 云消息队列 MQTT 版 所支持的开发语言下载对应SDK。云消息队列 MQTT 版 默认支持标准的MQTT 3.1.1协议,理论上能够适配所有的MQTT客户端,但不排除部分MQTT客户...
云消息队列 RabbitMQ 版 提供包年包月预付费和Serverless按量后付费计费方式,每种计费方式的计费项和计费规则都有所差异,您可以按照不同的使用场景和业务规模选择合适计费方式及实例类型,达到成本最优化的效果。实例类型和计费模式 说明...
在使用 云消息队列 MQTT 版 客户端(下文简称MQTT客户端)收发消息前,需根据 云消息队列 MQTT 版 所支持的开发语言下载对应SDK。云消息队列 MQTT 版 默认支持标准的MQTT 3.1.1协议,理论上能够适配所有的MQTT客户端,但不排除部分MQTT客户...
使用 云消息队列 RocketMQ 版 进行消息收发,必须先创建 云消息队列 RocketMQ 版 实例。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查看实例详情。背景信息 云消息队列 RocketMQ 版 实例按照规格分为标准版和企业...
云消息队列 RocketMQ 版 支持集成Spring框架的Java SDK收发消息,本文为您介绍如何使用 云消息队列 RocketMQ 版 提供的Spring框架的Demo工程。背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成:普通消息的...
HMAC-SHA1的算法实现,各个语言都有现成的函数库,请自行搜索,或者参见 微消息队列MQTT版使用签名模式收发消息 的示例代码中设置Username和Password的部分。使用控制台验证签名 云消息队列 MQTT 版 控制台 提供了签名计算工具,以方便您...
本文主要对 云消息队列 RabbitMQ 版 涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用 云消息队列 RabbitMQ 版。A Alternate Exchange 备份Exchange,简称AE,用于接收配置了备份Exchange的Exchange路由失败的消息。...
本文介绍如何使用 云消息队列 Kafka 版 提供的迁移工具将某个 云消息队列 Kafka 版 实例的Topic迁移到另一个 云消息队列 Kafka 版 实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云...
云消息队列 RocketMQ 版 对某些具体指标进行了约束和规范,您在使用 云消息队列 RocketMQ 版 时注意不要超过相应的限制值,以免程序出现异常。限制项 限制值 说明 Topic名称长度 64个字符 Topic名称长度不得超过该限制,否则会导致无法发送...
在调用TCP协议的SDK收发消息前,您需在 云消息队列 RocketMQ 版 控制台创建相关资源。您在调用SDK时需填写这些资源信息。前提条件 开通消息队列服务并授权 背景信息 针对TCP和HTTP两种通信协议,云消息队列 RocketMQ 版 分别提供了多语言...
本文介绍如何使用 云消息队列 Kafka 版 提供的迁移工具将自建Kafka集群的 Group 迁移到 云消息队列 Kafka 版 实例。前提条件 您已完成以下操作:下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署 云消息队列 Kafka 版 ...
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时,您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
网络访问限制 在使用 云消息队列 RocketMQ 版 时,请注意以下网络访问限制:只有在同一个地域下的同一个实例中的Topic和Group ID才能互通,例如,某Topic创建在 华东1(杭州)地域的实例A中,那么该Topic只能被在 华东1(杭州)地域的实例A...
借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力,云消息队列 RabbitMQ 版 为企业版和铂金版实例提供Dashboard大盘功能。通过该功能,您可以查看企业版和铂金版实例、Vhost、Queue和Exchange的各种指标数据,帮助您及时...
本文从稳定性、内核能力、治理能力以及使用习惯等方面,对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
方案架构 因为 云消息队列 RocketMQ 版 具有重试功能且能保证消息不丢失,所以推出此方案来确保DB和缓存数据的强一致性,即在DB和缓存间使用 云消息队列 RocketMQ 版,架构如下图所示。方案优势 云消息队列 RocketMQ 版 有以下优势:巨大的...
本文提供使用 云消息队列 RabbitMQ 版 的Java SDK收发消息的快速入门视频。
本文提供使用 微消息队列MQTT版 的Java SDK收发消息的快速入门视频。
本文提供相关更新说明,帮助您更顺畅地使用 云消息队列 RocketMQ 版。说明 为兼容新老资源配置,建议您将ons-client客户端升级到最新版本。资源隔离优化(实例化支持)云消息队列 RocketMQ 版 开放实例化功能,解决多租户之间的隔离问题,...
使用 云消息队列 RocketMQ 版 进行消息收发,您需要创建Group ID用于标识同一类生产者实例或者同一类消费者实例。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除和查询Group。使用限制 单实例下最多创建1000个Group,建议您...
如果您准备使用或正在使用 云消息队列 MQTT 版,有任何疑问和建议,欢迎您搜索钉钉群号 35228338加入钉钉群与我们交流。
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端与终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...
如果您准备使用或正在使用 云消息队列 RabbitMQ 版,有任何产品相关疑问和建议,欢迎自行搜索以下群号加入钉钉群与我们交流。钉钉群号:31735582
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式,可根据本文提供的签名计算方式获取签名,再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述,如果选择签名校验模式,MQTT客户端实际连接MQTT消息服务器时,...
云消息队列 Kafka 版 提供全托管、免运维的迁移上云服务,用于自建实例或跨云云实例与 云消息队列 Kafka 版 实例之间的数据同步。本文介绍迁移上云的源实例类型、使用限制、跨VPC数据同步以及使用流程。前提条件 您已购买并部署 云消息队列...
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警,登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象:在 Group 详情 页面,看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹,单击 创建查询任务,...
本文介绍如何在 云消息队列 Confluent 版 控制台中进行RBAC授权。背景信息 RBAC的全称是Role Based Access Control。RBAC的授权方式是基于角色进行授权的,而ACL是基于权限进行授权。因此,RBAC比ACL更适合批量授权以及权限回收。RBAC授权...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...
本文为您介绍快速使用 云消息队列 RabbitMQ 版 进行消息收发的操作流程。操作流程 后续步骤 步骤一:(可选)RAM用户授权 步骤二:创建资源 步骤三:调用SDK收发消息
调用OpenOnsService开通云消息队列 RocketMQ 版服务。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能会导致...
此场景中,MQTT客户端产生上下线等状态变更,云消息队列 MQTT 版 会根据您配置的客户端状态通知规则,将状态变更封装后转发到 云消息队列 RocketMQ 版 消息的方式来实现客户端状态数据的聚合和统计。说明 针对其他场景,推荐您使用同步查询...
前提条件 创建消息队列RocketMQ版5.0系列实例 创建服务关联角色 角色名称:AliyunServiceRoleForRMQMigration 权限策略:AliyunServiceRolePolicyForRMQMigration 权限说明:允许 云消息队列 RocketMQ 版 使用该角色获取访问专有网络VPC的...
本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档,帮助您了解 云消息队列 RocketMQ 版 的发布动态。2024-04-24 实例系列 功能名称 功能描述 变更类型 相关文档 5.x系列实例 Serverless公网...
当消费客户端出现Rebalance时,您可以查看Rebalance的详情,包括Rebalance的时间、耗时、次数、原因以及...后续步骤 当客户端频繁出现Rebalance时,您可以参考以下文档解决此问题:使用云消息队列 Kafka 版时消费客户端频繁出现Rebalance。
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同,都是服务端根据消息设置的定时时间在某一固定时刻...
本文介绍使用C++ SDK v2.x.x版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项,以便后续使用C++ SDK收发消息。重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力研发版本,和 云消息队列 RocketMQ ...
当使用 云消息队列 Kafka 版 进行消息收发时,您需要在已成功部署的Kafka实例中创建Topic和Group资源。生产者需要将消息发送至指定Topic,消费者通过订阅Topic获取消息进行消费。消费者消费消息时,需要指定Group订阅对应的Topic。Group和...
在使用云消息队列 Kafka 版时,客户端可能报错,您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权(sasl.mechanisms)...
本文介绍使用 云消息队列 RocketMQ 版 提供的商业版HTTP协议的SDK收发消息时可能遇到的错误码,以及建议的处理方式。错误码 错误描述 HTTP状态码 建议处理方式 AccessDenied The OwnerId that your Access Key Id associated to is ...
开通 云消息队列 Kafka 版 服务需要使用阿里云其他云产品中的资源,因此,您需要先授权 云消息队列 Kafka 版 访问您所拥有的其他阿里云资源。前提条件 注册阿里云账号并完成实名认证。详情请参见 注册阿里云账号。背景信息 为了方便您快速...