应用场景 企业A购买了 云消息队列 MQTT 版 服务,企业A的员工需要操作这些服务所涉及的资源,例如实例、Topic或Group资源,比如有的负责创建资源,有的负责发布消息,还有的负责订阅消息。由于每个员工的工作职责不一样,需要的权限也不...
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端,解决开源各种稳定性痛点(例如消息堆积、脑裂等问题),同时具备高并发、分布式、灵活扩缩容等云...
定义和模型关系 在 轻量消息队列(原 MNS)中,一个主题是一个存储消息的容器。主题里的消息可以被订阅到多种渠道进行消费,订阅类型包括队列、HTTP、短信服务、邮件推送、移动终端。每个订阅类型可以订阅主题里的所有消息,也可以配置消息...
例如涉及部署在云端服务器上的应用场景。本示例以 公网接入点 为例接入 云消息队列 MQTT 版。使用流程 使用MQTT.fx收发消息的流程如下图所示。(RAM用户必选)步骤一:为RAM用户授权 若您开通消息队列服务使用的是账号是RAM用户,必须先为...
轻量消息队列(原 MNS)提供队列级别和消息级别的延时功能,本文为您介绍延时功能的典型应用场景、生效规则和使用方法。应用场景 典型场景一:分布式定时调度 在分布式定时调度场景下,需要实现各类精度的定时任务,例如每天05:00执行文件...
一个新的应用接入 云消息队列 RabbitMQ 版 服务端,您需要提前创建 云消息队列 RabbitMQ 版 的相关资源,包括创建 云消息队列 RabbitMQ 版 实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...
作为一款典型的分布式中间件产品,云消息队列 RocketMQ 版 被广泛应用于业务核心链路中,每条消息都关联着核心业务数据的变化,通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
MNS)是否支持长轮询 轻量消息队列(原 MNS)是否提供对消息的先入先出(FIFO)访问 轻量消息队列(原 MNS)是否可以与其他阿里云产品协作使用 轻量消息队列(原 MNS)相对于自主研发、商用或开源的消息队列系统有什么优势 计费相关 删除...
适用场景 在互联网应用中,尤其在网络不稳定的情况下,云消息队列 RocketMQ 版 的消息有可能会出现重复。如果消息重复会影响您的业务处理,请对消息做幂等处理。消息重复的场景如下:发送时消息重复 当一条消息已被成功发送到服务端并完成...
云消息队列 MQTT 版 提供同步查询和异步上下线事件通知两种方式,来获取MQTT客户端在线状态。本文介绍这两种方式的基本原理、应用场景、具体差异以及实现方式。基本原理 云消息队列 MQTT 版 服务端(下文简称为MQTT服务端)提供以下方式...
本文介绍 轻量消息队列(原 MNS)的典型使用场景。典型的使用场景如下:将 轻量...将业务流程中重要事件的通知保存在 轻量消息队列(原 MNS)中,每个事件在队列中都有一条对应的消息,需要知晓该事件的应用程序可以读取和处理对应的消息。
云消息队列 RabbitMQ 版是阿里云消息队列(MQ)团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维,帮助您快速上云。
应用场景 使用私网连接接入点指定VPC访问 云消息队列 RabbitMQ 版 适合用于以下场景:实例型产品访问网络时需要对网络链路做隔离。云企业网(CEN)上云组网及跨地域组网。CEN组网时无法使用路由规则访问云产品。创建私网连接接入点后,原...
作为使用和熟悉产品功能的入门指导,本文提供如何快速使用 云消息队列 MQTT 版 通过默认支持的MQTT协议收发消息的步骤。对于非MQTT协议的接入,例如新能源,您必须首先购买 云消息队列 MQTT 版 企业铂金版,并通过专属通道享受对应的文档和...
接口说明 警告 为优化服务性能,轻量消息队列即将下线以下字段的返回值(后续默认为 0):ActiveMessages-InactiveMessages-DelayMessages 请通过以下方式获取替代方案:使用云监控 OpenAPI 获取队列指标,请参考 云监控 OpenAPI 文档 云...
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证,并限制访问权限,以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行,同时需要调用多个下游业务...
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证,并限制访问权限,以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
云消息队列 RabbitMQ 版 SDK(RAM角色跨账号授权场景)如果您是RAM STS角色授权的使用场景,需要通过 云消息队列 RabbitMQ 版 SDK收发消息,该SDK只比开源SDK多一个加签依赖。云消息队列 RabbitMQ 版 支持的多语言或框架SDK如 云消息队列 ...
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台,面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。前置概念 阅读...
消息收发为 云消息队列 MQTT 版 最基本的功能,云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器,实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
升级说明 云消息队列 MQTT 版 新版本 相比 旧版本 而言,实现了自身的消息独立存储,再也无需强制绑定 云消息队列 RocketMQ 版,因此购买开通 云消息队列 MQTT 版 实例后即可直接创建资源,从而降低您的使用与理解成本。新版本 除了独立...
升级说明 云消息队列 MQTT 版 新版本 相比 旧版本 而言,实现了自身的消息独立存储,再也无需强制绑定 云消息队列 RocketMQ 版,因此购买开通 云消息队列 MQTT 版 实例后即可直接创建资源,从而降低您的使用与理解成本。新版本 除了独立...
本文介绍 云消息队列 MQTT 版 云端Go SDK的参数说明。公共参数 参数 说明 domain 云消息队列 MQTT 版 实例的接入点。客户端通过接入点连接 云消息队列 MQTT 版 服务端。使用云端SDK接入 云消息队列 MQTT 版 时,需要填写的接入点格式如下:...
适用场景 在互联网应用中,尤其在网络不稳定的情况下,云消息队列 RabbitMQ 版 的消息有可能会出现重复。如果消息重复消费会影响您的业务处理,请对消息做幂等处理。消息重复的可能原因如下:发送时消息重复 当一条消息已被成功发送到服务...
当设备与 云消息队列 MQTT 版 建立连接时,需要将设备访问凭证中的信息按照约定的形式设置到Username和Password中,向 云消息队列 MQTT 版 发起认证请求,云消息队列 MQTT 版 认证通过后激活设备,设备与 云消息队列 MQTT 版 间才可传输...
变更说明 由于 新版本 的 云消息队列 MQTT 版 实现了自身的消息存储,因此所有的 云消息队列 MQTT 版 Topic资源都需要在 云消息队列 MQTT 版 控制台或调用其OpenAPI进行管理。云消息队列 MQTT 版 的Topic资源不再和 云消息队列 RocketMQ 版...
应用场景 您在收发消息的过程中,是否遇到过以下问题:消息成功发送到队列,但消费端收不到消息,消息去哪儿了?消息被谁消费了?消费了几次?消费端宕机了,消费失败的消息什么时候可以再次被消费?消息发布到主题,Endpoint却迟迟收不到...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
true DelaySeconds integer 否 发送到该 Queue 的所有消息的延迟时间,发送到队列的消息经过此参数设定的延时时间后,才能被消费。取值范围:0~604800,单位为秒。默认值:0。0 Tag array object 否 资源标签列表。object 否 标签键对应的...
testqueue DelaySeconds integer 否 发送到该 Queue 的所有消息的延迟时间,发送到队列的消息经过此参数设定的延时时间后,才能被消费。取值范围:0~604800,单位为秒。默认值:0。0 MaximumMessageSize integer 否 发送到该 Queue 的消息...
方案步骤 请根据业务场景的不同,选择对应的消息迁移步骤:业务不可中断:队列的生产者和消费者集成在同一应用服务中,请参考 场景一。队列的生产者和消费者分布在独立的多个应用服务中,请参考 场景二。复杂场景,自建 RabbitMQ 集群有...
如果需要专门发送消息给某一个应用端,那么可以使用队列接口,单独给应用端创建专门的队列,那么这个队列的消息就只有这个应用端能消费。如果本地域不支持主题,又想使用主题服务,该怎么办?例如,您的ECS在阿联酋(迪拜),但是阿联酋...
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
注意事项 云消息队列 MQTT 版 通过配置的流入规则和 云消息队列 RocketMQ 版 进行跨云产品的消息交互时,若 云消息队列 RocketMQ 版 的服务端进行升级,则在升级期间,可能会造成 云消息队列 MQTT 版 客户端消费消息延迟。产品升级动态,请...
获取客户端在线状态主要的应用场景如下:主业务流程中需要根据客户端是否在线来决定后续运行逻辑;运维过程需要判断特定客户端当前是否在线;业务应用需要在客户端上线或者下线时触发一些预定义的动作。基本原理 云消息队列 MQTT 版 服务器...
当您想要将A地域的 云消息队列 Kafka 版 上的业务无损迁移至B地域,或者创建实例后想复制已有实例元数据(Topic、Group)配置时,您可以使用 云消息队列 Kafka 版 提供的迁移工具将某个 云消息队列 Kafka 版 实例的Topic、Group迁移至另...
本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ,其中 {SDK...
应用场景 使用私网连接接入点指定VPC访问 轻量消息队列(原 MNS)适合用于以下场景:实例型产品访问网络时需要对网络链路做隔离。云企业网(CEN)上云组网及跨地域组网。CEN组网时无法使用路由规则访问云产品。创建私网连接接入点后,原...