本文介绍 云消息队列 Kafka 版 发布者的最佳实践,帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端,其基本概念与思想是相通的,但实现细节可能存在差异。发送消息 发送消息的示例代码如下:Future ...
针对各种业务需求,云消息队列 MQTT 版 提供相关的实践教程,您可以根据实例版本选择对应的最佳实践教程进行参考。云消息队列 MQTT 云消息队列 MQTT最佳实践 云消息队列 MQTT(旧版)云消息队列 MQTT(旧版)最佳实践
针对各种业务需求,云消息队列 RocketMQ 版 提供相关的实践教程,您可以根据实例版本选择对应的最佳实践教程进行参考。云消息队列 RocketMQ 版5.x系列 5.x系列最佳实践 云消息队列 RocketMQ 版4.x系列 4.x系列最佳实践
本文提供在线教育视频直播场景的最佳实践引导。场景描述 适用于在线教育的视频直播场景,通过阿里云视频直播服务实现移动端的推拉流能力,同时移动端利用 云消息队列 MQTT 版 实现发送和接收消息,在消息转发时利用内容安全服务对消息内容...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...
推荐的做法是使用RAM身份(即RAM用户和RAM角色)来访问 云消息队列 MQTT 版。RAM用户 RAM用户需要由阿里云账号(即主账号)或拥有管理员权限的RAM用户、RAM角色来创建,且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的资源。...
在 消息队列RocketMQ版 中,Topic与Tag都是业务上用来归类的标识,区分在于Topic是一级分类,而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下:Topic 消息主题,通过...
订阅者最佳实践 客户端首次接入云消息队列 Kafka 版时出现异常的排查方法 为什么消费客户端频繁出现Rebalance?消费端从服务端拉取不到消息或拉取消息缓慢 为什么不推荐使用Sarama Go客户端收发消息?使用云消息队列 Kafka 版时出现消息...
原生延时消息最佳实践 生产者客户端 云消息队列 RabbitMQ 版 原生延时消息的使用方式非常简单。您只需要在生产者客户端发布消息时,通过 delay 为消息设置一个延时时间。发布延时消息的Java示例代码如下:Map String,Object headers=new ...
使用云消息队列 Kafka 版时客户端的报错及解决方案 无法ping通云消息队列 Kafka 版的接入点 开启幂等功能,发送消息报“Cluster authorization failed”错误 客户端消费问题 订阅者最佳实践 客户端首次接入云消息队列 Kafka 版时出现异常的...
本文为您介绍 云消息队列 RocketMQ 版 的分账规则和最佳实践。分账规则 分账对象:云消息队列 RocketMQ 版 5.0系列实例的后付费账单。分账粒度:云消息队列 RocketMQ 版 支持实例级别的分账,您可以使用不同实例来隔离不同部门或不同应用的...
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践,帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为:Poll数据→执行消费逻辑→再次Poll数据,详情参见下图。负载均衡 每个 ...
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践,帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为:Poll数据→执行消费逻辑→再次Poll数据,详情参见下图。负载均衡 每个 ...
轻量消息队列(原 MNS)支持顺序消息的能力。本文将为您介绍其核心概念、与普通消息的区别、创建与使用方法、API使用说明,以及相关的限制与最佳实践。功能定义 轻量消息队列(原 MNS)的顺序消息支持为同一分组内的消息提供先进先出...
本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所...} 更多信息 云消息队列 RocketMQ 版 消费端流控的最佳实践,请参见 客户端流控设计。
哪里可以找到发送最佳实践?如何进行发送消息的测试?使用客户端发送消息后,如何确定是否发送成功?生产者会建立多少个到Broker的连接?Java客户端设置回调是否会影响消息发送的速度?为什么PHP发送延时比较长?如何配置客户端参数?使用...
云消息队列 RabbitMQ 版是阿里云消息队列(MQ)团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维,帮助您快速上云。
云消息队列 MQTT 版 旧版本 强依赖 云消息队列 RocketMQ 版 作为消息存储,因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通,创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信。...
云消息队列 MQTT 版 升级后实现了自身数据存储的能力,同时还去除了对 云消息队列 RocketMQ 版 的消息依赖,因此,云消息队列 MQTT 版 的实例和Topic使用有变更。资源 旧版本 使用说明 新版本 使用说明 云消息队列 MQTT 版 实例 旧版本 云...
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景,提供交互中所涉及的消息结构和属性字段的映射关系,方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品,可通过数据互通...
映射关系如下:轻量消息队列(原 MNS)默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$....
映射关系如下:轻量消息队列(原 MNS)默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$....
映射关系如下:轻量消息队列(原 MNS)默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$....
映射关系如下:轻量消息队列(原 MNS)默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$....
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信,云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
云消息队列 MQTT 版 升级后,实现了独立存储,Topic资源不再依赖于 云消息队列 RocketMQ 版,因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 由于 新版本 的 云...
映射关系如下:轻量消息队列(原 MNS)默认入参 源端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data...
云消息队列 MQTT 版 支持与 云消息队列 RocketMQ 版 的数据流转功能,本文为您介绍数据流转中的属性字段的映射关系。功能说明 云消息队列 MQTT 版 可以通过数据互通规则实现与其他阿里云产品的交互,例如 云消息队列 RocketMQ 版。规则的...
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信,云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
如果您是首次使用 云消息队列 MQTT 版,您可以参考快速入门文档,了解如何购买实例并接入 云消息队列 MQTT 版 服务端完成基本的消息收发流程。操作流程 使用SDK收发消息流程如下图所示。云消息队列 MQTT 云消息队列 MQTT快速入门 云消息...
您可通过配置 云消息队列 MQTT 版 的数据流入规则来自定义数据从其他阿里云产品流入到 云消息队列 MQTT 版。本文介绍跨产品数据流入的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将...
本文为您介绍 云消息队列 RocketMQ 版 的操作视频。云消息队列 RocketMQ 版5.x系列 快速使用 云消息队列 RocketMQ 版5.x系列的Java SDK收发消息 云消息队列 RocketMQ 版4.x系列 快速使用云消息队列 RocketMQ 版4.x系列的Java SDK收发消息
本文介绍 云消息队列 MQTT 版 的升级公告,以及本次升级所涉及的使用变更。公告说明 自2020年07月23日起,云消息队列 MQTT 版 将启动升级流程。升级过程不影响客户端消息收发。如果您对升级时间和窗口有特殊要求,请联系 云消息队列 MQTT ...
您可通过配置 云消息队列 MQTT 版 的数据流出规则来自定义数据从 云消息队列 MQTT 版 流出至其他阿里云产品。本文介绍数据流出的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将 云消息...
本文介绍 云消息队列 MQTT 版 的升级公告,以及本次升级所涉及的使用变更。公告说明 自2020年07月23日起,云消息队列 MQTT 版 将启动升级流程。升级过程不影响客户端消息收发。如果您对升级时间和窗口有特殊要求,请联系 云消息队列 MQTT ...
云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示,一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka 版 的系统架构 Producer 通过push模式向 云消息队列 Kafka 版...
针对各种业务需求,云消息队列 Kafka 版 提供相关的实践教程,您可以根据本文查看适合您业务的实践教程文档。实践教程 最佳实践 生态对接
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域,已成为大数据生态中不可或缺的部分。前置概念 阅读本文前,...