如需使用压缩消息,您需要在 云消息队列 Kafka 版 的客户端进行设置。在 云消息队列 Kafka 版 客户端进行消息压缩的说明如下:压缩格式:支持Snappy、LZ4、GZIP等压缩格式。其中,GZIP对CPU的消耗较高,因此不建议您选择GZIP,建议您选择...
场景四:系统通知消息 此场景使用 云消息队列 MQTT 版 的消息收发功能,系统的更新通知都会发送到直播间的所有成员。此场景下,所有的客户端都需订阅room/system Topic,其中:room为父级Topic,需要在 云消息队列 MQTT 版 控制台创建。...
轻量消息队列(原 MNS)客户端内置了Base64编码与不使用Base64编码两种选项,本文介绍在不同的生产消费场景中是否需要使用Base64编码。背景知识 Base64编码是一种用于将二进制数据转换为ASCII字符串的编码方案,广泛应用于需要通过文本处理...
本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数以及如何查看消息轨迹。使用场景 云消息队列 RocketMQ 版 将消息收发流程中的关键数据定义为轨迹参数,并支持可视化查询,通过查看轨迹信息可快速获取当前业务处理的...
使用场景 断连重连场景:在网络不稳定或者移动环境中,例如车联网,客户端的连接可能频繁中断,通过设置较长的会话过期时间,确保连接重建后会话可以无缝恢复。临时设备连接:对于那些短暂连接、发送少量数据后即断开连接的设备(如一次性...
产品介绍 什么是轻量消息队列(原 MNS)如何使用轻量消息队列(原 MNS)轻量消息队列(原 MNS)的使用场景 什么是Account ID 轻量消息队列(原 MNS)不同地域的接入地址 轻量消息队列(原 MNS)提供哪些可用的操作 主题订阅的使用限制 轻量...
云消息队列 RabbitMQ 版 SDK(RAM角色跨账号授权场景)如果您是RAM STS角色授权的使用场景,需要通过 云消息队列 RabbitMQ 版 SDK收发消息,该SDK只比开源SDK多一个加签依赖。云消息队列 RabbitMQ 版 支持的多语言或框架SDK如 云消息队列 ...
背景信息 云消息队列 MQTT 版 最简单的使用场景即MQTT客户端消息的自发自收。如下图所示,您可以使用MQTT.fx作为MQTT客户端,在MQTT.fx客户端配置相关参数后接入 云消息队列 MQTT 版 实现消息的发送和接收。云消息队列 MQTT 版 同时提供了 ...
消息收发流程变更 如果您有 云消息队列 MQTT 版 与 云消息队列 RocketMQ 版 客户端交互的使用场景,请参见 消息收发流程变更,及时配置您的规则。OpenAPI使用变更 您需根据 OpenAPI使用变更 中的迁移指南完成相应代码改造。
消息收发流程变更 如果您有 云消息队列 MQTT 版 与 云消息队列 RocketMQ 版 客户端交互的使用场景,请参见 消息收发流程变更,及时配置您的规则。OpenAPI使用变更 您需根据 OpenAPI使用变更 中的迁移指南完成相应代码改造。
本文介绍 云消息队列 MQTT 版 提供的云端SDK和管控SDK的使用场景。使用说明 使用 云消息队列 MQTT 版 的云端SDK收发消息时,需要和终端SDK搭配使用。例如,使用云端SDK发送消息,终端SDK接收消息;或使用终端SDK发送消息,云端SDK接收消息...
典型的使用场景如下:将 轻量消息队列(原 MNS)与其他阿里云产品集成,让应用程序更加可靠、灵活。将 轻量消息队列(原 MNS)用作工作队列,其中每条消息代表一项任务,需要通过一个流程来完成。一台或多台ECS可以从队列中读取并执行任务...
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户,必须先为RAM用户进行授权,才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源,并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
背景信息 云消息队列 MQTT 版 最简单的使用场景即MQTT终端和终端交互,消息生产者和消费者均分布在终端设备。各终端设备均通过终端SDK 云消息队列 MQTT 版 与 云消息队列 MQTT 版 服务端连接实现消息收发。本文以公网环境为例,说明如何...
允许用户根据具体应用场景定制消息的元数据,不仅增加了消息传输的灵活性和适用性,还使得MQTT能够更加高效地处理复杂的业务逻辑和需求。使用限制 用户属性序列化后大小不能超过8K字节。序列化后的用户属性如下:[{"key":"mQ","value":...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...
如果您对发送到 云消息队列 RabbitMQ 版 的消息有问题,您可以在控制台查询消息。云消息队列 RabbitMQ 版 支持按Queue查询和按Message ID查询两种方式,前者适用于只知道消息发送到的Queue,不知道发送消息时设置的Message ID的模糊查询...
使用限制 使用 云消息队列 RabbitMQ 版 消息轨迹功能时,限制如下:仅当实例支持消息轨迹时,才可以查询该实例中消息收发的轨迹。说明 实例是否支持消息轨迹和可以查询的消息轨迹时间范围,由您在创建实例时选择配置。如果实例未配置消息...
本文介绍跨产品数据流入的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将其他阿里云产品的数据导入 云消息队列 MQTT 版,您需创建数据流入规则。该规则用于从您配置的阿里云产品中读取...
本文介绍数据流出的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 如需将 云消息队列 MQTT 版 的数据导出至其他阿里云产品,您需创建数据流出规则。该规则用于将MQTT客户端发送的消息导出到...
使用场景 轻量消息队列(原 MNS)的消息轨迹功能可以帮助您解决以下问题:查看消息是否发送成功:当您怀疑消息没有收到时,可以通过消息轨迹确认消息是否成功发送到队列或主题,以及消息是否被消费。排查消息重复消费问题:当您发现同一条...
其中使用 云消息队列 MQTT 版 构建音视频通话场景的信令传输时,相关的消息类型设计以及参数设计请尽可能遵循如下原则:客户端ID映射 MQTT协议要求每个客户端都有一个全局唯一的Client ID,Client ID由以下两部分组成,这两部分通过“@”...
本文介绍 云消息队列 Kafka 版 使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中,自定义权限策略是指在系统权限策略之外,您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来...
云消息队列 MQTT 版 升级后实现了自身数据存储的能力,同时还去除了对 云消息队列 RocketMQ 版 的消息依赖,因此,云消息队列 MQTT 版 的实例和Topic使用有变更。资源 旧版本 使用说明 新版本 使用说明 云消息队列 MQTT 版 实例 旧版本 云...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
本文介绍客户端上下线通知的原理、应用场景、使用限制以及 云消息队列 MQTT 版 与其他阿里云产品的资源映射关系。基本原理 在客户端上线和下线事件触发时,MQTT服务器会根据您配置的客户端上下线通知规则,向后端其他云产品推送一条上下线...
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景,提供交互中所涉及的消息结构和属性字段的映射关系,方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品,可通过数据互通...
如需追踪和识别消息,您可以在 云消息队列 RabbitMQ 版 的Producer客户端设置Message ID属性,为每条消息设置唯一标识符。本文介绍Message ID的相关概念和设置方法。什么是Message ID Message ID(消息标识符)是消息的可选属性,类型为...
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信,云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
适用场景及风险点 场景 风险 云消息队列 Kafka 版 非Serverless实例的磁盘使用率偏高,即将影响正常业务进行,需要扩容磁盘。升级后会引发集群逐台重启。云消息队列 Kafka 版 非Serverless实例的流量规格持续超过已购买的规格,无法满足...
以下场景建议使用消息重试 业务处理失败,且失败原因跟当前的消息内容相关,比如该消息对应的事务状态还未获取到,预期一段时间后可执行成功。消费失败的原因不会导致连续性,即当前消息消费失败是一个小概率事件,不是常态化的失败,后面...
消费者从 云消息队列 RocketMQ 版 获取消息消费时,通过消费者负载均衡策略,可将主题内的消息分配给指定消费者分组中的多个消费者共同分担,提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
操作流程 具体操作流程如下:请您首先自行评估OpenAPI的使用场景和调用链路。请联系 云消息队列 MQTT 版 技术支持,钉钉群号:116015007918。产品方会根据具体情况给出迁移方案。按照迁移方案,一般您需提前进行代码改造,实现新版OpenAPI...
若您使用 云消息队列 MQTT 版 的数据流入、数据流出规则和 云消息队列 RocketMQ 版 进行通信,云消息队列 RocketMQ 版 会根据调用的 云消息队列 RocketMQ 版 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...
本文介绍 轻量消息队列(原 MNS)使用自定义权限策略的场景和策略示例。什么是自定义权限策略 在基于RAM的访问控制体系中,自定义权限策略是指在系统权限策略之外,您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您...
如果您的 云消息队列 Kafka 版 实例的公网流量消耗远小于购买的公网流量配置,或者分区的使用量远小于购买的分区数量,您可以降低公网流量和分区数量配置,从而节约成本。本文介绍如何在 云消息队列 Kafka 版 控制台降低实例的公网流量、...
您可以使用 云消息队列 Confluent 版 的日志管理功能将 云消息队列 Confluent 版 实例的消息操作日志推送到日志服务。您可通过开通该服务,查询客户端的所有请求日志。前提条件 创建 云消息队列 Confluent 版 实例。具体操作,请参见 购买...
本文旨在以简单明了的方式引导您快速上手 云消息队列 Kafka 版。操作流程 根据网络类型不同,快速入门的操作流程有所不同,详情请参见 云消息队列 Kafka 版快速入门操作流程。图 1.云消息队列 Kafka 版 快速入门操作流程 操作步骤 具体操作...
云消息队列 RabbitMQ 版 具有丰富的安全防护能力,通过多项合规认证,支持存储加密、传输加密等安全特性。为您的云端数据安全进行全方位的保驾护航,并满足您企业数据的安全与合规要求。存储加密 功能说明 云消息队列 RabbitMQ 版 支持在...
本文提供使用TCP协议下的Java SDK收发延时消息的示例代码供您参考。前提条件 您已完成以下操作:安装Java SDK。更多信息,请参见 准备环境。创建资源。代码中涉及的资源信息,例如实例、Topic和Group ID等,需要在控制台上提前创建。更多...