本文为您介绍 云消息队列 RabbitMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RabbitMQ 版。异步解耦 云消息队列 RabbitMQ 版 可用于单体应用被拆解为微服务后不同微服务间的通信。应用解耦的好处是不同应用的迭代不再...
应用场景 指令下发场景 部署在云端的后台管控服务发送指令到 云消息队列 RocketMQ 版，云消息队列 MQTT 版 产品根据配置的数据流入规则，将 云消息队列 RocketMQ 版 的Topic映射到MQTT的Topic，然后将对应的数据推送到目标的MQTT设备端。...
MQTT 5.0的用户属性功能，使得接收方能够获取关于消息更丰富的上下文信息，让数据处理变得更加高效，操作更加有针对性，从而满足多样化的应用场景需求。消息示例 例如，现在需要发送一个温度读数的消息，同时附带设备所在位置和读数取得的...
轻量消息队列（原 MNS）凭借其简单的队列模型、轻量化协议以及按量后付费的计费模式，成为众多阿里云产品首选的消息传输通道，此外，其无损发布能力和多可用区的高可用特性，确保了云产品之间以及云产品与用户应用之间的消息可靠传输。...
本文介绍 云消息队列 Kafka 版 的典型应用场景，包括网站活动跟踪、日志聚合、数据处理、数据中转枢纽。网站活动跟踪 成功的网站运营需要对站点的用户行为进行分析。通过 云消息队列 Kafka 版 的发布/订阅模型，您可以实时收集网站活动数据...
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的消费完整性问题，是一种为业务兜底的策略，不应该被用作业务流程控制。以下场景建议使用消息...
本文介绍标签的应用场景、使用说明、使用限制以及标签的相关操作。应用场景 随着您创建的 云消息队列 RocketMQ 版 实例的增加，管理难度也随之增加。除了通过实例名称进行标识和区分外，您还可以通过标签将实例按照业务、用途、使用对象等...
应用场景 设备数据上报 海量设备通过MQTT协议上报状态数据到 云消息队列 MQTT 版，配置数据流出规则将 云消息队列 MQTT 版 的Topic映射到 云消息队列 RocketMQ 版 的Topic后，可以直接在后台服务启动 云消息队列 RocketMQ 版 的消费者消费...
云消息队列 MQTT 版 基于标准的MQTT协议，广泛服务于终端应用场景。MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和 云消息队列 RocketMQ 版 各自的消息收发。MQTT客户端 用于和MQTT服务器交互的...
如果说传统的消息队列中间件一般应用于 微服务 之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联。本文介绍 云消息队列 MQTT 版 的消息收发模型、产品优势和应用场景。前置概念 阅读本文...
应用场景 消息存活时间可用于保障消息流通性。例如，某应用的消息在某些特定时间会剧烈增加，如果您的业务可以接受消息丢失，您可以通过设置消息存活时间丢弃堆积的消息，从而保障消息流通性。消息存活时间设置规则 云消息队列 RabbitMQ 版...
本文为您介绍如何将 云消息队列 RocketMQ 版 可观测性功能应用于 云消息队列 RocketMQ 版 的故障管理场景中，为您的日常运维和故障处理提供实践方案。设计思路 核心问题 运维场景下，故障处理的核心问题如下：服务出现异常如何预警并上报 ...
应用场景 轻量消息队列（原 MNS）的规范中，每条消息都有默认的可见性超时时间。消费者在接收到消息后，立即开始计时。如果消费者在可见性超时时间内没能处理完消息，那么消息就有可能被其他消费者接收到并处理。计时的好处在于消息处理完...
应用场景 客户端上下线通知主要的应用场景为业务应用需要在客户端上线或者下线时触发一些预定义的动作。例如，客户端在线状态聚合。此场景中，MQTT客户端产生上下线等状态变更，云消息队列 MQTT 版 会根据您配置的客户端状态通知规则，将...
应用场景 企业A购买了 云消息队列 RocketMQ 版 服务来开展业务，并希望将部分业务授权给企业B。具体需求如下：A希望能专注于业务系统，仅作为资源Owner；而控制台的查询资源和可观测等功能授权给企业B使用。企业A希望当企业B的员工加入或...
如需追踪和识别消息，您可以在 云消息队列 RabbitMQ 版 的Producer客户端设置Message ID属性，为每条消息设置唯一标识符。本文介绍Message ID的相关概念和设置方法。什么是Message ID Message ID（消息标识符）是消息的可选属性，类型为...
安装1.8或以上版本JDK 安装2.5或以上版本Maven 背景信息 轻量消息队列（原 MNS）提供队列（Queue）和主题（Topic）两种模型，基本能满足大多数应用场景。队列提供的是一对一的共享消息消费模型，采用客户端主动拉取（Pull）模式。主题模型...
本文介绍 轻量消息队列（原 MNS）如何处理较长时间没有任何消息的队列。在您正常使用服务期间，阿里云 轻量消息队列（原 MNS）不会对不可见的队列或主题进行删除操作。但是，如果您的 轻量消息队列（原 MNS）使用权限因为欠费或其他原因被...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 云消息队列 MQTT 版 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流出任务，将指定 云消息队列 RabbitMQ 版 实例中的数据导出至其他的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 轻量消息队列（原 MNS）中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已创建 轻量消息队列（原 MNS）队列。具体步骤，请参见 开通轻量消息队列（原 MNS）并...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建流入任务，将指定 云消息队列 RabbitMQ 版 实例中的数据快速导入至另外的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。...
本文介绍 云消息队列 MQTT 版 的Demo工程，包含各种应用场景的使用指导，请参见程序源码的文档注释进行理解。获取多语言Demo 示例代码全集请参见 mqtt-demo。下载完成后解压即可看到本地新增了 mqtt-demo-main 文件夹。其中一级文件夹是...
本文介绍 云消息队列 MQTT 版 的Demo工程，包含各种应用场景的使用指导，请参见程序源码的文档注释进行理解。获取多语言Demo 示例代码全集请参见 mqtt-demo。下载完成后解压即可看到本地新增了 mqtt-demo-main 文件夹。其中一级文件夹是...
本文介绍 云消息队列 RocketMQ 版 中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
云消息队列 RabbitMQ 版 兼容开源RabbitMQ并提供一套完善的运维工具。资源支持 云消息队列 RabbitMQ 版 兼容开源RabbitMQ的各个组件：Queue：支持消息存储，支持集群消费模式。说明 云消息队列 RabbitMQ 版 独享实例支持消息优先级功能。...
应用场景 企业A购买了 云消息队列 RocketMQ 版 服务，企业A的员工需要操作这些服务所涉及的资源，例如实例、Topic或Group资源，有的员工负责创建资源，有的负责发布消息，还有的负责订阅消息。由于每个员工的工作职责不一样，需要的权限也...
应用场景 企业A购买了 云消息队列 RocketMQ 版 服务，企业A的员工需要操作这些服务所涉及的资源，例如实例、Topic或Group资源，有的员工负责创建资源，有的负责发布消息，还有的负责订阅消息。由于每个员工的工作职责不一样，需要的权限也...
云消息队列 RocketMQ 版 支持Global Replicator功能，能够实现跨地域及跨实例的消息和消费进度同步。本文将介绍Global Replicator特性等信息。功能简介 Global Replicator为您提供跨地域、跨实例的消息和消费进度同步能力，支持开源和商业...
轻量队列模型易接入、易集成 提供更简单，轻量的消息队列，聚焦消息领域核心能力构建。提供轻量Queue/Topic资源模型，简单易用，无复杂模型概念。提供轻量HTTP RESTful接口，原生支持HTTP协议，对平台无依赖。提供多种语言SDK，包括C++、...
云消息队列 Confluent 版 支持SSO登录Control Center，本文为您介绍使用SSO登录Control Center前的配置操作。背景 SSO（Single Sign On，单点登录），是一种统一的身份验证机制，允许用户通过一次登录访问多个相互信任的应用系统。云消息...
当您访问 轻量消息队列（原 MNS）出错时，轻量消息队列（原 MNS）会返回一个合适的3xx、4xx或5xx的HTTP状态码，以及一个text或xml格式的消息体。本文介绍 轻量消息队列（原 MNS）错误码消息体说明及列表。错误码说明 错误响应的消息体示例...
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。前置概念 阅读本文前，...
若根据上述几个方法查到消息确实已经被 云消息队列 RabbitMQ 版 服务端存储，则可以重点排查后续的消息推送过程是否存在异常。若是没有查询到消息，则需要检查生产者代码的参数是否正确，队列是否正确绑定。消费者问题 消息的推送事件可以...
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将数据传输服务DTS中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：创建...
应用场景 企业A购买了 云消息队列 MQTT 版 服务，企业A的员工需要操作这些服务所涉及的资源，例如实例、Topic或Group资源，比如有的负责创建资源，有的负责发布消息，还有的负责订阅消息。由于每个员工的工作职责不一样，需要的权限也不...
定义和模型关系 在 轻量消息队列（原 MNS）中，一个队列是一个存储消息的容器。生产者将消息发送到队列中，而消费者则从队列中消费消息。功能说明 至少一次（At least once）：在消息保存时长和最大投递次数范围内的消息，每一条都将被接收...
本文介绍 云消息队列 MQTT 版 提供的应用服务器Token OpenAPI接口。API 描述 ApplyToken 调用 ApplyToken 申请临时访问的Token。QueryToken 调用 QueryToken 校验Token的有效性。RevokeToken 调用 RevokeToken 吊销Token。
本文介绍 云消息队列 MQTT 版 提供的应用服务器Token OpenAPI接口。OpenAPI 描述 ApplyToken 调用ApplyToken申请临时访问的Token。QueryToken 调用QueryToken校验Token的有效性。RevokeToken 调用RevokeToken吊销Token。