获取MQTT客户端在线状态
异步上下线事件通知 该方式使用消息通知，在客户端上线和下线事件触发时，MQTT服务端支持将上下线消息直接推送到部署在阿里云服务器上的云端应用。该方式属于异步感知客户端的状态，且感知到的是上下线事件，而非在线状态，云端应用需要...
基础术语
本文主要对 SOFAStack 消息队列涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用消息队列。中文 英文 释义 消息主题 Topic 消息主题，一级消息类型，通过 Topic 对消息进行分类。详情请参见 Topic 与 Tag。消息 ...
Notification
名称 类型 描述 示例值 object 消息通知对象，支持多种消息中间件，消息格式详情请见 异步通知消息格式，请选择其中一种方式接收消息，使用方式如下所示：在与智能媒体管理相同的地域下开通并接入 事件总线 EventBridge 服务，及时获取任务...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
顺序消息
顺序消息、定时消息、事务消息是不同的消息类型，三者是互斥关系，不能叠加在一起使用。顺序消息支持哪些地域（Region）？支持消息队列所有部署的地域。顺序消息的使用范围是什么？关于顺序消息的使用范围，包括适用场景和使用限制等，请...
SOFAMQ 常见问题
上述方式可以查询到消息的具体内容以及消费情况，如果需要追踪一条消息从生产者发出到被消费者消费的整个链路中各个相关节点的时间地点，可以使用消息队列最新的消息轨迹查询功能，具体使用方式请参考 查询消息轨迹。消息队列是否能保证...
什么是云消息队列 RocketMQ 版？
削峰填谷提高稳定性 传统消息中间件仅满足业务的异步化需求，而 云消息队列 RocketMQ 版 诞生于在线互联网和交易业务场景，除了满足异步能力，还将削峰填谷作为消息的基础能力。通过削峰填谷不仅能够提高系统稳定性，还能大幅降低业务成本...
快速入门概述
云消息队列 MQTT 版 支持使用多种语言的SDK接入服务端实现消息收发，本文以Java为例介绍不同场景下的消息收发流程。操作流程 使用SDK收发消息流程如下图所示。具体操作步骤如下：开通服务并授权 开通消息队列服务，并授予RAM用户操作 云...
延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
消息收发流程变更
云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储，因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通，创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信...
Topic 与 Tag
建议您从以下几个方面进行判断：消息类型是否一致：如普通消息、事务消息、定时或延时消息、顺序消息，不同的消息类型使用不同的 Topic。创建 Topic 时需要指定消息类型，无法通过 Tag 进行区分。业务是否相关联：没有直接关联的消息，如...
Topic与Tag最佳实践
建议您从以下几个方面进行判断：消息类型是否一致：如普通消息、事务消息、定时（延时）消息、顺序消息，不同的消息类型使用不同的Topic，无法通过Tag进行区分。业务是否相关联：没有直接关联的消息，如淘宝交易消息，京东物流消息使用不同...
定时和延时消息
本文主要介绍 云消息队列 RocketMQ 版 的定时消息和延时消息的概念、适用场景以及使用过程中的注意事项。概念介绍 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点...
使用Spring Cloud框架收发消息
spring.cloud.stream.bindings.MyOutput.destination=${kafka.output.topic.name} spring.cloud.stream.bindings.MyOutput.contentType=text/plain spring.cloud....MyInput.contentType=text/plain#Binder是Spring Cloud对消息中间件的封装模块...
消息过滤
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
消息轨迹
计费说明 包年包月和按量付费实例可免费使用消息轨迹功能且默认支持消息轨迹。Serverless实例可选择手动开启或关闭消息轨迹功能，具体操作，请参见 开启/关闭Serverless实例的消息轨迹功能。若开启消息轨迹，则Serverless实例按照实际产生...
P2P消息收发模式（MQTT）
P2P模式和Pub/Sub模式的区别 在 云消息队列 MQTT 版 中使用P2P模式收发消息与使用Pub/Sub的普通模式收发消息的区别如下所述：发送消息时，Pub/Sub模式下，发送者需要按照和接收者约定好的Topic发送消息；而P2P模式下，发送者无需事先约定...
P2P消息收发模式（MQTT）
P2P模式和Pub/Sub模式的区别 在 云消息队列 MQTT 版 中使用P2P模式收发消息与使用Pub/Sub的普通模式收发消息的区别如下所述：发送消息时，Pub/Sub模式下，发送者需要按照和接收者约定好的Topic发送消息；而P2P模式下，发送者无需事先约定...
云端SDK常见问题
本文介绍使用 云消息队列 MQTT 版 云端SDK时的常见问题。使用云端SDK发送消息成功，为什么无法消费？云端SDK发送消息，只能使用终端SDK消费消息；或终端SDK发送消息，云端SDK消费消息，不支持云端SDK发送消息，云端SDK消费消息。终端SDK...
中间件
name是指服务名称 三方中间件 Kafka 使用服务名称 ZooKeeper 使用服务名称 InfluxDB 使用服务名称 MongoDB 使用服务名称 MySQL 使用服务名称 PostgreSQL 使用服务名称 RabbitMQ 使用服务名称 SQL Server 使用服务名称 MySQL-HA 使用服务...
三方标准中间件对接
中间件通讯方式 操作系统 中间件类型 中间件名称 访问节点方式 Linux 阿里云中间件 IotEdge 固定的服务名称 iotedge LinkVisual 固定的服务名称 linkvisual 三方中间件 RedisHA 使用服务名称 SQL Server 使用服务名称 Redis 使用服务名称 ...
Exchange
使用示例 Headers Exchange根据消息Headers属性和Binding Headers属性的匹配规则路由消息的示例如下：Message 消息Headers属性 Binding Headers属性 Queue Message A type=read resource=group type=read resource=group x-match=all type=...
环境准备（v2.x.x）
本文介绍使用C++ SDK v2.x.x及以上版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。使用前，请注意以下几点：本文仅针对C++ SDK v2.x.x及以上版本进行说明，若您需从当前使用的v...
队列模型基本概念
本文对 消息服务MNS 的队列模型涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列（Queue）消息存储的目的地，分成普通队列和延时队列两类。消息包含数据和属性，可以分成...
怎样让Consumer不立即消费消息并使消息重入队列？
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...
怎样让Consumer不立即消费消息并使消息重入队列？
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
常见问题
本文汇总了使用 云消息队列 Kafka 版 实例时的常见问题。计费问题 为什么购买了按量付费实例后不使用也要收费？为什么按流量峰值收费？按流量峰值收费的依据是什么？为什么额外增加分区要收费？我使用的Connector组件如何计费？客户端报错 ...
日志服务事件通知概述
已授权消息服务使用AliyunMNSLoggingRole角色导出日志。单击 云资源访问授权，根据提示完成授权。警告 请勿取消授权或删除RAM角色，否则将导致MNS日志无法正常推送到日志服务。背景信息 如下图所示，如果您创建了事件通知规则，当您在请求...
注意要点
本文介绍使用开源的客户端SDK接入 云消息队列 RabbitMQ 版 服务端时的注意事项。要点 说明 com.rabbitmq.client.ConnectionFactory 接口 设置 com.rabbitmq.client.ConnectionFactory 接口时，必须开启连接自动恢复功能，保证服务端升级时...
云端开发概述
本文介绍 云消息队列 MQTT 版 提供的云端SDK和管控SDK的使用场景。使用说明 使用 云消息队列 MQTT 版 的云端SDK收发消息时，需要和终端SDK搭配使用。例如，使用云端SDK发送消息，终端SDK接收消息；或使用终端SDK发送消息，云端SDK接收消息...
资源使用变更
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明 云消息队列 MQTT 版 ...
查看消费者状态
如果消息消费出现异常，您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
开源对比
本文从稳定性、内核能力、治理能力以及使用习惯等方面，对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
快速入门概述
本文为您介绍如何快速使用 云消息队列 RocketMQ 版 实现消息收发。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。使用说明 权限说明 若您的账号为RAM用户，则必须先为该RAM用户进行授权，才能访问 云消息队列 ...
音视频通信解决方案（MQTT）
对于上文描述的交互流程，建议使用 云消息队列 MQTT 版 提供的P2P消息，P2P消息不需要订阅，发送方直接指定对端接收即可，P2P消息的详细信息，请参见 P2P消息收发模式（MQTT）。收发消息参数设计 由于移动App可能存在应用切入后台被杀死...
开源RabbitMQ迁移上云
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...
日志管理
消息服务MNS 可以为队列和主题开启日志管理功能，支持将队列或主题的消息操作日志推送到 日志服务 SLS（Simple Log Service）。在成功将MNS日志推送到 SLS 后，MNS支持通过日志查询特定信息。例如在消息发送、消费、确认等环节出现异常时，...
快速入门
如果您是首次使用 云消息队列 RocketMQ 版，您可以参考快速入门文档，了解如何购买实例并接入 云消息队列 RocketMQ 版 服务端完成基本的消息收发流程。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。详细操作，请...
- 产品推荐
- 这些文档可能帮助您